【MongoDB】5.MongoDB與java的簡單結合

1.首先 你的清楚你的MongoDB的版本是多少  就下載對應的架包

下載地址如下：

http://mongodb.github.io/mongo-java-driver/  

2.新建一個項目  把架包扔進去，並Build path到你的項目下【如果用於測試，請如下 多用一個架包】

 

3.新建一個MongoConnection類 用來獲取MongoDB的連接對象：

package com.mongo.util;

import java.util.ArrayList;
import java.util.List;

import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import com.mongodb.client.MongoDatabase;

public class MongoConnection {
     
    /**
     * 需要驗證用戶名  密碼的 MongoDB的連接方式   com.mongodb.MongoClient.getDatabase("數據庫名")
     * @return
     */
    public MongoDatabase getConnection() {
         try {  
                //連接到MongoDB服務 如果是遠程連接可以替換“localhost”為服務器所在IP地址  
                //ServerAddress()兩個參數分別為 服務器地址 和 端口  
                ServerAddress serverAddress = new ServerAddress("localhost",27017);  
                List<ServerAddress> addrs = new ArrayList<ServerAddress>();  
                addrs.add(serverAddress);  
                  
                //MongoCredential.createScramSha1Credential()三個參數分別為 用戶名 數據庫名稱 密碼  
                MongoCredential credential = MongoCredential.createScramSha1Credential("username", "databaseName", "password".toCharArray());  
                List<MongoCredential> credentials = new ArrayList<MongoCredential>();  
                credentials.add(credential);  
                  
                //通過連接認證獲取MongoDB連接  
                MongoClient mongoClient = new MongoClient(addrs,credentials);  
                  
                //連接到數據庫  
                MongoDatabase mongoDatabase = mongoClient.getDatabase("databaseName");  
                System.out.println("連接成功");  
                return mongoDatabase;
            } catch (Exception e) {  
                System.err.println( e.getClass().getName() + ": " + e.getMessage() );  
            }  
         return null;
    }
    
    /**
     * 不需要驗證  用戶名+密碼  的獲取連接的方式 com.mongodb.MongoClient.getDatabase("數據庫名")
     * @return
     */
    public MongoDatabase getConnectionBasis(){
        try {
            //連接到mongodb服務
            MongoClient mongoClient = new MongoClient("localhost",27017);
            MongoDatabase mongoDatabase = mongoClient.getDatabase("databaseName");
            System.out.println("連接成功");
            return mongoDatabase;
        } catch (Exception e) {
            System.out.println(e.getClass().getName()+":"+e.getMessage());
        }
        return null;
    }
    
}

4.再建一個類 用來測試 你的增刪改查

package com.mongo.test;


import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.List;

import org.bson.Document;
import org.junit.Test;

import com.mongo.util.MongoConnection;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Filters;

public class MongoTest {
    
    MongoConnection connection = new MongoConnection();
    //連接到數據庫
    MongoDatabase mongoDatabase = connection.getConnectionBasis();
    
    
    @Test
    public void test(){
        //createCollection();//創建   集合 一次就好
        MongoCollection<Document> collection = getCollection();
        insertDomcument(collection);
        findAll(collection);
        //delete(collection);
    }
    
    /**
     * 創建  集合【對應RDBMS 中的數據表】 com.mongodb.client.MongoDatabase.createCollection("集合名")
     */
    public void createCollection(){
        mongoDatabase.createCollection("testConllection");
        System.out.println("創建集合成功");
    }
    
    /**
     * 獲取  集合【對應RDBMS 中的數據表】com.mongodb.client.MongoDatabase.getCollection("集合名")
     */
    public MongoCollection<Document> getCollection(){
        MongoCollection<Document>  collection = mongoDatabase.getCollection("testConllection");
        System.out.println("轉換到指定集合");
        return collection;
    }
    
    /**
     * 插入  文檔【對應RDBMS 中的一條數據】com.mongodb.client.MongoCollection<Document>.insertOne()/insertMany()
     */
    public void insertDomcument(MongoCollection<Document> collection){
        /** 
        * 1. 創建文檔 org.bson.Document 參數為key-value的格式 
        * 2. 創建文檔集合List<Document> 
        * 3. 將文檔集合插入數據庫集合中 mongoCollection.insertMany(List<Document>) 插入單個文檔可以用 mongoCollection.insertOne(Document) 
        * */
        Document document = new Document();
        document.append("name", "走四方");
        document.append("age", 23);
        document.append("url", "www.baidu.com");
        
        List<Document> list = new ArrayList<Document>();
        list.add(document);
        
        collection.insertMany(list);
        System.out.println("插入文檔成功");
        
        //插入 單條數據
        Document  t = new Document();
        t.append("name", "走什么");
        t.append("age", 26);
        t.append("url", "www.agen.cn");
        
        collection.insertOne(t);
        System.out.println("插入單條數據成功");
    }
    
    /**
     * 查詢  所有文檔【表內 數據】com.mongodb.client.MongoCollection<Document>.find()
     * 查詢  本條數據的時間節點   _id采用ObjectId格式
     * 
     * ObjectId 是一個12字節 BSON 類型數據，有以下格式：
            前4個字節表示時間戳
            接下來的3個字節是機器標識碼
            緊接的兩個字節由進程id組成（PID）
            最后三個字節是隨機數。
     */
    public void findAll(MongoCollection<Document> collection){
        /** 
        * 1. 獲取迭代器FindIterable<Document> 
        * 2. 獲取游標MongoCursor<Document> 
        * 3. 通過游標遍歷檢索出的文檔集合 
        * */
         FindIterable<Document> findIterable = collection.find();
         MongoCursor<Document> mongoCursor = findIterable.iterator();
         while(mongoCursor.hasNext()){
             Document document = mongoCursor.next();
             System.out.println("MongoDB數據："+document);
             System.out.println("本地時間："+new SimpleDateFormat().format(document.getObjectId("_id").getDate()));
         }
    }
    
    /**
     * 更新   所有文檔【表內  數據】com.mongodb.client.MongoCollection<Document>.updateMany()
     */
    public void update(MongoCollection<Document> collection){
        
        collection.updateMany(Filters.eq("age", 26), new Document("$set",new Document("age",100)));
        
        FindIterable<Document> findIterable = collection.find();
        MongoCursor<Document> cursor = findIterable.iterator();
        while (cursor.hasNext()) {
            System.out.println("更新后的MongoDB數據："+cursor.next());
        }
    }
    
    
    /**
     * 刪除  文檔 com.mongodb.client.MongoCollection<Document>.deleteMany()/deleteOne()
     */
    public void delete(MongoCollection<Document> collection){
        // 刪除符合條件的 第一個文檔
        collection.findOneAndDelete(Filters.eq("age", 26));
        //刪除符合條件的  所有文檔
        collection.deleteMany(Filters.gte("age", 20));
        
        FindIterable<Document> findIterable = collection.find();
        MongoCursor<Document> cursor = findIterable.iterator();
        while(cursor.hasNext()){
            System.out.println("刪除后的MongoDB數據："+cursor.next());
        }
    }
    
    
    
    
    
}

 

5.完成  自行研究