/** * 带有身份认证的连接 * * @param userName * @param database * @param password * @param host * @param port * @param databaseName * @param collectionName * @return */ public static MongoCollection<Document> mongoDBConn(String userName, String database, String password, String host, int port, String databaseName, String collectionName) { MongoCredential credential = MongoCredential.createCredential(userName, database, password.toCharArray()); ServerAddress address = new ServerAddress(host, port); MongoClient mongoClient = new MongoClient(address, Arrays.asList(credential)); //得到数据库 MongoDatabase database1 = mongoClient.getDatabase(databaseName); //得到集合 MongoCollection<Document> collection = database1.getCollection(collectionName); return collection; }
注:database和databaseName不同。一般database在默认的情况下是admin。databaseName是要连接的数据库名称。