28.操作数据库

发布于:2024-12-20 ⋅ 阅读:(170) ⋅ 点赞:(0)

第三方库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()


网站公告

今日签到

点亮在社区的每一天
去签到