PYTHON执行SQL语句操作MySQL数据库软件

准备

安装第三方包PyMySQL

创建到MySQL的数据库链接

# 例

from pymysql import Connection
# 获取到MySQL数据库的链接对象
conn = Connection(
    host='localhost',
    port=3306,
    user='root',
    password=''
)
# 打印MySQL数据库软件信息
print.(conn.get_server_info())
# 关闭到数据库的链接
conn.close()

执行SQL语句

# 例

# 执行非查询性质的SQL语句
# 获取游标对象
cursor = conn.cursor()
# 选择数据库
conn.select_db("test")
# 使用游标对象,执行SQL语句
cursor.execute("CREATE TABLE test_pymysql(id INT,info VARCHAR(255))")

# 执行查询性质的SQL语句
# 获取游标对象
cursor = conn.cursor()
# 选择数据库
conn.select_db("world")
# 使用游标对象,执行SQL语句
cursor.execute("SELECT * FROM city")
# 获取查询结果(返回的结果是元组类型数据)
results = cursor.fetchall()
for x in results:
    print(x)

数据插入

# pymysql在执行数据插入或其他产生数据更改的SQL语句时,默认是需要提交更改的
# 通过链接对象.commit()即可确认此行为
cursor.execute("")
conn.commit()
# ------------------------------------------------------------------------------------
# 自动commit
conn = Connection(
    host='localhost',
    port=3306,
    user='root',
    password='',
    autocommit=True
)