java操作mongodb实现CURD功能实例_java

先下载相应的驱动:官网上下载:http://central.maven.org/maven2/org/mongodb/mongo-java-driver/
本文使用mongo-2.10.1.jar版本:

下面有详细代码的,每个方法可以单独执行。其中为了方便运行,每个方法中都重新链接数据库,而没有再提出来,因为在此的目的是为了认识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;

/**
* 对基本实体的存储测试
* @author lhy
*
*/
public class EntityTest {

     public static void main(String[] args) throws Exception{
          delete();
     }

     /**
     * 保存实体对象
     * @throws Exception
     */
     public static void saveEntity() throws Exception{
          //第一:实例化mongo对象,连接mongodb服务器  包含所有的数据库

          //默认构造方法,默认是连接本机,端口号,默认是27017
          //相当于Mongo mongo =new Mongo("localhost",27017)
          Mongo mongo =new Mongo();

          //第二:连接具体的数据库
          //其中参数是具体数据库的名称,若服务器中不存在,会自动创建
          DB db=mongo.getDB("myMongo");

          //第三:操作具体的表
         //在mongodb中没有表的概念,而是指集合
          //其中参数是数据库中表,若不存在,会自动创建
          DBCollection collection=db.getCollection("user");

          //添加操作
          //在mongodb中没有行的概念,而是指文档
          BasicDBObject document=new BasicDBObject();

          document.put("id", 1);
          document.put("name", "小明");
//          //然后保存到集合中
//     //     collection.insert(document);

        
          //当然我也可以保存这样的json串
/*          {
               "id":1,
               "name","小明",
               "address":
               {
               "city":"beijing",
               "code":"065000"
               }
          }*/
          //实现上述json串思路如下:
          //第一种:类似xml时,不断添加
          BasicDBObject addressDocument=new BasicDBObject();
          addressDocument.put("city", "beijing");
          addressDocument.put("code", "065000");
          document.put("address", addressDocument);
          //然后保存数据库中
          collection.insert(document);

          //第二种:直接把json存到数据库中
/*          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{
          //第一:实例化mongo对象,连接mongodb服务器  包含所有的数据库

          //默认构造方法,默认是连接本机,端口号,默认是27017
          //相当于Mongo mongo =new Mongo("localhost",27017)
          Mongo mongo =new Mongo();

          //第二:连接具体的数据库
          //其中参数是具体数据库的名称,若服务器中不存在,会自动创建
          DB db=mongo.getDB("myMongo");

          //第三:操作具体的表
         //在mongodb中没有表的概念,而是指集合
          //其中参数是数据库中表,若不存在,会自动创建
          DBCollection collection=db.getCollection("user");

          //查询操作
          //查询所有
          //其中类似access数据库中游标概念
          DBCursor cursor=collection.find();
          System.out.println("mongodb中的user表结果如下:");
          while(cursor.hasNext()){
               System.out.println(cursor.next());
          }
     }

     /**
     * 根据条件查询
     * @throws Exception
     */
     public static void selectPart() throws Exception{
          //第一:实例化mongo对象,连接mongodb服务器  包含所有的数据库

          //默认构造方法,默认是连接本机,端口号,默认是27017
          //相当于Mongo mongo =new Mongo("localhost",27017)
          Mongo mongo =new Mongo();

          //第二:连接具体的数据库
          //其中参数是具体数据库的名称,若服务器中不存在,会自动创建
          DB db=mongo.getDB("myMongo");

          //第三:操作具体的表
         //在mongodb中没有表的概念,而是指集合
          //其中参数是数据库中表,若不存在,会自动创建
          DBCollection collection=db.getCollection("user");

   
          //可以直接put
          BasicDBObject queryObject=new BasicDBObject();
          queryObject.put("id", 1);
          DBCursor querycursor=collection.find(queryObject);
          System.out.println("条件查询如下:");
          while(querycursor.hasNext()){
               System.out.println(querycursor.next());
          }
     }

     /**
     * 更新操作
     * 更新一条记录
     * @throws Exception
     */
     public static void update()throws Exception{
          //第一:实例化mongo对象,连接mongodb服务器  包含所有的数据库

          //默认构造方法,默认是连接本机,端口号,默认是27017
          //相当于Mongo mongo =new Mongo("localhost",27017)
          Mongo mongo =new Mongo();

          //第二:连接具体的数据库
          //其中参数是具体数据库的名称,若服务器中不存在,会自动创建
          DB db=mongo.getDB("myMongo");

          //第三:操作具体的表
         //在mongodb中没有表的概念,而是指集合
          //其中参数是数据库中表,若不存在,会自动创建
          DBCollection collection=db.getCollection("user");

          //更新后的对象
//          第一种更新方式
          BasicDBObject newBasicDBObject =new BasicDBObject();
          newBasicDBObject.put("id", 2);
          newBasicDBObject.put("name", "小红");
          collection.update(new BasicDBObject().append("id", 1),newBasicDBObject);

//          第二种更新方式
//          更新某一个字段
//          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("更新后结果如下:");
          while(querycursor1.hasNext()){
               System.out.println(querycursor1.next());
          }
     }

     /**
     * 删除文档,其中包括删除全部或删除部分
     * @throws Exception
     */
     public static void delete() throws Exception{

          //第一:实例化mongo对象,连接mongodb服务器  包含所有的数据库

          //默认构造方法,默认是连接本机,端口号,默认是27017
          //相当于Mongo mongo =new Mongo("localhost",27017)
          Mongo mongo =new Mongo();

          //第二:连接具体的数据库
          //其中参数是具体数据库的名称,若服务器中不存在,会自动创建
          DB db=mongo.getDB("myMongo");

          //第三:操作具体的表
         //在mongodb中没有表的概念,而是指集合
          //其中参数是数据库中表,若不存在,会自动创建
          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("删除后的结果如下:");
          while(cursor1.hasNext()){
               System.out.println(cursor1.next());
          }

   
     }

   
}

时间: 2024-10-28 10:08:30

java操作mongodb实现CURD功能实例_java的相关文章

Java操作MongoDB模糊查询和分页查询_java

本文实例为大家分享了Java操作MongoDB模糊查询和分页查询,供大家参考,具体内容如下 模糊查询条件: 1.完全匹配 Pattern pattern = Pattern.compile("^name$", Pattern.CASE_INSENSITIVE); 2.右匹配 Pattern pattern = Pattern.compile("^.*name$", Pattern.CASE_INSENSITIVE); 3.左匹配 Pattern pattern =

java操作mongodb时,对象bean和DBObject相互转换的方法(推荐)_java

如下所示: package com.iqbon.spider.util; import java.lang.reflect.Field; import java.lang.reflect.InvocationTargetException; import java.util.Date; import org.apache.commons.beanutils.BeanUtils; import com.mongodb.BasicDBObject; import com.mongodb.DBObje

Java操作MongoDB进行增删改查实例教程

现在我们就用Java来操作MongoDB的数据. 一.准备工作 1. 首先,下载mongoDB对Java支持的驱动包 驱动包下载地址:https://github.com/mongodb/mongo-java-driver/downloads mongoDB对Java的相关支持.技术:http://www.mongodb.org/display/DOCS/Java+Language+Center 驱动源码下载:https://download.github.com/mongodb-mongo-j

【MongoDB for Java】Java操作MongoDB数据库_MongoDB

本篇文章主要介绍Java操作MongoDB. 开发环境: System:Windows IDE:eclipse.MyEclipse 8 Database:mongoDB 开发依赖库: JavaEE5.mongo-2.5.3.jar.junit-4.8.2.jar   一.准备工作 1. 首先,下载mongoDB对Java支持的驱动包 驱动包下载地址:http://www.jb51.net/softs/41751.html mongoDB对Java的相关支持.技术:http://www.mongo

java操作mongoDB实现按两个字段排序的问题

问题描述 java操作mongoDB实现按两个字段排序的问题 java操作mongoDB,想通过先按照某一字段排序,在该字段中有相同值时按照另一字段排序,怎么实现? db.adult.find().sort({age:1label1})是直接操作mongoDB的代码 解决方案 .sort(fields) Order by the given fields. There are several equivalent syntaxes:.sort({field1: -1 field2: 1}) de

java操作mongoDB的时候出错

问题描述 java操作mongoDB的时候出错 com.mongodb.MongoTimeoutException: Timed out after 30000 ms while waiting for a server that matches WritableServerSelector. Client view of cluster state is {type=UNKNOWN, servers=[{address=localhost:27017, type=UNKNOWN, state=

【MongoDB for Java】Java操作MongoDB

开发环境: System:Windows IDE:eclipse.MyEclipse 8 Database:mongoDB 开发依赖库: JavaEE5.mongo-2.5.3.jar.junit-4.8.2.jar 一.准备工作 1. 首先,下载mongoDB对Java支持的驱动包 驱动包下载地址:https://github.com/mongodb/mongo-java-driver/downloads mongoDB对Java的相关支持.技术:http://www.mongodb.org/

MongoDB系列教程(六):java操作mongodb实例_MongoDB

java操作mysql数据库的代码我们已经了如指掌了,增删改查,java对mongodb数据库也是类似的操作,先是数据库连接,再是进行操作. 首先我们进入进入admin数据库,然后建立自己的数据库testMongoDb,进入admin数据库后,就可以直接进入testMongoDb,因为用户可以进入系统的数据库,就是超级管理员,use testMongoDb后,为该数据库设置用户名和密码,db.addUser('root','root'),这样我们在程序中连该数据库,并实现增删改查,代码如下所示.

Java操作MongoDB数据库示例分享_MongoDB

MongoDB是一个文档型数据库,是NOSQL家族中最重要的成员之一,以下代码封装了MongoDB的基本操作. MongoDBConfig.java package com.posoftframework.mongodb; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.util.Enumeration; import java.util.HashMap; i