Python 的 `oracledb` 模块是一个用于连接 Oracle 数据库的扩展模块，支持同步和并发编程风格，并且符合 Python DB API 2.0 规范。以下是几个使用 `oracledb` 模块连接和操作 Oracle 数据库的示例代码。 ### 1. 安装 oracledb 模块 在开始之前，需要先安装 `oracledb` 模块。可以通过 pip 安装： ```bash pip install oracledb ``` ### 2. 连接 Oracle 数据库并执行查询 以下是一个简单的示例，展示如何连接 Oracle 数据库并执行 SQL 查询： ```python import oracledb # 创建连接 connection = oracledb.connect( user='your_username', password='your_password', dsn='your_dsn' # 例如：'localhost/orcl' ) # 创建游标 cursor = connection.cursor() # 执行查询 cursor.execute("SELECT * FROM your_table") # 获取结果 for row in cursor: print(row) # 关闭游标和连接 cursor.close() connection.close() ``` ### 3. 使用精简模式（Thin Mode） `oracledb` 模块支持新的精简模式，该模式不需要安装 Oracle Instant Client，简化了部署流程： ```python import oracledb # 使用精简模式连接数据库 connection = oracledb.connect( user='your_username', password='your_password', dsn='your_dsn', thin=True # 启用精简模式 ) # 创建游标 cursor = connection.cursor() # 执行插入操作 cursor.execute("INSERT INTO your_table (id, name) VALUES (:1, :2)", (1, 'John Doe')) # 提交事务 connection.commit() # 关闭游标和连接 cursor.close() connection.close() ``` ### 4. 使用上下文管理器简化连接管理 Python 的上下文管理器可以简化连接和游标的创建与关闭： ```python import oracledb # 使用上下文管理器自动管理连接 with oracledb.connect( user='your_username', password='your_password', dsn='your_dsn' ) as connection: with connection.cursor() as cursor: # 执行查询 cursor.execute("SELECT COUNT(*) FROM your_table") result = cursor.fetchone() print(f"Total rows: {result[0]}") ``` ### 5. 执行批量插入 `oracledb` 模块还支持批量插入操作，可以显著提高插入数据的性能： ```python import oracledb # 创建连接 with oracledb.connect( user='your_username', password='your_password', dsn='your_dsn' ) as connection: with connection.cursor() as cursor: # 准备数据 data = [(1, 'Alice'), (2, 'Bob'), (3, 'Charlie')] # 执行批量插入 cursor.executemany("INSERT INTO your_table (id, name) VALUES (:1, :2)", data) # 提交事务 connection.commit() ``` ### 6. 调用存储过程 `oracledb` 模块也支持调用 Oracle 数据库中的存储过程： ```python import oracledb # 创建连接 with oracledb.connect( user='your_username', password='your_password', dsn='your_dsn' ) as connection: with connection.cursor() as cursor: # 调用存储过程 cursor.callproc('your_procedure_name', [param1, param2]) # 获取输出参数（如果有） output_param = cursor.getvalue() print(f"Output parameter: {output_param}") ``` ###