### Sanic 框架中的数据库操作 在 Sanic 桨架中进行数据库操作通常涉及使用异步驱动程序来处理数据库连接和查询。以下是一个基于 SQLAlchemy 和 pymysql 的 MySQL 数据库配置示例以及如何集成到 Sanic 庈架中的方法。 #### 使用 Asyncpg 或 AioMySQL 进行数据库操作 对于 PostgreSQL，可以使用 `asyncpg`；而对于 MySQL，则推荐使用 `aiomysql` 来实现异步数据库交互。下面展示了一个简单的例子： ```python from sanic import Sanic import aiomysql app = Sanic("MyApp") @app.listener('before_server_start') async def init_db(app, loop): app.ctx.db_pool = await aiomysql.create_pool( host='127.0.0.1', port=3306, user='root', password='', db='learn_flask_mysql', loop=loop ) @app.listener('after_server_stop') async def close_db(app, _): app.ctx.db_pool.close() await app.ctx.db_pool.wait_closed() @app.get("/users/<user_id:int>") async def get_user(request, user_id): async with request.app.ctx.db_pool.acquire() as conn: async with conn.cursor(aiomysql.DictCursor) as cur: await cur.execute(f"SELECT * FROM users WHERE id={user_id}") result = await cur.fetchone() return {"data": result} if __name__ == "__main__": app.run(host="0.0.0.0", port=8000) ``` 上述代码展示了如何初始化一个异步池并执行 SQL 查询[^2]。通过这种方式，可以在不阻塞事件循环的情况下完成数据库读写操作。 #### ORM 方式 (SQLAlchemy + Gino) 如果更倾向于使用 ORM 工具而不是原生 SQL 语句，那么可以选择 **Gino** —— 它是对 SQLAlchemy 的一种封装，支持异步编程风格。以下是其基本用法： 安装依赖项： ```bash pip install gino sqlalchemy pymysql ``` 创建模型类并与路由绑定： ```python from sanic import Sanic from gino.ext.sanic import GINO db = GINO() class User(db.Model): __tablename__ = 'users' id = db.Column(db.Integer(), primary_key=True) name = db.Column(db.String()) app = Sanic("ORMExample") app.config['DB_HOST'] = 'localhost' app.config['DB_USER'] = 'root' app.config['DB_PASSWORD'] = '' app.config['DB_NAME'] = 'test' app.config['DB_PORT'] = 3306 app.config['SQLALCHEMY_DATABASE_URI']="mysql+pymysql://root:@127.0.0.1:3306/learn_flask_mysql" db.init_app(app) @app.route('/create', methods=['POST']) async def create_user(request): new_user = await User.create(name=request.json.get('name')) return {'id':new_user.id,'name':new_user.name} @app.route('/read/<uid>',methods=["GET"]) async def read_user(request, uid): user = await User.get(uid) if not user: abort(404,"User Not Found.") return text(str(user)) ``` 此部分说明了如何利用 Gino 实现 CRUD 功能。 --- ###