Django多数据库（MySQL+PostgreSQL）下CopyManager导出CSV报错求助

在Django多数据库配置下（默认数据库为MySQL，另一个为PostgreSQL），使用postgres_copy的CopyManager执行Items.objects.all().to_csv('./path/to/csv')导出CSV时，出现以下语法错误：

psycopg2.errors.SyntaxError: syntax error at or near "."
LINE 1: COPY (SELECT `sales_item`.`id`, `sales_item`.`sales_value`,...

错误原因是生成的SQL使用了MySQL的反引号语法，而PostgreSQL不支持该语法，推测CopyManager默认使用了default的MySQL数据库连接，而非模型预期的PostgreSQL数据库。

数据库配置：

DATABASES = {
    'default': {
        'ENGINE': 'django.db.backends.mysql', 
        'NAME': 'mysql_db',
        'USER': 'username',
        'PASSWORD': 'password',
        'HOST': 'hostname',
        'PORT': '3306',
    },
    'postgres_db': {
        'ENGINE': 'django.db.backends.postgresql',
        'NAME': 'pgsql_db',
        'USER': 'username',
        'PASSWORD': 'password',
        'HOST': 'hostname',
        'PORT': '5432',
    }
}

模型定义：

from postgres_copy import CopyManager
class Items(models.Model):
    class params:
        db = "postgres_db"
    sales_value = models.CharField(max_length=255, null=True, blank=True)
    primary_email = models.CharField(max_length=255, null=True, blank=True)
    
    objects = CopyManager()

方案1：查询时显式指定数据库连接 #

直接在查询链中通过using()方法指定使用PostgreSQL数据库，强制CopyManager使用正确的数据库连接生成对应语法的SQL：

Items.objects.using('postgres_db').all().to_csv('./path/to/csv')

方案2：配置数据库路由实现自动匹配 #

通过Django的数据库路由功能，让Items模型默认使用PostgreSQL数据库，无需每次查询手动指定：

1. 在项目中创建路由文件（如routers.py）：

class PostgresRouter:
    def db_for_read(self, model, **hints):
        # 指定Items模型读操作使用postgres_db
        if model._meta.model_name == 'items':
            return 'postgres_db'
        return None

    def db_for_write(self, model, **hints):
        # 指定Items模型写操作使用postgres_db
        if model._meta.model_name == 'items':
            return 'postgres_db'
        return None

    def allow_relation(self, obj1, obj2, **hints):
        # 允许同一app内模型的关联
        if obj1._meta.app_label == 'your_app_name' and obj2._meta.app_label == 'your_app_name':
            return True
        return None

    def allow_migrate(self, db, app_label, model_name=None, **hints):
        # 只允许在postgres_db上迁移Items模型
        if app_label == 'your_app_name' and model_name == 'items':
            return db == 'postgres_db'
        return None

2. 在settings.py中配置路由：

DATABASE_ROUTERS = ['your_project_name.routers.PostgresRouter']

配置完成后，Items模型的所有查询（包括CopyManager的操作）都会自动使用PostgreSQL数据库，生成正确的SQL语法。

注意事项 #

模型中自定义的class params: db = "postgres_db"并非Django官方指定数据库的方式，CopyManager无法识别该配置，因此需要使用上述两种官方方法指定数据库。

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