首页 > 数据库技术 > 详细

使用 Morphia 和 MongoDB 实现持久化

时间:2016-03-18 23:33:52      阅读:579      评论:0      收藏:0      [点我收藏+]

直接来一个简单的demo:

新建一个maven java project(maven-archetype-quickstart):

技术分享技术分享


DBHelper:

package com.mongo.dao;

import com.mongodb.Mongo;
import com.mongodb.MongoClient;
import org.mongodb.morphia.Datastore;
import org.mongodb.morphia.Morphia;

/**
 * Created by hejy on 2016/3/18.
 */
public class DBHelper {
    
    public Datastore ds;



    public DBHelper(){
       //初始化数据
        init();
    }
    public void init(){
        try{

            Mongo mongo = new Mongo("localhost");
            MongoClient mongoClient=new MongoClient("localhost");
            ds = new Morphia().createDatastore(mongoClient, "mydb");
        }
        catch(Exception e){
            e.printStackTrace();
        }
    }


}

测试类:


package com.mongo;

import com.mongo.dao.DBHelper;
import com.mongo.model.Entry;
import org.mongodb.morphia.Datastore;
import org.mongodb.morphia.query.Query;
import java.util.List;

/**
 * Unit test for simple App.
 */
public class MongoDBTest
{
    private static DBHelper dbHelper=new DBHelper();
    private static Entry en=new Entry();
    private static Datastore db=dbHelper.ds;
   public static void queryAll(){
       Query<Entry> query=db.createQuery(Entry.class);
       List<Entry> list=query.asList();
       for(Entry entry:list){
           System.out.println(entry);
       }
   }
    public static void add(){
        int num=(int)System.currentTimeMillis();
        for(int i=0;i<10;i++){
            Entry en=new Entry();
            en.setId(num++);
            en.setName("hjy");
            db.save(en);
        }
    }
    public static void main(String args[]){
        add();
        queryAll();
    }
}


执行结果:


技术分享


说明:

在操作之前我们不需要给mongodb建立数据库,当我们往数据库中存入数据时,数据库会自动创建。


技术分享



使用 Morphia 和 MongoDB 实现持久化

原文:http://blog.csdn.net/hejingyuan6/article/details/50925845

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!