Поделиться через


Краткое руководство: Использование Azure DocumentDB с драйвером MongoDB для Java

В этом кратком руководстве описано, как создать базовое приложение Azure DocumentDB с помощью Java. Azure DocumentDB — это хранилище данных NoSQL, позволяющее приложениям хранить документы в облаке и получать к ним доступ с помощью официальных драйверов MongoDB. В этом руководстве показано, как создавать документы и выполнять основные задачи в кластере Azure DocumentDB с помощью Java.

Справочник по | APIИсходный код | Пакет (Maven)

Предпосылки

  • Java 21 или более поздней версии

Создание кластера Azure DocumentDB

Чтобы приступить к работе, сначала необходимо создать кластер Azure DocumentDB, который служит основой для хранения данных NoSQL и управления ими.

  1. Войдите на портал Azure (https://portal.azure.com).

  2. В меню портала Azure или на главной странице выберите Создать ресурс.

  3. На новой странице найдите и выберите Azure DocumentDB.

    Снимок экрана: поиск Azure DocumentDB.

  4. На странице Создание кластера Azure DocumentDB и в разделе Основы выберите параметр Настройка в разделе Уровень кластера.

    Снимок экрана: параметр

  5. На странице масштабирования настройте эти параметры и нажмите кнопку "Сохранить ", чтобы сохранить изменения на уровне кластера.

    Ценность
    Уровень кластера M30 tier, 2 vCore, 8-GiB RAM
    Хранилище на сегмент 128 GiB

    Снимок экрана: параметры конфигурации для вычислений и хранилища для нового кластера Azure DocumentDB.

  6. В разделе "Основные сведения" настройте следующие параметры:

    Ценность
    Subscription Выберите подписку Azure.
    Группа ресурсов Создание новой группы ресурсов или выбор существующей группы ресурсов
    Имя кластера Укажите глобально уникальное имя
    Местоположение Выбор поддерживаемого региона Azure для подписки
    Версия MongoDB Выберите 8.0
    Имя администратора Создание имени пользователя для доступа к кластеру в качестве администратора пользователя
    Пароль Использование уникального пароля, связанного с именем пользователя

    Снимок экрана: параметры кластера.

    Подсказка

    Запишите значения, используемые для имени пользователя и пароля. Эти значения используются далее в этом руководстве. Дополнительные сведения о допустимых значениях см. в разделе об ограничениях кластера.

  7. Выберите Next: Networking.

  8. В разделе правил брандмауэра на вкладке "Сеть" настройте следующие параметры:

    Ценность
    Метод подключения Public access
    Разрешить общедоступный доступ из служб и ресурсов в Azure к этому кластеру Enabled
  9. Добавьте правило брандмауэра для текущего клиентского устройства, чтобы предоставить доступ к кластеру, нажав кнопку +Добавить текущий IP-адрес клиента.

    Снимок экрана: конфигурации сети.

    Подсказка

    Во многих корпоративных средах IP-адреса компьютера разработчика скрыты из-за VPN или других параметров корпоративной сети. В этих случаях можно временно разрешить доступ ко всем IP-адресам, добавив 0.0.0.0 - 255.255.255.255 диапазон IP-адресов в качестве правила брандмауэра. Используйте это правило брандмауэра только временно в рамках тестирования и разработки подключений.

  10. Выберите Review + create.

  11. Проверьте настройки, которые вы указали, и затем выберите Создать. Создание кластера занимает несколько минут. Дождитесь завершения развертывания ресурсов.

  12. Наконец, выберите "Перейти к ресурсу" , чтобы перейти к кластеру Azure DocumentDB на портале.

Снимок экрана: параметры ресурса goto.

Получение учетных данных кластера

Получите учетные данные, используемые для подключения к кластеру.

  1. На странице кластера выберите параметр "Строки подключения " в меню ресурсов.

  2. В разделе "Строки подключения" скопируйте или запишите значение из поля строки подключения .

Снимок экрана: опция строк подключения.

Это важно

Строка подключения на портале не включает значение пароля. Вы должны заменить плейсхолдер <password> на учетные данные, введенные при создании кластера, или ввести пароль в интерактивном режиме.

Инициализируйте проект

Создайте проект Maven в текущем каталоге.

  1. Начните в пустом каталоге.

  2. Откройте терминал в текущем каталоге.

  3. Создайте проект Maven с помощью архетипа быстрого запуска.

    mvn archetype:generate -DgroupId=com.example -DartifactId=azure-documentdb-java-quickstart -DarchetypeArtifactId=maven-archetype-quickstart -DinteractiveMode=false
    
  4. Перейдите в созданный каталог проекта.

    cd azure-documentdb-java-quickstart
    
  5. Создайте проект, чтобы убедиться, что он был успешно создан.

    mvn compile
    

Установка клиентской библиотеки

Клиентская библиотека доступна через Maven в качестве артефакта mongodb-driver-sync .

  1. Добавьте зависимость драйвера Java MongoDB в pom.xml файл.

    <dependency>
        <groupId>org.mongodb</groupId>
        <artifactId>mongodb-driver-sync</artifactId>
        <version>5.2.0</version>
    </dependency>
    
  2. Откройте и просмотрите файл pom.xml , чтобы проверить наличие записи зависимостей.

  3. Импортируйте необходимые пакеты в код приложения:

    import com.mongodb.client.MongoClient;
    import com.mongodb.client.MongoClients;
    import com.mongodb.client.MongoCollection;
    import com.mongodb.client.MongoDatabase;
    import com.mongodb.client.model.Filters;
    import com.mongodb.client.model.ReplaceOptions;
    import org.bson.Document;
    import org.bson.conversions.Bson;
    
    import java.util.Arrays;
    import java.util.List;
    

Объектная модель

Имя Description
MongoClient Тип, используемый для подключения к MongoDB.
MongoDatabase Представляет базу данных в кластере.
MongoCollection<Document> Представляет коллекцию в базе данных в кластере.

Примеры кода

Код в этом приложении подключается к базе данных с именем adventureworks и коллекцией с именем products. Коллекция products содержит такие сведения, как имя, категория, количество, уникальный идентификатор и флаг продажи для каждого продукта. Примеры кода, приведенные здесь, выполняют наиболее распространенные операции при работе с коллекцией.

аутентификация клиента;

Сначала подключитесь к клиенту с помощью базовой строки подключения.

  1. Создайте основной метод и настройте строку подключения. Замените <your-cluster-name>и <your-username><your-password> фактическими сведениями о кластере.

    public class App {
        public static void main(String[] args) {
            // Connection string for Azure DocumentDB cluster
            String connectionString = "mongodb+srv://<your-username>:<your-password>@<your-cluster-name>.global.mongocluster.cosmos.azure.com/?tls=true&authMechanism=SCRAM-SHA-256&retrywrites=false&maxIdleTimeMS=120000";
    
  2. Создайте клиент MongoDB и проверьте подключение.

            // Create a new client and connect to the server
            try (MongoClient mongoClient = MongoClients.create(connectionString)) {
    
                // Ping the server to verify connection
                MongoDatabase database = mongoClient.getDatabase("admin");
                database.runCommand(new Document("ping", 1));
    
                System.out.println("Successfully connected and pinged Azure DocumentDB");
    

Получите коллекцию

Теперь получите базу данных и коллекцию. Если база данных и коллекция еще не существуют, используйте драйвер для автоматического создания.

  1. Получите ссылку на базу данных.

                // Get database reference
                MongoDatabase adventureWorksDatabase = mongoClient.getDatabase("adventureworks");
                System.out.println("Connected to database: " + adventureWorksDatabase.getName());
    
  2. Получите ссылку на коллекцию в базе данных.

                // Get collection reference
                MongoCollection<Document> productsCollection = adventureWorksDatabase.getCollection("products");
                System.out.println("Connected to collection: products");
    

Создание документа

Затем создайте несколько новых документов в коллекции. Добавление или обновление документов, чтобы гарантировать замену существующих документов при совпадении уникальных идентификаторов.

  1. Создайте примеры документов продукта с помощью класса Document.

                // Create sample products
                List<Document> products = Arrays.asList(
                    new Document("_id", "00000000-0000-0000-0000-000000004018")
                        .append("name", "Windry Mittens")
                        .append("category", "apparel-accessories-gloves-and-mittens")
                        .append("quantity", 121)
                        .append("price", 35.00)
                        .append("sale", false),
                    new Document("_id", "00000000-0000-0000-0000-000000004318")
                        .append("name", "Niborio Tent")
                        .append("category", "gear-camp-tents")
                        .append("quantity", 140)
                        .append("price", 420.00)
                        .append("sale", true)
                );
    
  2. Вставьте документы с помощью операций upsert.

                // Insert documents with upsert
                for (Document product : products) {
                    Bson filter = Filters.eq("_id", product.getString("_id"));
                    ReplaceOptions options = new ReplaceOptions().upsert(true);
    
                    productsCollection.replaceOne(filter, product, options);
                    System.out.println("Upserted product: " + product.getString("name"));
                }
    

Получение документа

Затем выполните операцию точечного чтения, чтобы получить определенный документ из вашей коллекции.

  1. Определите фильтр для поиска определенного документа по идентификатору.

                // Retrieve a specific document by ID
                Bson filter = Filters.eq("_id", "00000000-0000-0000-0000-000000004018");
    
  2. Выполните запрос и получите результат.

                Document retrievedProduct = productsCollection.find(filter).first();
    
                if (retrievedProduct != null) {
                    System.out.println("Retrieved product: " + retrievedProduct.getString("name") + 
                                     " - $" + retrievedProduct.getDouble("price"));
                } else {
                    System.out.println("Product not found");
                }
    

Поиск документов

Наконец, запросите несколько документов с помощью языка запросов MongoDB (MQL).

  1. Определите запрос для поиска документов, соответствующих определенным критериям.

                // Query for products on sale
                Bson saleFilter = Filters.eq("sale", true);
    
  2. Выполните итерацию по курсору, чтобы получить все соответствующие документы.

                System.out.println("Products on sale:");
                for (Document product : productsCollection.find(saleFilter)) {
                    System.out.printf("- %s: $%.2f (Category: %s)%n",
                        product.getString("name"),
                        product.getDouble("price"),
                        product.getString("category"));
                }
    
            } catch (Exception e) {
                System.err.println("An error occurred: " + e.getMessage());
                e.printStackTrace();
            }
        }
    }
    

Изучение данных с помощью Visual Studio Code

Используйте расширение DocumentDB в Visual Studio Code для выполнения основных операций базы данных, включая запросы, вставку, обновление и удаление данных.

  1. Откройте Visual Studio Code.

  2. Перейдите к представлению расширений и найдите термин DocumentDB. Найдите расширение DocumentDB для VS Code .

  3. Нажмите кнопку "Установить " для расширения. Дождитесь завершения установки. При появлении запроса перезагрузите Visual Studio Code.

  4. Перейдите к расширению DocumentDB , выбрав соответствующий значок в строке действий.

  5. В области "Подключения DocumentDB" выберите +Создать подключение....

  6. В диалоговом окне выберите "Обнаружение служб" , а затем Azure DocumentDB — Обнаружение служб Azure.

  7. Выберите подписку Azure и созданный кластер Azure DocumentDB.

    Подсказка

    Во многих корпоративных средах IP-адреса компьютера разработчика скрыты из-за VPN или других параметров корпоративной сети. В этих случаях можно временно разрешить доступ ко всем IP-адресам, добавив 0.0.0.0 - 255.255.255.255 диапазон IP-адресов в качестве правила брандмауэра. Используйте это правило брандмауэра только временно в рамках тестирования и разработки подключений. Дополнительные сведения см. в разделе "Настройка брандмауэра".

  8. В области "Подключения DocumentDB" разверните узел кластера и перейдите к существующим узлам документа и коллекции.

  9. Откройте контекстное меню для коллекции, а затем выберите DocumentDB Scrapbook New DocumentDB Scrapbook>.

  10. Введите следующие команды языка запросов MongoDB (MQL) и нажмите кнопку "Выполнить все". Просмотрите выходные данные команд.

    db.products.find({
      price: { $gt: 200 },
      sale: true
    })
    .sort({ price: -1 })
    .limit(3)
    

Очистите ресурсы

Когда вы закончите работу с кластером Azure DocumentDB, вы можете удалить созданные ресурсы Azure, чтобы не взимать больше расходов.

  1. В строке поиска портал Azure найдите и выберите группы ресурсов.

    Снимок экрана: параметр поиска групп ресурсов.

  2. В списке выберите группу ресурсов, которую вы использовали для этого быстрого начала.

    Снимок экрана: группа ресурсов.

  3. На странице группы ресурсов выберите Удалить группу ресурсов.

  4. В диалоговом окне подтверждения удаления введите имя группы ресурсов, чтобы убедиться, что она будет удалена. Наконец, выберите "Удалить ", чтобы окончательно удалить группу ресурсов.

    Снимок экрана, показывающий кнопку подтверждения удаления группы ресурсов.