环境：python 3.6.1 + Mysql 5.1
python3 支持用 pymysql 模块来链接数据库
1、pymysql安装
windows下：pip install pymysql 直接安装
官方文档：Http://www.pymssql.org/en/stable/
2、实现思路
和用c++访问数据库方法基本相同
A. 通过pymysql模块的方法，与数据库建立连接
B. 编写SQL语句
C. 通过连接的返回的数据库对象，调用相应方法执行SQL语句
D. 读取数据库返回的数据（即缓存区中的数据）
E. 对相应的返回数据进行操作
F. 关闭数据库对象，关闭数据库
3、查询语句执行流程图：
4、增删改语句执行流程图：
5、事务：访问和更新数据库的一个程序执行单元
- 原子性：事务中包括的操作要么做，要么都不做（捆绑不可分割）
- 一致性：事务必须使数据库从一致性状态变到另一个一致性状态
- 隔离性：一个事务的执行不能被其他事务干扰
- 持久性：事务一旦提交，它对数据库的改变就是永久性的
6、增删改查功能实现代码：
#导入pymysql模块
import pymysql
class MYSQL:
# 初始化函数，初始化连接列表
def __init__(self,host,user,pwd,dbname):
self.host = host
self.user = user
self.pwd = pwd
self.dbname = dbname
# 获取数据库游标对象cursor
# 游标对象：用于执行查询和获取结果
def getCursor(self):
# 建立数据库连接
self.db = pymysql.connect(self.host,self.user,self.pwd,self.dbname)
# 创建游标对象
cur = self.db.cursor()
# 返回
return cur
# 查询操作
def queryOperation(self,sql):
# 建立连接获取游标对象
cur = self.getCursor()
# 执行SQL语句
cur.execute(sql)
# 获取数据的行数
row = cur.rowcount
# 获取查询数据
# fetch*
# all 所有数据,one 取结果的一行，many(size),去size行
dataList = cur.fetchall()
# 关闭游标对象
cur.close()
# 关闭连接
self.db.close()
# 返回查询的数据
return dataList,row
# 删除操作
def deleteOperation(self,sql):
# 获取游标对象
cur = self.getCursor()
try:
# 执行SQL语句
cur.execute(sql)
# 正常结束事务
self.db.commit()
except Exception as e:
print(e)
# 数据库回滚
self.db.rollback()
# 关闭游标对象
cur.close()
# 关闭数据库连接
self.db.close()
# 数据更新
def updateOperation(self,sql):
cur = self.getCursor()
try:
cur.execute(sql)
self.db.commit()
except Exception as e:
print(e)
self.db.rollback()
cur.close()
self.db.close()
# 添加数据
def insertOperation(self,sql):
cur = self.getCursor()
try:
cur.execute(sql)
self.db.commit()
except Exception as e:
print(e)
self.db.rollback()
cur.close()
self.db.close()
正在持续更新，若有错误，欢迎大家指正。
