java操作mongoDB数据库的简单实例

首先导入mongoDB的jar包 http://pan.baidu.com/s/1bnGMJRD

//DataBase.java

package com.mongodb.test;

import java.net.UnknownHostException;

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.util.JSON;

public class DataBase { 
 public static void main(String[] args) 
  throws UnknownHostException, MongoException { 
  //1.建立一个Mongo的数据库连接对象 
  Mongo mg = new Mongo("127.0.0.1:27017"); 
        //查询所有的Database 
        for (String name : mg.getDatabaseNames()) { 
            System.out.println("dbName: " + name); 
        } 
        //2.创建相关数据库的连接 
        DB db = mg.getDB("foobar"); 
        //查询数据库所有的集合 
        for (String name : db.getCollectionNames()) { 
            System.out.println("collectionName: " + name); 
        } 
        
        DBCollection users = db.getCollection("persons"); 
        //查询所有的数据 
        DBCursor cur = users.find(); 
        while (cur.hasNext()) { 
         DBObject object = cur.next(); 
         System.out.println(object.get("name")); 
        } 
        System.out.println(cur.count()); 
        System.out.println(cur.getCursorId()); 
        System.out.println(JSON.serialize(cur)); 
    } 
} 
//MongoDb.java

package com.mongodb.test;

import java.net.UnknownHostException; 
import java.util.List;

import org.bson.types.ObjectId;

import com.mongodb.BasicDBObject; 
import com.mongodb.DB; 
import com.mongodb.DBCollection; 
import com.mongodb.DBCursor; 
import com.mongodb.DBObject; 
import com.mongodb.Mongo; 
import com.mongodb.MongoException;

public class MongoDb { 
 //1.建立一个Mongo的数据库连接对象 
 static Mongo connection = null; 
 //2.创建相关数据库的连接 
 static DB db = null; 
 public MongoDb(String dbName) throws UnknownHostException, MongoException{ 
  connection = new Mongo("127.0.0.1:27017"); 
  db = connection.getDB(dbName); 
 } 
 public static void main(String[] args) throws UnknownHostException, MongoException { 
  //实例化 
  MongoDb mongoDb = new MongoDb("foobar"); 
     /** 
      * 1.创建一个名字叫javadb的数据库 
      */ 
//  mongoDb.createCollection("javadb"); 
  /** 
   * 2.为集合javadb添加一条数据 
   */ 
//  DBObject dbs = new BasicDBObject(); 
//  dbs.put("name", "uspcat.com"); 
//  dbs.put("age", 2); 
//  List<String>  books = new ArrayList<String>(); 
//  books.add("EXTJS"); 
//  books.add("MONGODB"); 
//  dbs.put("books", books); 
//  mongoDb.insert(dbs, "javadb"); 
  /** 
   * 3.批量插入数据 
   */ 
//  List<DBObject> dbObjects = new ArrayList<DBObject>(); 
//  DBObject jim = new BasicDBObject("name","jim"); 
//  DBObject lisi = new BasicDBObject("name","lisi"); 
//  dbObjects.add(jim); 
//  dbObjects.add(lisi); 
//  mongoDb.insertBatch(dbObjects, "javadb"); 
  /** 
   * 4.根据ID删除数据 
   */ 
//  mongoDb.deleteById("502870dab9c368bf5b151a04", "javadb"); 
  /** 
   * 5.根据条件删除数据 
   */ 
//  DBObject lisi = new BasicDBObject(); 
//  lisi.put("name", "lisi"); 
//  int count = mongoDb.deleteByDbs(lisi, "javadb"); 
//  System.out.println("删除数据的条数是: "+count); 
  /** 
   * 6.更新操作,为集合增加email属性 
   */ 
//  DBObject update = new BasicDBObject(); 
//  update.put("$set", 
//    new BasicDBObject("eamil","test @126.com")); 
//  mongoDb.update(new BasicDBObject(), 
//    update,false,true,"javadb"); 
  /** 
   * 7.查询出persons集合中的name和age 
   */ 
//  DBObject keys = new BasicDBObject(); 
//  keys.put("_id", false); 
//  keys.put("name", true); 
//  keys.put("age", true); 
//  DBCursor cursor = mongoDb.find(null, keys, "persons"); 
//     while (cursor.hasNext()) { 
//      DBObject object = cursor.next(); 
//      System.out.println(object.get("name")); 
//     } 
     /** 
      * 7.查询出年龄大于26岁并且英语成绩小于80分 
      */ 
//  DBObject ref = new BasicDBObject(); 
//  ref.put("age", new BasicDBObject("$gte",26)); 
//  ref.put("e", new BasicDBObject("$lte",80)); 
//  DBCursor cursor = mongoDb.find(ref, null, "persons"); 
//     while (cursor.hasNext()) { 
//      DBObject object = cursor.next(); 
//      System.out.print(object.get("name")+"-->"); 
//      System.out.print(object.get("age")+"-->"); 
//      System.out.println(object.get("e")); 
//     } 
  /** 
   * 8.分页例子 
   */ 
  DBCursor cursor = mongoDb.find(null, null, 0, 3, "persons"); 
     while (cursor.hasNext()) { 
      DBObject object = cursor.next(); 
      System.out.print(object.get("name")+"-->"); 
      System.out.print(object.get("age")+"-->"); 
      System.out.println(object.get("e")); 
     }   
  //关闭连接对象 
  connection.close(); 
 } 
 /** 
  * 穿件一个数据库集合 
  * @param collName 集合名称 
  * @param db  数据库实例 
  */ 
 public void createCollection(String collName){ 
  DBObject dbs = new BasicDBObject(); 
  db.createCollection("javadb", dbs); 
 } 
 /** 
  * 为相应的集合添加数据 
  * @param dbs 
  * @param collName 
  */ 
 public void insert(DBObject dbs,String collName){ 
  //1.得到集合 
  DBCollection coll = db.getCollection(collName); 
  //2.插入操作 
  coll.insert(dbs); 
 } 
 /** 
  * 为集合批量插入数据 
  * @param dbses 
  * @param collName 
  */ 
 public void insertBatch(List<DBObject> dbses,String collName){ 
  //1.得到集合 
  DBCollection coll = db.getCollection(collName); 
  //2.插入操作 
  coll.insert(dbses); 
 } 
 /** 
  * 根据id删除数据 
  * @param id 
  * @param collName 
  * @return 返回影响的数据条数 
  */ 
 public int deleteById(String id,String collName){ 
  //1.得到集合 
  DBCollection coll = db.getCollection(collName); 
  DBObject dbs = new BasicDBObject("_id", new ObjectId(id)); 
  int count = coll.remove(dbs).getN(); 
  return count; 
 } 
 /** 
  * 根据条件删除数据 
  * @param id 
  * @param collName 
  * @return 返回影响的数据条数 
  */  
 public int deleteByDbs(DBObject dbs,String collName){ 
  //1.得到集合 
  DBCollection coll = db.getCollection(collName); 
  int count = coll.remove(dbs).getN(); 
  return count; 
 } 
 /** 
  * 更新数据 
  * @param find 查询器 
  * @param update 更新器 
  * @param upsert 更新或插入 
  * @param multi 是否批量更新 
  * @param collName 集合名称 
  * @return 返回影响的数据条数 
  */ 
 public int update(DBObject find, 
      DBObject update, 
      boolean upsert, 
      boolean multi, 
      String collName){ 
  //1.得到集合 
  DBCollection coll = db.getCollection(collName); 
  int count = coll.update(find, update, upsert, multi).getN(); 
  return count; 
 } 
 /** 
  * 查询器(分页) 
  * @param ref 
  * @param keys 
  * @param start 
  * @param limit 
  * @return 
  */ 
 public DBCursor find(DBObject ref, 
   DBObject keys, 
   int start, 
   int limit, 
   String collName){ 
  DBCursor cur = find(ref, keys, collName); 
  return cur.limit(limit).skip(start); 
 } 
 /** 
  * 查询器(不分页) 
  * @param ref 
  * @param keys 
  * @param start 
  * @param limit 
  * @param collName 
  * @return 
  */ 
 public DBCursor find(DBObject ref, 
   DBObject keys, 
   String collName){ 
  //1.得到集合 
  DBCollection coll = db.getCollection(collName); 
  DBCursor cur = coll.find(ref, keys); 
  return cur; 
 }  
}

时间： 2024-12-28 20:22:52

java操作mongoDB数据库的简单实例的相关文章

java操作MongoDB数据库

1.如何启动MongoDB数据库? 如图所示:安装好MongoDB之后,文件夹显示如下: MongoDB默认开启27017端口,打开浏览器,输入http://localhost:27017/,显示如下: 启动数据库步骤: (1)cd d:\beiyongkaifa\mongodb\bin (2)输入:mongod --dbpath=D:\beiyongkaifa\mongodb\db,回车.如图1所示: (3)启动另一个cmd,cd d:\beiyongkaifa\mongodb\bin (4)

不使用spring的情况下原生java代码两种方式操作mongodb数据库

由于更改了mongodb3.0数据库的密码,导致这几天storm组对数据进行处理的时候,一直在报mongodb数据库连接不上的异常.   主要原因实际上是和mongodb本身无关的,因为他们改的是配置文件的密码,而实际上这个密码在代码中根本就没有使用,他们在代码中已经把用户验证信息写死.   在协助他们解决这个问题的时候,我看到他们代码中在和mongodb数据库交互时使用了已经不被建议使用的方法,于是便抽时间尝试了一下另一种被建议的方式实现各功能.   当然了,生产环境中用的是mongodb集群

Java连接MySQL数据库及简单操作代码

1.Java连接MySQL数据库 Java连接MySql需要下载JDBC驱动MySQL-connector-java-5.0.5.zip(举例,现有新版本).然后将其解压缩到任一目录.我是解压到D盘,然后将其目录下的MySQL-connector-java-5.0.5-bin.jar加到classpath里,具体如下: "我的电脑"-> "属性" -> "高级" -> "环境变量",在系统变量那里编辑clas

不使用spring的情况下用java原生代码操作mongodb数据库的两种方式

由于更改了mongodb3.0数据库的密码,导致这几天storm组对数据进行处理的时候,一直在报mongodb数据库连接不上的异常.   主要原因实际上是和mongodb本身无关的,因为他们改的是配置文件的密码,而实际上这个密码在代码中根本就没有使用,他们在代码中已经把用户验证信息写死.   在协助他们解决这个问题的时候,我看到他们代码中在和mongodb数据库交互时使用了已经不被建议使用的方法,于是便抽时间尝试了一下另一种被建议的方式实现各功能.   当然了,生产环境中用的是mongodb集群

[转载]使用Java操作Mongodb

HelloWorld程序 学习任何程序的第一步,都是编写HelloWorld程序,我们也不例外,看下如何通过Java编写一个HelloWorld的程序. 首先,要通过Java操作Mongodb,必须先下载Mongodb的Java驱动程序,可以在这里下载. 新建立一个Java工程,将下载的驱动程序放在库文件路径下,程序代码如下: 1 package com.mkyong.core; 2 import java.net.UnknownHostException; 3 import com.mongo

MongDB基础学习（七）—— 【MongoDB for Java】Java操作MongoDB

[MongoDB for Java]Java操作MongoDB 开发的产品为了融资,不停得改版,从第一版到现在最新版本,最后发现公司发展方向都变了,有最初电子商务改成VR内容提供者(没办法,要别人钱,就得按照别人的规划的战略走).本来本章节会放到后面再做讲解,无奈,部门需要做一次培训任务,我就想到拿Java操作MongoDB作为培训内容,开发环境和依赖jar如下: (1)开发环境: System:Windows IDE:eclipse Database:mongoDB2.6 Maven:apac

学习MongoDB--（11）：应用举例（利用java操作MongoDB）

原文地址:http://blog.csdn.net/drifterj/article/details/7948090 目录地址:http://blog.csdn.net/DrifterJ/article/category/1191327/2 前面我们都是通过shell来操作存取MongoDB的数据,shell中使用的语言就是javascript.我们这次说一下如何通过Java来访问操作MongoDB数据库的. Java驱动程序是MongoDB最早的驱动,已用于生产环境很长时间,十分稳定.可以到M

java操作mongoDB实现CURD

java操作mongoDB mongoDB作为一个牛气哄哄的nosql内存数据库,的确有很多优点,对于大数据量.高并发.弱事务的互联网应用,MongoDB可以应对自如.接触到mongoDB 参考了下api实现了增删改查.mongoDB 是面向对象设计,不用写sql语句 直接操作api 方法 就可以实现,这会儿数据库语句写不好的娃娃们有福了.直接贴码: DataTest.java package com.zk.db; import java.net.UnknownHostException; im

使用Java操作MongoDB

该篇比较简单,仅介绍Java操作MongoDB的简单CRUD案例,开搞前需要引入mongo-java-driver-3.2.2.jar,Java操作MongoDB的API众多,高级功能还需查询官方文档. public void insert() { // 建立数据库连接 Mongo mongo = new Mongo("localhost", 27017); // 获取指定的数据库 DB db = mongo.getDB("kaiye"); // 获取指定的集合 D