java操作mongodb——連接數據庫

MongoDB 提供了Java語言操作的驅動jar，我使用的版本是：mongo-java-driver-3.2.2.jar

驅動jar下載地址：https://mongodb.github.io/mongo-java-driver/

以下是創建Mongo連接，獲取數據庫和表的方法，拿到表以后可以進行增刪改查的操作，后續章節會更新。

 /**
     * 初始化連接池，設置參數。
     */
    private static void init() {

        // 參數依次是：鏈接池數量 最大等待時間 scoket超時時間 設置連接池最長生命時間 連接超時時間
        MongoClientOptions options = MongoClientOptions.builder()
                .connectionsPerHost(Integer.parseInt(ConfigUtil.getParameter("mongodb.connectionsPerHost")))
                .maxWaitTime(Integer.parseInt(ConfigUtil.getParameter("mongodb.maxWaitTime")))
                .socketTimeout(Integer.parseInt(ConfigUtil.getParameter("mongodb.socketTimeout")))
                .maxConnectionLifeTime(Integer.parseInt(ConfigUtil.getParameter("mongodb.maxConnectionLifeTime")))
                .connectTimeout(Integer.parseInt(ConfigUtil.getParameter("mongodb.connectTimeout"))).build();

        // 連接到MongoDB服務 如果是遠程連接可以替換“localhost”為服務器所在IP地址
        // ServerAddress()兩個參數分別為 服務器地址 和 端口
        ServerAddress serverAddress = new ServerAddress(ConfigUtil.getParameter("mongodb.hostName"),
                Integer.parseInt(ConfigUtil.getParameter("mongodb.port")));
        List<ServerAddress> addrs = new ArrayList<ServerAddress>();
        addrs.add(serverAddress);

        // 三個參數分別為 用戶名 數據庫名稱 密碼
        MongoCredential credential = MongoCredential.createScramSha1Credential(
                ConfigUtil.getParameter("mongodb.username"), ConfigUtil.getParameter("mongodb.databaseName"),
                ConfigUtil.getParameter("mongodb.password").toCharArray());
        List<MongoCredential> credentials = new ArrayList<MongoCredential>();
        credentials.add(credential);

        // 通過連接認證獲取MongoDB連接
        client = new MongoClient(addrs, credentials, options);
    }

/**
     * 根據名稱獲取DB，相當於是連接
     * 
     * @param dbName
     * @return
     */
    public static MongoDatabase getDatabase() {
        if (client == null) {
            // 初始化
            init();
        }
        return client.getDatabase(ConfigUtil.getParameter("mongodb.databaseName"));
    }
    /**
     * 獲取Collection
     * @param collectionName
     * @return
     */
    public static MongoCollection<Document> getCollection(String collName){
        if (client == null) {
            // 初始化
            init();
        }
        MongoDatabase db = getDatabase();
        MongoCollection<Document> collection = db.getCollection(collName);  
        return collection;
    }