14.MongoDBUtils工具类

1.

public class DbUtils {

    public static MongoCollection<Document> getMongoCollection(String localhost, int port) {
        MongoClient mongoClient = new MongoClient(localhost, port);
        MongoDatabase mongoDatabase = mongoClient.getDatabase("admin");
        System.out.println("Connect to database successfully");
        MongoCollection collection = mongoDatabase.getCollection("person");
        return collection;
    }
}

2.

public class ListEnterpriseAdapterDaoImpl  implements ListEnterpriseAdapterDao{


    @Override
    public void saveEnterprise(List<Enterprise> enterpriseList,long projectId) {

        MongoCollection<Document> collection =  DbUtils.getMongoCollection("127.0.0.1",27017);
        log.info("数据开始保存的mongoDB...............");
        for(Enterprise enterprise:enterpriseList){
            String jsonData =  JSON.toJSONString(enterpriseList);
            Random random = new Random();
            long fid = random.nextLong();
            long fTenantId = random.nextLong();
            Document document = new Document();
            document.append("F_ID", fid);
            document.append("F_PROJECT_ID", projectId);
            document.append("F_RAW_DATA", jsonData);
            collection.insertOne(document);
        }
        log.info("数据开始保存的mongoDB结束...............");
    }
}