NoSQL 之 Morphia 操作 MongoDB

上两篇文章:http://www.cnblogs.com/hoojo/archive/2011/06/01/2066426.html

http://www.cnblogs.com/hoojo/archive/2011/06/02/2068665.html

介绍到了在MongoDB的控制台完成MongoDB的数据操作、以及通过Java MongoDB 的驱动完成在Java中对MongoDB的操作，通过前两篇文章我们对MongoDB有了全面、深刻的认识和理解。现在我们就看看利用Morphia库来操作MongoDB。

开发环境：

System：Windows

IDE：eclipse、MyEclipse 8

Database：mongoDB

开发依赖库：

JavaEE5、mongo-2.5.3.jar、junit-4.8.2.jar

Email：hoojo_@126.com

Blog：http://blog.csdn.net/IBM_hoojo

http://hoojo.cnblogs.com/

一、准备工作

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-java-driver-r2.6.1-7-g6037357.zip

在线查看源码：https://github.com/mongodb/mongo-java-driver

Morphia jar包下载：http://code.google.com/p/morphia/downloads/list

2、下面建立一个JavaProject工程，导入下载下来的驱动包。即可在Java中使用Morphia，目录如下：

二、Java操作MongoDB示例

在本示例之前你需要启动mongod.exe的服务，在你安装mongoDB的目录中，找到mongod.exe启动服务后，下面的程序才能顺利执行；

1、 Java操作mongoDB数据库，操作索引

Mongo mongo = new Mongo();

这样就创建了一个MongoDB的数据库连接对象，它默认连接到当前机器的localhost地址，端口是27017。

DB db = mongo.getDB(“test”);

这样就获得了一个test的数据库，如果mongoDB中没有创建这个数据库也是可以正常运行的。如果你读过上一篇文章就知道，mongoDB可以在没有创建这个数据库的情况下，完成数据的添加操作。当添加的时候，没有这个库，mongoDB会自动创建当前数据库。

得到了db，下一步我们要获取一个“聚集集合DBCollection”，通过db对象的getCollection方法来完成。

DBCollection users = db.getCollection("users");

这样就获得了一个DBCollection，它相当于我们数据库的“表”。

查询所有数据

DBCursor cur = users.find();

while (cur.hasNext()) {

System.out.println(cur.next());

}

用BasicDBObjectBuilder，向users对象中添加数据

user = BasicDBObjectBuilder.start("id",1546555)

.append("name","jojo").add("address","gz")

.append("email","hoojo_@126.com")

.get();

插入数据

users.insert(user);

可以利用JSON工具来序列化对象数据

JSON.serialize(cur)

完整源码

package com.hoo.test;

import java.net.UnknownHostException;

import com.hoo.entity.User;

import com.hoo.util.BasicDBObjectUtils;

import com.mongodb.BasicDBObjectBuilder;

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;

/**

 * <b>function:</b> Mongo实例对象的相关方法测试

 * @author hoojo

 * @createDate 2011-5-24 下午02:42:29

 * @file MongoDBTest.java

 * @package com.hoo.test

 * @project MongoDB

 * @blog http://blog.csdn.net/IBM_hoojo

 * @email hoojo_@126.com

 * @version 1.0

*/

public class MongoDBTest {

    static void main(String[] args) throws UnknownHostException,MongoException {

        Mongo mg = new Mongo();

        System.out.println("查询所有的Database的名称");

        for (String name : mg.getDatabaseNames()) {

            System.out.println("dbName: " + name);

        System.out.println("查询test库中的所有collection集合（表）名称");

        DB db = mg.getDB("test");

for (String name : db.getCollectionNames()) {

"collectionName: " + name);

"添加测试数据");

        DBCollection users = db.getCollection("users");

try {

            // 用自定义BasicDBObjectUtils工具类，将User Enity对象转换成DBObject

            DBObject user = BasicDBObjectUtils.castModel2DBObject(new User("345567","jack",22,128)">"beijin"));

            users.insert(user);

            // 用BasicDBObjectBuilder构建一个DBObject对象

            user = BasicDBObjectBuilder.start("id",1546555).append("name",128)">"jojo").add("address",128)">"gz").append("email",128)">"hoojo_@126.com").get();

            users.insert(user);

        } catch (Exception e) {

            e.printStackTrace();

"游标查询所有users集合数据");

        DBCursor cur = users.find();

        while (cur.hasNext()) {

            System.out.println(cur.next());

"查询游标相关内容");

        System.out.println(cur.count());

        System.out.println(cur.getCursorId());

        System.out.println(cur.getOptions());

        System.out.println(cur.getQuery());

        System.out.println(cur.getSizes().listIterator());

        System.out.println(cur.itcount());

//System.out.println(cur.length());

        System.out.println(cur.size());

        System.out.println(cur.numGetMores());

        System.out.println(cur.curr());

//System.out.println(cur.toArray().get(0));

"显示游标查询到的所有内容： " + JSON.serialize(cur));

工具类，将带有getter、setter方法的Java类序列化成DBObject对象

package com.hoo.util;

import java.lang.reflect.Method;

import com.mongodb.BasicDBObject;

 * <b>function:</b> 将Entity/Model转换成DBObject

 * @createDate 2011-5-30下午01:53:08

 * @file BasicDBObjectUtil.java

 * @package com.hoo.util

publicclass BasicDBObjectUtils {

    static<T> DBObject castModel2DBObject(T entity) throws Exception {

        Method[] method =  entity.getClass().getMethods();

        DBObject dbObject = new BasicDBObject();

for (Method m : method) {

//System.out.println(m.getName());

if (m.getName().startsWith("get")) {

                String name = m.getName().replace("get",128)">"");

                for (Method m2 : method) {

                    if (m2.getName().equals("set" + name)) {

                        name = name.substring(0,1).toLowerCase() + name.substring(1);

                        Object returnVal = m.invoke(entity,255)">new Object[] {});

                        if (returnVal != null) {

                            //System.out.println(name + " : " + m.invoke(shipping,new Object[] {}));

                            dbObject.put(name,returnVal);

"dbObject: " + dbObject);

return dbObject;

 2、 完成索引操作，首先建立一个MongoDB4IndexTest.java，基本测试代码如下： 
import java.util.ArrayList;

import java.util.List;

import org.bson.types.ObjectId;

import org.junit.After;

import org.junit.Before;

import org.junit.Test;

import com.mongodb.Bytes;

import com.mongodb.QueryOperators;

 * <b>function:</b> 实现MongoDB的Index操作

 * @createDate 2011-6-2 下午03:21:23

 * @file MongoDB4IndexTest.java

class MongoDB4IndexTest {

private Mongo mg = null;

private DB db;

private DBCollection users;

    @Before

void init() {

            mg = //mg = new Mongo("localhost",27017);

catch (UnknownHostException e) {

catch (MongoException e) {

//获取temp DB；如果默认没有创建，mongodb会自动创建

        db = mg.getDB("temp");

//获取users DBCollection；如果默认没有创建，mongodb会自动创建

        users = db.getCollection(    }

    @After

void destory() {

if (mg != null)

            mg.close();

        mg = null;

        db = null;

        users = null;

        System.gc();

void print(Object o) {

        System.out.println(o);

"updateFirst: " + ds.updateFirst(ds.createQuery(User.//当参数createIfMissing为true的时候，如果修改的对象不存在就会添加这条数据，如果为false的情况下，不存在也不添加

"findAndDelete: " + ds.findAndDelete(ds.createQuery(User."id").equal(1306813979609L)));

 4、 Query查询操作 
 * <b>function:</b> query查询

 * @createDate 2012-2-16 下午10:40:10

void testQuery() {

// 查询所有

"query: " + ds.createQuery(User."query key: " + ds.createQuery(User.class).asKeyList());

// 结果集数量

class).countAll());

// 抓取查询所有记录

    Iterable<User> it = ds.createQuery(User.// null

    it = ds.createQuery(User.class).fetchEmptyEntities();

"fetchEmptyEntities: " + it.iterator().next());

// all key

    Iterable<Key<User>> itkeys = ds.createQuery(User.class).fetchKeys();

while(itkeys.iterator().hasNext()) {

"fetchKeys: " + itkeys.iterator().next());

// age > 24

class).filter("age > ",24).asList());

// age in (20,28)

"age in ",newint[] { 20,28 }).asList());

// limit 3

class).limit(3).asList());

// 分页类似MysqL

class).offset(11).limit(5).asList());

// order排序，默认asc

class).order("age").asList());

//desc

"-age").asList());

// 组合排序 order by age,name

"age,name").asList());

class).queryNonPrimary().asList());

class).queryPrimaryOnly().asList());

//如果include 为true就表示取该属性的值，其他的默认null，反之为false则该属性为null，取其他的值

class).retrievedFields(false,sans-serif; font-size:13px"> 5、 get和count查询 
 * <b>function:</b> get查询

 * @createDate 2012-2-16 下午10:39:09

void testGet() {

    User user = new User();

"get: " + ds.get(user));

    List<Long> ids = new ArrayList<Long>();

    ids.add(1306907246519L);

    ids.add(1306916670524L);

// 通过id集合查询相当于in ()

"get: " + ds.get(User.// id查询

 * <b>function:</b> count查询

 * @createDate 2012-2-16 下午10:38:02

@Test

void testGetCount() {

    user.setId(1306916670518L);

"getCount: " + ds.getCount(user));

"getCount: " + ds.getCount(User.    List<Long> ids =     ids.add(1306907246519L);

    ids.add(1306916670524L);

"getCount: " + ds.getCount(ds.get(User.// age > 22的记录

"getCount: " + ds.getCount(ds.createQuery(User.// 所有

"countAll: " + ds.get(User."countAll: " + ds.find(User. 6、 其他操作 
void testOthers() {

    query();

/** 索引 */

    ds.ensureIndexes();

// 同时用annotation也可以给指定的属性建立索引

// 只需用在JavaEntity建立索引的属性上添加annotation

/*@Indexed(value = IndexDirection.ASC,name = "address_index")

    String address;

    // 建立唯一索引

    @Indexed(value = IndexDirection.ASC,name = "bandName",unique = true)

    String name;*/

    ds.ensureCaps();

"getDB: " + ds.getDB());

"getDefaultWriteConcern: " + ds.getDefaultWriteConcern());

"DBColl: " + ds.getCollection(User.class)); // 查询User对象对应的集合

    Key<User> key = ds.getKey(user); // 主键

"getKey: " + key);

"exists: " + ds.exists(user)); //是否存在该对象

"exists: " + ds.exists(ds.getKey(user)));

"getByKey: " + ds.getByKey(User.    List<Key<User>> keys = new ArrayList<Key<User>>();

    keys.add(key);

    user.setId(1306916670521L);

    keys.add(ds.getKey(user));

"getByKey: " + ds.getByKeys(keys));

"getByKey: " + ds.getByKeys(User.}

NoSQL 之 Morphia 操作 MongoDB

一、准备工作

二、Java操作MongoDB示例

三、Morphia基本操作

四、利用Morphia完成对Datastore对象的CRUD操作

猜你在找的NoSQL相关文章