如何用Python通过DSN连接MSSQL与Oracle并读取表到Pandas DataFrame

核心问题解决 #

SQLAlchemy 1.4 完全支持通过DSN连接Oracle，只是连接字符串的构造方式容易踩坑。你之前用cx_Oracle直接连接无法使用pd.read_sql_table()，是因为该方法仅接受SQLAlchemy引擎/连接对象，而非原生DBAPI连接。

依赖安装 #

先确保安装对应数据库的SQLAlchemy方言库：

• Oracle：pip install sqlalchemy cx-Oracle（若用Oracle官方新驱动，可安装oracledb替换cx-Oracle）
• MSSQL：pip install sqlalchemy pyodbc

统一代码实现 #

下面是兼容Oracle和MSSQL的DSN连接代码，后续扩展PostgreSQL/MySQL时只需新增对应分支即可：

import pandas as pd
import sqlalchemy as sqla

# 从配置文件读取的参数
loginuser = 'username'
loginpwd = 'password'
logindsn = 'dsnname'
dbtype = 'oracle'  # 或 'MSSQL'

# 根据数据库类型创建SQLAlchemy引擎
if dbtype == 'oracle':
    # 推荐用connect_args方式，避免密码含特殊字符导致的拼接错误
    engine = sqla.create_engine(
        "oracle+cx_oracle://",
        connect_args={
            "user": loginuser,
            "password": loginpwd,
            "dsn": logindsn
        }
    )
    # 若习惯拼接字符串，也可使用：
    # engine = sqla.create_engine(f"oracle+cx_oracle://{loginuser}:{loginpwd}@{logindsn}")
elif dbtype == 'MSSQL':
    engine = sqla.create_engine(f"mssql+pyodbc://{loginuser}:{loginpwd}@{logindsn}")

# 读取整张表为DataFrame
testdf = pd.read_sql_table('Employees', engine)

# 执行自定义查询的写法
# testdf = pd.read_sql_query("SELECT * FROM Employees WHERE id < 100", engine)

关键说明 #

1. Oracle连接细节：

   • 若使用oracledb驱动，只需将连接字符串前缀改为oracle+oracledb://，connect_args参数保持不变。
   • 确保本地Oracle客户端已正确配置tnsnames.ora，DSN名称与配置文件完全一致，也可使用EZCONNECT格式的DSN（如host:port/service_name）。

2. 扩展性：

   • 后续添加PostgreSQL时，可使用postgresql+psycopg2://{user}:{pwd}@{dsn}或connect_args方式。
   • MySQL则使用mysql+pymysql://{user}:{pwd}@{dsn}，同样支持DSN连接。

3. 版本兼容：

   • SQLAlchemy 1.4需搭配cx-Oracle 8.0+或oracledb 1.0+，避免版本不兼容导致的连接失败。

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