要將 Spring Boot 應用程序連接到 Amazon DocumentDB，我們需要在?application.properties?文件中定義數(shù)據(jù)庫配置。您需要配置數(shù)據(jù)庫 URI、數(shù)據(jù)庫名稱或主機名、用戶名、密碼等屬性，以及其他與連接相關(guān)的屬性。要連接到 Amazon DocumentDB 集群，您需要在位于?src/main/resources?文件夾的?application.properties?文件中指定連接 URI 字符串。

要檢索您的 Amazon DocumentDB 集群端點并配置?application.properties ，請完成以下步驟：

1. 在 Amazon DocumentDB 控制臺的導航窗格中，選擇?Clusters（集群）。

2. 找到您的集群并選擇區(qū)域集群標識符。

3. 在?Connectivity & security（連接和安全性）選項卡上，復制用于通過 application.

連接到集群的命令。

4. 從復制的連接字符串中刪除?&ssl_ca_certs=rds-combined-ca-bundle.pem ，因為您已經(jīng)將亞馬遜云科技提供的 CA 文件導入了信任存儲。

5. 將連接 URI 添加到位于您的項目?src/main/resources?文件夾的?application.properties?文件中。連接 URI 的鍵為?spring.data.mongodb.uri 。確保復制的連接字符串格式如下：

spring.data.mongodb.uri=mongodb://<用戶名>:<密碼>@<集群端點>: 27017/?ssl=true&replicaSet=rs0&readPreference=secondaryPreferred&retryWrites=false

左滑查看更多

或者，您可以單獨提供連接詳細信息，包括主機名、端口、用戶名和密碼以及對應的屬性鍵，例如?spring.data.mongodb.host?或?spring.data.mongodb.port 。有關(guān)可用的 Spring Boot 參數(shù)配置選項的完整列表，請參閱?Common Application Properties（常用應用程序?qū)傩裕┫碌?Data Properties（數(shù)據(jù)屬性）（https://docs.spring.io/spring-boot/docs/current/reference/html/application-properties.html#appendix.application-properties.data）。

6. 您也可以選擇在?application.properties?文件中指定數(shù)據(jù)庫名稱：

spring.data.mongodb.database=catalog

創(chuàng)建配置類并設(shè)置密鑰庫

現(xiàn)在屬性配置已經(jīng)完成，您需要定義配置類來設(shè)置密鑰庫屬性，以便建立安全連接。

要在應用程序中使用密鑰庫，請在配置類中設(shè)置以下系統(tǒng)屬性：

javax.net.ssl.trustStore: <truststore>
javax.net.ssl.trustStorePassword: <truststorePassword>

左滑查看更多

請參閱以下示例配置類。使用?@Configuration?注釋將該類標記為配置類。具有?@Configuration?注釋的類由 Spring 容器用作 bean 定義的來源。

?Java?

@Bean
 ? ? ? ?public MongoClientSettings mongoClientSettings() { 
 ? ? ? ? ? ? setSslProperties();
 ? ? ? return MongoClientSettings.builder()
 ? ? ? ? ? ? ? ? ? ?.applyToSslSettings(builder -> builder.enabled(true))
 ? ? ? ? ? ? ? ? ? ?.build();
 ?}


 ? ? ? ?private static void setSslProperties() { 
 ? ? ? ? ? ?System.setProperty("javax.net.ssl.trustStore", KEY_STORE_TYPE);
 ? ? ? ? ? ?System.setProperty("javax.net.ssl.trustStorePassword", ? ? ? ? ?
 ? ? ? ? ? ? ? ? ? ?DEFAULT_KEY_STORE_PASSWORD);
 ? ? ? ?}
 ?@Bean
 ? ? ? ?public MongoPropertiesClientSettingsBuilderCustomizer mongoPropertiesCustomizer(final MongoProperties properties) {
 ? ? ?return new MongoPropertiesClientSettingsBuilderCustomizer(properties);
 ?}
}

左滑查看更多

以上是 Spring Boot 中 Amazon DocumentDB 配置的全部內(nèi)容現(xiàn)在，您可以通過擴展?MongoRepository?開始定義基于接口的存儲庫類。

配置存儲庫接口

現(xiàn)在，您可以使用?MongoRepository?訪問數(shù)據(jù)庫中的數(shù)據(jù)。 MongoRepository?提供常用功能，例如創(chuàng)建、讀取、更新和刪除（CRUD，Create, Read, Update, and Delete）操作。它充當模型與數(shù)據(jù)庫之間的鏈接。它獲取域類（Product）進行管理，并獲取域類的 ID 類型作為類型參數(shù)。您可以編寫幾種方法，由存儲庫為您生成查詢。

創(chuàng)建查詢?Product?文檔的存儲庫接口，如下所示：

?Java?

public interface ProductRepository extends MongoRepository<Product, String> {


}

左滑查看更多

?ProductRepository?擴展?MongoRepository?接口。此接口包含許多操作，包括標準的 CRUD 操作。您將在下一節(jié)中定義其他自定義操作。

定義服務(wù)類

服務(wù)類利用了 Spring Data 存儲庫接口。我們通過引用您在上一步中創(chuàng)建的存儲庫來定義它：

?Java?

@Service
public class ProductService {
 ? ?
 ? ?@Autowired
 ? ?private ProductRepository productRepo;
}

左滑查看更多

在下一節(jié)中，您將在此類上通過添加其他方法進行構(gòu)建，該節(jié)還介紹了 CRUD 示例。

使用 CrudRepository

使用擴展了?CrudRepository?的?MongoRepository?時，您的存儲庫可以從?CrudRepository?接口的實施類訪問基本功能，包括?save 、 count 、 findAll?和?delete?方法。您的?ProductRepository?接口擴展了?MongoRepository ，并可以訪問所有基本 CRUD 操作。

我們來逐個探索和測試這些操作。

保存或創(chuàng)建

首先，您使用?save?方法向集合中添加一些文檔。 save?方法獲取?Product?對象作為輸入，并將產(chǎn)品文檔保存到 Amazon DocumentDB 集合中。將以下代碼片段添加到您的服務(wù)類中：

?Java?

public void saveProducts() {
 
 ?productRepo.save(new Product("RayBan Sunglass Pro", "1590234","RayBan Sunglasses for professional sports people", 100, "fashion"));
 ?productRepo.save(new Product("GUCCI Handbag", "3451290", "Fashion Hand bags for all ages", 75, "fashion"));
 ?productRepo.save(new Product("Round hat", "8976045", "", 200, "fashion"));
 ?productRepo.save(new Product("Polo shirt", "6497023", "Cool shirts for hot summer", 25, "cloth"));
 ?productRepo.save(new Product("Swim shorts", "8245352", "Designer swim shorts for athletes", 200, "cloth"));
 ?productRepo.save(new Product("Running shoes", "3243662", "Shoes for work out and trekking", 20, "footware"));
 ?
 ?System.out.println(" Save complete ");
 ? ? ? ?
}

左滑查看更多

計數(shù)

在下一個示例中，如果存儲庫中沒有任何方法，則調(diào)用服務(wù)類中的?count() 方法，對集合中的文檔進行計數(shù)。

?Java?

public long getCount() {
 ? ?long count = productRepo.count();
 ? ?System.out.println(" Total number of products : "+count);
 ? ?return count;
}

左滑查看更多

讀取

在此示例中，您執(zhí)行三種不同的讀取操作。您可以按名稱或 SKU 提取產(chǎn)品，然后根據(jù)類別查找產(chǎn)品列表。

您在存儲庫（ ProductRepository ）中添加了三種簡單方法。第一種方法?findProductByName?根據(jù)?name?屬性查詢集合。查詢篩選條件使用注釋?@Query?定義，在本例中，注釋為?@Query("{name:'?0'}") 。第二種方法?findProductBySKU?根據(jù)?sku?屬性查詢集合，并在查詢響應中僅輸出?name?和?inventory?屬性。第三種方法?findAll?檢索特定類別的所有文檔。請參閱以下代碼：

?Java?

public interface ProductRepository extends MongoRepository<Product, String> {
 ? ?
 ? ?@Query("{name:'?0'}")
 ? ?Product findProductByName(String name);
 ? ?
 ? ?@Query(value="{sku:'?0'}", fields="{'name' : 1, 'inventory' : 1}")
 ? ?Product findProductBySKU (String sku); ? 


 ? ?@Query("{category:'?0'}")
 ? ?List<Product> findAllByCategory(String category);
 ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?
}

左滑查看更多

您可以從存儲庫在服務(wù)類中調(diào)用這三種方法，按名稱、SKU 和類別查找文檔。

?Java?

public Product getProductByName(String name) {
 ?System.out.println(" Getting product by name : " + name);
 ?Product product = productRepo.findProductByName(name);
 ?System.out.println(product);
 ?return product; 
}


public Product getProductBySKU(String sku) {
 ?System.out.println(" Getting product by SKU : " + sku);
 ?Product product = productRepo.findProductBySKU(sku);
 ?System.out.println(product);
 ? return product; 
}


public List<Product> findAllProductsByCategory(String category) {
 ?List<Product> productList = productRepo.findAllByCategory(category);
 ?productList.forEach(product -> System.out.println(product));
 ?return productList;
}

左滑查看更多

更新

您可以通過傳遞更新后的實體對象，使用?save?方法來更新現(xiàn)有文檔。在此示例中，您按 SKU 查詢現(xiàn)有產(chǎn)品并將庫存增加 10。將以下方法添加到您的服務(wù)中：

?Java?

public void updateInventory(String sku) {
 ?Product product = ?getProductBySKU(sku);
 ?System.out.println(" Updating Inventory for product by sku: " + sku); ?
 ?product.setInventory(product.getInventory()+10);
 ?Product updatedProd = productRepo.save(product);
}

左滑查看更多

刪除

在本示例中，您將創(chuàng)建兩個刪除操作。首先，您按照 ID 刪除一個產(chǎn)品；在第二種方法中，您將刪除集合中的所有文檔（products）。將以下方法添加到您的服務(wù)類中：

?Java?

public void deleteProduct(String id) {
 ? productRepo.deleteById(id);
 ?System.out.println("Product with id " + id + " deleted");
}


public void deleteAll() {
 ?productRepo.deleteAll();
 ?System.out.println("All Products deleted.");
}

左滑查看更多

構(gòu)建 Spring Boot 應用程序

默認的 Spring Boot 應用程序已經(jīng)由 Spring Initializr 在根程序包（例如?com.example.documentdb ）中創(chuàng)建。在 IDE 中打開默認應用程序：

?Java?

@SpringBootApplication
public class DocumentdbApplication {


 ?public static void main(String[] args) {
 ? ?SpringApplication.run(DocumentdbApplication.class, args);
 ?}
}

左滑查看更多

?CommandLineRunner?接口表明，當 bean 包含在?SpringApplication 中時應該運行，以便在控制臺上查看輸出。實施?CommandLineRunner?接口并為 run 方法提供植入方法。我們使用?@Autowired?注釋定義對您服務(wù)的引用。Spring 使用?@SpringBootApplication?注釋來初始化應用程序上下文：

?Java?

@Override
 ?public void run(String... args) throws Exception {
 ? ?
 ? ?System.out.printf("%n Insert few products : %n");
 ? ?prodService.saveProducts();
 ? ?
 ? ?System.out.printf("%n Count all products : %n");
 ? ?prodService.getCount();
 ? ?
 ? ?
 ? ?System.out.printf("%n Get product by name : %n");
 ? ?prodService.getProductByName("GUCCI Handbag");
 ? ?
 ? ?System.out.printf("%n Get product by sku : %n");
 ? ?prodService.getProductBySKU("8976045");
 ? ?
 ? ?System.out.printf("%n Get all products by category : %n");
 ? ?prodService.findAllProductsByCategory("fashion");
 ? ?
 ? ?System.out.printf("%n Update Inventory for Product by sku : ?%n");
 ? ?prodService.updateInventory("3451290");
 ? ?
 ? ?System.out.printf("%n Delete product id ?%n");
 ? ?prodService.deleteProduct("639a0046efe46b7343dd5004"); 
 ? ?
 ? ?System.out.printf("%n Deleting all products/documents ?%n");
 ? ?prodService.deleteAll(); 
 ?}
}

左滑查看更多

運行并測試您的應用程序

使用以下 Maven 命令運行 Spring Boot 應用程序：

?Bash?

mvn spring-boot:run

以下屏幕截圖是 Spring Boot 應用程序的示例輸出。

您做到了！ 您已成功從 Spring Boot 應用程序連接到 Amazon DocumentDB。

總結(jié)

在這篇文章中，您了解了如何通過簡單的應用程序?qū)?Amazon DocumentDB 與 Spring Boot 應用程序集成，該應用程序使用 Spring Data MongoDB 將對象保存到數(shù)據(jù)庫以及從數(shù)據(jù)庫中提取對象，所有這些過程都無需編寫具體的存儲庫實施，而且配置簡單。

這篇文章中使用的示例在?GitHub?上作為示例項目提供（https://github.com/aws-samples/amazon-documentdb-samples/tree/master/blogs/docdb-springboot）。

Original URL:?

https://aws.amazon.com/cn/blogs/database/integrate-your-spring-boot-application-with-amazon-documentdb/

本篇作者

Gururaj S Bayari?

亞馬遜云科技的資深 DocumentDB 專家解決方案架構(gòu)師。他非常樂于幫助客戶采用 Amazon 的專用數(shù)據(jù)庫。他針對采用 NoSQL 和/或關(guān)系數(shù)據(jù)庫的互聯(lián)網(wǎng)規(guī)模的高性能工作負載，幫助客戶進行設(shè)計、評估和優(yōu)化。

聽說，點完下面4個按鈕

就不會碰到bug了！

文章來源地址http://www.zghlxwxcb.cn/news/detail-693689.html