第三方库pymysql
使用安装命令 pip install pymysql
连接数据库、选择库、获取游标，执行创建表语句
from pymysql import Connection
# 获取到mysql数据库连接对象
conn = Connection(host="localhost", passwd="123456", user="root", port=3306)
# 5.1.72-community
print(conn.get_server_info())
# 执行非查询性质的SQL语句
# 获取游标对象
cursor = conn.cursor()
conn.select_db("xkj") # 选择数据库
# 使用游标对象执行sql语句
cursor.execute("create table test_pymysql (id INT, info varchar(255))")
# 关闭数据库连接
conn.close()执行获取表中记录的语句
from pymysql import Connection
# 获取到mysql数据库连接对象
conn = Connection(host="localhost", passwd="123456", user="root", port=3306)
# 5.1.72-community
print(conn.get_server_info())
# 执行查询性质的SQL语句
# 获取游标对象
cursor = conn.cursor()
conn.select_db("xkj") # 选择数据库
# 使用游标对象执行sql语句
cursor.execute("select * from user ")
# 获取查询结果
result: tuple = cursor.fetchall()
# result 是大元组里面套了很多个小元组
for r in result:
# (1, 'zhangsan', '111111', '22')
print(r)
# 关闭数据库连接
conn.close()
给数据库表中添加一条记录
from pymysql import Connection
# 获取到mysql数据库连接对象
conn = Connection(host="localhost", passwd="123456", user="root", port=3306)
# 5.1.72-community
print(conn.get_server_info())
# 执行查询性质的SQL语句
# 获取游标对象
cursor = conn.cursor()
conn.select_db("xkj") # 选择数据库
# 使用游标对象执行sql语句
cursor.execute("insert into user(username, password, money) values('小宇', '111111', 100) ")
# 提交事务
conn.commit()
# 关闭数据库连接
conn.close()
也可以在Connection的构造方法中这是事务自动提交
from pymysql import Connection
# 获取到mysql数据库连接对象
conn = Connection(host="localhost", passwd="123456", user="root", port=3306, autocommit=True)
# 5.1.72-community
print(conn.get_server_info())
# 执行查询性质的SQL语句
# 获取游标对象
cursor = conn.cursor()
conn.select_db("xkj") # 选择数据库
# 使用游标对象执行sql语句
cursor.execute("insert into user(username, password, money) values('小宇', '111111', 100) ")
# 提交事务
# conn.commit()
# 关闭数据库连接
conn.close()
