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

org.mongodb

mongodb-driver

3.4.1

org.mongodb

bson

3.4.1

org.springframework.data

spring-data-mongodb

1.7.0.RELEASE

org.mongodb

mongo-java-driver

3.9.1

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

List addrs = new ArrayList();

addrs.add(new ServerAddress(dataSource.getSourceIp(), Integer.valueOf(dataSource.getSourcePort())));

List credentials = new ArrayList();

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 addrs = new ArrayList();

addrs.add(serverAddress);

//MongoCredential.createScramSha1Credential()三個參數分別為 用戶名 數據庫名稱 密碼

MongoCredential credential = MongoCredential.createScramSha1Credential("root", "admin", "123456Ab".toCharArray());

List credentials = new ArrayList();

credentials.add(credential);

//通過連接認證獲取MongoDB連接

MongoClient mongoClient = new MongoClient(addrs,credentials);

//連接到數據庫

MongoDatabase mongoDatabase = mongoClient.getDatabase("admin");

mongoDatabase.getCollection("test").find().iterator();

// 關閉數據庫連接

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)兩個參數分別為 IP地址 端口號

ServerAddress serverAddress = new ServerAddress(host,port);

List addrs = new ArrayList();

addrs.add(serverAddress);

//MongoCredential.createScramSha1Credential(username,source,password)三個參數分別為 用戶名 數據庫名稱 密碼

MongoCredential credential = MongoCredential.createScramSha1Credential(username, databaseName, password.toCharArray());

List credentials = new ArrayList();

credentials.add(credential);

//通過連接認證獲取MongoDB連接

MongoClient mongoClient = new MongoClient(addrs,credentials);

MongoDbFactory mongoDbFactory = new SimpleMongoDbFactory(mongoClient, databaseName);

MongoTemplate mongoTemplate = new MongoTemplate(mongoDbFactory);

return mongoTemplate;

}

/**

* 插入數據

*/

@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插入數據成功,集合為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(){{put("id","1");put("name","動物");}});

mongoTemplate.save(good,"col");

}

@Test

public void save3(){

mongoTemplate.save(JSONObject.fromObject("{\"這樣\":\"we\",\"好吧\":\"hai\"}"),"col");

System.out.println("mongoDB插入數據成功,集合為col,文檔為："+mongoTemplate.getCollection("col"));

}

/**

* 查詢所有

*/

@Test

public void findAll(){

List list = mongoTemplate.findAll(ShopDO.class,"col");

System.out.println("mongoDB查詢數據成功,集合為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 list = mongoTemplate.find(query,ShopDO.class,"col");

System.out.println("mongoDB按條件ID查詢數據成功,集合為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")); //結果集進行排序

query.with(sort);

List list = mongoTemplate.find(query,ShopDO.class,"col");

System.out.println("mongoDB組合查詢數據成功,集合為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 list = mongoTemplate.find(query,ShopDO.class,"col");

System.out.println("mongoDB分頁查詢下標為1開始總共3行數據,集合為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 list = mongoTemplate.find(query,ShopDO.class,"col");

System.out.println("mongoDB查詢名稱叫菜鳥的數據成功,集合為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更新數據成功,集合為col,行數為：" + wr.getN());

}

/**

* 更新

*/

@Test

public void update(){

Query query = new Query(Criteria.where("no").is(100));

List list = mongoTemplate.find(query,ShopDO.class,"col");

System.out.println("mongoDB查詢no為100的數據成功,集合為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更新數據成功,集合為col,行數為：" + 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刪除數據成功,集合為col,行數為：" + result.getN() + "刪除的ID為"+result.getUpsertedId());

}

}

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

總結

以上是生活随笔為你收集整理的java访问mongodb_Java中获取MongoDB连接的方法详解的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。