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;

     }

 }

 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结束...............");

     }

 }