java操作mongodb的代码，包含基本的增删改查操作
获取数据库连接工具类
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 使用注意事项
* @author liuchao
* @date 2013-12-30
* @note begin modify by 修改人 修改时间 修改内容摘要说明
*/
public class MongoDBUtil {
/**
*
* \brief 无需认证获取数据库连接
* @return
* @attention 方法的使用注意事项
* @author liuchao
* @date 2013-12-30
* @note begin modify by 修改人 修改时间 修改内容摘要说明
*/
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;
}
}
/**
*
获取需认证获取数据库连接
启动登录密码认证：
登录数据库，添加用户
use
db.addUser('user1','pwd1');
重启服务端开启认证服务
mongod --auth --dbpath=D:\mongodb\db
接下来登录就需要用户名密码认证了
启动客户端：
use admin;
//进行登陆验证，如果不通过，是没有操作权限的了。
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);//登陆验证，成功之后才能进行有效操作
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 使用注意事项
* @author liuchao
* @date 2013-12-30
* @note begin modify by 修改人 修改时间 修改内容摘要说明
*/
public class MognoDBCURDUtil {
/**
*
* \brief查询所有数据
*
* @attention 方法的使用注意事项
* @author liuchao
* @date 2013-12-30
* @note begin modify by 修改人 修改时间 修改内容摘要说明
*/
private static void queryAll(String collectionName) {
DBCollection users = MongoDBUtil
.getDBConnectionWithAuth(collectionName);
// db游标
DBCursor cur = users.find();
System.out.println("数据总条数:" + users.count());
while (cur.hasNext()) {
System.out.println(cur.next());
}
}
/**
*
* \brief 添加数据
*
* @param collectionName
* @attention 方法的使用注意事项
* @author liuchao
* @date 2013-12-30
* @note begin modify by 修改人 修改时间 修改内容摘要说明 save和insert的区别
* save函数实际就是根据参数条件,调用了insert或update函数.
* 如果想插入的数据对象存在,insert函数会报错,而save函数是改变原来的对象;
* 如果想插入的对象不存在,那么它们执行相同的插入操作. 这里可以用几个字来概括它们两的区别,即所谓"有则改之,无则加之".
*/
public static void add(String collectionName, List list) {
DBCollection users = MongoDBUtil
.getDBConnectionWithAuth(collectionName);
users.insert(list).getN();
}
/**
*
* \brief 更新
* @param collectionName
* @param sour