DATABASE NOTES · 07
通过 PyMySQL 连接数据库并完成查询与数据写入。
- PyMySQL
- Python
使用 PyMySQL 操作 MySQL
通过 PyMySQL 连接数据库并完成查询与数据写入。
1.查询
##1.调包
##2.连接
##3.创建游标
##4.执行语句
##5.关闭游标
##6.关闭连接
# 查询
# 1.调包
import pymysql
# 2.连接数据库
conn = pymysql.connect(host='127.0.0.1',
port=3306,
user='root',
password="your_password",
charset='utf8')
# 3.创建游标
cous = conn.cursor()
# 4.执行SQL语句
cous.execute('select * from first_db.users')
# 5.获取数据
print(f"获取一条数据{cous.fetchone()}")
print(f"获取所有数据{cous.fetchall()}")
# 6.关闭游标
cous.close()
# 7.关闭连接
conn.close()
2.增删改
##1.调包
##2.连接
##3.创建游标
##4.操作sql数据库
try:
执行语句
连接对象提交
expcet Expcetion as e:
回滚至上一次提交
##5.关闭游标
##6.关闭连接
# 操作数据
# 1.调包
import pymysql
# 2.连接数据库
conn = pymysql.connect(host='127.0.0.1',
port=3306,
user='root',
password="your_password",
charset='utf8')
# 3.创建游标
cous = conn.cursor()
# 4.执行SQL语句
try:
cous.execute("""insert into first_db.shop (sid,name,cid) values(6,"小米",2)""")
cous.execute("""insert into first_db.users values (10,"王五","1111@qq.com",'2023-06-18','上海')""")
conn.commit()
except Exception as e:
print(f"出错了,{e}")
conn.rollback()
# 6.关闭游标
cous.close()
# 7.关闭连接
conn.close()