MongoDB中的_id字段与文档唯一性
mongodb为每个文档自动生成一个_id字段，该字段在集合中是强制且唯一的。如果应用程序在插入文档时未指定_id，mongodb会自动为其分配一个objectid类型的值。_id字段上默认存在一个唯一索引，确保了集合中不会有两个文档拥有相同的_id值。此外，_id字段的值一旦设定便不可修改，且其上的唯一索引也无法被删除或修改。
然而，_id的唯一性仅针对_id本身。如果需要确保文档中其他字段（或字段组合）的唯一性，例如根据name、supplier、food和country of origin这四个字段的组合来判断文档是否重复，则需要手动创建复合唯一索引。
利用唯一索引防止重复插入
防止基于特定字段组合的重复插入，最可靠和原子性的方法是创建唯一索引。当尝试插入一个违反唯一索引约束的文档时，MongoDB将拒绝该操作并抛出异常。
1. 创建复合唯一索引
假设我们希望name、supplier、food和country of origin这四个字段的组合是唯一的。
在MongoDB Shell中创建索引： 在MongoDB shell中，可以使用createIndex方法创建复合唯一索引。
db.yourCollectionName.createIndex(
{
"name": 1,
"supplier": 1,
"food": 1,
"country of origin": 1
},
{ unique: true }
)这里的yourCollectionName应替换为实际的集合名称。1表示升序索引，-1表示降序索引，对于唯一索引而言，顺序通常不重要，但需要指定。
立即学习“Java免费学习笔记（深入）”；
在Java代码中创建索引： 在应用程序启动时或首次连接到数据库时，可以执行索引创建操作。
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
import com.mongodb.client.model.IndexOptions;
import com.mongodb.client.model.Indexes;
import com.mongodb.MongoCommandException;
// 假设 mongoClient 是已连接的MongoClient实例
// MongoDatabase database = mongoClient.getDatabase("yourDatabaseName");
MongoCollection collection = database.getCollection("yourCollectionName");
// 定义构成唯一键的字段及其排序方式
Document uniqueKeys = new Document()
.append("name", 1)
.append("supplier", 1)
.append("food", 1)
.append("country of origin", 1);
// 设置索引选项，指定为唯一索引
IndexOptions indexOptions = new IndexOptions().unique(true);
try {
// 创建唯一索引。如果索引已存在，MongoDB通常会忽略创建请求，除非选项不同。
String indexName = collection.createIndex(uniqueKeys, indexOptions);
System.out.println("成功创建唯一索引: " + indexName);
} catch (MongoCommandException e) {
// 错误代码 48 通常表示索引已存在且属性不同，或尝试创建不同属性的同名索引
if (e.getErrorCode() == 48) {
System.out.println("唯一索引已存在或尝试创建不同属性的同名索引: " + e.getMessage());
} else {
System.err.println("创建唯一索引时发生错误: " + e.getMessage());
}
} catch (Exception e) {
System.err.println("创建唯一索引时发生未知错误: " + e.getMessage());
} 2. 在Java中插入文档并处理重复异常
创建唯一索引后，当尝试插入一个与现有文档在唯一索引字段上完全匹配的新文档时，MongoDB将拒绝该操作并抛出MongoWriteException。我们可以在Java代码中捕获并处理此异常。
import com.mongodb.MongoWriteException; import com.mongodb.client.MongoCollection; import com.mongodb.client.result.InsertOneResult; import org.bson.Document; // 假设 collection 是已获取的MongoCollection实例 // MongoCollection collection = ...; Document newDocument = new Document(); newDocument.put("name", "Apple"); newDocument.put("supplier", "Fruit Inc."); newDocument.put("food", "Fruit"); newDocument.put("country of origin", "USA"); try { InsertOneResult result = collection.insertOne(newDocument); if (result.wasAcknowledged()) { System.out.println("文档插入成功，_id: " + result.getInsertedId()); } } catch (MongoWriteException e) { // 检查是否是重复键错误 (错误代码 11000) if (e.getError().getCode() == 11000) { System.err.println("[错误] 尝试插入重复文档: " + newDocument.toJson()); // 根据业务需求，可以选择抛出自定义异常或记录日志 // throw new CustomDuplicateDocumentException("Document already exists.", e); } else { System.err.println("插入文档时发生其他写入错误: " + e.getMessage()); } } catch (Exception e) { System.err.println("插入文档时发生未知错误: " + e.getMessage()); }
通过这种方式，我们利用了数据库本身的原子性操作来管理重复性，这是最推荐的方法。
替代方案：先查找后插入（慎用）
虽然不推荐作为防止重复插入的主要策略，但了解如何正确执行“先查找后插入”的逻辑也是有益的。这种方法存在竞态条件的风险，即在查找操作和插入操作之间，另一个进程可能已经插入了相同的文档，导致仍然插入重复数据。
正确使用find().first()进行查找：MongoCollection.find(filter).first()方法用于查找一个匹配的文档。如果未找到匹配文档，则返回null。
import com.mongodb.client.MongoCollection; import com.mongodb.client.model.Filters; import org.bson.Document; import org.bson.conversions.Bson; import com.mongodb.client.result.InsertOneResult; // 假设 collection 是已获取的MongoCollection实例 // MongoCollection collection = ...; String name = "Apple"; String supplier = "Fruit Inc."; String food = "Fruit"; String countryOfOrigin = "USA"; // 构建查询过滤器，用于查找是否存在匹配的文档 Bson filter = Filters.and( Filters.eq("name", name), Filters.eq("supplier", supplier), Filters.eq("food", food), Filters.eq("country of origin", countryOfOrigin) ); // 执行查找操作，获取第一个匹配的文档 Document existingDocument = collection.find(filter).first(); if (existingDocument == null) { // 未找到重复文档，可以安全插入 Document documentToInsert = new Document() .append("name", name) .append("supplier", supplier) .append("food", food) .append("country of origin", countryOfOrigin); try { InsertOneResult result = collection.insertOne(documentToInsert); if (result.wasAcknowledged()) { System.out.println("文档插入成功，_id: " + result.getInsertedId()); } } catch (Exception e) { System.err.println("插入文档时发生错误: " + e.getMessage()); } } else { System.out.println("已存在重复文档，无需插入: " + existingDocument.toJson()); // 根据业务需求，可以抛出异常或执行其他逻辑 // throw new RuntimeException("[Error] duplicate insertion detected before insert attempt"); }
重要提示： 原始问题中的代码逻辑是错误的，它在duplicate != null（即找到重复文档）时才执行insertOne，这与“如果不存在则插入”的目标相反。上述代码展示了正确的逻辑：仅当existingDocument == null时才执行插入操作。
注意事项
- 原子性与并发: 唯一索引是实现原子性“插入或更新”操作（upsert）和防止重复插入的最佳方式。find().first()后跟insertOne()的操作序列不是原子的，在高并发环境下可能导致竞态条件，从而仍然插入重复文档。对于需要严格保证唯一性的场景，强烈推荐使用唯一索引。
- 错误处理: 在Java中处理MongoDB操作时，务必捕获MongoWriteException（或其更具体的子类如MongoBulkWriteException），并通过错误代码（例如11000表示DuplicateKey错误）来区分不同的写入错误，以便进行精确的异常处理。
- 索引选择: 仔细考虑哪些字段或字段组合能够唯一标识您的业务实体。选择合适的字段来创建唯一索引至关重要。不恰当的唯一索引可能导致数据无法插入或查询效率低下。
- **索引开销
