|
@@ -121,7 +121,11 @@ public class InMongoServiceImpl extends InBaseService implements IInMongoService
|
|
|
}
|
|
|
}
|
|
|
MongoDatabase database = mongoClient.getDatabase(nss[0]);
|
|
|
- MongoCollection<BasicBSONObject> collection = database.getCollection(nss[1], BasicBSONObject.class);
|
|
|
+ String table = nss[1];
|
|
|
+ if ("fs".equals(table)) {
|
|
|
+ table = nss[1] + "." + nss[2];
|
|
|
+ }
|
|
|
+ MongoCollection<BasicBSONObject> collection = database.getCollection(table, BasicBSONObject.class);
|
|
|
BasicBSONObject bson = (BasicBSONObject) obj.get("o");
|
|
|
if ("i".equals(op)) {
|
|
|
//读取数据插入
|