基于Peewee的MariaDB应用如何复用模型类向MSSQL同步插入？

嘿，刚好我之前处理过Peewee跨MariaDB和MSSQL的同步场景，给你几个靠谱的方案，核心就是不重复写模型，直接复用你现有的代码：

方案1：用Peewee官方的Database Proxy实现多库适配 #

这是最干净的方式，完全遵循Peewee的设计思路，能彻底复用现有模型：

1. 把现有模型的数据库连接换成代理：原来你可能直接把模型绑定到MariaDB的连接，现在改成用DatabaseProxy()作为中间层
2. 分别初始化两个数据库实例：MariaDB用你原来的连接，MSSQL用peewee-mssql驱动创建的连接
3. 插入时切换数据库：用上下文管理器切换代理指向的数据库，调用同一个模型的create()方法

代码示例：

from peewee import DatabaseProxy, Model, CharField, IntegerField, MySQLDatabase
from peewee_mssql import MSSQLDatabase

# 1. 创建数据库代理，替代原来直接绑定的MariaDB连接
db_proxy = DatabaseProxy()

# 2. 复用你现有的模型结构，只绑定代理
class BaseModel(Model):
    class Meta:
        database = db_proxy

# 这就是你原来的模型，完全不用改
class YourExistingModel(BaseModel):
    name = CharField(max_length=100)
    value = IntegerField()
    # 其他字段保持原样

# 3. 初始化两个数据库连接
mariadb_db = MySQLDatabase(
    "your_maria_db_name",
    user="maria_user",
    password="maria_pass",
    host="maria_host"
)
mssql_db = MSSQLDatabase(
    "your_mssql_db_name",
    user="mssql_user",
    password="mssql_pass",
    host="mssql_host",
    port=1433
)

# 4. 先给MSSQL创建表（如果还没有的话）
db_proxy.initialize(mssql_db)
YourExistingModel.create_table(safe=True)  # safe=True避免重复创建
# 切回MariaDB
db_proxy.initialize(mariadb_db)

# 5. 同步插入的函数
def sync_insert(data):
    # 插入MariaDB
    with mariadb_db.atomic():
        db_proxy.initialize(mariadb_db)
        YourExistingModel.create(**data)
    
    # 插入MSSQL，复用同一个模型
    with mssql_db.atomic():
        db_proxy.initialize(mssql_db)
        # 注意：如果MSSQL有特殊字段（比如自增ID），Peewee会自动适配，不用手动改
        YourExistingModel.create(**data)

方案2：模型继承+分离数据库绑定 #

如果觉得代理有点绕，也可以让MSSQL的模型直接继承你现有的MariaDB模型，只替换数据库连接：

# 你的原有MariaDB模型（完全不变）
class BaseMariaDBModel(Model):
    class Meta:
        database = mariadb_db

class YourModel(BaseMariaDBModel):
    name = CharField(max_length=100)
    value = IntegerField()

# MSSQL模型继承原有模型的所有字段，只改数据库
class YourModelMSSQL(YourModel):
    class Meta:
        database = mssql_db
        table_name = "your_model"  # 如果表名和MariaDB一致可以省略

# 同步插入
def sync_insert(data):
    # 插入MariaDB
    YourModel.create(**data)
    # 插入MSSQL
    YourModelMSSQL.create(**data)

解决你遇到的方法差异问题 #

你说的select/insert方法和原生Peewee有差异，大概率是用了旧版本的驱动：

• 卸载旧的peewee-mssqlserv，安装最新的peewee-mssql（用pip install peewee-mssql），它完全遵循Peewee的官方API，和原生方法完全一致
• 不用找单独的API文档，直接看Peewee的官方文档就行，因为peewee-mssql是符合Peewee接口规范的第三方驱动，所有核心方法都是通用的

另外，字段类型的差异Peewee会自动适配：比如MariaDB的TEXT对应MSSQL的VARCHAR(MAX)，AutoField会自动处理MariaDB的AUTO_INCREMENT和MSSQL的IDENTITY，不用手动修改模型字段。

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