Как вызвать db.Collection.stats () из драйвера Mon go java, используя класс MongoClient - PullRequest
Новая
       70

Как вызвать db.Collection.stats () из драйвера Mon go java, используя класс MongoClient

0 голосов
/ 06 апреля 2020

Я использую эту зависимость. 

        <dependency>
            <groupId>org.mongodb</groupId>
            <artifactId>mongodb-driver</artifactId>
            <version>3.12.2</version>
        </dependency>

Пакет:

пакет com.mongodb.MongoClient;

Как получить коллекцию по имени, затем получите его статус, так что будет доступна следующая информация:

  1. размер
  2. storageSize

Состояние сбора

Кажется, что ответ для этого Как вызвать db.Collection.stats () из Mon go java driver использует устаревший класс package com.mongodb; 

        // Mongodb initialization parameters.
        int port_no = 27017;
        String auth_user="jcg", auth_pwd = "admin@123", host_name = "localhost", db_name = "mongoauthdemo", db_col_name = "emp", encoded_pwd = "";

        /* Imp. Note -
         *      1.  Developers will need to encode the 'auth_user' or the 'auth_pwd' string if it contains the <code>:</code> or the <code>@</code> symbol. If not, the code will throw the <code>java.lang.IllegalArgumentException</code>.
         *      2.  If the 'auth_user' or the 'auth_pwd' string does not contain the <code>:</code> or the <code>@</code> symbol, we can skip the encoding step.
         */
        try {
            encoded_pwd = URLEncoder.encode(auth_pwd, "UTF-8");
        } catch (UnsupportedEncodingException ex) {
            log.error(ex);
        }

        // Mongodb connection string.
        String client_url = "mongodb://" + auth_user + ":" + encoded_pwd + "@" + host_name + ":" + port_no + "/" + db_name;
        MongoClientURI uri = new MongoClientURI(client_url);

        // Connecting to the mongodb server using the given client uri.
        MongoClient mongo_client = new MongoClient(uri);

        // Fetching the database from the mongodb.
        MongoDatabase db = mongo_client.getDatabase(db_name);

        // Fetching the collection from the mongodb.
        MongoCollection<Document> coll = db.getCollection(db_col_name);

1 Ответ

1 голос
/ 06 апреля 2020

Используется версия драйвера 3.12 MongoDB Java: 

try(MongoClient mongoClient = MongoClients.create("mongodb://localhost:27017/")) {

    MongoDatabase db = mongoClient.getDatabase("test");
    Document collStatsResults = db.runCommand(new Document("collStats", "myCollection"));
    System.out.println(collStatsResults.get("size"));
    System.out.println(collStatsResults.get("storageSize"));
}

Обратите внимание на использование предложения try-with-resources; он закрывает объект MongoClient после его использования для освобождения ресурсов, связанных с подключением.

...