Python知识分享网 - 专业的Python学习网站 学Python,上Python222
pymysql执行DDL语句
发布于:2023-09-19 10:42:15

1小时学会 Python操作Mysql数据库之pymysql模块技术https://www.bilibili.com/video/BV1Dz4y1j7Jr

 

 

 

pymysql对操作mysql DDL(Data Definition Language) 数据库模式定义语言,提供了很好的支持。

连接MySQL数据库后,可以使用cursor()方法创建一个游标对象。游标对象用于执行MySQL语句并返回结果。

建表DDL:

 

"""
    pymysql执行DDL语句
"""
from pymysql import Connection

con = None

try:
    # 创建数据库连接
    con = Connection(
        host="localhost",  # 主机名
        port=3306,  # 端口
        user="root",  # 账户
        password="123456",  # 密码
        database="db_python"  # 指定操作的数据库
    )
    # 创建游标对象
    cursor = con.cursor()

    # 定义建表sql语句
    sql = """CREATE TABLE `t_student3` (
      `id` int(11) NOT NULL AUTO_INCREMENT,
      `name` varchar(10) DEFAULT NULL,
      `age` int(11) DEFAULT NULL,
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8
    """

    # 选择要操作的数据库
    # con.select_db("db_python")

    # 使用游标对象,执行sql
    cursor.execute(sql)
except Exception as e:
    print("异常", e)
finally:
    if con:
        # 关闭连接
        con.close()

 

 

 
#对表中的字段进行增,删,改的操作
#格式:alter table 表名 add/drop/modify/change [column] .......
 
#向表中添加字段:alter table 表名 add [column] 字段名 字段类型;
ALTER TABLE stu ADD COLUMN age INT;
 
#删除表中的字段:alter table 表名 drop [column] 字段名:
ALTER TABLE stu DROP age;
 
#修改字段的名字:alter table 表名 change [column] 旧字段名 新字段名 字段类型;
ALTER TABLE stu CHANGE COLUMN sname s2name VARCHAR(20);
 
#修改字段的类型:alter table 表名 modify [column] 字段名 字段类型;
ALTER TABLE stu MODIFY id VARCHAR(20);
 
 
#修改表的名字: alter table 旧表名 rename to 新表名:
ALTER TABLE stu4 RENAME TO stu5;

 

增加字段

 

ALTER TABLE t_student3 ADD COLUMN sex VARCHAR(2)

 

修改字段

 

ALTER TABLE t_student3 MODIFY NAME VARCHAR(12)

 

 

from pymysql import Connection

con = None

try:
    # 创建数据库连接
    con = Connection(
        host="localhost",  # 主机名
        port=3306,  # 端口
        user="root",  # 账户
        password="123456"  # 密码
        # database="db_python"  # 指定操作的数据库
    )
    # 创建游标对象
    cursor = con.cursor()

    # 定义建表sql语句
    sql = "ALTER TABLE t_student2 MODIFY NAME VARCHAR(12)"

    # 选择要操作的数据库
    con.select_db("db_python")

    # 使用游标对象,执行sql
    cursor.execute(sql)
except Exception as e:
    print("异常", e)
finally:
    if con:
        # 关闭连接
        con.close()

 

 

 

转载自: