mongodb 통합

This commit is contained in:
2025-04-03 10:51:05 +09:00
parent 4b61af8909
commit 88c061fa65
3 changed files with 18 additions and 18 deletions

View File

@@ -18,7 +18,7 @@ import java.nio.charset.StandardCharsets;
@Configuration @Configuration
@EnableMongoRepositories(basePackages = "com.caliverse.admin.history.repository", mongoTemplateRef = "mongoAdminTemplate") //@EnableMongoRepositories(basePackages = "com.caliverse.admin.history.repository", mongoTemplateRef = "mongoAdminTemplate")
public class MongoAdminConfig { public class MongoAdminConfig {
@Value("${mongodb.host}") @Value("${mongodb.host}")
@@ -30,22 +30,22 @@ public class MongoAdminConfig {
@Value("${mongodb.admin.db}") @Value("${mongodb.admin.db}")
String db; String db;
@Bean(name = "mongoAdminClient") // @Bean(name = "mongoAdminClient")
public MongoClient mongoStatClient() { // public MongoClient mongoStatClient() {
String encodePassword = URLEncoder.encode(password, StandardCharsets.UTF_8); // String encodePassword = URLEncoder.encode(password, StandardCharsets.UTF_8);
String auth = username.isEmpty() ? "" : String.format("%s:%s@",username, encodePassword); // String auth = username.isEmpty() ? "" : String.format("%s:%s@",username, encodePassword);
String connection = String.format("mongodb://%s%s/?authSource=%s", auth, businessLogHost, db); // String connection = String.format("mongodb://%s%s/?authSource=%s", auth, businessLogHost, db);
return MongoClients.create(connection); // return MongoClients.create(connection);
} // }
@Bean(name = "mongoAdminFactory") // @Bean(name = "mongoAdminFactory")
public MongoDatabaseFactory mongoIndicatorFactory(@Qualifier("mongoAdminClient") MongoClient mongoIndicatorClient) { // public MongoDatabaseFactory mongoIndicatorFactory(@Qualifier("mongoAdminClient") MongoClient mongoIndicatorClient) {
return new SimpleMongoClientDatabaseFactory(mongoIndicatorClient, db); // return new SimpleMongoClientDatabaseFactory(mongoIndicatorClient, db);
} // }
@Bean(name = "mongoAdminTemplate") // @Bean(name = "mongoAdminTemplate")
public MongoTemplate mongoIndicatorTemplate(@Qualifier("mongoAdminFactory") MongoDatabaseFactory mongoIndicatorFactory) { // public MongoTemplate mongoIndicatorTemplate(@Qualifier("mongoAdminFactory") MongoDatabaseFactory mongoIndicatorFactory) {
return new MongoTemplate(mongoIndicatorFactory); // return new MongoTemplate(mongoIndicatorFactory);
} // }
} }

View File

@@ -18,7 +18,7 @@ import java.nio.charset.StandardCharsets;
@Configuration @Configuration
@EnableMongoRepositories(basePackageClasses = MongoIndicatorRepository.class, mongoTemplateRef = "mongoIndicatorTemplate") @EnableMongoRepositories(basePackageClasses = MongoIndicatorRepository.class, basePackages = "com.caliverse.admin.history.repository", mongoTemplateRef = "mongoIndicatorTemplate")
public class MongoIndicatorConfig { public class MongoIndicatorConfig {
// @Value("${mongodb.indicator.uri}") // @Value("${mongodb.indicator.uri}")

View File

@@ -35,7 +35,7 @@ public class DataInitializeHistoryService {
private final ObjectMapper objectMapper; private final ObjectMapper objectMapper;
@Autowired @Autowired
@Qualifier("mongoAdminTemplate") @Qualifier("mongoIndicatorTemplate")
private MongoTemplate mongoTemplate; private MongoTemplate mongoTemplate;
@Value("${amazon.dynamodb.metaTable}") @Value("${amazon.dynamodb.metaTable}")