python-oracledb 游标与绑定变量：连接管理与数据持久化解析

import oracledb
import connection_config # 假设包含用户、密码、DSN配置

# 第一次连接
con = oracledb.connect(user=connection_config.user, password=connection_config.pw, dsn=connection_config.dsn)
cursor = con.cursor()   # 第一个连接的游标

host_variable = cursor.var(str) # 创建一个Python绑定变量对象
host_variable.setvalue(0, 'VALUE') # 设置其值

print(f"第一次连接后，host_variable的值: {host_variable.getvalue()}") # 输出 'VALUE'

con.close() # 关闭第一个连接，终止会话

# 第二次连接
con = oracledb.connect(user=connection_config.user, password=connection_config.pw, dsn=connection_config.dsn)
cursor = con.cursor()   # 第二个连接的游标 (新会话)

print(f"第二次连接后，host_variable的值: {host_variable.getvalue()}") # 仍然输出 'VALUE'

import oracledb
import connection_config # 假设包含用户、密码、DSN配置

# 第一个连接和游标
con1 = oracledb.connect(user=connection_config.user, password=connection_config.pw, dsn=connection_config.dsn)
cursor1 = con1.cursor()

host_variable1 = cursor1.var(str)
host_variable1.setvalue(0, 'VALUE_ONE')

print(f"host_variable1 的值: {host_variable1.getvalue()}") # 输出 'VALUE_ONE'

con1.close() # 关闭第一个连接

# 第二个连接和游标
con2 = oracledb.connect(user=connection_config.user, password=connection_config.pw, dsn=connection_config.dsn)
cursor2 = con2.cursor()
host_variable2 = cursor2.var(str) # 创建一个新的绑定变量对象，与 cursor2 关联

# 尝试获取 host_variable2 的值
# 如果未设置，它将返回默认值（例如 None 或空字符串，取决于类型和驱动行为）
print(f"host_variable2 的值 (未设置): {host_variable2.getvalue()}") # 输出 None 或空字符串

import oracledb
import connection_config

# 存储需要持久化的值
persistent_data = 'MY_PERSISTENT_VALUE'

# 第一次连接
con1 = oracledb.connect(user=connection_config.user, password=connection_config.pw, dsn=connection_config.dsn)
cursor1 = con1.cursor()
bind_var1 = cursor1.var(str)
bind_var1.setvalue(0, persistent_data)
# 可以在此执行使用 bind_var1 的 SQL 语句
print(f"第一次连接中，使用持久化数据: {bind_var1.getvalue()}")
con1.close()

# 第二次连接
con2 = oracledb.connect(user=connection_config.user, password=connection_config.pw, dsn=connection_config.dsn)
cursor2 = con2.cursor()
bind_var2 = cursor2.var(str)
bind_var2.setvalue(0, persistent_data) # 将持久化数据重新赋给新的绑定变量
print(f"第二次连接中，重新使用持久化数据: {bind_var2.getvalue()}")
con2.close()

CREATE PACKAGE my_data_pkg AS
  g_session_value VARCHAR2(100);
  PROCEDURE set_value(p_value IN VARCHAR2);
  FUNCTION get_value RETURN VARCHAR2;
END my_data_pkg;
/

CREATE PACKAGE BODY my_data_pkg AS
  PROCEDURE set_value(p_value IN VARCHAR2) IS
  BEGIN
    g_session_value := p_value;
  END set_value;

  FUNCTION get_value RETURN VARCHAR2 IS
  BEGIN
    RETURN g_session_value;
  END get_value;
END my_data_pkg;
/

import oracledb
import connection_config

con = oracledb.connect(user=connection_config.user, password=connection_config.pw, dsn=connection_config.dsn)
cursor = con.cursor()

# 设置包变量的值
cursor.execute("BEGIN my_data_pkg.set_value(:val); END;", val='SESSION_DATA')
con.commit()

# 获取包变量的值
cursor.execute("SELECT my_data_pkg.get_value FROM DUAL")
result = cursor.fetchone()
print(f"第一次获取包变量值: {result[0]}") # 输出 'SESSION_DATA'

# 此时如果关闭并重新打开连接，会创建一个新会话，新会话的包变量值将是初始值 (NULL)
# 但如果只是在同一个连接中执行其他操作，包变量值会保持。
# 演示：在同一个连接中再次获取
cursor.execute("SELECT my_data_pkg.get_value FROM DUAL")
result = cursor.fetchone()
print(f"同连接中再次获取包变量值: {result[0]}") # 仍输出 'SESSION_DATA'

con.close()

import oracledb
import connection_config

# 确保表存在
# cursor.execute("CREATE TABLE my_persistent_data (id NUMBER, value VARCHAR2(100))")
# cursor.execute("INSERT INTO my_persistent_data (id, value) VALUES (1, 'INITIAL_DATA')")
# con.commit()

# 第一次连接
con1 = oracledb.connect(user=connection_config.user, password=connection_config.pw, dsn=connection_config.dsn)
cursor1 = con1.cursor()

# 插入或更新数据
cursor1.execute("MERGE INTO my_persistent_data a USING (SELECT 1 id, :new_value value FROM DUAL) b ON (a.id = b.id) WHEN MATCHED THEN UPDATE SET a.value = b.value WHEN NOT MATCHED THEN INSERT (a.id, a.value) VALUES (b.id, b.value)", new_value='UPDATED_DATA_FROM_CON1')
con1.commit()
con1.close()

# 第二次连接
con2 = oracledb.connect(user=connection_config.user, password=connection_config.pw, dsn=connection_config.dsn)
cursor2 = con2.cursor()

# 从表中读取数据
cursor2.execute("SELECT value FROM my_persistent_data WHERE id = 1")
result = cursor2.fetchone()
print(f"从数据库表中获取持久化数据: {result[0]}") # 输出 'UPDATED_DATA_FROM_CON1'

con2.close()