ORMLite框架 的使用方法---给你的数据库操作插上翅膀

一：首先下载 ORMLite Jar 包

先去 ORMLite官网下载jar包 写博客时，目前最新的，对于Android为：ormlite-android-5.0.jar 和 ormlite-core-5.0.jar ； 
然后分包处理，建议如图所示分包：

二：配置Bean类

@DatabaseTable(tableName = "Book")
public class MyBean {

     @DatabaseField(generatedId = true)
     private int id;

     @DatabaseField(columnName = "name")
     public String name;

     @DatabaseField(columnName = "author")
     public String author;

     @DatabaseField(columnName = "price")
     public String price;

     @DatabaseField(columnName = "pages")
     public int pages;


     public String getAuthor() {
         return author;
     }

     public void setAuthor(String author) {
         this.author = author;
     }

     public String getPrice() {
         return price;
     }

     public void setPrice(String price) {
         this.price = price;
     }

     public int getPages() {
         return pages;
     }

     public void setPages(int pages) {
         this.pages = pages;
     }

     public String getName() {
         return name;
     }

     public void setName(String name) {
         this.name = name;
     }
 }

三：编写Helper类

public class MyDatabaseHelper extends OrmLiteSqliteOpenHelper {

     public static final String DB_NAME = "BookStore.db";
     public static final int DB_VERSION = 1;


     public MyDatabaseHelper(Context context) {
         super(context, DB_NAME, null, DB_VERSION);
     }


     @Override
     public void onCreate(SQLiteDatabase sqLiteDatabase, ConnectionSource connectionSource) {
         try {
             TableUtils.createTable(connectionSource, MyBean.class);
         } catch (SQLException e) {
             e.printStackTrace();
         }
     }

     @Override
     public void onUpgrade(SQLiteDatabase sqLiteDatabase, ConnectionSource connectionSource, int oldVersion, int newVersion) {
         System.out.println("MyDatabaseHelper.onUpgrade oldVersion=" + oldVersion + "  newVersion=" + newVersion);
         try {

             switch (oldVersion) {
                 case 1:
                     getDao(MyBean.class).executeRaw("alter table Book add column book_type varchar(20)");
                     //在数据库版本1的下一版本，Book表中新添加了 book_type 字段

                 case 2:
                    // TableUtils.createTable(connectionSource, MyBean2.class);
                    //在数据库版本2的下一版本，新增加了一张表
                 default:
                     break;
             }


             //显然这样处理比较暴力
             //TableUtils.dropTable(connectionSource, MyBean.class, true);
             //onCreate(sqLiteDatabase, connectionSource);
         } catch (SQLException e) {
             e.printStackTrace();
         }
     }

     private static MyDatabaseHelper instance;

     /**
      * 单例获取该Helper
      *
      * @param context
      * @return
      */
     public static MyDatabaseHelper getHelper(Context context) {
         if (instance == null) {
             synchronized (MyDatabaseHelper.class) {
                 if (instance == null)
                     instance = new MyDatabaseHelper(context);
             }
         }
         return instance;
     }


     private Map<String, Dao> daos = new HashMap<>();

     public synchronized Dao getDao(Class clazz) throws SQLException {
         Dao dao = null;
         String className = clazz.getSimpleName();
         if (daos.containsKey(className)) {
             dao = daos.get(clazz);
         }
         if (dao == null) {
             dao = super.getDao(clazz);
             daos.put(className, dao);
         }
         return dao;
     }


     @Override
     public void close() {
         super.close();
         for (String key : daos.keySet()) {
             Dao dao = daos.get(key);
             dao = null;
         }
     }


 }

四：编写DAO类

1：接口编写：

public interface MyDataImpl {

     void insert(ArrayList<MyBean> beanArrayList);

     void insert(MyBean myBean);

     void update(String name, String price);

     void update2(String columnName, String columnValue);

     void update3(String queryColumnName, String queryColumnValue, String setColumnName, String setColumnValue);


     void delete(String name);

     int deleteAll();


     ArrayList<String> queryPrice(String name);

     String queryAuthor(String name, String price);

     long queryCount();

     ArrayList<MyBean> queryId(int id);

     ArrayList<MyBean> queryAll();


 }

public class MyDataDao implements MyDataImpl {
     private MyDatabaseHelper mHelper;
     private Dao<MyBean, Integer> dao;
     private Context mContext;
     private static MyDataDao instance;

     protected MyDataDao(Context context) {
         this.mContext = context;
         try {
             mHelper = MyDatabaseHelper.getHelper(mContext);
             dao = mHelper.getDao(MyBean.class);
         } catch (SQLException e) {
             e.printStackTrace();
         }
     }


     public static MyDataDao getInstance(Context context) {
         if (instance == null) {
             synchronized (MyDataDao.class) {
                 if (instance == null) {
                     instance = new MyDataDao(context);
                 }
             }

         }
         return instance;
     }


     @Override
     public void insert(MyBean myBean) {


         try {

             //事务操作
            /* TransactionManager.callInTransaction(mHelper.getConnectionSource(), new Callable<Void>() {
                 @Override
                 public Void call() throws Exception {
                     return null;
                 }
             });*/


             dao.create(myBean);
             //dao.createOrUpdate(myBean);//和上一行的方法效果一样
         } catch (SQLException e) {
             e.printStackTrace();
         }
     }


     @Override
     public void insert(ArrayList<MyBean> beanArrayList) {
         try {
             dao.create(beanArrayList);
         } catch (SQLException e) {
             e.printStackTrace();
         }
     }

     @Override
     public void update(String name, String price) {
         ArrayList<MyBean> list = null;
         try {
             list = (ArrayList<MyBean>) dao.queryForEq("name", name);
             if (list != null) {
                 for (MyBean bean : list) {
                     bean.setPrice(price);
                     dao.update(bean);
                     //dao.createOrUpdate(bean);//和上一行的方法效果一样
                 }

             }
         } catch (SQLException e) {
             e.printStackTrace();
         }
     }

     @Override
     public void update2(String columnName, String columnValue) {
         try {
             //下面这两个代码的意思一样
             dao.updateBuilder().updateColumnValue(columnName, columnValue).update();
             //dao.updateRaw("update Book set " + columnName + "=?", new String[]{columnValue});
         } catch (SQLException e) {
             e.printStackTrace();
         }


     }

     @Override
     public void update3(String queryColumnName, String queryColumnValue, String setColumnName, String setColumnValue) {
         try {
             String sql = "update Book set " + setColumnName + "= '" + setColumnValue + "' where " + queryColumnName + "= '" + queryColumnValue + "'";
             System.out.println("MyDataDao.update3 sql=" + sql);
             dao.updateRaw(sql);

             //dao.updateRaw("update Book set price= '33333元' where name= '西游记'");//等价于上面的写法
         } catch (SQLException e) {
             e.printStackTrace();
         }
     }

     @Override
     public void delete(String name) {
         ArrayList<MyBean> list = null;
         try {
             list = (ArrayList<MyBean>) dao.queryForEq("name", name);
             if (list != null) {
                 for (MyBean bean : list) {
                     dao.delete(bean);
                 }
             }
         } catch (SQLException e) {
             e.printStackTrace();
         }
     }

     /**
      * @return -1:删除数据异常  0：无数据
      */
     @Override
     public int deleteAll() {
         int number = -1;
         try {
             number = dao.deleteBuilder().delete();//返回删除的数据条数  例如：删除1条数据，返回1，依次类推。

             //dao.deleteBuilder().where().eq("name", "记").reset();//????
         } catch (SQLException e) {
             e.printStackTrace();
         }
         return number;
     }

     @Override
     public ArrayList<String> queryPrice(String name) {
         List<MyBean> list = null;
         ArrayList<String> strings = null;
         try {
             list = dao.queryForEq("name", name);
             if (list != null) {
                 strings = new ArrayList<>();
                 for (MyBean myBean : list) {
                     strings.add(myBean.getPrice());
                 }
                 /*for (int i = 0; i < list.size(); i++) {
                     strings.add(list.get(i).getPrice());
                 }*/
             }
         } catch (SQLException e) {
             e.printStackTrace();
         }
         return strings;
     }

     @Override
     public String queryAuthor(String name1, String price1) {
         List<MyBean> list = null;
         String author = "";

         try {
             list = dao.queryBuilder().where().eq("name", name1).and().eq("price", price1).query();//上述相当与：select * from Book where name = name1 and price = price1 ;
             if (list != null) {
                 for (MyBean myBean : list) {
                     author = myBean.getAuthor();
                 }
             }
         } catch (SQLException e) {
             e.printStackTrace();
         }

         return author;//说明：如果这个 author 是唯一的，可以这样的返回。如果是多个的话，要返回一个ArrayList<String> 类型
     }

     /**
      * @return 表中数据的个数
      */
     @Override
     public long queryCount() {
         long number = 0;
         try {
             number = dao.queryBuilder().countOf();
         } catch (SQLException e) {
             e.printStackTrace();
         }
         return number;
     }

     /**
      * @param id 这个id 就是表中，每次插入数据，自己递增的id 字段
      */
     @Override
     public ArrayList<MyBean> queryId(int id) {
         ArrayList<MyBean> list = null;

         try {
             MyBean myBean = dao.queryForId(id);
             if (myBean != null) {
                 list = new ArrayList<>();
                 list.add(myBean);
             }
             return list;
         } catch (SQLException e) {
             e.printStackTrace();
         }
         return list;
     }

     @Override
     public ArrayList<MyBean> queryAll() {
         ArrayList<MyBean> list = null;
         try {
             list = (ArrayList<MyBean>) dao.queryForAll();


             if (list != null) {
                 return list;
             }
         } catch (SQLException e) {
             e.printStackTrace();
         }
         return list;
     }


     public boolean delteTables(Context context, String DBname) {
         //?????
         return false;
     }


     /**
      * 这个方法可以的
      */
     public boolean delteDatabases(Context context, String DBname) {
         return context.deleteDatabase(DBname);
     }


 }

五：测试

源码下载地址

参考文章：

 ● Android快速开发–使用ORMLite操作数据库

 ●  鸿洋的博客：

 ●  Android ORMLite 框架的入门用法

 ●  Android 快速开发系列 ORMLite 框架最佳实践

 ●  SQL 语法

 ●  SQL UPDATE 语句

 ●  OrmLite 官网