Sqlalchemy是Python生态中常用的数据库ORM框架，在实际使用中很多开发者会遇到数据库连接无法正确关闭的问题，长期运行后会出现数据库连接数飙升、数据库响应变慢甚至拒绝新连接的情况。要解决这个问题，首先需要明确连接无法关闭的常见原因，再针对性调整代码和配置。
一、Sqlalchemy连接无法正确关闭的常见原因
1. 会话未手动释放
Sqlalchemy的Session对象默认不会自动关闭，如果没有显式调用close()方法，或者没有使用上下文管理器管理会话生命周期，就会导致会话对应的数据库连接无法归还到连接池，形成连接泄漏。
2. 事务未正常结束
如果会话中开启了事务，既没有提交也没有回滚，连接会一直处于占用状态，不会被释放。尤其是发生异常时如果没有捕获并处理事务状态，很容易出现这类问题。
3. 连接池配置不合理
Sqlalchemy默认的连接池配置了最大连接数等参数，如果业务并发量超过了连接池的最大连接数，多余的连接请求会等待，而如果等待超时或者连接没有被正确回收，也会出现连接无法正常关闭的表现。
4. 长时间持有会话不释放
有些开发者会把会话对象作为全局变量或者长时间保存在某个对象中，导致会话一直存活，对应的连接也不会被关闭，随着时间推移连接数会不断累积。
二、解决Sqlalchemy连接无法关闭的方法
1. 使用上下文管理器管理会话
推荐使用sessionmaker生成的会话类配合with语句使用，这样可以保证会话在退出上下文时自动调用close()方法，避免手动遗漏释放操作。
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
# 创建数据库引擎，这里以SQLite为例，实际使用时替换为对应的数据库连接字符串
engine = create_engine("sqlite:///test.db")
Session = sessionmaker(bind=engine)
# 使用上下文管理器管理会话
with Session() as session:
# 执行数据库操作
result = session.execute("SELECT 1")
print(result.fetchone())
# 退出with块后，会话会自动关闭，连接归还到连接池2. 规范事务的提交与回滚
所有涉及写操作的会话都需要在操作完成后明确提交事务，发生异常时回滚事务，保证事务状态正常结束，避免连接被事务占用无法释放。
with Session() as session:
try:
# 执行新增、修改、删除等写操作
session.execute("INSERT INTO user (name) VALUES ('test')")
# 提交事务
session.commit()
except Exception as e:
# 发生异常时回滚事务
session.rollback()
print(f"操作失败: {e}")3. 合理配置连接池参数
可以在创建引擎时调整连接池的相关参数，比如设置最大连接数、回收闲置连接的时间等，避免连接池中的连接无法正常回收。
from sqlalchemy import create_engine
# 配置连接池参数：最大连接数5，闲置连接回收时间30秒，连接超时时间10秒
engine = create_engine(
"mysql+pymysql://user:password@127.0.0.1:3306/test_db",
pool_size=5,
pool_recycle=30,
pool_timeout=10
)常用连接池参数说明：
| 参数名 | 作用 |
|---|---|
| pool_size | 连接池保持的最小连接数，默认是5 |
| max_overflow | 连接池允许超出pool_size的最大连接数，默认是10 |
| pool_recycle | 连接回收时间，单位秒，超过该时间的闲置连接会被回收，避免数据库主动断开连接 |
| pool_timeout | 获取连接的超时时间，单位秒，默认是30 |
4. 避免长期持有会话对象
不要在全局作用域或者长时间存活的对象中保存会话实例，每次需要操作数据库时再创建会话，操作完成后立即释放。如果是Web应用，可以结合框架的请求生命周期管理会话，比如在请求开始时创建会话，请求结束时关闭会话。
5. 监听连接池事件排查问题
如果仍然无法定位连接泄漏的原因，可以添加连接池的事件监听，查看连接的创建、释放、回收等状态，辅助排查问题。
from sqlalchemy import event
# 监听连接池的连接创建事件
@event.listens_for(engine, "connect")
def on_connect(dbapi_connection, connection_record):
print("新的数据库连接被创建")
# 监听连接池的连接关闭事件
@event.listens_for(engine, "close")
def on_close(dbapi_connection, connection_record):
print("数据库连接被关闭")
# 监听连接归还到连接池的事件
@event.listens_for(engine, "checkin")
def on_checkin(dbapi_connection, connection_record):
print("连接被归还到连接池")三、验证连接是否正常关闭
可以通过查看数据库的当前连接数来验证问题是否解决，比如MySQL可以执行以下SQL查看连接数：
-- 查看当前数据库的连接数 SHOW PROCESSLIST; -- 查看数据库的最大连接数配置 SHOW VARIABLES LIKE 'max_connections';
如果应用运行一段时间后连接数保持稳定，没有持续增长，说明连接已经可以正常关闭和回收。
Sqlalchemy数据库连接连接关闭数据库连接池修改时间：2026-06-06 16:23:47