3

我在使用 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

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

4

2 回答 2

9

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

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)

这是要点。

于 2012-10-17T03:20:13.703 回答
1

您可以使用 ModelForm 进行消毒：

from django.forms.models import modelform_factory
form_class = modelform_factory(MyModel)

for obj in my_data:
    form = form_class(obj)
    if not form.is_valid():
        raise Hell()

至于原始 SQL，我说去吧。Django 的 ORM 似乎不支持ON DUPLICATE KEY UPDATE，所以不要让它妨碍你。Django 文档谈论毫无保留地这样做。

不过，它可能值得使用Manager.raw。

于 2012-10-16T21:54:55.880 回答