|
|
@@ -11,6 +11,7 @@ import com.jjt.common.utils.LinuxCommand;
|
|
|
import com.jjt.out.domain.OutProcessInfo;
|
|
|
import com.jjt.out.service.IOutMongoService;
|
|
|
import com.jjt.out.service.IOutProcessInfoService;
|
|
|
+import com.jjt.system.domain.SysConfig;
|
|
|
import com.jjt.system.service.ISysConfigService;
|
|
|
import com.mongodb.BasicDBObject;
|
|
|
import com.mongodb.MongoClient;
|
|
|
@@ -178,10 +179,16 @@ public class OutMongoServiceImpl extends OutBaseService implements IOutMongoServ
|
|
|
String port = mongoInfo.getString("port");
|
|
|
MongoClient mongo = new MongoClient(host, Integer.parseInt(port));
|
|
|
|
|
|
+ String saveDbs = sysConfigService.selectConfigByKey("out.mongo.save");
|
|
|
+ String[] dbs = saveDbs.split(",");
|
|
|
+
|
|
|
List<String> baseDB = new ArrayList<>();
|
|
|
baseDB.add("admin");
|
|
|
baseDB.add("config");
|
|
|
baseDB.add("local");
|
|
|
+ for (String db : dbs) {
|
|
|
+ baseDB.add(db);
|
|
|
+ }
|
|
|
//查询所有的databases
|
|
|
for (String dbName : mongo.listDatabaseNames()) {
|
|
|
if (!baseDB.contains(dbName)) {
|
