更改会话集 current_schema 不能全局工作

Question

我正在更改主函数中的架构

db_dwh.cursor.execute("alter session set current_schema = SCHEMA_NAME")

但是当我将这个 db_dwh 对象传递给一个函数并尝试对一个表执行查询时，我得到了 table not found 错误， 为此，我必须再次使用以下方法设置架构：

db_dwh.cursor.execute("alter session set current_schema = SCHEMA_NAME")

有没有办法在全球只在一个地方设置架构？

---

PS 在 Hadoop 环境中运行的作业。

Answer 1

我希望您的函数具有不同的连接 - 我希望您使用的是连接池。

评论有一个解决方案。

这里有一些其他可用的工具。它们可能有用，具体取决于您（或其他读者）的应用程序架构：

• Connection.current_schema 而不是显式的 ALTER SESSION。这节省了execute() 的往返开销。

• 连接池回调以有效设置状态：https://cx-oracle.readthedocs.io/en/latest/user_guide/connection_handling.html#session-callbacks-for-setting-pooled-connection-state 您说您正在尝试全局设置架构。如果它始终具有相同的值，那么我会将此解决方案与Connection.current_schema 属性结合使用。

    def init_session(connection, requested_tag):
        connection.current_schema = 'ALISON'

    # Create the pool with a session callback
    pool = cx_Oracle.SessionPool(user="whoever", password=userpwd, dsn="orclpdb1", session_callback=init_session)

    # Get a connection from the pool.  It will always have the current schema
    # set to ALISON
    connection = pool.acquire()

    . . .  # Use the connection

• 异构连接池：https://cx-oracle.readthedocs.io/en/latest/user_guide/connection_handling.html#heterogeneous-and-homogeneous-connection-pools