Spring Data Unlocked: Performance Optimization Techniques With MongoDB

1
@Repository
2
public interface TransactionRepository extends MongoRepository<Transaction, String> {
3
4
   List<Transaction> findByTransactionType(String type);
5
   // Other methods ..	
6
}

1
db.transactions.find({"transactionType": "Debit"}).explain()

1
public String explain() {
2
3
   MongoCollection<Document> collection = mongoOperations.getCollection("transactions");
4
5
   Document query = new Document("transactionType", "Debit");
6
   Document explanation = collection.find(query).explain();
7
8
   logger.info(explanation.toJson());
9
   return explanation.toJson();
10
}

1
db.transactions.createIndex({"transactionType": 1})

1
import lombok.Data;
2
import org.springframework.data.annotation.Id;
3
import org.springframework.data.mongodb.core.index.Indexed;
4
import org.springframework.data.mongodb.core.mapping.Document;
5
6
@Document(collection = "transactions")
7
@Data
8
public class Transaction {   
9
10
   @Indexed
11
   private String transactionType;
12
13
   // Other fields
14
}

1
spring:
2
 data:
3
   mongodb:
4
     auto-index-creation: true

1
@Repository
2
public interface TransactionRepository extends MongoRepository<Transaction, String> {
3
4
   List<Transaction> findByTransactionTypeAndCurrency(String type, String currency);
5
6
 // Other methods
7
}

1
@CompoundIndex(name = "type_currency", def = "{'transactionType': 1, 'currency': 1}")
2
@Data
3
public class Transaction {
4
  // fields
5
}

1
public class Transaction {
2
   @Indexed(unique = true)
3
   private String authCode;
4
}

1
com.mongodb.MongoWriteException - E11000 duplicate key error collection

1
public class Transaction {
2
3
   @Indexed(
4
5
           name = "PartialIndex",
6
7
           expireAfterSeconds = 3456000, //40 days
8
9
           partialFilter = "{ 'status': { $in: ['SUCCESS', 'COMPLETED'] } }"
10
11
   )
12
13
   private LocalDateTime createdAt;
14
15
}

1
@Repository
2
public interface TransactionRepository extends MongoRepository<Transaction, String> { 
3
   @ReadPreference("secondaryPreferred")
4
   List<Transaction> findByTransactionType(String type);
5
}

1
@Configuration
2
public class MongoConfig  {
3
   @Bean
4
   public MongoClient mongoClient() {
5
       MongoClientSettings settings = MongoClientSettings.builder()
6
               .applyConnectionString(new ConnectionString(connectionString))
7
               .readPreference(ReadPreference.nearest())
8
               .build();
9
       return MongoClients.create(settings);
10
   }