我在使用 django 1.4 确定 MySQL INSERT ... ON DUPLICATE KEY UPDATE 时遇到问题。

我试图插入记录的表有一个 2 列(复合)唯一键。我收到的记录来自第 3 方来源，值会随着时间的推移而变化，但那些构成唯一键集的字段除外。我一次收到 1 ~ 5k 条记录，需要

目前我正在使用 Model.objects.bulk_create 进行批量插入，性能真的很惊人，因为无论记录集有多大，它通常都会发出一个查询。但是，由于我的记录在第 3 方端可能会随时间变化，因此我需要对记录集执行 MySQL INSERT ... ON DUPLICATE KEY UPDATE 查询。

我打算编写原始 SQL 语句并使用类似此处的语句执行:

sql = "MySQL INSERT ... ON DUPLICATE KEY UPDATE"

raw_insert(sql)

def raw_insert(sql):
    from django.db import connection, transaction
    cursor = connection.cursor()

    # Data modifying operation - commit required
    cursor.execute(sql)
    transaction.commit_unless_managed()

    return 1

想知道是否有更好的解决方案来解决我的问题。另外，我将如何清理原始插入的字段值？

最佳答案

所以我创建了一个自定义管理器。这是经理:

class BulkInsertManager(models.Manager):
    def _bulk_insert_or_update(self, create_fields, update_fields, values):

        from django.db import connection, transaction
        cursor = connection.cursor()

        db_table = self.model._meta.db_table

        values_sql = []
        values_data =[]

        for value_lists in values:
            values_sql.append( "(%s)" % (','.join([ "%s" for i in range(len(value_lists))]),) )
            values_data.extend(value_lists)

        base_sql = "INSERT INTO %s (%s) VALUES " % (db_table, ",".join(create_fields))

        on_duplicates = []

        for field in update_fields:
            on_duplicates.append(field + "=VALUES(" + field +")")

        sql = "%s %s ON DUPLICATE KEY UPDATE %s" % (base_sql, ", ".join(values_sql), ",".join(on_duplicates))

        cursor.executemany(sql, [values_data])
        transaction.commit_unless_managed()

和一个示例模型:

class User_Friend(models.Model):
    objects = BulkInsertManager() # assign a custom manager to handle bulk insert

    id = models.CharField(max_length=255)
    user = models.ForeignKey(User, null=False, blank=False)
    first_name = models.CharField(max_length=30)
    last_name = models.CharField(max_length=30)
    city = models.CharField(max_length=50, null=True, blank=True)
    province = models.CharField(max_length=50, null=True, blank=True)
    country =  models.CharField(max_length=30, null=True, blank=True)

和示例实现:

def save_user_friends(user, friends):
    user_friends = []
    for friend in friends:

        create_fields = ['id', 'user_id', 'first_name', 'last_name', 'city', 'province', 'country']
        update_fields = ['first_name', 'last_name', 'city', 'province', 'country']

        user_friends.append(
            [
                str(user.id), 
                str(friend['id']),
                friend['first_name'],
                friend['last_name'],
                friend['city'],
                friend['province'],
                friend['country'],
            ]
        )

    User_Friend.objects._bulk_insert_or_update(create_fields, update_fields, user_friends)

这是 gist .

关于python - MySQL INSERT ... ON DUPLICATE KEY UPDATE with django 1.4 for bulk insert，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/12916880/