本文目录
  1. 1.查询
  2. 2.增删改

使用 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()