Java(90):Java 连接MongoDB(调试用)

Java 连接MongoDB(调试用)

1.Maven引用

        
        
            org.mongodb
            mongo-java-driver
            3.12.11
        

2.Java连接MongoDB

package mongo;


import com.mongodb.MongoClientSettings;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import com.mongodb.client.*;
import org.bson.Document;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;




public class MongoTest {

    public static void main(String[] args){
        String[] ips="10.1.1.191:27017".split(",");
        String database = "aoe_mongo";
        String username = "humf";
        String password = "123456";
        MongoClient mongoClient=MongoConnect(ips,database,username,password);
        MongoDatabase mongoDatabase = mongoClient.getDatabase("aoe_mongo");
        MongoCollection collection = mongoDatabase.getCollection("aoe_java");
        FindIterable findIterable = collection.find();
        MongoCursor mongoCursor = findIterable.iterator();
        while(mongoCursor.hasNext()){
            System.out.println(mongoCursor.next());
        }

    }

    public static MongoClient MongoConnect(String[] ips,String database,String username,String password){
        List addressList = new ArrayList<>();
        for(String addr:ips){
            addressList.add(new ServerAddress(addr));
        }

        MongoCredential credential = MongoCredential.createCredential(username, database, password.toCharArray());

        //创建源数据库连接
        //.applyToSslSettings(builder-> builder.enabled(true).context(getSSL1()).invalidHostNameAllowed(true).build())
        MongoClient mongoClient = MongoClients.create(
                MongoClientSettings.builder()
                        //.applyToSslSettings(builder-> builder.enabled(true).context(getSSL1()).invalidHostNameAllowed(true).build())
                        .applyToClusterSettings(builder -> builder.hosts(addressList))
                        .credential(credential)
                        .applyToConnectionPoolSettings(builder-> builder.minSize(20).maxSize(100).maxWaitTime(1,
                                TimeUnit.SECONDS))
                        .build());

        return mongoClient;
    }
}

3.执行结果