Flask+Apache+mod_wsgi环境下cx_Oracle持久连接保活方案咨询

你当前的单全局连接实现除了超时问题外，还存在多线程并发风险：Apache配置了20个工作线程，所有线程共享同一个数据库连接，即使cx_Oracle开启了threaded=True参数，一旦连接中途中断，所有请求都会瞬间失效，且存在事务互相干扰的隐患。以下是两种可落地的有效方案：

方案1：操作前连接有效性校验 + 自动重连（适合低并发场景） #

修改DB类，每次执行数据库操作前先校验连接存活状态，失效则自动重建连接，代码修改如下：

# DB.py 修改后
import cx_Oracle
class DB:
    def __init__(self, connection_string):
        self.connection_string = connection_string
        self.conn = None
        self._connect()

    def _connect(self):
        # 新建连接
        self.conn = cx_Oracle.connect(self.connection_string, threaded=True)
    
    def _check_connection(self):
        # 校验连接有效性，失效则重连
        try:
            self.conn.ping()
        except cx_Oracle.Error:
            self._connect()
    
    def insert(self, query):
        self._check_connection()
        cur = self.conn.cursor()
        try:
            cur.execute(query)
            self.conn.commit()
        except Exception as e:
            self.conn.rollback()
            raise e
        finally:
            cur.close()

这个方案改动最小，无需额外依赖，每次执行插入前会自动检测连接状态，超时断开后会自动重建，上层业务完全无感知，等效于连接永久有效。

方案2：使用官方连接池（推荐，适合中高并发场景） #

cx_Oracle原生提供了数据库连接池实现，会自动管理连接的生命周期、失效重连、并发调度，比单连接方案稳定性高很多，配置示例：

# DB.py 连接池版本
import cx_Oracle
class DB:
    def __init__(self, connection_string, min_conn=2, max_conn=10, increment=1):
        self.pool = cx_Oracle.SessionPool(
            dsn=connection_string,
            min=min_conn,
            max=max_conn,
            increment=increment,
            threaded=True,
            getmode=cx_Oracle.SPOOL_ATTRVAL_WAIT,
            ping_interval=300 # 每300秒自动校验连接有效性，失效连接自动剔除
        )
    
    def insert(self, query):
        conn = self.pool.acquire()
        cur = conn.cursor()
        try:
            cur.execute(query)
            conn.commit()
        except Exception as e:
            conn.rollback()
            raise e
        finally:
            cur.close()
            self.pool.release(conn)

这个方案不仅解决了超时断连问题，还规避了多线程共享单连接的并发风险，性能和稳定性都更优。

可选补充：极端闲置场景主动保活 #

如果业务确实存在连续数天无请求的极端场景，可以在应用中添加一个定时任务，每隔6小时执行一次简单查询（比如SELECT 1 FROM DUAL），主动触发连接校验，避免长时间闲置被数据库侧主动断开。

内容的提问来源于stack exchange，提问作者greenlantern