使用SQLAlchemy连接SQL Server遇OptionEngine及编码错误求助

1. 修复 'OptionEngine' object has no attribute 'execute' 错误 #

该错误源于SQLAlchemy 2.0+版本的API变化：create_engine()返回的OptionEngine不再直接提供execute方法，而旧版pandas的read_sql_query仍依赖该方法调用。可通过以下两种方式解决：

• 传递连接对象而非引擎实例：先建立数据库连接再传入查询方法

  from sqlalchemy import create_engine
  import pandas as pd
  
  engine_sql = create_engine(
      'mssql+pyodbc://abcd:xxxx@tt.t.t.tt/fruit?driver=SQL+Server+Native+Client+8.0',
      fast_executemany=True)
  
  sql_query = '''
  SELECT TOP(10)
     A.[Fruit_Name]
    ,B.[Store_Location]
  FROM [fruit].[dbo].[info]  A
  LEFT JOIN [fruit].[dbo].[shop]  B
  ON A.fruit_ID = B.fruit_ID
  '''
  
  # 用连接对象执行查询
  with engine_sql.connect() as conn:
      df = pd.read_sql_query(sql_query, conn)
  

• 升级pandas版本：确保pandas≥2.0，新版本已适配SQLAlchemy 2.0的API规范

2. 修复 UnicodeDecodeError: 'cp950' codec can't decode byte... 错误 #

此问题是由于数据库返回UTF-8编码数据，但系统默认用cp950编码解析导致的编码不兼容，可通过以下方式指定编码：

• 在连接URL中追加编码参数：

  engine_sql = create_engine(
      'mssql+pyodbc://abcd:xxxx@tt.t.t.tt/fruit?driver=SQL+Server+Native+Client+8.0&charset=utf8',
      fast_executemany=True)
  

• 通过connect_args强制设置编码：

  engine_sql = create_engine(
      'mssql+pyodbc://abcd:xxxx@tt.t.t.tt/fruit?driver=SQL+Server+Native+Client+8.0',
      fast_executemany=True,
      connect_args={'unicode_results': True, 'charset': 'utf8'}
  )
  

3. 关于“单独运行报错、完整代码正常”的补充提示 #

这种差异通常是因为完整代码中存在全局配置（如编码预设、连接池初始化、SQLAlchemy上下文配置等），单独测试时缺少这些前置依赖。建议：

• 检查完整代码中是否有sqlalchemy或pandas的全局设置语句，将其复制到测试代码中
• 确保测试环境的依赖版本（SQLAlchemy、pandas、pyodbc）与完整代码完全一致

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