如何用pyodbc连接MySQL？或在单Python类中兼容双数据库驱动

问题1：用pyodbc连接MySQL的修改方案（可行） #

• 前置条件：先安装对应版本的MySQL ODBC驱动（比如MySQL ODBC 8.0 Unicode Driver，需匹配系统和Python版本），同时确保pyodbc已安装。
• 修改连接字符串：替换驱动标识、调整参数格式，示例如下：

# MySQL的pyodbc连接示例
conn = pyodbc.connect(
    'Driver={MySQL ODBC 8.0 Unicode Driver};'
    'Server=xyzhbv;'
    'Database=Test;'
    'UID=root;'
    'PWD=12345;'
    'PORT=3306;'  # MySQL默认端口，可省略
    'CHARSET=utf8mb4;'
)

• 注意：不同版本的MySQL ODBC驱动，Driver名称可能有差异（比如{MySQL ODBC 8.0 ANSI Driver}），需根据实际安装的驱动调整。

问题2：同一类中兼容两个库且避免混淆 #

完全可以实现，核心是封装差异、统一接口，具体做法：

• 导入库时使用别名，从根源避免命名冲突：

  import pyodbc as sqlserver_driver
  import mysql.connector as mysql_driver
  

• 类实例化时传入数据库类型参数（比如db_type="sqlserver"或"mysql"），内部根据类型选择对应驱动。
• 封装统一的操作方法（比如connect()、execute_query()、close()），内部处理不同驱动的细微差异，对外暴露一致的接口。
• 针对同名方法的差异做适配：比如mysql.connector的游标默认不缓冲结果，需在内部调用fetchall()时处理这类细节，上层无需感知。

示例兼容类结构 #

import pyodbc as sqlserver_driver
import mysql.connector as mysql_driver

class DBHandler:
    def __init__(self, db_type, host, database, user, password, port=None):
        self.db_type = db_type.lower()
        self.host = host
        self.database = database
        self.user = user
        self.password = password
        self.port = port or (1433 if self.db_type == "sqlserver" else 3306)
        self.conn = None
        self.cursor = None

    def connect(self):
        if self.db_type == "sqlserver":
            conn_str = (
                f'Driver={{SQL Server}};'
                f'Server={self.host},{self.port};'
                f'Database={self.database};'
                f'ENCRYPT=yes;'
                f'UID={self.user};'
                f'PWD={self.password};'
            )
            self.conn = sqlserver_driver.connect(conn_str)
        elif self.db_type == "mysql":
            self.conn = mysql_driver.connect(
                host=self.host,
                port=self.port,
                database=self.database,
                user=self.user,
                password=self.password,
                charset='utf8mb4'
            )
        self.cursor = self.conn.cursor()

    def execute_query(self, query, params=None):
        params = params or ()
        self.cursor.execute(query, params)
        # 适配不同驱动的结果返回逻辑
        return self.cursor.fetchall()

    def commit(self):
        self.conn.commit()

    def close(self):
        self.cursor.close()
        self.conn.close()

# 使用示例
# SQL Server实例
sqlserver_db = DBHandler(
    db_type="sqlserver",
    host="xyzhbv",
    database="Test",
    user="root",
    password="12345"
)
sqlserver_db.connect()

# MySQL实例
mysql_db = DBHandler(
    db_type="mysql",
    host="xyzhbv",
    database="Test",
    user="root",
    password="12345"
)
mysql_db.connect()

这种设计既不用维护两个重复类，又能在实例化时灵活切换数据库类型，同时避免了库之间的命名冲突。

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