dengwanchuan
- 浏览: 45449 次
- 性别:
- 来自: 武汉
-
文章分类
最新评论
-
zn100200：
从一到五我都配置成功了也能正常运行，很好，虽然还是有些不明白的 ...
Java中间件JMS(四)之ActiveMQ整合spring之类转换 -
dengwanchuan：
pansonphy 写道public class TopicP ...
Java中间件JMS(二)之ActiveMQ整合spring(一) -
pansonphy：
public class TopicPublisherServ ...
Java中间件JMS(二)之ActiveMQ整合spring(一) -
AallenXu：
我直接用您的代码，运行时发现报好多java.lang.NoSu ...
NoSQL之MongoDB的CRUD操作 -
dengwanchuan：
sun_2008 写道 4) 创建全局dblink这个你 ...
Database Link详解
MongoDB是一个基于分布式文件存储的数据库,是NoSQL实现的一种,支持Java.NoSQL越来越受到IT界的重视,所以掌握NoSQL技术,也非常重要。
在空闲时间写了Mongo的CRUD代码，请大家参考。有什么地方不好或意见,大家可以提出！
import java.lang.reflect.Field;
import java.lang.reflect.Method;
import java.util.ArrayList;
import java.util.List;
import net.sf.json.JSONObject;
import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBObject;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
import com.mongodb.util.JSON;
/**
*
* <b>功能：实现MongoDB的CRUD操作</b><br>
* <br>
* <b>完整路径：</b> .MongoUtil2 <br>
* <b>创建日期：</b> 2012-4-26 上午10:54:56 <br>
* @author <a href="mailto:dengwanchuan@shareinfo.com.cn">dwc</a><br>
* <a href="http://www.shareinfo.com.cn">Shenzhen Share Info System Co.,Ltd.</a>
* @version 1.0, 2012-4-26
*/
public class MongoDBUtil{
private static final String URL="localhost";//连接地址
private static final int PORT=27017;//连接端口
private static final String DB="test";//连接DB
private static Mongo mg = null;
private static DB db=null;
private DBCollection conn=null;
/**
*
* <b>功能：单例模式</b><br>
* <b>提示:在这里DB理解为数据库,DBCollection理解为表</b><br>
* <br>
* @修改者 ~ 邓万川, 2012-4-26
* @return DB
*/
private static synchronized DB getDb(){
try {
if(db==null){
mg = new Mongo(URL, PORT);
//获取 DB；如果默认没有创建，mongodb会自动创建
db = mg.getDB(DB);
}
} catch (Exception e) {
e.printStackTrace();
}
return db;
}
/**
*
* <b>功能：获取连接</b><br>
* <br>
* @修改者 ~dwc, 2012-4-26
* @param connName 表连接名称
* @return DBCollection 表连接对象
*/
public static DBCollection getConn(String connName){
getDb();
return db.getCollection(connName);
}
/**
*
* <b>功能：对象销毁，清除内存</b><br>
* <br>
* @修改者 ~ dwc 2012-4-26 void
*/
public void destory() {
if (mg != null)
mg.close();
mg = null;
db = null;
conn = null;
System.gc();
}
/**
*
* <b>功能：根据Mongo对象条件查询所有数据</b><br>
* <br>
* @修改者 ~ dwc, 2012-4-26
* @param dbObject Mongo条件对象
* @param connName 表连接名称
* @param className 获取对象的类名称
* @return
* @throws Exception List 返回集合
*/
public List findAll(DBObject dbObject,String connName,String className)throws Exception{
List<Object> resultList=new ArrayList<Object>();
try {
conn=getConn(connName);
List<DBObject> list = conn.find(dbObject).toArray();
for(DBObject dbObj:list){
Object obj= DB2Bean(dbObj,className);
resultList.add(obj);
}
} catch (Exception e) {
e.printStackTrace();
throw new Exception();
}finally{
destory();
}
return resultList;
}
/**
*
* <b>功能：根据自定义对象条件查询所有数据</b><br>
* <br>
* @修改者 ~ dwc, 2012-4-26
* @param object 定义条件对象
* @param connName 表连接名称
* @param className 获取对象的类名称
* @return
* @throws Exception List 返回集合
*/
public List findAll(Object object,String connName,String className)throws Exception{
List<Object> resultList=new ArrayList<Object>();
try {
conn=getConn(connName);
List<DBObject> list = conn.find(bean2DB(object)).toArray();
for(DBObject dbObj:list){
Object obj= DB2Bean(dbObj,className);
resultList.add(obj);
}
} catch (Exception e) {
e.printStackTrace();
throw new Exception();
}finally{
destory();
}
return resultList;
}
/**
*
* <b>功能：根据Mongo对象查询单个数据</b><br>
* <br>
* @修改者 ~ dwc, 2012-4-26
* @param dbObject Mongo条件对象
* @param connName 表连接名称
* @param className 获取对象的类名称
* @return
* @throws Exception Object 返回对象
*/
public Object findOne(DBObject dbObject,String connName,String className)throws Exception{
Object obj=null;
try {
conn=getConn(connName);
DBObject result = conn.findOne(dbObject);
obj=DB2Bean(dbObject, className);
} catch (Exception e) {
e.printStackTrace();
throw new Exception();
}finally{
destory();
}
return obj;
}
/**
*
* <b>功能：根据自定义对象查询单个数据</b><br>
* <br>
* @修改者 ~ dwc, 2012-4-26
* @param object 自定义条件对象
* @param connName 表连接名称
* @param className 获取对象的类名称
* @return
* @throws Exception Object 返回对象
*/
public Object findOne(Object object,String connName,String className)throws Exception{
Object obj=null;
try {
conn=getConn(connName);
DBObject result = conn.findOne(bean2DB(object));
obj=DB2Bean(result, className);
} catch (Exception e) {
e.printStackTrace();
}finally{
destory();
}
return obj;
}
/**
*
* <b>功能：根据条件id查询数据</b><br>
* <br>
* @修改者 ~ dwc, 2012-4-26
* @param id 条件id
* @param connName 表连接名称
* @param className 获取对象的类名称
* @return
* @throws Exception Object 返回对象
*/
public Object findOneById(Object id,String connName,String className)throws Exception{
Object obj=null;
try {
conn=getConn(connName);
DBObject dbObject = conn.findOne(new BasicDBObject("_id",id));
obj=DB2Bean(dbObject, className);
} catch (Exception e) {
e.printStackTrace();
throw new Exception();
}finally{
destory();
}
return obj;
}
/**
*
* <b>功能：增加数据</b><br>
* <br>
* @修改者 ~ dwc, 2012-4-26
* @param obj 要增加对象
* @param connName 表连接名称
* @return
* @throws Exception int 返回影响结果
*/
public int add(Object obj,String connName)throws Exception{
int result=-1;
try {
conn=getConn(connName);
DBObject dbObject= (DBObject) JSON.parse(JSONObject.fromObject(obj).toString());
result=conn.insert(dbObject).getN();
} catch (Exception e) {
e.printStackTrace();
throw new Exception();
}finally{
destory();
}
return result;
}
/**
*
* <b>功能：增加数据</b><br>
* <br>
* @修改者 ~ dwc, 2012-4-26
* @param dbObject 封装对象的数据
* @param connName 表连接名称
* @return
* @throws Exception int 返回影响结果
*/
public int add(DBObject dbObject,String connName)throws Exception{
int result=-1;
try {
conn=getConn(connName);
result=conn.insert(dbObject).getN();
} catch (Exception e) {
e.printStackTrace();
throw new Exception();
}finally{
destory();
}
return result;
}
/**
*
* <b>功能：修改数据</b><br>
* <br>
* @修改者 ~ dwc, 2012-4-26
* @param value 修改的数据
* @param where 修改条件
* @param connName 表连接名称
* @return
* @throws Exception int 返回影响结果
*/
public int update(DBObject value,DBObject where,String connName) throws Exception{
int result=-1;
try {
conn=getConn(connName);
result= conn.update(where, value).getN();
} catch (MongoException e) {
e.printStackTrace();
throw new Exception();
}finally{
destory();
}
return result;
}
/**
*
* <b>功能：修改数据</b><br>
* <br>
* @修改者 ~ dwc, 2012-4-26
* @param value 修改的数据
* @param where 修改条件
* @param connName 表连接名称
* @return
* @throws Exception int 返回影响结果
*/
public int update(Object value,Object where,String connName)throws Exception {
int result=-1;
try {
conn=getConn(connName);
result= conn.update(bean2DB(where),bean2DB(value)).getN();
} catch (MongoException e) {
e.printStackTrace();
throw new Exception();
}finally{
destory();
}
return result;
}
/**
*
* <b>功能：根据条件删除数据</b><br>
* <br>
* @修改者 ~ dwc, 2012-4-26
* @param obj 要删除的对象
* @param connName 表连接名称
* @return
* @throws Exception int 返回影响结果
*/
public int remove(Object obj,String connName) throws Exception{
int result=-1;
try {
conn=getConn(connName);
result= conn.remove(bean2DB(obj)).getN();
} catch (MongoException e) {
e.printStackTrace();
throw new Exception();
}finally{
destory();
}
return result;
}
/**
*
* <b>功能：根据条件删除数据</b><br>
* <br>
* @修改者 ~ dwc, 2012-4-26
* @param dbObject 要删除的数据
* @param connName 表连接名称
* @return
* @throws Exception int 返回影响结果
*/
public int remove(DBObject dbObject,String connName)throws Exception {
int result=-1;
try {
conn=getConn(connName);
result= conn.remove(dbObject).getN();
} catch (MongoException e) {
e.printStackTrace();
throw new Exception();
}finally{
destory();
}
return result;
}
/**
*
* <b>功能：根据条件得到数据总和</b><br>
* <br>
* @修改者 ~ dwc, 2012-4-26
* @param dbObject 条件对象
* @param connName 表连接名称
* @return
* @throws Exception int 返回影响结果
*/
public int getCount(DBObject dbObject,String connName)throws Exception{
int result=0;
try {
conn=getConn(connName);
result=conn.find(dbObject).count();
} catch (Exception e) {
e.printStackTrace();
throw new Exception();
}
return result;
}
/**
*
* <b>功能：根据条件得到数据总和</b><br>
* <br>
* @修改者 ~ dwc, 2012-4-26
* @param obj 条件对象
* @param connName 表连接名称
* @return
* @throws Exception int 返回影响结果
*/
public int getCount(Object obj,String connName)throws Exception{
int result=0;
try {
conn=getConn(connName);
result=conn.find(bean2DB(obj)).count();
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
/**
*
* <b>功能：将自定义对象转换为Mongo对象</b><br>
* <br>
* @修改者 ~ dwc, 2012-4-26
* @param obj 自定义对象
* @return DBObject Mongo对象
*/
public static DBObject bean2DB(Object obj)throws Exception{
DBObject dbObject=new BasicDBObject();
Class<? extends Object> clazz=obj.getClass();
Field [] fields=clazz.getDeclaredFields();
for(Field field:fields){
String fieldName=field.getName();
String methodName="get"+fieldName.substring(0,1).toUpperCase()+fieldName.substring(1,fieldName.length());
Method method=null;
Object resultObj=null;
try {
method=clazz.getMethod(methodName);
} catch (Exception e) {
e.printStackTrace();
continue;
}
try {
resultObj=method.invoke(obj);
} catch (Exception e) {
continue;
}
if(resultObj!=null&&!resultObj.equals("")){
dbObject.put(fieldName, resultObj);
}
}
return dbObject;
}
/**
*
* <b>功能：将Mongo对象转换为自定义对象</b><br>
* <br>
* @修改者 ~ 邓万川, 2012-4-26
* @param dbObject Mongo对象
* @param className 要转换的类名称
* @return
* @throws Exception Object
*/
public static Object DB2Bean(DBObject dbObject,String className) throws Exception{
Class clazz=Class.forName(className);
Object obj=clazz.newInstance();
Field [] fields=clazz.getDeclaredFields();
for(Field field:fields){
String fieldName=field.getName();
String methodName="set"+fieldName.substring(0,1).toUpperCase()+fieldName.substring(1,fieldName.length());
Method method=null;
Object resultObj=null;
try {
method=clazz.getMethod(methodName,new Class[]{field.getType()});
} catch (Exception e) {
e.printStackTrace();
continue;
}
resultObj=dbObject.get(fieldName);
try {
resultObj=method.invoke(obj,new Object[]{resultObj});
} catch (Exception e) {
continue;
}
}
return obj;
}
}
public class Student {
private Object _id;
private String name;
private String age;
public Object get_id() {
return _id;
}
public void set_id(Object_id) {
this._id = _id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getAge() {
return age;
}
public void setAge(String age) {
this.age = age;
}
}
import java.lang.reflect.Field;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;
import javax.swing.text.TabableView;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import org.bson.BSONObject;
import org.bson.types.ObjectId;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import com.mongodb.BasicDBObject;
import com.mongodb.Bytes;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
import com.mongodb.QueryOperators;
import com.mongodb.util.JSON;
/**
*
* <b>功能：MongoDB测试类</b><br>
* <br>
* <b>完整路径：</b> .MongoTest <br>
* <b>创建日期：</b> 2012-4-26 下午2:15:41 <br>
* @author <a href="mailto:dengwanchuan@shareinfo.com.cn">dwc</a><br>
* <a href="http://www.shareinfo.com.cn">Shenzhen Share Info System Co.,Ltd.</a>
* @version 1.0, 2012-4-26
*/
public class MongoDBTest{
MongoDBUtil mu=new MongoDBUtil();
@Test
public void find(){
//List<DBObject> list=queryAll(null, "student");
try {
Student stu=new Student();
List<Student> list=mu.findAll(stu,"student",Student.class.getName());
for (Student result : list) {
System.out.println("name="+result.getName());
System.out.println("age="+result.getAge());
System.out.println("========================");
}
} catch (Exception e) {
e.printStackTrace();
}
}
@Test
public void add() {
Student stu=new Student();
stu.setAge("24");
stu.setName("tom");
try {
mu.add(stu, "stu");
} catch (Exception e) {
e.printStackTrace();
}
}
@Test
public void update(){
try {
Student where=new Student();
where.setAge("22");
where.setName("tom");
Student value=(Student) mu.findOne(where, "stu", where.getClass().getName());
value.setAge("25");
value.setName("joke");
System.out.println(mu.update(value,where,"stu"));
} catch (Exception e) {
e.printStackTrace();
}
}
@Test
public void remove(){
try {
Student where=new Student();
where.setAge("25");
where.setName("joke");
mu.remove(where, "stu");
} catch (Exception e) {
e.printStackTrace();
}
}
}
- MongoDB.rar (408.8 KB)
- 下载次数: 41
分享到：
评论
7 楼
AallenXu
2013-06-09
我直接用您的代码，运行时发现报好多java.lang.NoSuchMethodException...如何解决啊？！！！ 不知道现在你还有时间帮助一下不？
6 楼
hyneng
2012-05-30
dengwanchuan 写道
hyneng 写道
再说一下我遇到的问题。
如果想按测试类MongoDBTest的add-->find-->update-->find-->remove这个流程跑进来，要注意几点。
1.find方法的表名得注意了，要不，添加进去后查看不到添加的数据，student->stu,
List<Student> list=mu.findAll(stu,"student",Student.class.getName());
2.update方法，如果按照where找不到对象，会出现空指针异常，所以 where.setAge("22"); 应改为 where.setAge("24"); 在此插一句，是不是应该处理这种情况下空针异常的问题
如果想按测试类MongoDBTest的add-->find-->update-->find-->remove这个流程跑进来，要注意几点。
1.find方法的表名得注意了，要不，添加进去后查看不到添加的数据，student->stu,
List<Student> list=mu.findAll(stu,"student",Student.class.getName());
2.update方法，如果按照where找不到对象，会出现空指针异常，所以 where.setAge("22"); 应改为 where.setAge("24"); 在此插一句，是不是应该处理这种情况下空针异常的问题
对不起，回复晚了，第二个问题，的确是要处理空指针异常.
写得挺好的
5 楼
dengwanchuan
2012-05-30
hyneng 写道
再说一下我遇到的问题。
如果想按测试类MongoDBTest的add-->find-->update-->find-->remove这个流程跑进来，要注意几点。
1.find方法的表名得注意了，要不，添加进去后查看不到添加的数据，student->stu,
List<Student> list=mu.findAll(stu,"student",Student.class.getName());
2.update方法，如果按照where找不到对象，会出现空指针异常，所以 where.setAge("22"); 应改为 where.setAge("24"); 在此插一句，是不是应该处理这种情况下空针异常的问题
如果想按测试类MongoDBTest的add-->find-->update-->find-->remove这个流程跑进来，要注意几点。
1.find方法的表名得注意了，要不，添加进去后查看不到添加的数据，student->stu,
List<Student> list=mu.findAll(stu,"student",Student.class.getName());
2.update方法，如果按照where找不到对象，会出现空指针异常，所以 where.setAge("22"); 应改为 where.setAge("24"); 在此插一句，是不是应该处理这种情况下空针异常的问题
对不起，回复晚了，第二个问题，的确是要处理空指针异常.
4 楼
steafler
2012-05-10
灰常不错呀
3 楼
hyneng
2012-05-05
再说一下我遇到的问题。
如果想按测试类MongoDBTest的add-->find-->update-->find-->remove这个流程跑进来，要注意几点。
1.find方法的表名得注意了，要不，添加进去后查看不到添加的数据，student->stu,
List<Student> list=mu.findAll(stu,"student",Student.class.getName());
2.update方法，如果按照where找不到对象，会出现空指针异常，所以 where.setAge("22"); 应改为 where.setAge("24"); 在此插一句，是不是应该处理这种情况下空针异常的问题
如果想按测试类MongoDBTest的add-->find-->update-->find-->remove这个流程跑进来，要注意几点。
1.find方法的表名得注意了，要不，添加进去后查看不到添加的数据，student->stu,
List<Student> list=mu.findAll(stu,"student",Student.class.getName());
2.update方法，如果按照where找不到对象，会出现空指针异常，所以 where.setAge("22"); 应改为 where.setAge("24"); 在此插一句，是不是应该处理这种情况下空针异常的问题
2 楼
hyneng
2012-05-05
还有加以下包：
ezmorph-1.0.2.jar
commons-beanutils-1.7.0.jar
commons-collections-3.2.jar
commons-lang-2.0.jar
commons-logging-1.0.4.jar
ezmorph-1.0.2.jar
commons-beanutils-1.7.0.jar
commons-collections-3.2.jar
commons-lang-2.0.jar
commons-logging-1.0.4.jar
1 楼
hyneng
2012-05-04
赞一个发表评论
相关推荐
Nosql非关系型数据库
我想用NoSQL数据库练习编程，这就是为什么我选择mongoDB的原因，这很容易学习。 我使用了漂亮的代码为代码提供了模式。 我与docker合作为数据库创建了容器。 建于 安装 克隆仓库git clone ...
使用Node.js，Express和Mongodb进行CRUD
RESTful API-NoSQL MongoDB 推介会： 后端项目：以下使用堆栈的NodeJS，规范与Eslint和更漂亮的代码MVC概念的RESTful API。 主要软件包： Express负责创建路由，Middleware JWT负责令牌的30分钟持久性，维护用户的...
这篇文章就是展示如何使用Java基于MongoDB和Spring Data创建一个CRUD应用。 Spring Data for MongoDB提供了一个类似于基于Sping编程模型的NoSQL数据存储。Spring Data for MongoDB提供了很多特性，它使很多MongoDB的...
直接调用方法就可以轻松的实现CRUD操作 NoSQL数据库与传统的关系型数据库相比 它具有操作简单 完全免费 源码公开 随时下载等特点 并可以用于各种商业目的 这使NoSQL产品广泛应用于各种大型门户网站和专业网站 大大...
这个NoSQL应用程序向用户提供完整的CRUD操作，并显示图表和图形以传达用户上周的锻炼数据。 链接到应用程序： : 目录 学分 使用的第三方资产：MongoDB，Mongoose.js，Express.js，Heroku 执照 麻省理工学院许可证...
CRUD JAVA + MONGODB NESTE PROJETO USEI： MONGODB版本4.4.3 IDE JAVAEclipseAPACHE MAVEN DE POIS DE INICIAR O BANCO DE DADOS ESCOLA QUE ACOMPANHA一个意大利面食项目，没有ELEESTARÁPRONTO PAARA O ESTUDO ...
第5章 执行CRUD操作 84 5.1 创建记录 84 5.1.1 在以文档为中心的数据库中创建记录 85 5.1.2 面向列数据库的创建操作 91 5.1.3 键/值映射表的创建操作 93 5.2 访问数据 96 5.2.1 用MongoDB访问文档 96 5.2.2 ...
成功进入交互式外壳后，尝试以下操作： 内容 创造 建立资料库 要创建数据库，请输入命令use db_name ，其中db_name是要创建的数据库的名称。 此命令还用于在数据库之间切换 例如：- use cars 列出数据库 要查看...
使用Mongoose和Mocha在MongoDb中进行CRUD测试 功能标签 粗鲁的 摩卡咖啡 猫鼬 模板 直接祖先 要求 安装 yarn 运行测试 yarn test 作者 -醒目的 灵感 执照 根据。
MongoDb，NoSql被用作数据库。 将MySQL中使用的db Student1.sql导入mongoDb并使用。 通过JPA完成了CRUD工作。 使用的技术 红色：有关存储源代码，文档等和分发服务器的空间的信息。 蓝色：前端区域。 绿色：...
使用NodeJS，Experss，MongoDB的CRUD API 关于 此存储库适用于想要提供完整API服务的NodeJS初学者。 此仓库具有良好的文件夹结构。 Joi用于验证传入的数据。 用于加密密码的护照。 先决条件 以下是启动和运行此api所...
Mongo DB ,是目前在IT行业非常流行的一种非关系型数据库(NoSql),其灵活的数据存储方式,备受当前IT...Mongo DB最大的优势在于所有的数据持久操作都无需开发人员手动编写SQL语句,直接调用方法就可以轻松的实现CRUD操作。
编程语言： JavaScript NodeJS v11.10.1 集成开发环境（IDE）： Visual Studio代码（ ） Web应用程序服务器： 表达数据库： MongoDB（NoSQL）使用MongoDB的Crud NodeJS （第二部分-带Mongo DB的Crud NodeJS） Versi...
有几个微服务通过NoSQL（MongoDB，Redis）和关系数据库（Sql Server）在Product，Basket和Ordering微服务上实现了电子商务模块，并通过RabbitMQ事件驱动通信和Ocelot API Gateway进行了通信。 此存储库中包括什么 ...
创建读取更新删除（API） API CRUD dengan menggunakan NodeJS（ExpressJS）和MongoDB sebagai数据库NoSQL用于创建网站的工具必须安装的工具项目安装安装NPM npm install安装验证npm i fastest-validator安装DotEnv ...
Mongo DB 是目前在IT行业非常流行的一种非关系型数据库(NoSql),其灵活的数据存储方式备受当前IT...Mongo DB最大的优势在于所有的数据持久操作都无需开发人员手动编写SQL语句,直接调用方法就可以轻松的实现CRUD操作。
Mongo DB最大的优势在于所有的数据持久操作都无需开发人员手动编写SQL语句,直接调用方法就可以轻松的实现CRUD操作。 windows 安装 这里我说的是命令行安装方法 准备.到官网下载相应的版本 https://www.mongodb.org/ ...