generated from root/miduo_server
gm的jl_core修改
parent
8e44fa8b9e
commit
6123cc4884
|
|
@ -1,5 +1,6 @@
|
||||||
package com.jmfy.utils;
|
package com.jmfy.utils;
|
||||||
|
|
||||||
|
import com.jmfy.model.Constant;
|
||||||
import com.mongodb.MongoClient;
|
import com.mongodb.MongoClient;
|
||||||
import com.mongodb.MongoClientURI;
|
import com.mongodb.MongoClientURI;
|
||||||
import com.mongodb.client.MongoIterable;
|
import com.mongodb.client.MongoIterable;
|
||||||
|
|
@ -28,6 +29,8 @@ public class Connect {
|
||||||
private static final Logger LOGGER = LoggerFactory.getLogger(Connect.class);
|
private static final Logger LOGGER = LoggerFactory.getLogger(Connect.class);
|
||||||
@Value("${spring.data.gameMongodb.uri}")
|
@Value("${spring.data.gameMongodb.uri}")
|
||||||
private String oldMongoClient;
|
private String oldMongoClient;
|
||||||
|
@Value("${spring.data.mongodb.uri}")
|
||||||
|
private String coreMongoClient;
|
||||||
private Map<String, MongoTemplate> oldMongomaps = new ConcurrentHashMap<>();
|
private Map<String, MongoTemplate> oldMongomaps = new ConcurrentHashMap<>();
|
||||||
@PostConstruct
|
@PostConstruct
|
||||||
public void init() {
|
public void init() {
|
||||||
|
|
@ -43,7 +46,13 @@ public class Connect {
|
||||||
|
|
||||||
public MongoTemplate getMongoTemplete(String dbName) throws Exception {
|
public MongoTemplate getMongoTemplete(String dbName) throws Exception {
|
||||||
if (!oldMongomaps.containsKey(dbName)) {
|
if (!oldMongomaps.containsKey(dbName)) {
|
||||||
MongoClient mongoClient = new MongoClient(new MongoClientURI(oldMongoClient));
|
MongoClient mongoClient;
|
||||||
|
//jl_core库单走一个配置位置
|
||||||
|
if(dbName.equals(Constant.dbName)){
|
||||||
|
mongoClient= new MongoClient(new MongoClientURI(coreMongoClient));
|
||||||
|
}else{
|
||||||
|
mongoClient = new MongoClient(new MongoClientURI(oldMongoClient));
|
||||||
|
}
|
||||||
try {
|
try {
|
||||||
MongoDbFactory mongoDbFactory = (new SimpleMongoDbFactory(mongoClient, dbName));
|
MongoDbFactory mongoDbFactory = (new SimpleMongoDbFactory(mongoClient, dbName));
|
||||||
MongoTemplate mongoTemplate = new MongoTemplate(mongoDbFactory, mappingMongoConverter(mongoDbFactory));
|
MongoTemplate mongoTemplate = new MongoTemplate(mongoDbFactory, mappingMongoConverter(mongoDbFactory));
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue