diff --git a/README.md b/README.md index 7f7362d..6436613 100644 --- a/README.md +++ b/README.md @@ -4,12 +4,9 @@ Does bulk insertion of documents in a collection using Spring Data Framework for Connects to a replica set and bulk inserts a number of random documents. Uses the application.properties to configure connection. - - Uses properties file to point to the MongoURI -- Makes use of certificates for the TrustStore. - Documents are sent to the products collection in a user defined database. - This sample application is provided to demonstrate integration capability. Users should review this code for component versioning and overall applicability for their own use case. diff --git a/src/main/java/com/mongodb/examples/springdatabulkinsert/CustomProductsRepository.java b/src/main/java/com/mongodb/examples/springdatabulkinsert/CustomProductsRepository.java deleted file mode 100644 index bc92eed..0000000 --- a/src/main/java/com/mongodb/examples/springdatabulkinsert/CustomProductsRepository.java +++ /dev/null @@ -1,6 +0,0 @@ -package com.mongodb.examples.springdatabulkinsert; - -public interface CustomProductsRepository { - void updateProductQuantity(String name, int newQty) ; - int bulkInsertProducts(int count); -} diff --git a/src/main/java/com/mongodb/examples/springdatabulkinsert/MongoConfig.java b/src/main/java/com/mongodb/examples/springdatabulkinsert/MongoConfig.java index 6a26171..e7bc4df 100644 --- a/src/main/java/com/mongodb/examples/springdatabulkinsert/MongoConfig.java +++ b/src/main/java/com/mongodb/examples/springdatabulkinsert/MongoConfig.java @@ -9,10 +9,6 @@ import org.springframework.context.annotation.Configuration; import org.springframework.data.mongodb.core.MongoTemplate; -import javax.net.ssl.SSLContext; -import java.nio.file.Paths; -import nl.altindag.ssl.SSLFactory; - @Configuration public class MongoConfig { @Value("${mongodb.uri}") @@ -20,14 +16,6 @@ public class MongoConfig { @Value("${mongodb.database}") private String databaseName; - @Value("${truststore.path}") - private String trustStorePath; - @Value("${truststore.pwd}") - private String trustStorePwd; - - @Value("${mongodb.atlas}") - private boolean atlas; - @Bean public MongoClient mongo() { @@ -35,23 +23,8 @@ public MongoClient mongo() { MongoClientSettings mongoClientSettings = MongoClientSettings.builder() .applyConnectionString(connectionString) - .applyToSslSettings(builder -> { - if (!atlas) { - // Use SSLContext if a trustStore has been provided - if (!trustStorePath.isEmpty()) { - SSLFactory sslFactory = SSLFactory.builder() - .withTrustMaterial(Paths.get(trustStorePath), trustStorePwd.toCharArray()) - .build(); - SSLContext sslContext = sslFactory.getSslContext(); - builder.context(sslContext); - builder.invalidHostNameAllowed(true); - } - } - builder.enabled(true); - }) .build(); - return MongoClients.create(mongoClientSettings); } diff --git a/src/main/java/com/mongodb/examples/springdatabulkinsert/Products.java b/src/main/java/com/mongodb/examples/springdatabulkinsert/Product.java similarity index 85% rename from src/main/java/com/mongodb/examples/springdatabulkinsert/Products.java rename to src/main/java/com/mongodb/examples/springdatabulkinsert/Product.java index 2d968e3..bcf6db5 100644 --- a/src/main/java/com/mongodb/examples/springdatabulkinsert/Products.java +++ b/src/main/java/com/mongodb/examples/springdatabulkinsert/Product.java @@ -11,10 +11,10 @@ @Document("products") -public class Products { +public class Product { private static final Logger LOG = LoggerFactory - .getLogger(Products.class); + .getLogger(Product.class); @Id private String id; @@ -25,7 +25,7 @@ public class Products { private Date unavailable; private String skuId; - public Products(String name, int qty, double price, Date available, Date unavailable, String skuId) { + public Product(String name, int qty, double price, Date available, Date unavailable, String skuId) { this.name = name; this.qty = qty; this.price = price; @@ -34,15 +34,15 @@ public Products(String name, int qty, double price, Date available, Date unavail this.skuId = skuId; } - public static Products [] RandomProducts( int count) { + public static Product [] RandomProducts( int count) { Faker faker = new Faker(); Random rand = new Random(); - Products [] retProds = new Products[count]; + Product [] retProds = new Product[count]; for (int i=0; i -mongodb.atlas=1 - -truststore.path=/etc/ssl/truststore.jks -truststore.pwd=P4ssw0rd documentCount=25000