当前位置：首页 > 数据库 > 正文

python怎么连接oracle数据库

admin
数据库
2025-08-04
7

cx_Oracle 库，安装后通过 connect() 函数传入用户名、密码、DSN 即可连接 Oracle 数据库，示例：`conn = cx_Oracle.connect(“user/pass@host:port/service_name”)

是关于Python如何连接Oracle数据库的详细指南：

前置准备与环境搭建

安装cx_Oracle库：这是Python访问Oracle的核心驱动包，支持SQL执行、事务管理及高性能交互，可通过pip install cx_Oracle完成安装（推荐使用最新稳定版），若遇版本兼容性问题，可尝试降级或升级对应版本的whl文件；
配置Oracle Instant Client：作为底层依赖项，需从官网下载与操作系统匹配的版本，解压后将目录添加到系统环境变量PATH中，例如在Windows下通过“系统属性→高级→环境变量”设置；Linux/macOS则修改~/.bashrc或~/.bash_profile文件，添加export PATH=<your_instant_client_directory>:$PATH；
验证架构一致性：确保Python解释器、cx_Oracle和Instant Client均为同一架构（32/64位），否则会导致运行时错误。

基础连接流程

步骤1：导入模块并构造DSN

使用cx_Oracle.makedsn()生成数据源名称（DSN），包含主机名、端口和服务名三要素，示例代码如下：

import cx_Oracle
dsn_tns = cx_Oracle.makedsn('hostname', 'port', service_name='service_name')

其中service_name对应Oracle监听器中配置的服务标识符，也可替换为SID（系统ID）形式如'ORCL'。

python怎么连接oracle数据库第1张

步骤2：建立数据库会话

通过connect()方法传入认证信息与DSN参数：

connection = cx_Oracle.connect(user='username', password='password', dsn=dsn_tns)

若使用简化写法,可直接拼接字符串形式的连接串：conn_str = "username/password@host:port/service_name"，注意敏感信息应避免硬编码，生产环境建议采用配置文件或密钥管理系统存储凭证。

python怎么连接oracle数据库第2张

步骤3：创建游标对象执行操作

游标是执行SQL语句的主要接口,典型用法包括：

查询数据：调用cursor.execute("SELECT FROM table")后，通过fetchall()获取全部结果集，或用fetchone()逐行读取；
参数化插入/更新：利用占位符绑定变量防止SQL注入，如cursor.execute("INSERT INTO emp (id, name) VALUES (:1, :2)", (1001, 'John'))；
批量处理：对于大量数据的增删改查，推荐使用executemany()方法提升效率。

高级功能实践

功能特性	实现方式	优势场景
连接池	`pool = cx_Oracle.SessionPool(...)`动态复用已有连接	高并发请求下减少建连开销
事务控制	`connection.commit()`显式提交；异常时调用`rollback()`回滚	确保数据一致性
分页检索	`cursor.fetchmany(batch_size)`配合循环实现内存友好的大数据集遍历	避免单次加载全表导致OOM崩溃
ORM映射	集成SQLAlchemy框架，通过声明式模型类操作数据库	复杂业务逻辑解耦，可读性增强

示例代码对比

原生API模式

import cx_Oracle
conn = cx_Oracle.connect("scott/tiger@localhost:1521/XE")
cur = conn.cursor()
cur.execute("SELECT deptno FROM dept")
for r in cur:
    print(r[0]) # 输出部门编号列表
cur.close()
conn.close()

SQLAlchemy ORM模式

from sqlalchemy import create_engine, Table, MetaData
engine = create_engine('oracle+cx_oracle://user:pass@host:port/dbname')
metadata = MetaData(bind=engine)
users = Table('users', metadata, autoload=True)
result = engine.execute(users.select()).fetchall() # 自动映射结果到元组结构

常见问题排查手册

客户端版本不匹配报错：检查Instant Client与数据库服务器的大版本号是否一致（如19c客户端连19c数据库），必要时重新安装兼容版本；
DLL缺失异常（仅限Windows）：将Instant Client解压后的oci.dll等动态库复制到Python安装目录的Lib/site-packages文件夹下；
网络连通性失败：使用tnsping host命令测试主机可达性，确认防火墙未拦截默认端口1521；
字符集乱码问题：在连接字符串中添加编码参数encoding='UTF8'强制指定字符集。

FAQs

Q1: 如何处理“找不到Oracle库文件”的错误？
A: 此错误通常由环境变量未正确配置引起，解决方案包括：①将Instant Client路径加入系统PATH；②在代码开头添加os.environ["ORACLE_HOME"] = <path_to_instant_client>手动指定主目录；③验证DLL文件是否完整存在于指定位置。

python怎么连接oracle数据库第3张