【java操作mongoDB】完整例子

gaojingsong

浏览: 1210246 次
性别:
来自: 深圳

最近访客更多访客>>

ZZ_lll

boveysmith

zah5897

xckouy

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

博客分类：

大数据--MongoDB

NOSQL JAVA操作MongoDB

步骤一、启动数据库

[root@master ~]# cd /opt/mongodb
[root@master mongodb]# ls
bin data GNU-AGPL-3.0 log README THIRD-PARTY-NOTICES
[root@master mongodb]# cd data/
[root@master data]# ls
mongod.lock test.0 test.1 test.ns _tmp
[root@master data]# cd ../bin/
[root@master bin]# ./mongod --dbpath=/opt/mongodb/data/ --logpath=/opt/mongodb/log/mongodb.log
all output going to: /opt/mongodb/log/mongodb.log
另开一个窗口，监视日志进程
[root@master ~]# tail -f /opt/mongodb/log/mongodb.log
Wed Jan 6 11:54:40 MongoDB starting : pid=3679 port=27017 dbpath=/opt/mongodb/data/ 64-bit
Wed Jan 6 11:54:40 db version v1.6.3, pdfile version 4.5
Wed Jan 6 11:54:40 git version: 278bd2ac2f2efbee556f32c13c1b6803224d1c01
Wed Jan 6 11:54:40 sys info: Linux domU-12-31-39-06-79-A1 2.6.21.7-2.ec2.v1.2.fc8xen #1 SMP Fri Nov 20 17:48:28 EST 2009 x86_64 BOOST_LIB_VERSION=1_41
Wed Jan 6 11:54:40 [initandlisten] waiting for connections on port 27017
Wed Jan 6 11:54:40 [websvr] web admin interface listening on port 28017

步骤二、使用maven构建编码环境

package cn.com.mongodbtest.mongodbtest;

import java.util.ArrayList;
import java.util.List;

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

/**
* Hello world!
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongo-java-driver</artifactId>
<version>2.0</version>
</dependency>
*/
public class App {
public static void main(String[] args) throws Exception {
System.out.println("Hello World!");

  Mongo mongo = new Mongo("192.168.1.109");
  // * Mongo mongo2 = new Mongo( "127.0.0.1", 27017 );
  // * Mongo mongo3 = new Mongo( new DBAddress( "127.0.0.1:27017", "test"
  // ) )

List<String> dbNames = mongo.getDatabaseNames();
System.out.println(dbNames);// [test, admin, local]

DB db = mongo.getDB(dbNames.get(0));
System.out.println(db.getCollectionNames());// [c1, system.indexes]

DBCollection conn = db.getCollection("c1");
System.out.println(conn.getName());// c1

  // 一、增加
  // DBObject doc = new BasicDBObject();
  // doc.put( "foo", "bar1" );
  // conn.insert(doc);

// BSONObject

  // DBObject doc = new BasicDBObject();
  // doc.put( "name", "tomcat" );
  // Map map = new HashMap();
  // map.put("school", "华北航天工业学院");
  // List list =new ArrayList();
  // list.add("邮箱1");
  // list.add("邮箱2");
  // map.put("email", list);
  // doc.putAll(map);
  // conn.insert(doc);

  // 二、修改
  /**
   * @param q search query for old object to update
   * @param o object with which to update <tt>q</tt>
   * @param upsert    if the database should create the element if it does not   exist
   * @param multi    if the update should be applied to all objects matching (db version 1.1.3 and above)
   */
  // BasicDBObject old = new BasicDBObject();
  // old.put( "foo", "bar" );
  // DBObject newobj = new BasicDBObject();
  // newobj.put( "性别", "保密" );
  // newobj.put( "name", "tom" );
  // DBObject query = conn.findOne(old);
  // // 这里的q对象一定要是find出的而不是new的，否则多字段的情况下就会丢失其它字段信息
  // conn.update(query, newobj);

// 三、删除
//  DBObject delobj = new BasicDBObject();
//  delobj.put("foo", "bar1");
//  conn.remove(delobj);

  // 四、遍历
  DBCursor cursor = conn.find();
  // System.out.println(cursor.explain());
  while (cursor.hasNext()) {
   DBObject obj = cursor.next();
   System.out.println(obj);
  }

  // 五、统计总数
  System.out.println(conn.count());
  DBObject where = new BasicDBObject("name", "tomcat");
  System.out.println(conn.count(where));

  //六、建立索引
  DBObject index = new BasicDBObject("foo", "bar1");
  conn.createIndex(index);

  DBObject save = new BasicDBObject("name", "tomcat");
  save.put("age", 24);
  save.put("生日", 123);
  conn.save(save);

  // conn.drop();

}
}