MongoDB Java 學習筆記

阿新 • • 發佈：2018-12-24

【前言】

由於處於執行緒安全等考慮，MongoDBJava從3.0開始已經打算廢棄DB開頭的類的使用，所以整體呼叫上有了較大的區別，特以此文志之

【正文】

環境配置

在Java程式中如果要使用MongoDB，你需要確保已經安裝了Java環境及MongoDB JDBC 驅動。

· 首先你必須下載mongo jar包，

國內快速下載地址：http://central.maven.org/maven2/org/mongodb/mongo-java-driver/

網盤下載地址：http://pan.baidu.com/s/1i3Mv0dn (這裡測試使用3.2.2版)。

· 你需要將mongo.jar

包含在你的 classpath中

連線資料庫

連線資料庫，你需要指定資料庫名稱，如果指定的資料庫不存在，mongo會自動建立資料庫。

連線資料庫的Java程式碼如下：

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 MongoDBJDBC {
	public static void main(String[] args){
		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("Connect to database successfully");
		} catch (Exception e) {
			System.err.println( e.getClass().getName() + ": " + e.getMessage() );
		}
	}
}

建立集合

我們可以使用com.mongodb.client.MongoDatabase類中的createCollection()來建立集合

程式碼片段如下：

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 MongoDBJDBC {
	public static void main(String[] args){
		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("Connect to database successfully");
			
			//建立集合 引數為 “集合名稱”
			mongoDatabase.createCollection("collectionName");
			System.out.println("Collection created successfully");
		} catch (Exception e) {
			System.err.println( e.getClass().getName() + ": " + e.getMessage() );
		}
	}
}

獲取集合

我們可以使用com.mongodb.DBCollection類的 getCollection()方法來獲取一個集合

程式碼片段如下：

import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;

public class MongoDBJDBC {
	public static void main(String[] args){
		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("Connect to database successfully");
			
			//獲取集合 引數為“集合名稱”
			MongoCollection<Document> mongoCollection = mongoDatabase.getCollection("collectionName");
			System.out.println("Collection mycol selected successfully");
		} catch (Exception e) {
			System.err.println( e.getClass().getName() + ": " + e.getMessage() );
		}
	}
}

插入文件

我們可以使用com.mongodb.client.MongoCollection類的insert()方法來插入一個文件

程式碼片段如下：

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

public class MongoDBJDBC {
	public static void main(String[] args){
		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("Connect to database successfully");
						
			//獲取集合 引數為“集合名稱”
			MongoCollection<Document> mongoCollection = mongoDatabase.getCollection("collectionName");
			System.out.println("Collection mycol selected successfully");
			
			//插入文件
			/**
			 * 1. 建立文件 org.bson.Document 引數為key-value的格式
			 * 2. 建立文件集合List<Document>
			 * 3. 將文件集合插入資料庫集合中 mongoCollection.insertMany(List<Document>) 插入單個文件可以用 mongoCollection.insertOne(Document)
			 * */
			Document document = new Document("title", "MongoDB").
		            append("description", "database").
		            append("likes", 100).
		            append("by", "Fly");
			List<Document> documents = new ArrayList<Document>();
			documents.add(document);
			mongoCollection.insertMany(documents);
			System.out.println("Document inserted successfully");
			
		} catch (Exception e) {
			System.err.println( e.getClass().getName() + ": " + e.getMessage() );
		}
	}
}

檢索所有文件

我們可以使用com.mongodb.client.MongoCollection類中的find()方法來獲取集合中的所有文件。

此方法返回一個遊標，所以你需要遍歷這個遊標。

程式碼片段如下：

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

public class MongoDBJDBC {
	public static void main(String[] args){
		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("Connect to database successfully");
			
			//獲取集合 引數為“集合名稱”
			MongoCollection<Document> mongoCollection = mongoDatabase.getCollection("collectionName");
			System.out.println("Collection mycol selected successfully");
			
			//檢索所有文件
			/**
			 * 1. 獲取迭代器FindIterable<Document>
			 * 2. 獲取遊標MongoCursor<Document>
			 * 3. 通過遊標遍歷檢索出的文件集合
			 * */
			FindIterable<Document> findIterable = mongoCollection.find();
			MongoCursor<Document> mongoCursor = findIterable.iterator();
			while(mongoCursor.hasNext()){
				System.out.println(mongoCursor.next());
			}
			
		} catch (Exception e) {
			System.err.println( e.getClass().getName() + ": " + e.getMessage() );
		}
	}
}

更新文件

你可以使用com.mongodb.client.MongoCollection類中的 updateOne()或updateMany()方法來更新集合中的文件。

程式碼片段如下：

import java.util.ArrayList;
import java.util.List;
import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
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 MongoDBJDBC {
	public static void main(String[] args){
		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("Connect to database successfully");
			
			//獲取集合 引數為“集合名稱”
			MongoCollection<Document> mongoCollection = mongoDatabase.getCollection("collectionName");
			System.out.println("Collection mycol selected successfully");
			
			//更新文件	 將文件中likes=100的文件修改為likes=200 
			mongoCollection.updateMany(Filters.eq("likes", 100), new Document("$set",new Document("likes",200)));
			//檢索檢視結果
			FindIterable<Document> findIterable = mongoCollection.find();
			MongoCursor<Document> mongoCursor = findIterable.iterator();
			while(mongoCursor.hasNext()){
				System.out.println(mongoCursor.next());
			}
			
		} catch (Exception e) {
			System.err.println( e.getClass().getName() + ": " + e.getMessage() );
		}
	}
}

刪除文件

要刪除集合中符合條件的文件，需要使用com.mongodb.client.MongoCollection類中的deleteOne ()或deleteMany()方法。分別表示刪除第一個符合條件的文件和刪除所有符合條件的文件。

程式碼片段如下：

import java.util.ArrayList;
import java.util.List;
import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
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 MongoDBJDBC {
	public static void main(String[] args){
		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("<span style="font-family: Arial, Helvetica, sans-serif;">databaseName</span><span style="font-family: Arial, Helvetica, sans-serif;">");</span>
			System.out.println("Connect to database successfully");
			
			//獲取集合 引數為“集合名稱”
			MongoCollection<Document> mongoCollection = mongoDatabase.getCollection("collectionName");
			System.out.println("Collection mycol selected successfully");
			
			//刪除符合條件的第一個文件
			mongoCollection.deleteOne(Filters.eq("likes", 200));
			//刪除所有符合條件的文件
			mongoCollection.deleteMany (Filters.eq("likes", 200));
			//檢索檢視結果
			FindIterable<Document> findIterable = mongoCollection.find();
			MongoCursor<Document> mongoCursor = findIterable.iterator();
			while(mongoCursor.hasNext()){
				System.out.println(mongoCursor.next());
			}
			
		} catch (Exception e) {
			System.err.println( e.getClass().getName() + ": " + e.getMessage() );
		}
	}
}

要注意，上面的資料庫連線我都沒有手動呼叫關閉，為了防止意外發生建議加上如下程式碼：

finally{
    mongoClient.close();
}

你還可以使用aggregate(),createIndex(),count()等方法來操作MongoDB資料庫、集合。

MongoDB Java 學習筆記 (Java操作MongoDB)

sdn 學習筆記 style god java 學習筆記 b- 學習 .net 原文地址：http://blog.csdn.net/ererfei/article/details/50857103 參考文檔：http://www.runoob.com/mongodb/mo

MongoDB Java 學習筆記

【前言】由於處於執行緒安全等考慮，MongoDBJava從3.0開始已經打算廢棄DB開頭的類的使用，所以整體呼叫上有了較大的區別，特以此文志之【正文】環境配置在Java程式中如果要使用MongoDB，你需要確保已經安裝了Java環境及MongoDB JDBC 驅

java學習筆記——String類

通過 ray [] 原理 log spl 2.3 -s 長度一、概述 ·字符串是一個特殊的對象 ·字符串一旦初始化就不可以被改變 ·String str = "abc"; ·String str1 = new String("abc"); 有什麽區別？ package

java學習筆記——java中對象的創建，初始化，引用的解析

初始學習筆記 style article 學習 base 表達如果 bsp 如果有一個A類。 1、例如以下表達式： A a1 = new A(); 那麽A是類，a1是引用。new A()是對象。僅僅是a1這個引用指向了new A()這個對象。 2、又如： A

Java學習筆記--鏈表

引用變量 nts mage 集合 tran 分享 isp exce pub 心在山東身在吳，飄蓬江海漫嗟籲。他時若遂淩雲誌，敢笑黃巢不丈夫。　　　　　　　　　　　　　　　——水滸傳先上源代碼,LinkedList類: 1 private static class

Java學習筆記——淺談數據結構與Java集合框架（第一篇、List）

技術分享 emp 鏈表 adc 下標 -c nod nal integer 橫看成嶺側成峰，遠近高低各不同。不識廬山真面目，只緣身在此山中。　　　　　　　　　　　　　　——蘇軾這一塊兒學的是雲裏霧裏，咱們先從簡單的入手。逐漸的撥開迷霧見太陽。本次先做List集合的三

JAVA學習筆記（1）——a++與++a的區別

col int 演示 opera 解析代碼數據 ++i div 需求：此博客用於解釋i++與++i的區別。過程： 1、名稱解釋 ++：自增，即在原有數據基礎上+1，再賦給原有數據。 2、程序演示（1）代碼： 1 class OperateDemo 2 { 3

Java學習筆記——泛型

ray dem 想想 string stub odt 好處 reac test 一、什麽是泛型？為什麽要使用泛型？且看代碼： 1 public class GenericsDemo { 2 3 public static void main(String

Java學習筆記——排序算法之O(n²)排序

blog sel != 而是 while bsp 優化 ++ logs 男兒何不帶吳鉤，收取關山五十州。請君暫上淩煙閣，若個書生萬戶侯？　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　——南園十三首三種排序法： 1、冒泡法 2、簡單選擇法 3、直接插入法

Java學習筆記——排序算法之進階排序（堆排序與分治並歸排序）

進行技術分享 ring http 沒有 oid 有序重復調整春蠶到死絲方盡，蠟炬成灰淚始幹　　　　　　　　　　　　　　——無題這裏介紹兩個比較難的算法： 1、堆排序 2、分治並歸排序先說堆。這裏請大家先自行了解完全二叉樹的數據結構。堆是完全二叉樹。

Java學習筆記——設計模式之五.工廠方法

strong scanner multipl 石頭 simple 決定定義 opera 下使用水邊一只青蛙在笑　　　　　　——石頭和水工廠方法模式（Factory Method），定義了一個用於創建對象的接口，讓實現類決定實例化哪一個類。工廠方法使一個類的實

Java學習筆記——String類型轉換

世界 java學習筆記 getc [] bool bsp ati nbsp ole 一滴水裏觀滄海，一粒沙中看世界　　　　　　　　　　　　　　——一帶一路歡迎宴致辭上代碼： 1 package cn.stringtoobj; 2 3 public

Java學習筆記--double類型數據精度

java學習 double 在一次面試中被問到，有兩個double類型的數相減，會出現精度丟失，應該怎麽辦，有什麽解決方法。今天特地去搜了下，解決方法就是用BigDecimal類對數據進行處理。了解詳細參考：http://blog.csdn.net/u011328015/article

JAVA學習筆記（三）

byte repl efi ber 時間 clas 區分大小寫增強for size @SuppressWarnings("resource")是用來壓制資源泄露警告的。比如使用io類，最後沒有關閉。Set集合特點：1）無序，不隨機2）元素唯一3）沒下標註意：Collect

Java學習筆記——Linux下安裝配置MySQL

code names 刪掉 set 影響 per install nod 設置山重水復疑無路,柳暗花明又一村　　　　　　　　　　　　　　——遊山西村系統:Ubuntu 16.04LTS 1\官網下載mysql-5.7.18-linux-glibc2.5-x86

java 學習筆記1

跨平臺原理所有 com 路徑運行機制 main 單位 width rtu 、高級語言運行機制高級語言按程序的執行方式分為編譯型和解釋型兩種。 java語言比較特殊，Java程序的執行必須經過先編譯後解釋的步驟。 1 編譯生成字節碼，只面向JVM(.class) 2J

java學習筆記（二）圖形用戶接口

star strong per getwidth cep runnable graphics s2d gb2 這個學期主要放在ACM比賽上去了，比賽結束了。不知不覺就15周了，這周就要java考試了，復習一下java吧。java的學習的目的還是讓我們學以致用，讓我們可以

Java學習筆記——MySQL開放3306接口與設置用戶權限

delete 用戶權限 -a mysq min 修改 onf 127.0.0.1 權限系統Ubuntu16.04 LTS 1、開放3306端口查看端口狀態:netstat -an|grep 3306tcp 0 0 127.0.0.1:3306

Java學習筆記----容器

class div key-value 程序對象 dha for string 選擇一、Java Collections框架是什麽？ Java Collections 框架中包括了大量集合接口以及這些接口的實現類和操作它們的算法（如：排序、查找、反轉、替換、復制、取

java 學習筆記2 面向對象（上）

awr ges abs nal mage 有效面向對象 ima col 類和對象類是某一批對象的抽象，可以把類理解成某種概念。對象是一個具體存在的實體。類和對象是面向對象的核心。類定義的是多個實例的特征，類不是具體存在，實例才是具體存在。定義類(class)的語法：

MongoDB Java 學習筆記

連線資料庫

建立集合

獲取集合

插入文件

檢索所有文件

更新文件

刪除文件

相關推薦