使用索引优化查询

1
import com.mongodb.ConnectionString;
2
import com.mongodb.MongoClientSettings;
3
import com.mongodb.ServerApi;
4
import com.mongodb.ServerApiVersion;
5
6
import com.mongodb.client.model.ClusteredIndexOptions;
7
import com.mongodb.client.model.CreateCollectionOptions;
8
import com.mongodb.client.model.IndexOptions;
9
import com.mongodb.client.model.Indexes;
10
import com.mongodb.reactivestreams.client.*;
11
import org.bson.Document;
12
import org.reactivestreams.Publisher;
13
import reactor.core.publisher.Flux;
14
import reactor.core.publisher.Mono;
15
16
public class IndexApp {
17
    public static void main(String[] args) {
18
        // Replace the placeholder with your Atlas connection string
19
        String uri = "<connection string URI>";
20
21
        // Construct a ServerApi instance using the ServerApi.builder() method
22
        ServerApi serverApi = ServerApi.builder()
23
                .version(ServerApiVersion.V1)
24
                .build();
25
26
        MongoClientSettings settings = MongoClientSettings.builder()
27
                .applyConnectionString(new ConnectionString(uri))
28
                .serverApi(serverApi)
29
                .build();
30
31
        // Create a new client and connect to the server
32
        try (MongoClient mongoClient = MongoClients.create(settings)) {
33
            MongoDatabase database = mongoClient.getDatabase("<database name>");
34
            MongoCollection<Document> collection = database.getCollection("<collection name>");
35
36
            // Start example code here
37
38
            // End example code here
39
        }
40
    }
41
}

Document index = new Document("mappings", new Document("dynamic", true));
Publisher<String> publisher = collection.createSearchIndex("<index name>", index);
Mono.from(publisher).block();

ListSearchIndexesPublisher<Document> listIndexesPublisher = collection.listSearchIndexes();
Flux.from(listIndexesPublisher)
        .doOnNext(System.out::println)
        .blockLast();

Document newIndex = new Document("mappings", new Document("dynamic", true));
Publisher<Void> publisher = collection.updateSearchIndex("<index name>", newIndex);
Mono.from(publisher).block();

Publisher<Void> publisher = collection.dropIndex("<index name>");
Mono.from(publisher).block();