python使用笔记12--操作mysql数据库

1.创建连接

1 import pymysql
2 connect = pymysql.connect(host='127.0.0.1',
3                           user='root',
4                           password='123456',
5                           db='db001',
6                           port=3306,
7                           charset='utf8',
8                           autocommit='True'#自动提交
9                           )

2.常用方法

事务：多条sql一起执行，一条执行失败，则所有的sql都算失败

 1 cur = connect.cursor(pymysql.cursors.DictCursor)#建立游标
 2 #pymysql.cursors.DictCursor指定游标的类型为字典型
 3 #如果不传值，则直接返回数据内容，不会返回表头
 4 sql = 'select * from user1;'
 5 #insert_sql = "insert into user1(name,address,age,sex) values ('test001','广州',23,'女');"
 6 cur.execute(sql)
 7 #cur.execute(insert_sql)
 8 connect.commit()#提交
 9 connect.rollback()#回滚，sql执行失败的时候才使用，用在事务里
10 
11 #游标，每读取一条游标就移动一次
12 result1 = cur.fetchone()#只获取一条结果
13 result2 = cur.fetchmany(4)#获取指定的条数
14 result = cur.fetchall()#获取sql执行的结果
15 print(cur.description)
16 cur.close()
17 connect.close()#建立连接后，没有关闭连接，mysql会在24小时后才会自动断开连接，会导致访问不了数据库