连接mongo

master
gaojie 2019-05-20 18:12:44 +08:00
parent 32f619431b
commit 7d73ad4318
2 changed files with 6 additions and 8 deletions

View File

@ -22,7 +22,7 @@ public class Connect {
private static final Logger LOGGER = LoggerFactory.getLogger(Connect.class);
@Value("${spring.data.oldMongodb.uri}")
private String oldMongoClient;
@Value("${spring.data.mongodb.uri}")
@Value("${spring.data.newmongodb.uri}")
private String newMongoClient;
private Map<String, MongoTemplate> oldMongomaps = new ConcurrentHashMap<>();
private Map<String, MongoTemplate> newMongomaps = new ConcurrentHashMap<>();
@ -35,18 +35,16 @@ public class Connect {
MongoTemplate mongoTemplate = new MongoTemplate(mongoClient, dbName);
oldMongomaps.put(dbName, mongoTemplate);
}
// initNewMongoClient();
initNewMongoClient();
}
private void initNewMongoClient() {
MongoClient mongoClient = new MongoClient(new MongoClientURI(newMongoClient));
MongoIterable<String> databaseNames = mongoClient.listDatabaseNames();
for (String dbName : databaseNames) {
if (dbName.equals("ysj_core")){
LOGGER.info("addMongoClinent-->newMongomaps={}",dbName);
MongoTemplate mongoTemplate = new MongoTemplate(mongoClient, dbName);
newMongomaps.put(dbName, mongoTemplate);
}
LOGGER.info("initNewMongoClient-->newMongomaps={}", dbName);
MongoTemplate mongoTemplate = new MongoTemplate(mongoClient, dbName);
oldMongomaps.put(dbName, mongoTemplate);
}
}

View File

@ -5,8 +5,8 @@ spring.thymeleaf.cache=false
spring.thymeleaf.content-type=text/html
spring.thymeleaf.mode =LEGACYHTML5
spring.data.newmongodb.uri = mongodb://60.1.1.14:27017
spring.data.mongodb.uri = mongodb://60.1.1.14:27017/ysj_core
#spring.data.mongodb.uri = mongodb://150.116.94.74:27017/ysj_core
spring.data.oldMongodb.uri= mongodb://60.1.1.14:27017
# redis config