java访问mongodb_Java中获取MongoDB连接的方法详解
首先是所需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()三個(gè)參數(shù)分別為 用戶名 數(shù)據(jù)庫(kù)名稱 密碼
MongoCredential credential = MongoCredential.createScramSha1Credential("root", "admin", "123456Ab".toCharArray());
List credentials = new ArrayList();
credentials.add(credential);
//通過(guò)連接認(rèn)證獲取MongoDB連接
MongoClient mongoClient = new MongoClient(addrs,credentials);
//連接到數(shù)據(jù)庫(kù)
MongoDatabase mongoDatabase = mongoClient.getDatabase("admin");
mongoDatabase.getCollection("test").find().iterator();
// 關(guān)閉數(shù)據(jù)庫(kù)連接
mongoClient.close();
附帶簡(jiǎn)單增刪改查的例子：
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)兩個(gè)參數(shù)分別為 IP地址 端口號(hào)
ServerAddress serverAddress = new ServerAddress(host,port);
List addrs = new ArrayList();
addrs.add(serverAddress);
//MongoCredential.createScramSha1Credential(username,source,password)三個(gè)參數(shù)分別為 用戶名 數(shù)據(jù)庫(kù)名稱 密碼
MongoCredential credential = MongoCredential.createScramSha1Credential(username, databaseName, password.toCharArray());
List credentials = new ArrayList();
credentials.add(credential);
//通過(guò)連接認(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,"菜鳥(niǎo)教程");
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,"英語(yǔ)","32.5");
mongoTemplate.save(book,"col");
}
@Test
public void save2(){
Good good = new Good(new HashMap(){{put("id","1");put("name","動(dòng)物");}});
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 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 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("菜鳥(niǎo)教程"));
Query query = new Query(criteria); //組合查詢放入query
Sort sort = new Sort(new Sort.Order(Sort.Direction.DESC,"no")); //結(jié)果集進(jìn)行排序
query.with(sort);
List 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());
}
}
/**
* 分頁(yè)查詢
*/
@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分頁(yè)查詢下標(biāo)為1開(kāi)始總共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("菜鳥(niǎo)"));
List list = mongoTemplate.find(query,ShopDO.class,"col");
System.out.println("mongoDB查詢名稱叫菜鳥(niǎo)的數(shù)據(jù)成功,集合為col,文檔為：");
for (ShopDO shopDO:list){
System.out.println(shopDO.getNo()+"/"+shopDO.getName());
}
Update update = new Update();
update.set("name","菜鳥(niǎo)教程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 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","菜鳥(niǎo)教程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());
}
}
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
總結(jié)
以上是生活随笔為你收集整理的java访问mongodb_Java中获取MongoDB连接的方法详解的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： 获取进程名称与ID
- 下一篇： java里面value_「Java基础知