postgresql连接池（注意这里用create_async_engine，async_sessionmaker支持异步）4 配置config.py,注意postgresql这里用asyncpg支持异步。新建routers文件夹，routes文件夹下新建__init__.py文件。新建api文件夹，api文件夹下新建transfermogodb.py文件。3 文件夹core下新建config.p

response.body_iterator = iter([body])# 重置迭代器。response.body_iterator = iter([body])# 重置迭代器。body_data = body.decode()# 非JSON则保留原始数据。body_data = body.decode()# 非JSON则保留原始数据。frame.f_code.co_name == 'dispa

return get_collection().find_one({})# 安全访问。init_db() print(collection) # 输出集合对象 (全局变量已被修改)collection = ...# 修改的是file2的collection副本。def init_db(): global collection # 声明引用全局变量。print(collection)# 输出 Non

4 选中 Python 3.12.2('venv':venv)用虚拟环境启动。5 点击左侧create a launch.json file。3 选中Python:Select Interpreter。2 ctrl+shift+P打开配置窗口。6 选中python debugger。1 main.py中配置启动代码。8 选择 main.py。7 选中FastAPI。

response.body_iterator = iter([body])# 重置迭代器。response.body_iterator = iter([body])# 重置迭代器。body_data = body.decode()# 非JSON则保留原始数据。body_data = body.decode()# 非JSON则保留原始数据。frame.f_code.co_name == 'dispa

2 运行虚拟环境（command prompt）1 创建虚拟环境(power shell)6 app文件夹下创建main.py。5 虚拟环境同目录创建app文件夹。3 虚拟环境下安装fastapi。4 虚拟环境下安装uvicorn。mian.py 添加如下代码。7 配置main.py。9 配置swagger。

如果当前使用Power Shell，切换到 Command Prompt(CMD)再试。

3 使用WITH子查询‌（单语句完成）： 利用CTE实现条件判断。2 使用DO匿名块‌（通用性强）：通过显式判断实现条件插入。此方法依赖name列的唯一约束，冲突时自动跳过插入。方法1要求name列必须定义唯一约束。方法2可扩展添加更复杂的判断逻辑。字符串值需用单引号包裹（'1'）

print(f"通过原生SQL语句完成 {len(src_data)} 条记录更新")# 配置数据库连接（示例为PostgreSQL->MySQL）# 从源数据库查询数据（使用原生SQL）# 构建批量更新SQL语句。