java mongodb 增删改查_java操作mongodb：基本的增删改查
java操作mongodb的代碼，包含基本的增刪改查操作 獲取數(shù)據(jù)庫連接工具類 package com.liuc.db;import java.net.UnknownHostException;import com.mongodb.DB;import com.mongodb.DBCollection;import com.mongodb.Mongo;/** * * @brief MongoDBUtil.java 操作
java操作mongodb的代碼，包含基本的增刪改查操作
獲取數(shù)據(jù)庫連接工具類
package com.liuc.db;
import java.net.UnknownHostException;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.Mongo;
/**
*
* @brief MongoDBUtil.java 操作mongodb工具類
* @attention 使用注意事項(xiàng)
* @author liuchao
* @date 2013-12-30
* @note begin modify by 修改人 修改時(shí)間 修改內(nèi)容摘要說明
*/
public class MongoDBUtil {
/**
*
* \brief 無需認(rèn)證獲取數(shù)據(jù)庫連接
* @return
* @attention 方法的使用注意事項(xiàng)
* @author liuchao
* @date 2013-12-30
* @note begin modify by 修改人 修改時(shí)間 修改內(nèi)容摘要說明
*/
public static DBCollection getDBConnectionWithoutAuth(String colName){
try {
Mongo mongo = new Mongo("localhost", 27017);
DB db = mongo.getDB("liuchao");
return db.getCollection(colName);
} catch (UnknownHostException e) {
e.printStackTrace();
return null;
}
}
/**
*
獲取需認(rèn)證獲取數(shù)據(jù)庫連接
啟動(dòng)登錄密碼認(rèn)證：
登錄數(shù)據(jù)庫，添加用戶
use
db.addUser('user1','pwd1');
重啟服務(wù)端開啟認(rèn)證服務(wù)
mongod --auth --dbpath=D:\mongodb\db
接下來登錄就需要用戶名密碼認(rèn)證了
啟動(dòng)客戶端：
use admin;
//進(jìn)行登陸驗(yàn)證，如果不通過，是沒有操作權(quán)限的了。
db.auth('user1','pwd1');
*/
public static DBCollection getDBConnectionWithAuth(String colName){
try {
Mongo mongo = new Mongo("localhost", 27017);
DB db = mongo.getDB("liuchao");
char[] pwd_char = "liuchao".toCharArray();
boolean auth = db.authenticate("liuchao",pwd_char);//登陸驗(yàn)證，成功之后才能進(jìn)行有效操作
if(!auth){
throw new RuntimeException();
}
return db.getCollection(colName);
} catch (UnknownHostException e) {
e.printStackTrace();
return null;
}
}
public static void main(String[] args) {
System.out.println(getDBConnectionWithAuth("users"));
System.out.println(getDBConnectionWithoutAuth("users"));
}
}
基本增刪改查操作類：
package com.liuc.db;
import java.util.ArrayList;
import java.util.List;
import com.mongodb.BasicDBObject;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
/**
*
* @brief MognoDBCURDUtil.java 增刪改查工具類
* @attention 使用注意事項(xiàng)
* @author liuchao
* @date 2013-12-30
* @note begin modify by 修改人 修改時(shí)間 修改內(nèi)容摘要說明
*/
public class MognoDBCURDUtil {
/**
*
* \brief查詢所有數(shù)據(jù)
*
* @attention 方法的使用注意事項(xiàng)
* @author liuchao
* @date 2013-12-30
* @note begin modify by 修改人 修改時(shí)間 修改內(nèi)容摘要說明
*/
private static void queryAll(String collectionName) {
DBCollection users = MongoDBUtil
.getDBConnectionWithAuth(collectionName);
// db游標(biāo)
DBCursor cur = users.find();
System.out.println("數(shù)據(jù)總條數(shù):" + users.count());
while (cur.hasNext()) {
System.out.println(cur.next());
}
}
/**
*
* \brief 添加數(shù)據(jù)
*
* @param collectionName
* @attention 方法的使用注意事項(xiàng)
* @author liuchao
* @date 2013-12-30
* @note begin modify by 修改人 修改時(shí)間 修改內(nèi)容摘要說明 save和insert的區(qū)別
* save函數(shù)實(shí)際就是根據(jù)參數(shù)條件,調(diào)用了insert或update函數(shù).
* 如果想插入的數(shù)據(jù)對(duì)象存在,insert函數(shù)會(huì)報(bào)錯(cuò),而save函數(shù)是改變?cè)瓉淼膶?duì)象;
* 如果想插入的對(duì)象不存在,那么它們執(zhí)行相同的插入操作. 這里可以用幾個(gè)字來概括它們兩的區(qū)別,即所謂"有則改之,無則加之".
*/
public static void add(String collectionName, Listlist) {
DBCollection users = MongoDBUtil
.getDBConnectionWithAuth(collectionName);
users.insert(list).getN();
}
/**
*
* \brief 更新
* @param collectionName
* @param source
* @param target
* @attention 方法的使用注意事項(xiàng)
* @author liuchao
* @date 2013-12-30
* @note begin modify by 修改人 修改時(shí)間 修改內(nèi)容摘要說明
*/
public static void update(String collectionName, DBObject source,
DBObject target) {
DBCollection users = MongoDBUtil
.getDBConnectionWithAuth(collectionName);
/**
* true,//如果數(shù)據(jù)庫不存在，是否添加
false//多條修改
*/
users.update(source, target, true, false);
}
/**
*
* \brief 刪除
* @param collectionName
* @param obj
* @attention 方法的使用注意事項(xiàng)
* @author liuchao
* @date 2013-12-30
* @note begin modify by 修改人 修改時(shí)間 修改內(nèi)容摘要說明
*/
public static void delete(String collectionName, DBObject delObj) {
DBCollection users = MongoDBUtil
.getDBConnectionWithAuth(collectionName);
users.remove(delObj);
//print("remove age >= 24: " + users.remove(new BasicDBObject("age", new BasicDBObject("$gte", 24))).getN());
}
/**
*
* \brief 帶條件查詢
* @param collectionName
* @param delObj
* @attention 方法的使用注意事項(xiàng)
* @author liuchao
* @date 2013-12-30
* @note begin modify by 修改人 修改時(shí)間 修改內(nèi)容摘要說明
*/
public static void queryWithCondition(String collectionName, DBObject condition) {
DBCollection users = MongoDBUtil
.getDBConnectionWithAuth(collectionName);
//users.find(new BasicDBObject("_id", new ObjectId("4de73f7acd812d61b4626a77"))).toArray()
users.find(condition);
}
}
代碼下載：http://download.csdn.net/detail/shanhuhau/6788957
本文原創(chuàng)發(fā)布php中文網(wǎng)，轉(zhuǎn)載請(qǐng)注明出處，感謝您的尊重！
總結(jié)
以上是生活随笔為你收集整理的java mongodb 增删改查_java操作mongodb：基本的增删改查的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 微信小程序支付java视频_【原创】微信
- 下一篇： java 圆的交点_java计算两条线段