博客

package javagreendao;
import de.greenrobot.daogenerator.DaoGenerator;
import de.greenrobot.daogenerator.Entity;
import de.greenrobot.daogenerator.Property;
import de.greenrobot.daogenerator.Schema;
import de.greenrobot.daogenerator.ToMany;
/**
 * Generates entities and DAOs for the example project DaoExample.
 *
 * Run it as a Java application (not Android).
 *
 * @author Markus
 */
public class ExampleDaoGenerator
{
	/**
	 * 1.总之main函数就执行了下面几个函数                                                    
	 * 2.Schema()参数3是数据库版本号，“com.cn.speedchat.greendao”是包名，
	 *   也就是说生成的Dao文件会在这个包下，可以将Schema理解为数据库上下文吧
	 * 3.addNote() addSession() addReplay()这三个函数相当于建立了三个表，
	 *   表名你都可以不用管了会自动生成
	 * 4.new DaoGenerator().generateAll()这个是生成Dao文件的路径的位置，
	 *   生成在src-gen文件夹里面，跟src同一级目录，所以你自己要在src同一级目录下新建一个src-gen文件夹待会要生成的文件
	 * @param args
	 * @throws Exception
	 */
    public static void main(String[] args) throws Exception
    {
        Schema schema = new Schema(3, "com.cn.speedchat.greendao");
        addNote(schema);
        addSession(schema);
        addReplay(schema);
        addCustomerOrder(schema);
        new DaoGenerator().generateAll(schema, "src-gen");
    }
    
    /**
     * "MqttChatEntity"相当于是表的类名，用MqttChatEntity生成对象就可以访问这个表属性了，
     * 也就是这个表对应了这个类，待会使用你就会明白了,note.addStringProperty("sessionid").notNull()，
     * 相当于给表里面加一个名字为sessionid的字段，而且不能为空
     * @param schema
     */
    private static void addNote(Schema schema)
    {
        Entity note = schema.addEntity("MqttChatEntity");
        note.addIdProperty().autoincrement();
        note.addIntProperty("mode").notNull();
        note.addStringProperty("sessionid").notNull();
        note.addStringProperty("from").notNull();
        note.addStringProperty("to").notNull();
        note.addStringProperty("v_code");
        note.addStringProperty("timestamp").notNull();
        note.addStringProperty("platform");
        note.addStringProperty("message");
        note.addBooleanProperty("isread").notNull();
        note.addLongProperty("gossipid");
        note.addStringProperty("gossip");
        note.addIntProperty("chattype").notNull();
        note.addStringProperty("imagepath");
        note.addStringProperty("base64image");
    }
    
    /**
     * 这也是添加一个表
     * @param schema
     */
    private static void addSession(Schema schema)
    {
        Entity note = schema.addEntity("SessionEntity");
        note.addIdProperty().autoincrement();
        note.addStringProperty("sessionid").notNull().unique();
        note.addStringProperty("from").notNull();
        note.addStringProperty("to").notNull();
        note.addLongProperty("gossipid").notNull();
        note.addStringProperty("gossip");
        note.addIntProperty("sessiontype").notNull();
        note.addBooleanProperty("asdasd").notNull();
    }
    
    /**
     * 这也是添加一个表
     * @param schema
     */
    private static void addReplay(Schema schema)
    {
        Entity note = schema.addEntity("ReplayEntity");
        note.addIdProperty().autoincrement();
        note.addIntProperty("mode").notNull();
        note.addStringProperty("from").notNull();
        note.addStringProperty("to").notNull();
        note.addStringProperty("v_code");
        note.addStringProperty("timestamp").notNull();
        note.addStringProperty("platform");
        note.addStringProperty("message");
        note.addIntProperty("msgtype").notNull();
        note.addBooleanProperty("isread").notNull();
    } 
   
    /**
     * 这个照抄
     * @param schema
     */
    private static void addCustomerOrder(Schema schema)
    {
        Entity customer = schema.addEntity("Customer");
        customer.addIdProperty();
        customer.addStringProperty("name").notNull();                                                                   
        Entity order = schema.addEntity("Order");
        order.setTableName("ORDERS"); // "ORDER" is a reserved keyword
        order.addIdProperty();
        Property orderDate = order.addDateProperty("date").getProperty();
        Property customerId = order.addLongProperty("customerId").notNull().getProperty();
        order.addToOne(customer, customerId);                                               
        ToMany customerToOrders = customer.addToMany(order, customerId);
        customerToOrders.setName("orders");
        customerToOrders.orderAsc(orderDate);
    }                                                                                 
}

private static void addUser(Schema schema)  
    {
        Entity note = schema.addEntity("UserEntity");    
        note.addIdProperty().autoincrement();
        note.addStringProperty("name").notNull();
        note.addIntProperty("age").notNull();
        //true代表男，false代表女
        note.addBooleanProperty("sex").notNull();    
    }

package com.cn.greendaotest;

import com.cn.speedchat.greendao.DaoMaster; 
import com.cn.speedchat.greendao.DaoMaster.OpenHelper; 
import com.cn.speedchat.greendao.DaoSession;


import android.app.Application; import android.content.Context; 
import android.database.sqlite.SQLiteDatabase;


public class ControlApp extends Application{


    private static DaoMaster daoMaster;     
    private static DaoSession daoSession;   
    public static  SQLiteDatabase db;
    //数据库名，表名是自动被创建的    
    public static final String DB_NAME = "dbname.db";    


    public static DaoMaster getDaoMaster(Context context) {  
      if (daoMaster == null) {  
          OpenHelper helper = new DaoMaster.DevOpenHelper(context,DB_NAME, null);  
          daoMaster = new DaoMaster(helper.getWritableDatabase());  
      }  
      return daoMaster;     
   }  


     public static DaoSession getDaoSession(Context context) {  
      if (daoSession == null) {  
          if (daoMaster == null) {  
              daoMaster = getDaoMaster(context);  
          }  
          daoSession = daoMaster.newSession();  
      }  
      return daoSession;     
}     


      public static SQLiteDatabase getSQLDatebase(Context context) {  
      if (daoSession == null) {  
          if (daoMaster == null) {  
              daoMaster = getDaoMaster(context);  
          }  
          db = daoMaster.getDatabase();  
      }  
          return db;     
      }  


    @Override   
    public void onCreate() {

    }
}

package com.cn.speedchat.greendao;
import java.util.ArrayList;
import java.util.List;
import com.cn.greendaotest.ControlApp;
import com.cn.speedchat.greendao.MqttChatEntityDao.Properties;
import de.greenrobot.dao.query.QueryBuilder;
import android.content.Context;
import android.util.Log;

public class DBHelper {
    private static final String TAG = DBHelper.class.getSimpleName();  
    private static DBHelper instance;  
    private static Context appContext;
    private DaoSession mDaoSession;  
    private MqttChatEntityDao chatDao;
    private SessionEntityDao sessionDao;  
    private DBHelper() {
    } 
    //单例模式，DBHelper只初始化一次
    public static  DBHelper getInstance(Context context) {  
        if (instance == null) {
                   instance = new DBHelper();  
                   if (appContext == null){  
                       appContext = context.getApplicationContext();  
                   }  
                   instance.mDaoSession = ControlApp.getDaoSession(context);
                   instance.chatDao = instance.mDaoSession.getMqttChatEntityDao();
                   instance.sessionDao = instance.mDaoSession.getSessionEntityDao();
               } 
        return instance;  
    }


    //删除Session表
    public  void dropSessionTable()
    {
        SessionEntityDao.dropTable(mDaoSession.getDatabase(), true);
    }
    //删除MqttChatEntity表
    public void dropChatTable()
    {
        MqttChatEntityDao.dropTable(mDaoSession.getDatabase(), true);
    }
    //删除所有表
    public void dropAllTable()
    {
        MqttChatEntityDao.dropTable(mDaoSession.getDatabase(), true);
        SessionEntityDao.dropTable(mDaoSession.getDatabase(), true);
     ReplayEntityDao.dropTable(mDaoSession.getDatabase(), true);
    }
    //创建所有表
    public void createAllTable()
    {
        MqttChatEntityDao.createTable(mDaoSession.getDatabase(), true);
        SessionEntityDao.createTable(mDaoSession.getDatabase(), true);
     ReplayEntityDao.createTable(mDaoSession.getDatabase(), true);
    }
    /** 
     * insert or update note 
     * @param note 
     * @return insert or update note id 
     */  
    //插入或者删除session项
    public long saveSession(SessionEntity session){  
        return sessionDao.insertOrReplace(session);  
    }  


    //获得所有的Session倒序排存到List列表里面
    public List<SessionEntity> loadAllSession() {
        List<SessionEntity> sessions = new ArrayList<SessionEntity>();
        List<SessionEntity> tmpSessions = sessionDao.loadAll();
        int len = tmpSessions.size();
        for (int i = len-1; i >=0; i--) {
                sessions.add(tmpSessions.get(i));
        }
        return sessions;
    }  


    public void DeleteSession(SessionEntity entity) {
        sessionDao.delete(entity);
    }  
    //删除某一项Session    
    public void DeleteNoteBySession(SessionEntity entity) {
        QueryBuilder<MqttChatEntity> mqBuilder = chatDao.queryBuilder();
        mqBuilder.where(Properties.Sessionid.eq(entity.getSessionid()));
        List<MqttChatEntity> chatEntityList = mqBuilder.build().list();
        chatDao.deleteInTx(chatEntityList);
    }  


    //根据id找到某一项
    public MqttChatEntity loadNote(long id) {
        return chatDao.load(id);  
    }  
    //获得所有的MqttChatEntity列表 
    public List<MqttChatEntity> loadAllNote(){  
        return chatDao.loadAll();  
    }  


    /** 
     * query list with where clause 
     * ex: begin_date_time >= ? AND end_date_time <= ? 
     * @param where where clause, include 'where' word 
     * @param params query parameters 
     * @return 
     */  
      //查询满足params条件的列表
    public List<MqttChatEntity> queryNote(String where, String... params){
        ArrayList<MqttChatEntity> ad = new ArrayList<MqttChatEntity>();
        return chatDao.queryRaw(where, params); 
    }


    //不一一介绍了，大家可以自己写，有些比较难的查询可以使用QueryBuilder来查询
    public List<MqttChatEntity> loadLastMsgBySessionid(String sessionid){
        QueryBuilder<MqttChatEntity> mqBuilder = chatDao.queryBuilder();
        mqBuilder.where(Properties.Sessionid.eq(sessionid))
        .orderDesc(Properties.Id)
        .limit(1);
        return mqBuilder.list();
    }


    public List<MqttChatEntity> loadMoreMsgById(String sessionid, Long id){
        QueryBuilder<MqttChatEntity> mqBuilder = chatDao.queryBuilder();
        mqBuilder.where(Properties.Id.lt(id))
        .where(Properties.Sessionid.eq(sessionid))
        .orderDesc(Properties.Id)
        .limit(20);
        return mqBuilder.list();
    }


    /** 
     * delete all note 
     */  
    public void deleteAllNote(){  
        chatDao.deleteAll();  
    }  


    /** 
     * delete note by id 
     * @param id 
     */  
    public void deleteNote(long id){  
        chatDao.deleteByKey(id);  
        Log.i(TAG, "delete");  
    }  


    public void deleteNote(MqttChatEntity note){  
        chatDao.delete(note);  
    }  
}