如何在Python中操作MySQL

Python 标准数据库接口为 Python DB-API，Python DB-API为开发人员提供了数据库应用编程接口。Python 数据库接口支持非常多的数据库，你可以选择适合你项目的数据库：

• GadFly
• mSQL
• MySQL
• PostgreSQL
• Microsoft SQL Server 2000
• Informix
• Interbase
• Oracle
• Sybase ...

你可以访问Python数据库接口及API查看详细的支持数据库列表。

不同的数据库你需要下载不同的DB API模块，例如你需要访问Oracle数据库和Mysql数据，你需要下载Oracle和MySQL数据库模块。

DB-API 是一个规范. 它定义了一系列必须的对象和数据库存取方式, 以便为各种各样的底层数据库系统和多种多样的数据库接口程序提供一致的访问接口 。

Python的DB-API，为大多数的数据库实现了接口，使用它连接各数据库后，就可以用相同的方式操作各数据库。

Python DB-API使用流程：

• 引入 API 模块。
• 获取与数据库的连接。
• 执行SQL语句和存储过程。
• 关闭数据库连接。

二. python操作MySQL模块

Python操作MySQL主要使用两种方式：

1. DB模块(原生SQL)
   • PyMySQL(支持python2.x/3.x)
   • MySQLdb(目前仅支持python2.x)
2. ORM框架
   • SQLAchemy

2.1 PyMySQL模块

本文主要介绍PyMySQL模块,MySQLdb使用方式类似

2.1.1 安装PyMySQL

PyMySQL是一个Python编写的MySQL驱动程序，让我们可以用Python语言操作MySQL数据库。

import pymysql
import threading
from DBUtils.PooledDB import PooledDB, SharedDBConnection
POOL = PooledDB(
creator=pymysql,  # 使用链接数据库的模块
maxconnections=20,  # 连接池允许的最大连接数，0和None表示不限制连接数
mincached=2,  # 初始化时，链接池中至少创建的空闲的链接，0表示不创建
maxcached=5,  # 链接池中最多闲置的链接，0和None不限制
#maxshared=3,  # 链接池中最多共享的链接数量，0和None表示全部共享。PS: 无用，因为pymysql和MySQLdb等模块的 threadsafety都为1，所有值无论设置为多少，_maxcached永远为0，所以永远是所有链接都共享。
blocking=True,  # 连接池中如果没有可用连接后，是否阻塞等待。True，等待；False，不等待然后报错
maxusage=None,  # 一个链接最多被重复使用的次数，None表示无限制
setsession=[],  # 开始会话前执行的命令列表。如：["set datestyle to ...", "set time zone ..."]
ping=0,
# ping MySQL服务端，检查是否服务可用。# 如：0 = None = never, 1 = default = whenever it is requested, 2 = when a cursor is created, 4 = when a query is executed, 7 = always
host='192.168.11.38',
port=3306,
user='root',
passwd='apNXgF6RDitFtDQx',
db='m2day03db',
charset='utf8'
)

def connect():
# 创建连接
# conn = pymysql.connect(host='192.168.11.38', port=3306, user='root', passwd='apNXgF6RDitFtDQx', db='m2day03db')
conn = POOL.connection()
# 创建游标
cursor = conn.cursor(pymysql.cursors.DictCursor)

return conn,cursor

def close(conn,cursor):
# 关闭游标
cursor.close()
# 关闭连接
conn.close()

def fetch_one(sql,args):
conn,cursor = connect()
# 执行SQL，并返回收影响行数
effect_row = cursor.execute(sql,args)
result = cursor.fetchone()
close(conn,cursor)

return result

def fetch_all(sql,args):
conn, cursor = connect()

# 执行SQL，并返回收影响行数
cursor.execute(sql,args)
result = cursor.fetchall()

close(conn, cursor)
return result

def insert(sql,args):
"""
创建数据
:param sql: 含有占位符的SQL
:return:
"""
conn, cursor = connect()

# 执行SQL，并返回收影响行数
effect_row = cursor.execute(sql,args)
conn.commit()

close(conn, cursor)

def delete(sql,args):
"""
创建数据
:param sql: 含有占位符的SQL
:return:
"""
conn, cursor = connect()

# 执行SQL，并返回收影响行数
effect_row = cursor.execute(sql,args)

conn.commit()

close(conn, cursor)

return effect_row

def update(sql,args):
conn, cursor = connect()

# 执行SQL，并返回收影响行数
effect_row = cursor.execute(sql, args)

conn.commit()

close(conn, cursor)

return effect_row

PS: 可以利用静态方法封装到一个类中,方便使用