操作MySQL¶

Python操作MySQL数据库需要遵守DB-API规范，有很多封装好的驱动库供我们选择

20220809200749

步骤

引入 API 模块
与数据库建立连接
执行 SQL 语句
关闭数据库连接

MySQLdb¶

MySQLdb 1，依赖了mysql-connector-c，仅支持Py2.x，pip install MySQL-python
MySQLdb 2，即 mysqlclient，从MySQLdb 1 fork而来，适配了Py3.x并修复了一些问题，性能最好，Django推荐

参考官方文档：https://mysqlclient.readthedocs.io/user_guide.html#mysqldb

安装比较麻烦，参考README：https://github.com/PyMySQL/mysqlclient

# Mac 以下两步顺序不要颠倒，否则import MySQLdb时可能会报NameError: name ‘_mysql’ is not defined
brew install mysql-client
pip install mysqlclient

# Ubuntu
'''
sudo apt-get install python3-dev default-libmysqlclient-dev build-essential
    在docker容器（python:3.9）中实际测试发现貌似并不需要先执行此行命令
    apt-get list --installed 发现是有 default-libmysqlclient-dev 这个依赖包的
'''
pip install mysqlclient

import MySQLdb

conn = MySQLdb.connect(
    host = "localhost",
    port = 3306,  # int类型
    user = "root",
    passwd = "12345678",
    db = "cases"
)

cur = conn.cursor()  # 创建游标

exchange = "deribit"
subject = "SWAP_USD"
currency = "BTC"
# 注意：字段值要被''包裹
sql = f"""SELECT * FROM onestep_{exchange} WHERE subject='{subject}' and currency='{currency}'"""

r = cur.execute(sql)

print(r)  # 6，返回结果数量
print(cur.fetchone())
print(cur.fetchmany(2))
print(cur.fetchall())  # cur是一个迭代器，这里把结果都取完，则后面再取就是空的()
print(cur.fetchmany(2))

# 同时插入多条记录用executemany
sql = "INSERT INTO student VALUES(%s,%s,%s,%s)"
cur.executemany(sql,
    [
        ('3','Tom','1 year 1 class','6'),
        ('3','Jack','2 year 1 class','7'),
        ('3','Yaheng','2 year 2 class','7'),
    ]
)
conn.commit()  # 修改/插入后需要提交才能生效
cur.close()  # 关闭游标
conn.close()  # 关闭数据库

mysql-connector¶

pip install mysql-connector

MySQL官方提供的，纯Python实现，所以性能很差，且使用人数少

import mysql.connector

# 打开数据库连接
db = mysql.connector.connect(
       host="localhost",
       user="root",
       passwd="12345678",
       database='demo', 
       auth_plugin='mysql_native_password'  # 密码验证方式，采用明文，8.0版本为caching_sha2_password
)
# 获取操作游标 
cursor = db.cursor()
# 执行SQL语句
cursor.execute("SELECT VERSION()")
# 获取一条数据
data = cursor.fetchone()
print("MySQL版本: %s " % data)

# 关闭游标&数据库连接
cursor.close()
db.close()

PyMySQL¶

pip install PyMySQL

也是纯Python实现，性能最差，但最流行，如果项目里用了gevent貌似只能用pymysql

ORM¶

SQLAIchemy
peewee
Django admin

最后更新: 2022-08-10