環境配置 在 Java 程式中如果要使用 MongoDB，你需要確保已經安裝了 Java 環境及 MongoDB JDBC 驅動。 本章節實例時候 Mongo 3.x 以上版本。 你可以參考本站的Java教程來安裝Java程式。現在讓我們來檢測你是否安裝了 MongoDB JDBC 驅動。 首先你必 ...
環境配置
在 Java 程式中如果要使用 MongoDB，你需要確保已經安裝了 Java 環境及 MongoDB JDBC 驅動。
本章節實例時候 Mongo 3.x 以上版本。
你可以參考本站的Java教程來安裝Java程式。現在讓我們來檢測你是否安裝了 MongoDB JDBC 驅動。
-
首先你必須下載mongo jar包，下載地址：http://mongodb.github.io/mongo-java-driver/, 請確保下載最新版本。
- 你需要將 mongo-java-driver-3.2.2.jar （找到合適的版本）包含在你的 classpath 中。。
- 國內 mongodb-driver jar 下載地址：http://central.maven.org/maven2/org/mongodb/mongo-java-driver/
連接資料庫
連接資料庫，你需要指定資料庫名稱，如果指定的資料庫不存在，mongo會自動創建資料庫。
連接資料庫的Java代碼如下：
import com.mongodb.MongoClient;
import com.mongodb.client.MongoDatabase;
public class MongoDBJDBC{
public static void main( String args[] ){
try{
// 連接到 mongodb 服務
MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
// 連接到資料庫
MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol");
System.out.println("Connect to database successfully");
}catch(Exception e){
System.err.println( e.getClass().getName() + ": " + e.getMessage() );
}
}
}
現在，讓我們來編譯運行程式並連接到資料庫 test。
你可以根據你的實際環境改變 MongoDB JDBC 驅動的路徑。
本實例將 MongoDB JDBC 啟動包 mongo-java-driver-3.2.2.jar 放在本地目錄下:
$ javac -cp .:mongo-java-driver-3.2.2.jar MongoDBJDBC.java
$ java -cp .:mongo-java-driver-3.2.2.jar MongoDBJDBC
Connect to database successfully
Authentication: true
本實例中 Mongo 資料庫無需用戶名密碼驗證。如果你的 Mongo 需要驗證用戶名及密碼，可以使用以下代碼：
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 com.mongodb.MongoClient;
import com.mongodb.client.MongoDatabase;
public class MongoDBJDBC{
public static void main( String args[] ){
try{
// 連接到 mongodb 服務
MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
// 連接到資料庫
MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol");
System.out.println("Connect to database successfully");
mongoDatabase.createCollection("test");
System.out.println("集合創建成功");
}catch(Exception e){
System.err.println( e.getClass().getName() + ": " + e.getMessage() );
}
}
}
編譯運行以上程式，輸出結果如下:
Connect to database successfully
集合創建成功
獲取集合
我們可以使用com.mongodb.client.MongoDatabase類的 getCollection() 方法來獲取一個集合
代碼片段如下：
import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
public class MongoDBJDBC{
public static void main( String args[] ){
try{
// 連接到 mongodb 服務
MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
// 連接到資料庫
MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol");
System.out.println("Connect to database successfully");
MongoCollection<Document> collection = mongoDatabase.getCollection("test");
System.out.println("集合 test 選擇成功");
}catch(Exception e){
System.err.println( e.getClass().getName() + ": " + e.getMessage() );
}
}
}
編譯運行以上程式，輸出結果如下:
Connect to database successfully
集合 test 選擇成功
插入文檔
我們可以使用com.mongodb.client.MongoCollection類的 insertMany() 方法來插入一個文檔
代碼片段如下：
import java.util.ArrayList;
import java.util.List;
import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
public class MongoDBJDBC{
public static void main( String args[] ){
try{
// 連接到 mongodb 服務
MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
// 連接到資料庫
MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol");
System.out.println("Connect to database successfully");
MongoCollection<Document> collection = mongoDatabase.getCollection("test");
System.out.println("集合 test 選擇成功");
//插入文檔
/**
* 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);
collection.insertMany(documents);
System.out.println("文檔插入成功");
}catch(Exception e){
System.err.println( e.getClass().getName() + ": " + e.getMessage() );
}
}