当前位置:  编程技术>java/j2ee

java操作mongodb实现CURD功能实例

    来源: 互联网  发布时间:2014-10-31

    本文导语:  先下载相应的驱动:官网上下载:http://central.maven.org/maven2/org/mongodb/mongo-java-driver/本文使用mongo-2.10.1.jar版本:下面有详细代码的,每个方法可以单独执行。其中为了方便运行,每个方法中都重新链接数据库,而没有再提出来,...

先下载相应的驱动:官网上下载: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());
          }

   
     }

   
}


    
 
 

您可能感兴趣的文章:

  • java Servlet获取和设置cookie实例代码
  • 万般火急!关于java打印,已经得到printerJob实例,那么怎么通过它得到Pageable实例?
  • 可以有其他两个类的实例同时调用一个java实例的两个方法吗?
  • <java技术手册>与<java实例技术手册>这两本书怎么样?
  • Java单例模式实例简述
  • 寻求java加密算法及实例
  • java web start实例代码COPY不了,怎么办?
  • 请问哪里有《java实例技术手册》的电子书下载?100分赠送!
  • 请教:JAVA中说什么类的实例,那是怎么样的一个概念呢?
  • java实现大数加法(BigDecimal)的实例代码
  • Java究竟能干些什么呢?清高手们列举一些实例出来,跟帖有分.
  • java HashMap的keyset实例
  • java获取当前日期使用实例
  • java之super关键字用法实例解析
  • Java调用DOS实现定时关机的实例
  • java结束进程的实例代码
  • 急!大家谁有类似visio的java实例或代码?
  • java 如何获取对象实例的大小
  • 高分火速求解,请在线朋友回答:java自定义类怎样生成实例数组?( className[] N=new className[X];怎么不行?)
  • 刚学java想试编一个文本编辑器,各位能不能给推荐一些较好的参考程序或实例
  • Java位运算和逻辑运算的区别实例
  • MongoDB的Java DAO生成器 GuiceyData
  • MongoDB Java Driver
  • MongoDB的Java开发框架 BuguMongo
  • java查询mongodb中的objectid示例
  • java操作mongodb基础(查询 排序 输出list)
  • MongoDB支持的java数据类型和测试例子
  • java操作mongodb示例分享
  •  
    本站(WWW.)旨在分享和传播互联网科技相关的资讯和技术,将尽最大努力为读者提供更好的信息聚合和浏览方式。
    本站(WWW.)站内文章除注明原创外,均为转载、整理或搜集自网络。欢迎任何形式的转载,转载请注明出处。












  • 相关文章推荐
  • java操作excel2007文档介绍及代码例子
  • java执行操作系统命令的问题:如何判断多个操作系统?
  • java初学者问:java操作平台是什么?用什么工具?
  • 我是java新手,请问java中与平台相关的操作是怎样实现的
  • Java的XML操作类库 JDOM
  • Java操作系统 JNode
  • Java 操作 Excel 的类库 jExcelApi
  • JAVA与数据库操作问题
  • 请问又没有java控制.exe或操作注册表的方法?
  • Java的Excel操作包 OpenXLS
  • Java和DLL(COM)互操作 Jawin
  • 寻求java对串口操作的帮助
  • 小弟有如下问题:JAVA中怎样实现对操作平台的句柄!谢谢了:)
  • java 对树的操作,TreeSet,能否插入相同的数据,如果相同,如何解决
  • java的操作平台是什么?用什么工具?
  • JAVA可以获得操作系统的临时目录的路径吗?
  • Java类文件操作库 Barista
  • Java程序中能否直接操作本地文件?
  • 在Java里,有没有直接对XML文件进行操作的函数?
  • java中判断本机操作系统的类和方法
  • 怎样用JAVA语言实现对串口的操作?
  • java命名空间java.sql类types的类成员方法: java_object定义及介绍
  • 我想学JAVA ,是买THINK IN JAVA 还是JAVA2核心技术:卷1 好???
  • java命名空间java.awt.datatransfer类dataflavor的类成员方法: imageflavor定义及介绍
  • 请问Java高手,Java的优势在那里??,Java主要适合于开发哪类应用程序
  • java命名空间java.lang.management类managementfactory的类成员方法: getcompilationmxbean定义及介绍
  • 如何将java.util.Date转化为java.sql.Date?数据库中Date类型对应于java的哪个Date呢
  • java命名空间java.lang.management接口runtimemxbean的类成员方法: getlibrarypath定义及介绍
  • 谁有电子版的《Java编程思想第二版(Thinking in java second)》和《Java2编程详解(special edition java2)》?得到给分
  • java命名空间java.lang.management接口runtimemxbean的类成员方法: getstarttime定义及介绍
  • 本人想学java,请问java程序员的待遇如何,和java主要有几个比较强的方向


  • 站内导航:


    特别声明:169IT网站部分信息来自互联网,如果侵犯您的权利,请及时告知,本站将立即删除!

    ©2012-2021,,E-mail:www_#163.com(请将#改为@)

    浙ICP备11055608号-3