Java中怎么獲取MongoDB連接

這篇文章將為大家詳細(xì)講解有關(guān)Java中怎么獲取MongoDB連接，文章內(nèi)容質(zhì)量較高，因此小編分享給大家做個參考，希望大家閱讀完這篇文章后對相關(guān)知識有一定的了解。

公司主營業(yè)務(wù)：成都網(wǎng)站設(shè)計、做網(wǎng)站、移動網(wǎng)站開發(fā)等業(yè)務(wù)。幫助企業(yè)客戶真正實現(xiàn)互聯(lián)網(wǎng)宣傳，提高企業(yè)的競爭能力。創(chuàng)新互聯(lián)建站是一支青春激揚、勤奮敬業(yè)、活力青春激揚、勤奮敬業(yè)、活力澎湃、和諧高效的團隊。公司秉承以“開放、自由、嚴(yán)謹(jǐn)、自律”為核心的企業(yè)文化，感謝他們對我們的高要求，感謝他們從不同領(lǐng)域給我們帶來的挑戰(zhàn)，讓我們激情的團隊有機會用頭腦與智慧不斷的給客戶帶來驚喜。創(chuàng)新互聯(lián)建站推出開封免費做網(wǎng)站回饋大家。

首先是所需jar包，Maven中的配置如下：

<dependency> <groupId>org.mongodb</groupId> <artifactId>mongodb-driver</artifactId> <version>3.4.1</version></dependency><dependency> <groupId>org.mongodb</groupId> <artifactId>bson</artifactId> <version>3.4.1</version></dependency><dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-mongodb</artifactId> <version>1.7.0.RELEASE</version></dependency> <dependency> <groupId>org.mongodb</groupId> <artifactId>mongo-java-driver</artifactId> <version>3.9.1</version></dependency>

獲取連接的代碼如下（本中用的是模板類）：

List<ServerAddress> addrs = new ArrayList<ServerAddress>();addrs.add(new ServerAddress(dataSource.getSourceIp(), Integer.valueOf(dataSource.getSourcePort())));List<MongoCredential> credentials = new ArrayList<MongoCredential>();credentials.add(MongoCredential.createScramSha1Credential(dataSource.getUsername(), dataSource.getSourceName(), dataSource.getPassword().toCharArray()));MongoClient mongoClient = new MongoClient(addrs, credentials);MongoDbFactory mongoDbFactory = new SimpleMongoDbFactory(mongoClient, dataSource.getSourceName());MongoTemplate mongoTemplate = new MongoTemplate(mongoDbFactory);mongoTemplate.getCollectionNames();

或者用如下方式獲取：

ServerAddress serverAddress = new ServerAddress("192.168.16.121",27017); List<ServerAddress> addrs = new ArrayList<ServerAddress>(); addrs.add(serverAddress); //MongoCredential.createScramSha1Credential()三個參數(shù)分別為用戶名數(shù)據(jù)庫名稱密碼 MongoCredential credential = MongoCredential.createScramSha1Credential("root", "admin", "123456Ab".toCharArray()); List<MongoCredential> credentials = new ArrayList<MongoCredential>(); credentials.add(credential); //通過連接認(rèn)證獲取MongoDB連接 MongoClient mongoClient = new MongoClient(addrs,credentials); //連接到數(shù)據(jù)庫 MongoDatabase mongoDatabase = mongoClient.getDatabase("admin");mongoDatabase.getCollection("test").find().iterator();// 關(guān)閉數(shù)據(jù)庫連接mongoClient.close();

附帶簡單增刪改查的例子：

package test; import java.util.ArrayList;import java.util.HashMap;import java.util.List; import org.junit.Test;import org.springframework.data.domain.Sort;import org.springframework.data.mongodb.MongoDbFactory;import org.springframework.data.mongodb.core.MongoTemplate;import org.springframework.data.mongodb.core.SimpleMongoDbFactory;import org.springframework.data.mongodb.core.query.Criteria;import org.springframework.data.mongodb.core.query.Query;import org.springframework.data.mongodb.core.query.Update; import com.mongodb.MongoClient;import com.mongodb.MongoCredential;import com.mongodb.ServerAddress;import com.mongodb.WriteResult; import bean.Book;import bean.Good;import bean.ShopDO;import net.sf.json.JSONObject; public class MongoTemplateTest { public static MongoTemplate mongoTemplate = getMongoTemplate(); public static void main(String[] args) { System.out.println(mongoTemplate.getCollectionNames()); } public static MongoTemplate getMongoTemplate(){ String host = "192.168.16.121"; int port = 27017; String databaseName = "test"; String username = "root"; String password = "123456Ab"; //ServerAddress(host,port)兩個參數(shù)分別為 IP地址端口號 ServerAddress serverAddress = new ServerAddress(host,port); List<ServerAddress> addrs = new ArrayList<ServerAddress>(); addrs.add(serverAddress); //MongoCredential.createScramSha1Credential(username,source,password)三個參數(shù)分別為用戶名數(shù)據(jù)庫名稱密碼 MongoCredential credential = MongoCredential.createScramSha1Credential(username, databaseName, password.toCharArray()); List<MongoCredential> credentials = new ArrayList<MongoCredential>(); credentials.add(credential); //通過連接認(rèn)證獲取MongoDB連接 MongoClient mongoClient = new MongoClient(addrs,credentials); MongoDbFactory mongoDbFactory = new SimpleMongoDbFactory(mongoClient, databaseName); MongoTemplate mongoTemplate = new MongoTemplate(mongoDbFactory); return mongoTemplate; } /** * 插入數(shù)據(jù) */ @Test public void save(){ ShopDO shop1 = new ShopDO(100L,"菜鳥教程"); ShopDO shop2 = new ShopDO(101L,"有道筆記"); mongoTemplate.save(shop1,"col"); mongoTemplate.save(shop2,"col"); System.out.println("mongoDB插入數(shù)據(jù)成功,集合為col,文檔為："+mongoTemplate.getCollection("col")); } @Test public void save1(){ Book book = new Book(22L,"英語","32.5"); mongoTemplate.save(book,"col"); } @Test public void save2(){ Good good = new Good(new HashMap<String,String>(){{put("id","1");put("name","動物");}}); mongoTemplate.save(good,"col"); } @Test public void save3(){ mongoTemplate.save(JSONObject.fromObject("{\"這樣\":\"we\",\"好吧\":\"hai\"}"),"col"); System.out.println("mongoDB插入數(shù)據(jù)成功,集合為col,文檔為："+mongoTemplate.getCollection("col")); } /** * 查詢所有 */ @Test public void findAll(){ List<ShopDO> list = mongoTemplate.findAll(ShopDO.class,"col"); System.out.println("mongoDB查詢數(shù)據(jù)成功,集合為col,文檔為："); for (ShopDO shopDO:list){ System.out.println(shopDO.getNo()+"/"+shopDO.getName()); } } /** * 單條件查詢 */ @Test public void simpleQuery(){ Query query = Query.query(Criteria.where("no").is(100L)); List<ShopDO> list = mongoTemplate.find(query,ShopDO.class,"col"); System.out.println("mongoDB按條件ID查詢數(shù)據(jù)成功,集合為col,文檔為："); for (ShopDO shopDO:list){ System.out.println(shopDO.getNo()+"/"+shopDO.getName()); } } /** * 多條件查詢 */ @Test public void muchQuery(){ Criteria criteria = new Criteria(); //or是條件或查詢，and是條件與查詢 criteria.orOperator( Criteria.where("no").is(100), Criteria.where("name").is("菜鳥教程")); Query query = new Query(criteria); //組合查詢放入query Sort sort = new Sort(new Sort.Order(Sort.Direction.DESC,"no")); //結(jié)果集進行排序 query.with(sort); List<ShopDO> list = mongoTemplate.find(query,ShopDO.class,"col"); System.out.println("mongoDB組合查詢數(shù)據(jù)成功,集合為col,文檔為："); for (ShopDO shopDO:list){ System.out.println(shopDO.getNo()+"/"+shopDO.getName()); } } /** * 分頁查詢 */ @Test public void LimitQuery(){ Query query = new Query(); query.skip(1).limit(3); List<ShopDO> list = mongoTemplate.find(query,ShopDO.class,"col"); System.out.println("mongoDB分頁查詢下標(biāo)為1開始總共3行數(shù)據(jù),集合為col,文檔為："); for (ShopDO shopDO:list){ System.out.println(shopDO.getNo()+"/"+shopDO.getName()); } } /** * 模糊查詢 */ @Test public void LikeQuery(){ Query query = new Query(Criteria.where("name").regex("菜鳥")); List<ShopDO> list = mongoTemplate.find(query,ShopDO.class,"col"); System.out.println("mongoDB查詢名稱叫菜鳥的數(shù)據(jù)成功,集合為col,文檔為："); for (ShopDO shopDO:list){ System.out.println(shopDO.getNo()+"/"+shopDO.getName()); } Update update = new Update(); update.set("name","菜鳥教程old"); WriteResult wr = mongoTemplate.updateMulti(query,update,"col"); System.out.println("mongoDB更新數(shù)據(jù)成功,集合為col,行數(shù)為：" + wr.getN()); } /** * 更新 */ @Test public void update(){ Query query = new Query(Criteria.where("no").is(100)); List<ShopDO> list = mongoTemplate.find(query,ShopDO.class,"col"); System.out.println("mongoDB查詢no為100的數(shù)據(jù)成功,集合為col,文檔為："); for (ShopDO shopDO:list){ System.out.println(shopDO.getNo()+"/"+shopDO.getName()); } Update update = new Update(); update.set("name","菜鳥教程new"); WriteResult wr = mongoTemplate.updateFirst(query,update,"col"); System.out.println("mongoDB更新數(shù)據(jù)成功,集合為col,行數(shù)為：" + wr.getN()); } /** * 刪除 */ @Test public void delete(){ Query query = new Query(Criteria.where("no").is(1)); WriteResult result = mongoTemplate.remove(query, "col"); System.out.println("mongoDB刪除數(shù)據(jù)成功,集合為col,行數(shù)為：" + result.getN() + "刪除的ID為"+result.getUpsertedId()); }}

關(guān)于Java中怎么獲取MongoDB連接就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，可以學(xué)到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。

網(wǎng)站題目：Java中怎么獲取MongoDB連接
網(wǎng)站地址：http://muchs.cn/article36/ghehpg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供做網(wǎng)站、ChatGPT、外貿(mào)建站、定制開發(fā)、域名注冊、自適應(yīng)網(wǎng)站

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容