使用sqlalchemy如何基于每个请求动态绑定到数据库引擎

from flask import Flask, request
from sqlalchemy import create_engine
from sqlalchemy.orm import scoped_session, sessionmaker

app = Flask(__name__)

# 创建一个基于请求上下文的数据库连接
@app.before_request
def before_request():
    # 根据请求的参数或其他条件选择数据库引擎
    if request.args.get('db') == 'mysql':
        engine = create_engine('mysql://username:password@localhost/dbname')
    else:
        engine = create_engine('sqlite:///dbname.sqlite3')

    # 创建一个基于请求上下文的数据库会话
    session = scoped_session(sessionmaker(bind=engine))

    # 将数据库会话添加到请求上下文
    request.db_session = session

# 在请求结束时关闭数据库会话
@app.teardown_request
def teardown_request(exception):
    if hasattr(request, 'db_session'):
        request.db_session.remove()

# 示例路由，使用数据库会话
@app.route('/')
def index():
    # 使用请求上下文中的数据库会话
    session = request.db_session

    # 执行查询并返回结果
    result = session.execute('SELECT * FROM my_table')
    return str(result.fetchall())