如何用Python同时连接两个Oracle LDAP数据库并读取数据到Pandas

一、使用oracledb（原cx_Oracle）实现连接 #

oracledb是Oracle官方推荐的Python驱动，已替代旧版cx_Oracle。针对LDAP连接，需将JDBC格式的连接串转换为oracledb支持的格式：

连接串转换规则 #

JDBC串格式：jdbc:oracle:thin:@ldap://<ldap_host>:<port>/<db_service>,cn=OracleContext,dc=xxx,dc=xxx
oracledb对应格式：ldap://<ldap_host>:<port>/<db_service>,cn=OracleContext,dc=xxx,dc=xxx

完整代码示例 #

import oracledb
import pandas as pd

# 第一个数据库配置
db1_config = {
    "dsn": "ldap://acmeldap.acme.com:3000/dmart,cn=OracleContext,dc=acme,dc=com",
    "user": "your_dmart_username",
    "password": "your_dmart_password"
}

# 第二个数据库配置
db2_config = {
    "dsn": "ldap://acmeldap.acme.com:3000/smart,cn=OracleContext,dc=acme,dc=com",
    "user": "your_smart_username",
    "password": "your_smart_password"
}

def query_db(config, sql_query):
    # 创建独立连接，避免多库冲突
    with oracledb.connect(**config) as conn:
        df = pd.read_sql(sql_query, conn)
    return df

# 执行查询
df_dmart = query_db(db1_config, "SELECT * FROM your_dmart_table WHERE rownum <= 10")
df_smart = query_db(db2_config, "SELECT * FROM your_smart_table WHERE rownum <= 10")

# 查看结果
print("DMart数据：")
print(df_dmart.head())
print("\nSMart数据：")
print(df_smart.head())

二、使用jaydebeapi实现JDBC直接连接 #

若需直接使用JDBC串，jaydebeapi可调用Oracle JDBC驱动，但需提前准备对应版本的ojdbc驱动包（如ojdbc8.jar）。

完整代码示例 #

import jaydebeapi
import pandas as pd

# JDBC驱动类名
driver_class = "oracle.jdbc.OracleDriver"
# 替换为你的ojdbc驱动包实际路径
driver_jar = "/path/to/ojdbc8.jar"

# 第一个数据库连接参数
db1_params = {
    "jdbc_url": "jdbc:oracle:thin:@ldap://acmeldap.acme.com:3000/dmart,cn=OracleContext,dc=acme,dc=com",
    "user": "your_dmart_username",
    "password": "your_dmart_password"
}

# 第二个数据库连接参数
db2_params = {
    "jdbc_url": "jdbc:oracle:thin:@ldap://acmeldap.acme.com:3000/smart,cn=OracleContext,dc=acme,dc=com",
    "user": "your_smart_username",
    "password": "your_smart_password"
}

def query_jdbc_db(params):
    conn = jaydebeapi.connect(
        driver_class,
        params["jdbc_url"],
        [params["user"], params["password"]],
        driver_jar
    )
    df = pd.read_sql("SELECT * FROM your_table WHERE rownum <= 10", conn)
    conn.close()
    return df

# 执行查询
df_dmart = query_jdbc_db(db1_params)
df_smart = query_jdbc_db(db2_params)

# 查看结果
print("DMart数据：")
print(df_dmart.head())
print("\nSMart数据：")
print(df_smart.head())

三、连接失败常见排查点 #

• 驱动版本匹配：oracledb需与Oracle数据库版本兼容；jaydebeapi的ojdbc版本需对应数据库版本（如ojdbc8对应Oracle 12c+）
• 网络连通性：检查Python所在机器能否访问LDAP服务器的3000端口（可通过telnet acmeldap.acme.com 3000测试）
• LDAP配置正确性：确认LDAP路径中的cn=OracleContext、dc=acme,dc=com与实际LDAP目录结构一致
• 权限问题：所用用户名是否拥有对应数据库的访问权限，密码是否正确
• 并发连接限制：部分Oracle环境对并发连接数有限制，可咨询DBA确认配额

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