安装模块
windows:pip install pymysql
ubuntu:sudo pip3 install pymysql
python操作mysql步骤
import pymysql
(1) 链接mysql数据库
db = pymysql.connect(主机名,用户名,密码,数据库名)
(2) 设置字符编码
db.set_charset('utf8')
(3) 创建游标对象
cursor = db.cursor()
(4) 准备sql语句
sql = '...'
(5) 执行sql语句
cursor.execute(sql)
(6) 获取所有结果集
cursor.fetchall()
(7) 获取一条结果集
cursor.fetchone()
(8) 获取受影响的行数
cursor.rowcount
(9) 关闭数据库链接
db.close()
pymysql的事物处理
默认开启事物处理
需要提交或者回滚
完整的操作
|
1
2
3
4
5
6
7
8
9
10
11
12
|
import pymysqldb = pymysql.connect('127.0.0.1','root','123456','hz03')db.set_charset('utf8')cursor = db.cursor()try: sql = 'insert into goods values(null,1,"商品名称",12.1)' cursor.execute(sql) db.commit()except: db.rollback()print(cursor.rowcount)db.close() |
原文链接：https://segmentfault.com/a/1190000015124778
