Python的标准数据库接口为：Python DB-API，Python DB-API为开发人员提供了数据库应用编程接口。

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

一、安装PyMySQL

在使用 PyMySQL 之前，我们需要确保 PyMySQL 已安装。

PyMySQL 下载地址：https://github.com/PyMySQL/PyMySQL

如果还未安装，我们可以使用以下命令安装最新版的 PyMySQL：

pip install PyMySQL

二、连接数据库

1、建表

数据库准备，连接数据库之前，请确保已经创建了python数据库，以及students表

建表SQL如下：

CREATE TABLE `student`  (`id` int NOT NULL AUTO_INCREMENT COMMENT '主键',`stu_name` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '学生名字',`stu_class` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '学生班级',`stu_age` int NULL DEFAULT NULL COMMENT '学生年龄',PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 4 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '学生表' ROW_FORMAT = Dynamic;

2、创建Connection 对象：用于建立与数据库的连接

from pymysql import * 
# 导入pymysql模块 
# 创建连接对象 Connection对象 
# host:数据库主机地址 
# user:数据库账号 
# password：数据库密码 
# database : 需要连接的数据库的名称 
# port: mysql的端口号 
# charset: 通信采用编码格式 
conn = connect(host='127.0.0.1', user='root', password='mysql', database='python', port=3306, charset='utf8') 

1、Connection 连接对象拥有的方法

close()：关闭连接，连接数据库跟打开文件一样，操作完成之后需要关闭，否则会占用连接

commit()：提交，pymysql 默认开启事物，所以每次更新数据库都要提交 rollback()回滚，事务回滚

cursor()：返回Cursor对象，用于执行sql语句并获得结果

2、获取cursor对象

cur = conn.cursor() # cursor对象用于执行sql语句 

3、cursor对象拥有的方法

close()：关闭cursor对象

execute(operation [, parameters ]) 执行语句，返回受影响的行数，可以执行所有语句

fetchone()：获取查询结果集的第一个行数据，返回一个元组

fetchall()：执行查询时，获取结果集的所有行，一行构成一个元组，再将这些元组装入一个元组返回

3、SQL增删改查

1、插入语句

insertSql = '''insert into student(stu_name,stu_class,stu_age) values ('张三','高三一班',18)'''
cur.execute(insertSql)
conn.commit()  # 提交事务

2、查询语句

cur.execute('select * from students;') # 执行sql语句，select * from students; 
res = cur.fetchone() # 获取结果集的第一条数据 
res1 = cur.fetchall() # 获取结果及的所有数据 
print(res) # 将获取的查询结果打印 
print(res1) 

3、占位符：%s

执行sql语句参数化，参数化sql语句中使用%s占位。 execute(operation [parameters]) 执行语句，返回受影响的行数，可以执行所有语句 [parameters] 参数列表

# sql语句中使用%s占位
sql = 'select * from students where id=%s and stu_name= %s;' 	
# 执行sql语句
cur.execute(sql, [1,'张三'])

from pymysql import *'''
创建Connection 对象：用于建立与数据库的连接
导入pymysql模块 
# 创建连接对象 Connection对象 
# host:数据库主机地址 
# user:数据库账号 
# password：数据库密码 
# database : 需要连接的数据库的名称 
# port: mysql的端口号 
# charset: 通信采用编码格式
'''
conn = connect(host='localhost', port=3306, user='root', password='mysql', database='my_db', charset='utf8')try:# 创建游标对象cur = conn.cursor()# 执行sql语句# insertSql = '''insert into student(stu_name,stu_class,stu_age) values ('张三','高三一班',18);'''# cur.execute(insertSql)# conn.commit()  # 提交事务selectSql = '''select * from student where id=%s;'''cur.execute(selectSql,3)# selectSql = '''select * from student;'''# cur.execute(selectSql)# res = cur.fetchone()  # 获取结果集的第一条数据# print(res)# 获取结果及的所有数据result = cur.fetchall()for item in result:# 姓名：张三，班级：高三一班，年龄：18print('姓名：{0}，班级：{1}，年龄：{2}'.format(item[1], item[2], item[3]))
except Exception as msg:print(msg.args)
finally:# 关闭游标对象cur.close()# 关闭连接对象conn.close()

三、封装连接PyMySQL数据库工具

创建一个db_client.py文件

import pymysqlclass DBUtil():conn=None@classmethoddef get_conn(cls):if cls.conn is None:cls.conn=pymysql.connect(host="localhost",port=3306,user="root",password="mysql",database="my_db",charset="utf8")return cls.conn@classmethoddef close_conn(cls):if cls.conn is not None:cls.conn.close()cls.conn=None@classmethoddef select_all(cls,sql):cursor=Noneresult=Nonetry:cls.get_conn()cursor=cls.conn.cursor()cursor.execute(sql)result=cursor.fetchall()except Exception as e:print(e)finally:cursor.close()cls.close_conn()return result@classmethoddef uid(cls,sql):cursor=Nonetry:cls.get_conn()cursor=cls.conn.cursor()cursor.execute(sql)cls.conn.commit()except Exception as e:print(e)cls.conn.rollback()finally:cursor.close()cls.close_conn()

print('--------数据库工具DB--------')
# ((3, '张三', '高三一班', 18), (4, '李四', '高三二班', 16))
print(DBUtil.select_all("select * from student"))