Django 提供了多种批量操作方法，能显著提升数据库操作的效率，特别是在处理大量数据时。下面为你梳理这些方法，并说明其适用场景和注意事项。

下表总结了主要的批量操作方法及其核心用途：

使用 bulk_create()是创建大量对象时的首选方法。

基本用法：创建一个对象列表，然后传入 bulk_create()方法。

from myapp.models import Book

books = [
    Book(title='Book 1', author='Author 1'),
    Book(title='Book 2', author='Author 2'),
    # ... 可以继续添加更多对象
]
Book.objects.bulk_create(books)

处理海量数据：如果需要创建的对象数量极大（例如上万条），建议使用 batch_size参数进行分批提交，以避免单个数据库事务过大。batch_size参数可以控制每批处理的数据量。

# 方法一：在 bulk_create 中直接指定 batch_size
Book.objects.bulk_create(book_list, batch_size=1000)

# 方法二：手动分批次处理
batch_size = 1000
for i in range(0, len(book_list), batch_size):
    batch = book_list[i:i+batch_size]
    Book.objects.bulk_create(batch)

根据更新需求的不同，可以选择两种方法。

• 使用 update()进行统一更新

  当需要将符合条件的所有记录的某个字段设置为同一个值时，使用 update()效率最高。

  # 将所有状态为“pending”的书籍状态更新为“approved”
  Book.objects.filter(status='pending').update(status='approved')

  此方法不会调用模型的 save()方法，因此不会触发相关的信号（如 pre_save, post_save）。

• 使用 bulk_update()进行批量差异更新

  当需要更新的多个对象，其字段值各不相同时，应使用 bulk_update()。

  books = Book.objects.filter(status='pending')
  for book in books:
      # 对每个对象进行不同的修改
      book.price *= 1.1  # 每本书涨价10%
  
  # 批量更新，指定需要更新的字段
  Book.objects.bulk_update(books, ['price'])

   

   
   

   

使用 delete()方法可以快速删除符合条件的所有记录。

# 删除所有已下架的商品
Product.objects.filter(is_active=False).delete()

注意：此操作是物理删除，数据将从数据库中永久移除，操作前请务必确认。

对于多对多字段，也可以进行批量操作以减少**L查询次数。

• 批量添加关联：使用 add()方法并传入多个对象。

  my_band = Band.objects.get(id=1)
  member1 = Artist.objects.get(id=2)
  member2 = Artist.objects.get(id=3)
  my_band.members.add(member1, member2)  # 一次添加多个成员

• 批量移除关联：使用 remove()方法并传入多个对象。

  my_band.members.remove(member1, member2)  # 一次移除多个成员

希望这份总结能帮助你更好地运用Django的批量操作功能。

下面我们整理了一个批量更新的代码片段来说明一个批量更新的灵活运用方法

# 准备文章数据
            article_data = {
                'title':
                row_dict['log_Title'],
                'meta_keywords':
                meta_keywords.rstrip(','),
                'meta_description':
                strip_tags(row_dict['log_Intro']),
                'content':
                row_dict['log_Content'],
                'create_time':
                timezone.datetime.fromtimestamp(int(
                    row_dict['log_CreateTime'])),
                'update_time':
                timezone.datetime.fromtimestamp(int(
                    row_dict['log_UpdateTime'])),
                'hits':
                row_dict['log_ViewNums'],
                'status':
                99 if row_dict['log_Status'] == 0 else 0,
                'category':
                category_obj,
                'editor_id':
                userid
            } 
            if keep_id_c***istent:
                # 保持ID一致的逻辑
                if article_id in existing_article_ids:
                    articles_to_update.append((article_id, article_data))
                else:
                    article = Article(id=article_id, **article_data)
                    articles_to_create.append(article)
            else:
                # 不保持ID一致：不传入id，创建新记录并使用新ID
                article = Article(**article_data)  # 注意：这里没有传递 id
                articles_to_create.append(article)

        # 6. 批量数据库操作
        with transaction.atomic():
            # 批量创建新文章
            if articles_to_create:
                Article.objects.bulk_create(articles_to_create, batch_size=100)

            # 批量更新现有文章
            if articles_to_update:
                update_batch = []
                for article_id, article_data in articles_to_update:
                    article = Article(id=article_id, **article_data)
                    update_batch.append(article)

                # 指定要更新的字段
                update_fields = [
                    'title', 'meta_keywords', 'meta_description', 'content',
                    'create_time', 'update_time', 'hits', 'status',
                    'category_id', 'editor_id'
                ]
                Article.objects.bulk_update(update_batch,
                                            update_fields,
                                            batch_size=100)

💡 理解 bulk_update 的核心价值

📝 数据准备与字段映射

🔧 使用 bulk_update 执行批量更新

1. 构建对象列表：遍历 articles_to_update列表，为每个 (article_id, article_data)元组，使用 Article(id=article_id, **article_data)创建一个临时的、未保存的 Article实例。关键点在于必须指定 id=article_id，这样 Django 才知道要更新哪条现有记录，而不是创建新记录。

2. 明确更新字段：在 update_fields参数中明确列出所有需要更新的字段。这是一个好习惯，可以避免意外覆盖其他字段，并且在模型字段很多时能略微提升性能。

3. 设置批量大小：使用 batch_size参数（您设置为 100）非常重要。当需要更新的对象数量极大时（例如上万），此参数会将操作分批提交，防止单个数据库事务过大，有助于减轻数据库压力并保证稳定性。

⚠️ 重要注意事项

• 不触发信号和模型保存方法：bulk_update和 update()方法一样，为了效率直接生成 **L 语句操作数据库，不会调用每个模型的 save()方法，因此与 save()方法相关的逻辑（如自动更新 auto_now字段）以及 pre_save和 post_save信号都不会被触发。如果您的业务逻辑依赖这些，则需要考虑替代方案，如循环调用 save()或在 bulk_update前后手动执行相关逻辑。

• 事务保障：对于重要的数据迁移或更新操作，建议将整个 bulk_update操作包裹在 transaction.atomic()装饰器或上下文管理器中，以确保操作的原子性（要么全部成功，要么全部回滚）。