MongoDB 数据插入优化指南

1. 添加 Maven 依赖

在项目中添加 MongoDB 驱动依赖，采用以下方式配置：


       
    
     org.mongodb
        
    
     mongodb-driver-sync
        
    
     4.5.0

请根据实际需求选择最新版本。

2. 复制代码

以下是用于插入数据的完整 Java 类代码：

import com.mongodb.client.MongoClients;import com.mongodb.client.MongoClient;import com.mongodb.client.MongoDatabase;import com.mongodb.client.MongoCollection;import com.mongodb.client.model.Indexes;import org.bson.Document;import java.util.ArrayList;import java.util.List;import java.util.Random;public class MongoDBInsertTestData {    private static final String DATABASE_NAME = "test_database";    private static final String COLLECTION_NAME = "test_collection";    private static final int TOTAL_RECORDS = 100_000_000;    private static final int BATCH_SIZE = 10_000;    public static void main(String[] args) {        try (MongoClient mongoClient = MongoClients.create("mongodb://localhost:27017")) {            MongoDatabase database = mongoClient.getDatabase(DATABASE_NAME);            MongoCollection collection = database.getCollection(COLLECTION_NAME);            // 创建唯一索引            collection.createIndex(Indexes.ascending("id"));            insertData(collection);            System.out.println("Data insertion completed.");        }    }    private static void insertData(MongoCollection collection) {        Random random = new Random();        List
   
     batch = new ArrayList<>();        for (int i = 0; i < TOTAL_RECORDS; i++) {            Document doc = new Document("id", i)                .append("name", generateRandomString(10))                .append("value", random.nextDouble())                .append("timestamp", System.currentTimeMillis());            batch.add(doc);            if (batch.size() == BATCH_SIZE) {                collection.insertMany(batch);                System.out.println("Inserted " + batch.size() + " records.");                batch.clear();            }        }        if (!batch.isEmpty()) {            collection.insertMany(batch);            System.out.println("Inserted " + batch.size() + " records.");        }    }    private static String generateRandomString(int length) {        StringBuilder sb = new StringBuilder(length);        String characters = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz";        Random random = new Random();        for (int i = 0; i < length; i++) {            sb.append(characters.charAt(random.nextInt(characters.length())));        }        return sb.toString();    }}