建站
咨詢
售后
建站咨詢
新聞中心
創(chuàng)新互聯(lián)秉承實現(xiàn)全網(wǎng)價值營銷的理念，以專業(yè)定制企業(yè)官網(wǎng)，做網(wǎng)站、網(wǎng)站設(shè)計，微信小程序定制開發(fā)，網(wǎng)頁設(shè)計制作，成都做手機網(wǎng)站，網(wǎng)絡(luò)營銷推廣幫助傳統(tǒng)企業(yè)實現(xiàn)“互聯(lián)網(wǎng)+”轉(zhuǎn)型升級專業(yè)定制企業(yè)官網(wǎng),公司注重人才、技術(shù)和管理，匯聚了一批優(yōu)秀的互聯(lián)網(wǎng)技術(shù)人才,對客戶都以感恩的心態(tài)奉獻自己的專業(yè)和所長。
環(huán)境配置
想要在 Java 程序中使用 MongoDB，需要確保您的電腦上已經(jīng)安裝了 MongoDB，并搭建好了 Java 的環(huán)境。您可以查看《Java 教程》來了解不同系統(tǒng)下 Java 的安裝教程。
另外您還需要確認安裝了 MongoDB JDBC 驅(qū)動，您可以通過 http://mongodb.github.io/mongo-java-driver/ 來下載最新版的 mongodb-driver-3.11.2.jar 以及其依賴項 mongodb-driver-core-3.11.2.jar，并將它們包含進 classpath 中。
連接數(shù)據(jù)庫
要連接數(shù)據(jù)庫，首先需要指定要連接的數(shù)據(jù)庫名稱，如果數(shù)據(jù)庫不存在的話，MongoDB 則會自動創(chuàng)建它。下面通過簡單的代碼來演示如何使用 Java 代碼連接 MongoDB 數(shù)據(jù)庫：
import com.mongodb.client.MongoDatabase;
import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
public class ConnectToDB {
public static void main( String args[] ) {
// 創(chuàng)建 MongoDB 連接
MongoClient mongo = new MongoClient( "localhost" , 27017 );
// 連接到 MongoDB
MongoCredential credential;
credential = MongoCredential.createCredential("sampleUser", "myDb", "password".toCharArray());
System.out.println("Connected to the database successfully");
// 訪問數(shù)據(jù)庫
MongoDatabase database = mongo.getDatabase("myDb");
System.out.println("Credentials ::"+ credential);
}
} 編譯并運行上面的程序，即可創(chuàng)建名為“myDb”的數(shù)據(jù)庫，并輸出如下所示的內(nèi)容：
$javac ConnectToDB.java
$java ConnectToDB
Connected to the database successfully
Credentials ::MongoCredential{
mechanism = null,
userName = 'sampleUser',
source = 'myDb',
password =
mechanismProperties = {}
}
創(chuàng)建集合
若要創(chuàng)建集合，您可以使用 com.mongodb.client.MongoDatabase 類的 createCollection() 方法，示例代碼如下：
import com.mongodb.client.MongoDatabase;
import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
public class CreatingCollection {
public static void main( String args[] ) {
// 創(chuàng)建 MongoDB 連接
MongoClient mongo = new MongoClient( "localhost" , 27017 );
// 連接到 MongoDB
MongoCredential credential;
credential = MongoCredential.createCredential("sampleUser", "myDb", "password".toCharArray());
System.out.println("數(shù)據(jù)庫連接成功");
// 訪問數(shù)據(jù)庫
MongoDatabase database = mongo.getDatabase("myDb");
// 創(chuàng)建集合
database.createCollection("tutorial");
System.out.println("集合創(chuàng)建成功");
}
} 編譯并運行上面的程序，運行結(jié)果如下所示：
數(shù)據(jù)庫連接成功
集合創(chuàng)建成功
獲取/選擇集合
要獲取/選擇數(shù)據(jù)庫中的集合，您可以使用 com.mongodb.client.MongoDatabase 類的 getCollection() 方法，示例代碼如下：
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
public class selectingCollection {
public static void main( String args[] ) {
// 創(chuàng)建 MongoDB 連接
MongoClient mongo = new MongoClient( "localhost" , 27017 );
// 連接到 MongoDB
MongoCredential credential;
credential = MongoCredential.createCredential("sampleUser", "myDb", "password".toCharArray());
System.out.println("數(shù)據(jù)庫連接成功");
// 訪問數(shù)據(jù)庫
MongoDatabase database = mongo.getDatabase("myDb");
// 創(chuàng)建集合
database.createCollection("tutorial");
System.out.println("集合創(chuàng)建成功");
// 檢索集合
MongoCollection collection = database.getCollection("tutorial");
System.out.println("集合選擇成功 tutorial");
}
} 編譯并運行上面的程序，運行結(jié)果如下所示：
數(shù)據(jù)庫連接成功
集合創(chuàng)建成功
集合選擇成功 tutorial
插入文檔
想要向集合中插入文檔，您可以使用 com.mongodb.client.MongoCollection 類的 insert() 方法，示例代碼如下：
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
import com.mongodb.MongoClient;
public class InsertingDocument {
public static void main( String args[] ) {
// 創(chuàng)建 MongoDB 連接
MongoClient mongo = new MongoClient( "localhost" , 27017 );
// 連接到數(shù)據(jù)庫
MongoDatabase database = mongo.getDatabase("myDb");
// 創(chuàng)建集合
database.createCollection("tutorial");
System.out.println("集合創(chuàng)建成功");
// 檢索集合
MongoCollection collection = database.getCollection("tutorial");
System.out.println("集合選擇成功");
Document document = new Document("title", "MongoDB")
.append("description", "database")
.append("likes", 100)
.append("url", "http://www.biancheng.net/mongodb/")
.append("by", "編程幫");
// 將文檔插入到集合中
collection.insertOne(document);
System.out.println("文檔插入成功");
} 編譯并運行上面的程序，運行結(jié)果如下所示：
集合創(chuàng)建成功
集合選擇成功
文檔插入成功
查詢文檔
想要查詢集合中的文檔，您可以使用 com.mongodb.client.MongoCollection 類的 find() 方法，此方法會返回一個游標，因此想要查詢集合中的所有文檔您只需要不斷迭代此游標即可，示例代碼如下：
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
public class RetrievingAllDocuments {
public static void main( String args[] ) {
// 創(chuàng)建 MongoDB 連接
MongoClient mongo = new MongoClient( "localhost" , 27017 );
// 連接到 MongoDB
MongoCredential credential;
credential = MongoCredential.createCredential("sampleUser", "myDb", "password".toCharArray());
System.out.println("數(shù)據(jù)庫連接成功");
// 連接到數(shù)據(jù)庫
MongoDatabase database = mongo.getDatabase("myDb");
// 檢索集合
MongoCollection collection = database.getCollection("tutorial");
System.out.println("成功選擇了集合 tutorial");
Document document1 = new Document("title", "MongoDB")
.append("description", "database")
.append("likes", 100)
.append("url", "http://www.biancheng.net/mongodb/")
.append("by", "編程幫");
Document document2 = new Document("title", "html")
.append("description", "database")
.append("likes", 200)
.append("url", "http://www.biancheng.net/html/")
.append("by", "編程幫");
List list = new ArrayList();
list.add(document1);
list.add(document2);
collection.insertMany(list);
// 獲取 iterable 對象
FindIterable iterDoc = collection.find();
int i = 1;
// 獲取迭代器
Iterator it = iterDoc.iterator();
while (it.hasNext()) {
System.out.println(it.next());
i++;
}
}
} 編譯并運行上面的程序，運行結(jié)果如下所示：
數(shù)據(jù)庫連接成功
成功選擇了集合 tutorial
Document{{_id=5dce4e9ff68a9c2449e197b2, title=MongoDB, description=database, likes=100, url=http://www.biancheng.net/mongodb/, by=編程幫}}
Document{{_id=5dce4e9ff68a9c2449e197b3, title=html, description=database, likes=200, url=http://www.biancheng.net/html/, by=編程幫}}
更新文檔
要更新（修改）集合中文檔的數(shù)據(jù)，您可以使用 com.mongodb.client.MongoCollection 類的 updateOne() 方法，示例代碼如下：
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Filters;
import com.mongodb.client.model.Updates;
import java.util.Iterator;
import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
public class UpdatingDocuments {
public static void main( String args[] ) {
// 創(chuàng)建 MongoDB 連接
MongoClient mongo = new MongoClient( "localhost" , 27017 );
// 連接到 MongoDB
MongoCredential credential;
credential = MongoCredential.createCredential("sampleUser", "myDb", "password".toCharArray());
System.out.println("數(shù)據(jù)庫連接成功");
// 連接到數(shù)據(jù)庫
MongoDatabase database = mongo.getDatabase("myDb");
// 檢索集合
MongoCollection collection = database.getCollection("tutorial");
System.out.println("成功選擇了集合 tutorial");
collection.updateOne(Filters.eq("title", 1), Updates.set("likes", 150));
System.out.println("文檔更新成功...");
// 更新后檢索文檔
// 獲取 iterable 對象
FindIterable iterDoc = collection.find();
int i = 1;
// 獲取迭代器
Iterator it = iterDoc.iterator();
while (it.hasNext()) {
System.out.println(it.next());
i++;
}
}
} 編譯并運行上面的程序，運行結(jié)果如下所示：
數(shù)據(jù)庫連接成功
成功選擇了集合 tutorial
文檔更新成功...
Document{{_id=5dce4e9ff68a9c2449e197b2, title=MongoDB, description=database, likes=100, url=http://www.biancheng.net/mongodb/, by=編程幫}}
Document{{_id=5dce4e9ff68a9c2449e197b3, title=html, description=database, likes=200, url=http://www.biancheng.net/html/, by=編程幫}}
刪除文檔
想要從集合中刪除文檔，您可以使用 com.mongodb.client.MongoCollection 類的 deleteOne() 方法，示例代碼如下：
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Filters;
import java.util.Iterator;
import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
public class DeletingDocuments {
public static void main( String args[] ) {
// 創(chuàng)建 MongoDB 連接
MongoClient mongo = new MongoClient( "localhost" , 27017 );
// 連接到 MongoDB
MongoCredential credential;
credential = MongoCredential.createCredential("sampleUser", "myDb", "password".toCharArray());
System.out.println("數(shù)據(jù)庫連接成功");
// 訪問數(shù)據(jù)庫
MongoDatabase database = mongo.getDatabase("myDb");
// 檢索集合
MongoCollection collection = database.getCollection("tutorial");
System.out.println("成功選擇了集合 tutorial");
// 刪除文檔
collection.deleteOne(Filters.eq("title", "MongoDB"));
System.out.println("文檔刪除成功...");
// 更新后檢索文檔
// 獲取 iterable 對象
FindIterable iterDoc = collection.find();
int i = 1;
// 獲取迭代器
Iterator it = iterDoc.iterator();
while (it.hasNext()) {
System.out.println(it.next());
i++;
}
}
} 編譯并運行上面的程序，運行結(jié)果如下所示：
數(shù)據(jù)庫連接成功
成功選擇了集合 tutorial
文檔刪除成功...
Document{{_id=5dce4e9ff68a9c2449e197b3, title=html, description=database, likes=200, url=http://www.biancheng.net/html/, by=編程幫}}
刪除集合
要從數(shù)據(jù)庫中刪除集合，您可以使用 com.mongodb.client.MongoCollection 類中的 drop() 方法，示例代碼如下：
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
public class DropingCollection {
public static void main( String args[] ) {
// 創(chuàng)建 MongoDB 連接
MongoClient mongo = new MongoClient( "localhost" , 27017 );
// 連接到 MongoDB
MongoCredential credential;
credential = MongoCredential.createCredential("sampleUser", "myDb", "password".toCharArray());
System.out.println("數(shù)據(jù)庫連接成功");
// 訪問數(shù)據(jù)庫
MongoDatabase database = mongo.getDatabase("myDb");
// 創(chuàng)建集合
System.out.println("集合創(chuàng)建成功");
// 檢索集合
MongoCollection collection = database.getCollection("tutorial");
// 刪除集合
collection.drop();
System.out.println("集合刪除成功");
}
} 編譯并運行上面的程序，運行結(jié)果如下所示：
數(shù)據(jù)庫連接成功
集合創(chuàng)建成功
集合刪除成功
列出所有集合
要列出數(shù)據(jù)庫中的所有集合，您需要使用 com.mongodb.client.MongoDatabase 類的 listCollectionNames() 方法，示例代碼如下：
import com.mongodb.client.MongoDatabase;
import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
public class ListOfCollection {
public static void main( String args[] ) {
// 創(chuàng)建 MongoDB 連接
MongoClient mongo = new MongoClient( "localhost" , 27017 );
// 連接到 MongoDB
MongoCredential credential;
credential = MongoCredential.createCredential("sampleUser", "myDb", "password".toCharArray());
System.out.println("數(shù)據(jù)庫連接成功");
// 訪問數(shù)據(jù)庫
MongoDatabase database = mongo.getDatabase("myDb");
System.out.println("集合創(chuàng)建成功");
for (String name : database.listCollectionNames()) {
System.out.println(name);
}
}
} 編譯并運行上面的程序，運行結(jié)果如下所示：
數(shù)據(jù)庫連接成功
集合創(chuàng)建成功
myCollection
myCollection1
myCollection5
更多關(guān)于 Java 中 MongoDB 的操作可以參考 http://mongodb.github.io/mongo-java-driver/3.0/driver/getting-started/quick-tour/
新聞標題：Java操作MongoDB（詳細）
網(wǎng)頁URL：http://fisionsoft.com.cn/article/cdgpeji.html
