14.MongoDBUtils工具类

 1 public class DbUtils {
 2 
 3     public static MongoCollection<Document> getMongoCollection(String localhost, int port) {
 4         MongoClient mongoClient = new MongoClient(localhost, port);
 5         MongoDatabase mongoDatabase = mongoClient.getDatabase("admin");
 6         System.out.println("Connect to database successfully");
 7         MongoCollection collection = mongoDatabase.getCollection("person");
 8         return collection;
 9     }
10 }

 1 public class ListEnterpriseAdapterDaoImpl  implements ListEnterpriseAdapterDao{
 2 
 3 
 4     @Override
 5     public void saveEnterprise(List<Enterprise> enterpriseList,long projectId) {
 6 
 7         MongoCollection<Document> collection =  DbUtils.getMongoCollection("127.0.0.1",27017);
 8         log.info("数据开始保存的mongoDB...............");
 9         for(Enterprise enterprise:enterpriseList){
10             String jsonData =  JSON.toJSONString(enterpriseList);
11             Random random = new Random();
12             long fid = random.nextLong();
13             long fTenantId = random.nextLong();
14             Document document = new Document();
15             document.append("F_ID", fid);
16             document.append("F_PROJECT_ID", projectId);
18             document.append("F_RAW_DATA", jsonData);
20             collection.insertOne(document);
21         }
22         log.info("数据开始保存的mongoDB结束...............");
23     }
24 }