PyMySQL

一、PyMySQL?

1、概念

PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库，Python2中则使用mysqldb。PyMySQL 遵循 Python 数据库 API v2.0 规范，并包含了 pure-Python MySQL 客户端库。

2、PyMySQL安装

在使用 PyMySQL 之前，我们需要确保 PyMySQL 已安装。使用语句：pip install pymysql安装。

3、MySQL数据库准备

• 首先创建一个可连接的库并拥有该库的用户名和密码以及操作权限；
• 创建一个可供操作的表格并插入数据；
• 在你的机子上已经安装了 PyMySQL 模块。

4、连接数据库

# 导入pymsql模块
import pymysql
# 连接database
conn = pymysql.connect(host="127.0.0.1",port=3306,user="root",password ="123456",database="testdatase",charset="utf8")
# 得到一个可以执行SQL语句的光标对象
cursor = conn.cursor()
# 要执行的sql语句
sql = "select * from userinfo where name = %s and pwd = %s;"
# 执行sql语句
cursor.execute(sql,["name","pwd"])
# 关闭光标对象
cursor.close()
# 关闭数据库连接
conn.close()

# 得到一个可以执行SQL语句并且将结果作为字典返回的游标

cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)

二、基本操作

1、增

import pymysql
conn = pymysql.connect(host="127.0.0.1",port=3306,user="root",password ="123456",database="testdb",charset="utf8")
cursor = conn.cursor()
sql = "insert into userinfo (name,pwd) values (%s,%s);"
cursor.execute(sql,["小明",123])
#  数据的提交
conn.commit()
cursor.close()
conn.close()

批量的增加数据：

import pymysql
conn = pymysql.connect(host="127.0.0.1",port=3306,user="root",password ="123456",database="day59",charset="utf8")
cursor = conn.cursor()
sql = "insert into userinfo (name,pwd) values (%s,%s);"
data=[("小花",123),("小李",456),("小白",789)]
#  批量插入数据使用executemany,data是可迭代的数据
cursor.executemany(sql,data)
conn.commit()
cursor.close()
conn.close()

获取刚插入数据的ID：

在提交事务之后获取刚插入数据的ID值：last_id = cursor.lastrowid.

2、删 

   1 # 导入pymsql模块

   2 import pymysql

# 连接database
conn = pymysql.connect(host="127.0.0.1",port=3306,user="root",password ="123456",database="testdb",charset="utf8")
#  得到一个可以执行SQL语句的光标对象
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
print(cursor)
# 要执行的sql语句
sql = "delete from userinfo where name = %s;"
#  执行sql语句
cursor.execute(sql,"小明")
12 conn.commit()
13 # 关闭光标对象 
cursor.close() 
# 关闭数据库连接 
conn.close()

3、改

# 导入pymsql模块
import pymysql
# 连接database
conn = pymysql.connect(host="127.0.0.1",port=3306,user="root",password ="123456",database="testdb",charset="utf8")
#  得到一个可以执行SQL语句的光标对象
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
print(cursor)
# 要执行的sql语句
sql = "update userinfo set pwd=%s where name=%s;"
#  执行sql语句
cursor.execute(sql,["321","小明"])
12 conn.commit()
# 关闭光标对象
cursor.close()
# 关闭数据库连接
conn.close()

4、查

# 导入pymsql模块
import pymysql
# 连接database
conn = pymysql.connect(host="127.0.0.1",port=3306,user="root",password ="123456",database="testdb",charset="utf8")
#  得到一个可以执行SQL语句的光标对象
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
print(cursor)
# 要执行的sql语句
sql = "select * from userinfo where name = %s;"
#  执行sql语句
cursor.execute(sql,["小明"])
ret1 = cursor.fetchone()  # 取一条
ret2 = cursor.fetchmany(3)  # 取三条
ret3 = cursor.fetchall()  # 取所有
cursor.scroll(1, mode="absolute")  # 绝对移动,你指哪儿 它就移到哪儿
cursor.scroll(1, mode="relative")  # 相对移动, 相对它当前在的位置
cursor.scroll(-1, mode="relative")  # 相对移动, 相对它当前在的位置
# 关闭光标对象
cursor.close()
# 关闭数据库连接
conn.close()