JAVA API從MongoDB中讀取數據

    <dependency>
        <groupId>org.mongodb</groupId>
        <artifactId>mongodb-driver</artifactId>
        <version>3.2.2</version>
    </dependency>

import java.util.ArrayList;  

import org.bson.Document;
import java.util.List;  
import com.mongodb.MongoClient;  
import com.mongodb.MongoCredential;  
import com.mongodb.ServerAddress;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;  
import com.mongodb.client.FindIterable;  

public class MongodbAppHbaseTest {  
    public static void main(String[] args){  
        try {  
            //連接到MongoDB服務 如果是遠程連接可以替換“localhost”為服務器所在IP地址  
            //ServerAddress()兩個參數分別為 服務器地址 和 端口  
            ServerAddress serverAddress = new ServerAddress("1.1.1.1",27017);  
            List<ServerAddress> addrs = new ArrayList<ServerAddress>();  
            addrs.add(serverAddress);  
              
            //MongoCredential.createScramSha1Credential()三個參數分別為 用戶名 數據庫名稱 密碼  
            MongoCredential credential = MongoCredential.createScramSha1Credential("xxx", "xxx", "xxx".toCharArray());  
            List<MongoCredential> credentials = new ArrayList<MongoCredential>();  
            credentials.add(credential);  
              
            //通過連接認證獲取MongoDB連接  
            MongoClient mongoClient = new MongoClient(addrs, credentials);  
              
            //連接到數據庫  
            MongoDatabase mongoDatabase = mongoClient.getDatabase("name");  
            System.out.println("Connect to database successfully");  
            
//            mongoDatabase.createCollection("xxx");
//            System.out.println("集合創建成功");
            
            MongoCollection<Document> collection = mongoDatabase.getCollection("xxx");
            System.out.println("集合 xxx選擇成功");
            
          //檢索所有文檔  
            /** 
            * 1. 獲取迭代器FindIterable<Document> 
            * 2. 獲取游標MongoCursor<Document> 
            * 3. 通過游標遍歷檢索出的文檔集合 
            * */  
            FindIterable<Document> findIterable = collection.find();  
            MongoCursor<Document> mongoCursor = findIterable.iterator();
            int i=0;
            while(mongoCursor.hasNext()){  
               System.out.println(mongoCursor.next());  
               i++;
            }  
            System.out.println("i="+i);
            
        } catch (Exception e) {  
            System.err.println( e.getClass().getName() + ": " + e.getMessage() );  
        }  
    }  
}