更新時(shí)間:2022-09-27 10:46:40 來(lái)源:動(dòng)力節(jié)點(diǎn) 瀏覽1403次
要知道,MongoDB 是領(lǐng)先的 NoSQL 數(shù)據(jù)庫(kù)系統(tǒng),由于其動(dòng)態(tài)模式特性以及相對(duì)于大數(shù)據(jù)的高性能、水平可擴(kuò)展性、復(fù)制等優(yōu)勢(shì),近年來(lái)變得非常流行。與提供 JDBC 兼容的傳統(tǒng)關(guān)系數(shù)據(jù)庫(kù)系統(tǒng)不同驅(qū)動(dòng)程序,MongoDB 帶有自己的非 JDBC 驅(qū)動(dòng)程序,稱為 Mongo Java 驅(qū)動(dòng)程序。這意味著我們不能使用 JDBC API 從 Java 與 MongoDB 進(jìn)行交互。相反,我們必須使用它自己的 Mongo Java Driver API。
下載最新版本的 Mongo Java 驅(qū)動(dòng)程序(撰寫(xiě)本文時(shí)為 2.11.1 版)。JAR 文件名為mongo-java-driver-VERSION.jar(大約 400KB)。將下載的 JAR 文件復(fù)制到您的類路徑中。
Mongo Java 驅(qū)動(dòng)程序的在線 API 文檔可以在這里找到。
Mongo客戶端類用于與 MongoDB 服務(wù)器建立連接并執(zhí)行與數(shù)據(jù)庫(kù)相關(guān)的操作。這里有些例子:
創(chuàng)建一個(gè)MongoClient實(shí)例,該實(shí)例連接到在 localhost 和默認(rèn)端口上運(yùn)行的默認(rèn) MongoDB 服務(wù)器:
<font style="vertical-align: inherit;"><font style="vertical-align: inherit;">MongoClient mongoClient = new MongoClient();</font></font>
連接到在默認(rèn)端口 (27017) 上偵聽(tīng)的命名 MongoDB 服務(wù)器:
<font style="vertical-align: inherit;"><font style="vertical-align: inherit;">MongoClient mongoClient = new MongoClient("localhost");</font></font>
或者:
<font style="vertical-align: inherit;"><font style="vertical-align: inherit;">MongoClient mongoClient = new MongoClient("db1.server.com");</font></font>
連接到在特定端口上偵聽(tīng)的命名 MongoDB 服務(wù)器:
<font style="vertical-align: inherit;"><font style="vertical-align: inherit;">MongoClient mongoClient = new MongoClient("localhost", 27017);</font></font>
或者:
<font style="vertical-align: inherit;"><font style="vertical-align: inherit;">MongoClient mongoClient = new MongoClient("db1.server.com", 27018);</font></font>
連接到服務(wù)器副本集:
<font style="vertical-align: inherit;"><font style="vertical-align: inherit;">List<ServerAddress> 種子 = new ArrayList<ServerAddress>();</font></font><font></font><font style="vertical-align: inherit;"><font style="vertical-align: inherit;">
seed.add(new ServerAddress("db1.server.com", 27017));</font></font><font></font><font style="vertical-align: inherit;"><font style="vertical-align: inherit;">
seed.add(new ServerAddress("db2.server.com", 27018));</font></font><font></font><font style="vertical-align: inherit;"><font style="vertical-align: inherit;">
seed.add(new ServerAddress("db3.server.com", 27019));</font></font><font></font>
<font></font><font style="vertical-align: inherit;"><font style="vertical-align: inherit;">
MongoClient mongoClient = new MongoClient(seeds);</font></font>
建立連接后,我們可以獲取數(shù)據(jù)庫(kù)并進(jìn)行認(rèn)證(如果服務(wù)器運(yùn)行在安全模式下),例如:
<font style="vertical-align: inherit;"><font style="vertical-align: inherit;">MongoClient mongoClient = new MongoClient();</font></font><font></font><font style="vertical-align: inherit;"><font style="vertical-align: inherit;">
DB db = mongoClient.getDB("test");</font></font><font></font>
<font></font><font style="vertical-align: inherit;"><font style="vertical-align: inherit;">
char[] 密碼 = new char[] {'s', 'e', 'c', 'r', 'e', 't'};</font></font><font></font><font style="vertical-align: inherit;"><font style="vertical-align: inherit;">
boolean authenticated = db.authenticate("root", 密碼);</font></font><font></font>
<font></font><font style="vertical-align: inherit;"><font style="vertical-align: inherit;">
如果(經(jīng)過(guò)身份驗(yàn)證){</font></font><font></font><font style="vertical-align: inherit;"><font style="vertical-align: inherit;">
System.out.println("成功登錄MongoDB!");</font></font><font></font><font style="vertical-align: inherit;"><font style="vertical-align: inherit;">
} 別的 {</font></font><font></font><font style="vertical-align: inherit;"><font style="vertical-align: inherit;">
System.out.println("無(wú)效的用戶名/密碼");</font></font><font></font><font style="vertical-align: inherit;"><font style="vertical-align: inherit;">
}</font></font>
默認(rèn)情況下,MongoDB 服務(wù)器在不需要身份驗(yàn)證的信任模式下運(yùn)行。
我們來(lái)看一個(gè)完整的程序:
<font style="vertical-align: inherit;"><font style="vertical-align: inherit;">包 net.codejava.mongodb;</font></font><font></font>
<font></font><font style="vertical-align: inherit;"><font style="vertical-align: inherit;">
導(dǎo)入 java.net.UnknownHostException;</font></font><font></font><font style="vertical-align: inherit;"><font style="vertical-align: inherit;">
導(dǎo)入 java.util.List;</font></font><font></font><font style="vertical-align: inherit;"><font style="vertical-align: inherit;">
導(dǎo)入 java.util.Set;</font></font><font></font>
<font></font><font style="vertical-align: inherit;"><font style="vertical-align: inherit;">
導(dǎo)入com.mongodb.DB;</font></font><font></font><font style="vertical-align: inherit;"><font style="vertical-align: inherit;">
導(dǎo)入 com.mongodb.MongoClient;</font></font><font></font>
<font></font><font style="vertical-align: inherit;"><font style="vertical-align: inherit;">
公共類 JavaMongoDBConnection {</font></font><font></font>
<font></font><font style="vertical-align: inherit;"><font style="vertical-align: inherit;">
公共靜態(tài)無(wú)效主要(字符串[]參數(shù)){</font></font><font></font><font style="vertical-align: inherit;"><font style="vertical-align: inherit;">
嘗試 {</font></font><font></font>
<font></font>
MongoClient mongoClient = new MongoClient("localhost");<font></font>
<font></font>
List<String> databases = mongoClient.getDatabaseNames();<font></font>
<font></font>
for (String dbName : databases) {<font></font>
System.out.println("- Database: " + dbName);<font></font>
<font></font>
DB db = mongoClient.getDB(dbName);<font></font>
<font></font>
Set<String> collections = db.getCollectionNames();<font></font>
for (String colName : collections) {<font></font>
System.out.println("\t + Collection: " + colName);<font></font>
}<font></font>
}<font></font>
<font></font>
mongoClient.close();<font></font>
<font></font>
} catch (UnknownHostException ex) {<font></font>
ex.printStackTrace();<font></font>
}<font></font>
<font></font>
}<font></font>
}
這個(gè) Java 程序連接到在默認(rèn)端口上運(yùn)行在 localhost 上的 MongoDB 服務(wù)器,然后列出服務(wù)器上所有可用的數(shù)據(jù)庫(kù)名稱。對(duì)于每個(gè)數(shù)據(jù)庫(kù),它會(huì)列出所有的集合名稱(一個(gè)集合相當(dāng)于關(guān)系數(shù)據(jù)庫(kù)中的一個(gè)表),最后關(guān)閉連接。該程序?qū)a(chǎn)生以下輸出:
也可以使用表示數(shù)據(jù)庫(kù)連接 URI 的字符串來(lái)連接到 MongoDB 服務(wù)器,例如:
<font style="vertical-align: inherit;"><font style="vertical-align: inherit;">字符串 dbURI = "mongodb://localhost";</font></font><font></font><font style="vertical-align: inherit;"><font style="vertical-align: inherit;">
MongoClient mongoClient = new MongoClient(new MongoClientURI(dbURI));</font></font>
URI 的語(yǔ)法如下:
mongodb://[username:password@]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[database][?options]]
以下是一些連接字符串 URI 示例:
在默認(rèn)端口連接到在 localhost 上運(yùn)行的 MongoDB 服務(wù)器:
mongodb://localhost
使用用戶root和密碼secret連接到在端口27027上運(yùn)行的命名 MongoDB 服務(wù)器db1.server.com上的管理數(shù)據(jù)庫(kù):
mongodb://root:secret@db1.server.com:27027
連接到服務(wù)器db2.server.com上的用戶數(shù)據(jù)庫(kù):
mongodb://db2.server.com/users
使用用戶tom和密碼secret連接到運(yùn)行在端口27027上的命名 MongoDB 服務(wù)器db3.server.com上的產(chǎn)品數(shù)據(jù)庫(kù):
mongodb://tom:secret@db3.server.com:27027/products
連接到三個(gè)服務(wù)器的副本集:
mongodb://db1.server.com,db2.server.com,db3.server.com
以上就是關(guān)于“Java連接mongodb數(shù)據(jù)庫(kù)示例”介紹,大家如果想了解更多相關(guān)知識(shí),不妨來(lái)關(guān)注一下本站的Java視頻教程,里面的課程內(nèi)容細(xì)致全面,通俗易懂,很適合沒(méi)有基礎(chǔ)的小伙伴學(xué)習(xí),希望對(duì)大家能夠有所幫助哦。
相關(guān)閱讀
0基礎(chǔ) 0學(xué)費(fèi) 15天面授
有基礎(chǔ) 直達(dá)就業(yè)
業(yè)余時(shí)間 高薪轉(zhuǎn)行
工作1~3年,加薪神器
工作3~5年,晉升架構(gòu)
提交申請(qǐng)后,顧問(wèn)老師會(huì)電話與您溝通安排學(xué)習(xí)