java操作mongodb實(shí)現(xiàn)CURD功能實(shí)例
先下載相應(yīng)的驅(qū)動(dòng):官網(wǎng)上下載:http://central.maven.org/maven2/org/mongodb/mongo-java-driver/
本文使用mongo-2.10.1.jar版本:
下面有詳細(xì)代碼的,每個(gè)方法可以單獨(dú)執(zhí)行。其中為了方便運(yùn)行,每個(gè)方法中都重新鏈接數(shù)據(jù)庫,而沒有再提出來,因?yàn)樵诖说哪康氖菫榱苏J(rèn)識mongodb而已。
package com.mongo.dao;
import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.Mongo;
/**
* 對基本實(shí)體的存儲測試
* @author lhy
*
*/
public class EntityTest {
public static void main(String[] args) throws Exception{
delete();
}
/**
* 保存實(shí)體對象
* @throws Exception
*/
public static void saveEntity() throws Exception{
//第一:實(shí)例化mongo對象,連接mongodb服務(wù)器 包含所有的數(shù)據(jù)庫
//默認(rèn)構(gòu)造方法,默認(rèn)是連接本機(jī),端口號,默認(rèn)是27017
//相當(dāng)于Mongo mongo =new Mongo("localhost",27017)
Mongo mongo =new Mongo();
//第二:連接具體的數(shù)據(jù)庫
//其中參數(shù)是具體數(shù)據(jù)庫的名稱,若服務(wù)器中不存在,會(huì)自動(dòng)創(chuàng)建
DB db=mongo.getDB("myMongo");
//第三:操作具體的表
//在mongodb中沒有表的概念,而是指集合
//其中參數(shù)是數(shù)據(jù)庫中表,若不存在,會(huì)自動(dòng)創(chuàng)建
DBCollection collection=db.getCollection("user");
//添加操作
//在mongodb中沒有行的概念,而是指文檔
BasicDBObject document=new BasicDBObject();
document.put("id", 1);
document.put("name", "小明");
// //然后保存到集合中
// // collection.insert(document);
//當(dāng)然我也可以保存這樣的json串
/* {
"id":1,
"name","小明",
"address":
{
"city":"beijing",
"code":"065000"
}
}*/
//實(shí)現(xiàn)上述json串思路如下:
//第一種:類似xml時(shí),不斷添加
BasicDBObject addressDocument=new BasicDBObject();
addressDocument.put("city", "beijing");
addressDocument.put("code", "065000");
document.put("address", addressDocument);
//然后保存數(shù)據(jù)庫中
collection.insert(document);
//第二種:直接把json存到數(shù)據(jù)庫中
/* String jsonTest="{'id':1,'name':'小明',"+
"'address':{'city':'beijing','code':'065000'}"+
"}";
DBObject dbobjct=(DBObject)JSON.parse(jsonTest);
collection.insert(dbobjct);*/
}
/**
* 遍歷所有的
* @throws Exception
*/
public static void selectAll() throws Exception{
//第一:實(shí)例化mongo對象,連接mongodb服務(wù)器 包含所有的數(shù)據(jù)庫
//默認(rèn)構(gòu)造方法,默認(rèn)是連接本機(jī),端口號,默認(rèn)是27017
//相當(dāng)于Mongo mongo =new Mongo("localhost",27017)
Mongo mongo =new Mongo();
//第二:連接具體的數(shù)據(jù)庫
//其中參數(shù)是具體數(shù)據(jù)庫的名稱,若服務(wù)器中不存在,會(huì)自動(dòng)創(chuàng)建
DB db=mongo.getDB("myMongo");
//第三:操作具體的表
//在mongodb中沒有表的概念,而是指集合
//其中參數(shù)是數(shù)據(jù)庫中表,若不存在,會(huì)自動(dòng)創(chuàng)建
DBCollection collection=db.getCollection("user");
//查詢操作
//查詢所有
//其中類似access數(shù)據(jù)庫中游標(biāo)概念
DBCursor cursor=collection.find();
System.out.println("mongodb中的user表結(jié)果如下:");
while(cursor.hasNext()){
System.out.println(cursor.next());
}
}
/**
* 根據(jù)條件查詢
* @throws Exception
*/
public static void selectPart() throws Exception{
//第一:實(shí)例化mongo對象,連接mongodb服務(wù)器 包含所有的數(shù)據(jù)庫
//默認(rèn)構(gòu)造方法,默認(rèn)是連接本機(jī),端口號,默認(rèn)是27017
//相當(dāng)于Mongo mongo =new Mongo("localhost",27017)
Mongo mongo =new Mongo();
//第二:連接具體的數(shù)據(jù)庫
//其中參數(shù)是具體數(shù)據(jù)庫的名稱,若服務(wù)器中不存在,會(huì)自動(dòng)創(chuàng)建
DB db=mongo.getDB("myMongo");
//第三:操作具體的表
//在mongodb中沒有表的概念,而是指集合
//其中參數(shù)是數(shù)據(jù)庫中表,若不存在,會(huì)自動(dòng)創(chuàng)建
DBCollection collection=db.getCollection("user");
//可以直接put
BasicDBObject queryObject=new BasicDBObject();
queryObject.put("id", 1);
DBCursor querycursor=collection.find(queryObject);
System.out.println("條件查詢?nèi)缦拢?);
while(querycursor.hasNext()){
System.out.println(querycursor.next());
}
}
/**
* 更新操作
* 更新一條記錄
* @throws Exception
*/
public static void update()throws Exception{
//第一:實(shí)例化mongo對象,連接mongodb服務(wù)器 包含所有的數(shù)據(jù)庫
//默認(rèn)構(gòu)造方法,默認(rèn)是連接本機(jī),端口號,默認(rèn)是27017
//相當(dāng)于Mongo mongo =new Mongo("localhost",27017)
Mongo mongo =new Mongo();
//第二:連接具體的數(shù)據(jù)庫
//其中參數(shù)是具體數(shù)據(jù)庫的名稱,若服務(wù)器中不存在,會(huì)自動(dòng)創(chuàng)建
DB db=mongo.getDB("myMongo");
//第三:操作具體的表
//在mongodb中沒有表的概念,而是指集合
//其中參數(shù)是數(shù)據(jù)庫中表,若不存在,會(huì)自動(dòng)創(chuàng)建
DBCollection collection=db.getCollection("user");
//更新后的對象
// 第一種更新方式
BasicDBObject newBasicDBObject =new BasicDBObject();
newBasicDBObject.put("id", 2);
newBasicDBObject.put("name", "小紅");
collection.update(new BasicDBObject().append("id", 1),newBasicDBObject);
// 第二種更新方式
// 更新某一個(gè)字段
// BasicDBObject newBasicDBObject =new BasicDBObject().append("$set",new BasicDBObject().append("name", "小紅") );
// collection.update(new BasicDBObject().append("id", 1).append("name", "小明"),newBasicDBObject);
DBCursor querycursor1=collection.find();
System.out.println("更新后結(jié)果如下:");
while(querycursor1.hasNext()){
System.out.println(querycursor1.next());
}
}
/**
* 刪除文檔,其中包括刪除全部或刪除部分
* @throws Exception
*/
public static void delete() throws Exception{
//第一:實(shí)例化mongo對象,連接mongodb服務(wù)器 包含所有的數(shù)據(jù)庫
//默認(rèn)構(gòu)造方法,默認(rèn)是連接本機(jī),端口號,默認(rèn)是27017
//相當(dāng)于Mongo mongo =new Mongo("localhost",27017)
Mongo mongo =new Mongo();
//第二:連接具體的數(shù)據(jù)庫
//其中參數(shù)是具體數(shù)據(jù)庫的名稱,若服務(wù)器中不存在,會(huì)自動(dòng)創(chuàng)建
DB db=mongo.getDB("myMongo");
//第三:操作具體的表
//在mongodb中沒有表的概念,而是指集合
//其中參數(shù)是數(shù)據(jù)庫中表,若不存在,會(huì)自動(dòng)創(chuàng)建
DBCollection collection=db.getCollection("user");
BasicDBObject queryObject1=new BasicDBObject();
queryObject1.put("id", 2);
queryObject1.put("name","小紅");
//刪除某一條記錄
collection.remove(queryObject1);
//刪除全部
//collection.drop();
DBCursor cursor1=collection.find();
System.out.println("刪除后的結(jié)果如下:");
while(cursor1.hasNext()){
System.out.println(cursor1.next());
}
}
}
- ThinkJS中如何使用MongoDB的CURD操作
- Mongodb 數(shù)據(jù)類型及Mongoose常用CURD
- PHP操作MongoDB實(shí)現(xiàn)增刪改查功能【附php7操作MongoDB方法】
- mongodb+php實(shí)現(xiàn)簡單的增刪改查
- nodejs操作mongodb的增刪改查功能實(shí)例
- Java連接MongoDB進(jìn)行增刪改查的操作
- MongoDB.NET 2.2.4驅(qū)動(dòng)版本對Mongodb3.3數(shù)據(jù)庫中GridFS增刪改查
- PHP簡單操作MongoDB的方法(安裝及增刪改查)
- MongoDB簡單操作示例【連接、增刪改查等】
- mongodb數(shù)據(jù)庫入門之CURD簡單操作示例
相關(guān)文章
MyBatis-Plus攔截器實(shí)現(xiàn)數(shù)據(jù)權(quán)限控制的示例
本文主要介紹了MyBatis-Plus攔截器實(shí)現(xiàn)數(shù)據(jù)權(quán)限控制的示例,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-02-02Java實(shí)現(xiàn)FTP文件與文件夾的上傳和下載
本文主要分享了Java實(shí)現(xiàn)文件上傳和下載的具體實(shí)例,分為單個(gè)文件的上傳與下載和整個(gè)文件夾的上傳與下載。具有很好的參考價(jià)值,需要的朋友一起來看下吧2016-12-12Spring框架JavaMailSender發(fā)送郵件工具類詳解
這篇文章主要為大家詳細(xì)介紹了Spring框架JavaMailSender發(fā)送郵件工具類,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2019-04-04Java連接sftp服務(wù)器實(shí)現(xiàn)上傳下載功能
這篇文章主要介紹了java連接sftp服務(wù)器實(shí)現(xiàn)上傳下載,本文給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2023-08-08IDEA中的yml文件與properties互相轉(zhuǎn)換
這篇文章主要介紹了IDEA中的yml文件與properties互相轉(zhuǎn)換方式,具有很好的參考價(jià)值,希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-10-10