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小时后才会自动断开连接,会导致访问不了数据库