还是因为最近在开发fastapi应用、现在需要把一些关键信息存库，所以就很想要一些这方面的资料。我这里找到一些，希望你看了帖子能节省一些时间。

前边说过如何搭建fastapi开发环境，帖子链接为：
https://blog.csdn.net/weixin_42988262/article/details/148684972?spm=1001.2014.3001.5501
还说过如何搭建可用的mysql环境，帖子链接为：
https://blog.csdn.net/weixin_42988262/article/details/148716542?spm=1001.2014.3001.5501
所以，本文相关的部分就简化甚至省略掉了。

# 首先试一下pymysql

问一下ai或者自己搜一下，很容易就了解到这个东东，所以我就先试了一下

环境说明

我这里是用的《考古一下如何搭建可用的mysql环境》那个帖子时搞的虚拟机，操作系统Anolis8.6，已经装了mysql，不同的是我给/etc/my.cnf.d/mysql-server.cnf加了这一行：

systemctl restart mysqld，就可以看到监听的是127.0.0.1了：

 

这样从本机安装python3.9和python包“pymysql”，就可以连同在这个虚拟机上的mysql server了；如果再安装python包“fastapi[standard]”、DBUtils，就可以尝试使用连接池了。

安装python3.9、pymysql

安装一下python3.9

安装pip、setup tools、wheel：

确保pip、setup tools、wheel最新：

创建虚拟环境并激活、安装pymsyql：

去mysql创建数据库和表

CREATE TABLE `all_requests` (`col1` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL, `col2` char(200) DEFAULT NULL);

准备脚本main.py

文字版贴到这里：
(pymysql.ve) [root@localhost tryPymysql]# more main.py 
import pymysql
def insert_data_pymysql():try:# 建立数据库连接connection = pymysql.connect(host='127.0.0.1',user='root',password='xxxxxxxx',database='reqs',charset='utf8mb4',cursorclass=pymysql.cursors.DictCursor)with connection:with connection.cursor() as cursor:# 插入单条数据sql = "INSERT INTO all_requests (col1, col2) VALUES (%s, %s)"cursor.execute(sql, ("value1", "value2"))    # 提交事务connection.commit()print("记录插入成功")     except pymysql.MySQLError as e:print(f"数据库错误: {e}")insert_data_pymysql()

试试效果：

查一下看看：

# 弄个连接池，免得每次都去连接

到这里，就得考虑用连接池的事情了。不过，我们首先看一下如何查看mysql的连接数

如何查看mysql的连接数

我们开一个bash，登录mysql，执行SHOW STATUS LIKE 'Threads_connected';

 

再启动一个bash终端，也登录mysql，连接一下看看，变成2了：

关掉其中一个，用另一个看，成了1了，很稳。

安装DBUtils、fastapi

python3 -m pip install DBUtils -i https://mirrors.aliyun.com/pypi/simple

先把fastapi官网上那个例子改成用APIRouter的样子：

启动：

访问一下试试：

mysql数据库新建一个库表

因为现在需要一个能保存int值的，刚才那个不太行。。
CREATE TABLE `reqs` (`col1` int(10) NOT NULL, `col2` char(200) DEFAULT NULL);

 

参考ai的示例修改main.py、用DBUtils创建连接池

from typing import Union
from fastapi import FastAPI
from fastapi import APIRouter
import uvicorn
import pymysql
from dbutils.pooled_db import PooledDB# 创建连接池
pool = PooledDB(creator=pymysql,host='127.0.0.1',user='root',password='12345678',database='reqs',charset='utf8mb4',cursorclass=pymysql.cursors.DictCursor, autocommit=True,maxconnections=10
)def insert_data_using_pool(item_id: int, q: Union[str, None] = None):try:connection = pool.connection()with connection.cursor() as cursor:sql = "INSERT INTO reqs (col1, col2) VALUES (%s, %s)"cursor.execute(sql, (item_id, q))print("使用连接池插入记录成功")except pymysql.MySQLError as e:print(f"数据库错误：{e}")finally:if connection:connection.close()app = FastAPI()
router = APIRouter()# 定义了一个get接口，指定路径为/，当用户访问/的时候，FastAPI调用read_root函数
@router.get("/")
async def read_root():return {"Hello": "World"}@router.get("/items/{item_id}")
async def read_item(item_id: int, q: Union[str, None] = None):insert_data_using_pool(item_id, q)return {"item_id": item_id, "q": q}app.include_router(router, prefix="/api")if __name__ == "__main__":uvicorn.run(app="main:app", host='0.0.0.0', port=8000, reload=True)

打开服务，请求几次看效果：

看看库表和连接数：

别的不说，反正是入库成功了。这要是赶项目，这一块就可以过去了，大多数人都能懂哈。。不过，对我这个水平来说，我有种问号特别多还不知道咋表述的感觉，到这里曾经尝试参考ai的提示，打印连接池的连接数以及空闲连接数等，没学到任何东西，其过程让我想起来了这个图：

所以，我们还是去看看DBUtils的官方文档咋说。

# 看看DBUtils的官方文档咋说

https://pypi.org/project/DBUtils/看起来靠谱，页面这个样：

先看看我这是个啥版本，哦，就是最新的：

往下翻一下，看这里：

链接为https://webwareforpython.github.io/DBUtils/main.html，页面这个样：

因为咱们的示例在用PooledDb，所以直接去看这里了:

链接指向https://webwareforpython.github.io/DBUtils/main.html#pooleddb-pooled-db
 

既然链接都贴出来了，我还是学到啥就写啥了。
- pooled_db可以用来在不同的线程之间共享数据库连接，线程安全
- 创建连接池时，要给maxshared一个正数值
- 可以请求专用的连接（不一定要请求线程间共享的连接）
- mincached和maxcached设置的线程池，是预备给线程申请专用连接使用，或者“the pool of shared connections is not yet full”（用原文就是我还没大看明白）。。
 

接着看吧。。。

超链接指向https://webwareforpython.github.io/DBUtils/main.html#pooleddb-pooled-db-1

什么是DB-API 2

老遇见这个东西：DB-API 2 connection objects / DB-API 2 compliant database module
https://webwareforpython.github.io/DBUtils/main.html的页面往上翻，看到这个了：

链接指向：https://peps.python.org/pep-0249/

pymysql符合这个标准，就完了：

继续看PooledDB怎么用，示例过于简单了，基本等于没说，那就看看标准，就是链接https://peps.python.org/pep-0249/，这不就有东西嘛：

这里有更详细的说明，但没有示例。。。不过，还发现了这个：

写一段代码打出来后，这个样：

# 所以，我们现在可以参考的有

DBUtils包的文档

就是https://webwareforpython.github.io/DBUtils/main.html

help()方法打出的内容

略

DB-API 2标准的说明

就是https://peps.python.org/pep-0249/

ai给出的示例

略

我自己熟悉的某个私有项目

这个真的不能贴出来

哦，还可以参考pymysq的文档

https://pypi.org/project/PyMySQL/
这不就是个很好的示例么。。

算是有点儿收获了吧，起码找到了一堆资料，基本实现了0的突破，所以这个帖子到这里了，
AI老说with会自动回收连接资源，不用手动close，我这会儿准备考古一下去。