Java连接MongoDB


1.MongoDB没有添加使用auth认证方式

MongoClientURI uri = new MongoClientURI("mongodb://192.168.32.129:27017/local",
               MongoClientOptions.builder().cursorFinalizerEnabled(false));
     MongoClient client = new MongoClient(uri);
     MongoDatabase db=client.getDatabase("local");
     MongoCollection<Document> collection = db.getCollection("system.users");
     List<Document> foundDocument = collection.find().into(new ArrayList<Document>());
     System.out.println(foundDocument);

2.MongoDB启动的时候添加--auth参数启动MongoDB(即安全认证模式下)

private static MongoClient mongoClient = null;
   private static MongoDatabase database = null;
   private static ServerAddress serverAddress = null;
   private static MongoCredential  credentials  = null;
   private static List<ServerAddress> addressLists =new ArrayList<ServerAddress>();
   private static List<MongoCredential> credentialsLists = new ArrayList<MongoCredential>();

try{
       //mongoClient = new MongoClient("192.168.32.129",27017);
       serverAddress = new ServerAddress("192.168.32.129",27017);
       addressLists.add(serverAddress);
       credentials = MongoCredential.createMongoCRCredential("admin", "admin", "admin".toCharArray());
       credentialsLists.add(credentials);
       mongoClient = new MongoClient(addressLists, credentialsLists);
       }catch (MongoException e)
       {
           System.out.println(e.toString());
       }
       if(null != mongoClient){
           database = mongoClient.getDatabase("admin");
           /* collection = database.getCollection("system.users");
           foundDocument = collection.find().into(
                    new ArrayList<Document>());
           System.out.println(foundDocument);*/
       }

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM