Android sqlite数据库操作通用框架AHibernate(二)源码-用于交流

贴出源代码供大家交流使用,欢迎朋友们对代码提供宝贵意见,直接写到评论中即可.使用示例和步骤见上一篇博客:http://blog.csdn.net/lk_blog/article/details/7455992

源码和示例下载地址: http://download.csdn.net/detail/lk_blog/4222048

(一)注解类:Table.java
[java] view plaincopy
<span style="font-size:18px;">package com.tgb.lk.ahibernate.annotation;  import java.lang.annotation.Retention;  
import java.lang.annotation.RetentionPolicy;  
import java.lang.annotation.Target;  @Retention(RetentionPolicy.RUNTIME)  
@Target( { java.lang.annotation.ElementType.TYPE })  
public @interface Table {  /** * 表名 *  * @return */  public abstract String name();  
}</span>  
Column.java[java] view plaincopy
<span style="font-size:18px;">package com.tgb.lk.ahibernate.annotation;  import java.lang.annotation.Retention;  
import java.lang.annotation.RetentionPolicy;  
import java.lang.annotation.Target;  @Retention(RetentionPolicy.RUNTIME)  
@Target( { java.lang.annotation.ElementType.FIELD })  
public @interface Column {  /** * 列名 *  * @return */  public abstract String name();  public abstract String type() default "";  public abstract int length() default 0;  
}</span>  
Id.java
[java] view plaincopy
<span style="font-size:18px;">package com.tgb.lk.ahibernate.annotation;  import java.lang.annotation.Retention;  
import java.lang.annotation.RetentionPolicy;  
import java.lang.annotation.Target;  @Retention(RetentionPolicy.RUNTIME)  
@Target( { java.lang.annotation.ElementType.FIELD })  
public @interface Id {  
}</span>  
(二)Util类:TableHelper.java[java] view plaincopy
<span style="font-size:18px;">package com.tgb.lk.ahibernate.util;  import android.database.sqlite.SQLiteDatabase;  
import android.util.Log;  import java.lang.reflect.Field;  
import java.sql.Blob;  
import java.util.ArrayList;  
import java.util.LinkedHashMap;  
import java.util.List;  
import java.util.Map;  import com.tgb.lk.ahibernate.annotation.Column;  
import com.tgb.lk.ahibernate.annotation.Id;  
import com.tgb.lk.ahibernate.annotation.Table;  public class TableHelper {  private static final String TAG = "AHibernate";  public static <T> void createTablesByClasses(SQLiteDatabase db,  Class<?>[] clazzs) {  for (Class<?> clazz : clazzs)  createTable(db, clazz);  }  public static <T> void dropTablesByClasses(SQLiteDatabase db,  Class<?>[] clazzs) {  for (Class<?> clazz : clazzs)  dropTable(db, clazz);  }  public static <T> void createTable(SQLiteDatabase db, Class<T> clazz) {  String tableName = "";  if (clazz.isAnnotationPresent(Table.class)) {  Table table = (Table) clazz.getAnnotation(Table.class);  tableName = table.name();  }  StringBuilder sb = new StringBuilder();  sb.append("CREATE TABLE ").append(tableName).append(" (");  List<Field> allFields = TableHelper  .joinFields(clazz.getDeclaredFields(), clazz.getSuperclass()  .getDeclaredFields());  for (Field field : allFields) {  if (!field.isAnnotationPresent(Column.class)) {  continue;  }  Column column = (Column) field.getAnnotation(Column.class);  String columnType = "";  if (column.type().equals(""))  columnType = getColumnType(field.getType());  else {  columnType = column.type();  }  sb.append(column.name() + " " + columnType);  if (column.length() != 0) {  sb.append("(" + column.length() + ")");  }  if (((field.isAnnotationPresent(Id.class)) && (field.getType() == Integer.TYPE))  || (field.getType() == Integer.class))  sb.append(" primary key autoincrement");  else if (field.isAnnotationPresent(Id.class)) {  sb.append(" primary key");  }  sb.append(", ");  }  sb.delete(sb.length() - 2, sb.length() - 1);  sb.append(")");  String sql = sb.toString();  Log.d(TAG, "crate table [" + tableName + "]: " + sql);  db.execSQL(sql);  }  public static <T> void dropTable(SQLiteDatabase db, Class<T> clazz) {  String tableName = "";  if (clazz.isAnnotationPresent(Table.class)) {  Table table = (Table) clazz.getAnnotation(Table.class);  tableName = table.name();  }  String sql = "DROP TABLE IF EXISTS " + tableName;  Log.d(TAG, "dropTable[" + tableName + "]:" + sql);  db.execSQL(sql);  }  private static String getColumnType(Class<?> fieldType) {  if (String.class == fieldType) {  return "TEXT";  }  if ((Integer.TYPE == fieldType) || (Integer.class == fieldType)) {  return "INTEGER";  }  if ((Long.TYPE == fieldType) || (Long.class == fieldType)) {  return "BIGINT";  }  if ((Float.TYPE == fieldType) || (Float.class == fieldType)) {  return "FLOAT";  }  if ((Short.TYPE == fieldType) || (Short.class == fieldType)) {  return "INT";  }  if ((Double.TYPE == fieldType) || (Double.class == fieldType)) {  return "DOUBLE";  }  if (Blob.class == fieldType) {  return "BLOB";  }  return "TEXT";  }  // 合并Field数组并去重,并实现过滤掉非Column字段,和实现Id放在首字段位置功能  public static List<Field> joinFields(Field[] fields1, Field[] fields2) {  Map<String, Field> map = new LinkedHashMap<String, Field>();  for (Field field : fields1) {  // 过滤掉非Column定义的字段  if (!field.isAnnotationPresent(Column.class)) {  continue;  }  Column column = (Column) field.getAnnotation(Column.class);  map.put(column.name(), field);  }  for (Field field : fields2) {  // 过滤掉非Column定义的字段  if (!field.isAnnotationPresent(Column.class)) {  continue;  }  Column column = (Column) field.getAnnotation(Column.class);  if (!map.containsKey(column.name())) {  map.put(column.name(), field);  }  }  List<Field> list = new ArrayList<Field>();  for (String key : map.keySet()) {  Field tempField = map.get(key);  // 如果是Id则放在首位置.  if (tempField.isAnnotationPresent(Id.class)) {  list.add(0, tempField);  } else {  list.add(tempField);  }  }  return list;  }  
}</span>  
MyDBHelper.java
[java] view plaincopy
<span style="font-size:18px;">package com.tgb.lk.ahibernate.util;  import android.content.Context;  
import android.database.sqlite.SQLiteDatabase;  
import android.database.sqlite.SQLiteOpenHelper;  public class MyDBHelper extends SQLiteOpenHelper {  private Class<?>[] modelClasses;  public MyDBHelper(Context context, String databaseName,  SQLiteDatabase.CursorFactory factory, int databaseVersion,  Class<?>[] modelClasses) {  super(context, databaseName, factory, databaseVersion);  this.modelClasses = modelClasses;  }  public void onCreate(SQLiteDatabase db) {  TableHelper.createTablesByClasses(db, this.modelClasses);  }  public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {  TableHelper.dropTablesByClasses(db, this.modelClasses);  onCreate(db);  }  
}</span>  
(三)接口和实现:
BaseDao.java[java] view plaincopy
<span style="font-size:18px;">package com.tgb.lk.ahibernate.dao;  import java.util.List;  
import java.util.Map;  import android.database.sqlite.SQLiteOpenHelper;  public interface BaseDao<T> {  public SQLiteOpenHelper getDbHelper();  public abstract long insert(T entity);  public abstract void delete(int id);  public abstract void delete(Integer... ids);  public abstract void update(T entity);  public abstract T get(int id);  public abstract List<T> rawQuery(String sql, String[] selectionArgs);  public abstract List<T> find();  public abstract List<T> find(String[] columns, String selection,  String[] selectionArgs, String groupBy, String having,  String orderBy, String limit);  public abstract boolean isExist(String sql, String[] selectionArgs);  /** * 将查询的结果保存为名值对map. *  * @param sql *            查询sql * @param selectionArgs *            参数值 * @return 返回的Map中的key全部是小写形式. */  public List<Map<String, String>> query2MapList(String sql,  String[] selectionArgs);  /** * 封装执行sql代码. * @param sql * @param selectionArgs */  public void execSql(String sql, Object[] selectionArgs);  }</span>  BaseDaoImpl.java
[java] view plaincopy
<span style="font-size:18px;">package com.tgb.lk.ahibernate.dao.impl;  import android.content.ContentValues;  
import android.database.Cursor;  
import android.database.sqlite.SQLiteDatabase;  
import android.database.sqlite.SQLiteOpenHelper;  
import android.util.Log;  
import java.lang.reflect.Field;  
import java.sql.Blob;  
import java.util.ArrayList;  
import java.util.HashMap;  
import java.util.List;  
import java.util.Map;  import com.tgb.lk.ahibernate.annotation.Column;  
import com.tgb.lk.ahibernate.annotation.Id;  
import com.tgb.lk.ahibernate.annotation.Table;  
import com.tgb.lk.ahibernate.dao.BaseDao;  
import com.tgb.lk.ahibernate.util.TableHelper;  /** * AHibernate概要 <br/> * (一)支持功能: 1.自动建表,支持属性来自继承类:可根据注解自动完成建表,并且对于继承类中的注解字段也支持自动建表. 2.自动支持增删改 * ,增改支持对象化操作:增删改是数据库操作的最基本单元,不用重复写这些增删改的代码,并且添加和更新支持类似于hibernate中的对象化操作. * 3.查询方式灵活:支持android框架提供的方式,也支持原生sql方式. * 4.查询结果对象化:对于查询结果可自动包装为实体对象,类似于hibernate框架. * 5.查询结果灵活:查询结果支持对象化,也支持结果为List<Map<String,String>>形式,这个方法在实际项目中很实用,且效率更好些. * 6.日志较详细:因为android开发不支持热部署调试,运行报错时可根据日志来定位错误,这样可以减少运行Android的次数. <br/> * (二)不足之处: <br/> * 1.id暂时只支持int类型,不支持uuid,在sqlite中不建议用uuid. * 2.现在每个方法都自己开启和关闭事务,暂时还不支持在一个事务中做多个操作然后统一提交事务. <br/> * (三)作者寄语:<br/> * 昔日有JavaScript借Java发展,今日也希望AHibernate借Hibernate之名发展. * 希望这个项目以后会成为开源社区的重要一员,更希望这个项目能给所有Android开发者带便利. * 欢迎访问我的博客:http://blog.csdn.net/lk_blog, * 这里有这个框架的使用范例和源码,希望朋友们多多交流完善这个框架,共同推动中国开源事业的发展,AHibernate期待与您共创美好未来!!! */  
public class BaseDaoImpl<T> implements BaseDao<T> {  private String TAG = "AHibernate";  private SQLiteOpenHelper dbHelper;  private String tableName;  private String idColumn;  private Class<T> clazz;  private List<Field> allFields;  public BaseDaoImpl(SQLiteOpenHelper dbHelper) {  this.dbHelper = dbHelper;  this.clazz = ((Class<T>) ((java.lang.reflect.ParameterizedType) super  .getClass().getGenericSuperclass()).getActualTypeArguments()[0]);  if (this.clazz.isAnnotationPresent(Table.class)) {  Table table = (Table) this.clazz.getAnnotation(Table.class);  this.tableName = table.name();  }  // 加载所有字段  this.allFields = TableHelper.joinFields(this.clazz.getDeclaredFields(),  this.clazz.getSuperclass().getDeclaredFields());  // 找到主键  for (Field field : this.allFields) {  if (field.isAnnotationPresent(Id.class)) {  Column column = (Column) field.getAnnotation(Column.class);  this.idColumn = column.name();  break;  }  }  Log.d(TAG, "clazz:" + this.clazz + " tableName:" + this.tableName  + " idColumn:" + this.idColumn);  }  public SQLiteOpenHelper getDbHelper() {  return dbHelper;  }  public T get(int id) {  String selection = this.idColumn + " = ?";  String[] selectionArgs = { Integer.toString(id) };  Log.d(TAG, "[get]: select * from " + this.tableName + " where "  + this.idColumn + " = '" + id + "'");  List<T> list = find(null, selection, selectionArgs, null, null, null,  null);  if ((list != null) && (list.size() > 0)) {  return (T) list.get(0);  }  return null;  }  public List<T> rawQuery(String sql, String[] selectionArgs) {  Log.d(TAG, "[rawQuery]: " + sql);  List<T> list = new ArrayList<T>();  SQLiteDatabase db = null;  Cursor cursor = null;  try {  db = this.dbHelper.getReadableDatabase();  cursor = db.rawQuery(sql, selectionArgs);  getListFromCursor(list, cursor);  } catch (Exception e) {  Log.e(this.TAG, "[rawQuery] from DB Exception.");  e.printStackTrace();  } finally {  if (cursor != null) {  cursor.close();  }  if (db != null) {  db.close();  }  }  return list;  }  public boolean isExist(String sql, String[] selectionArgs) {  Log.d(TAG, "[isExist]: " + sql);  SQLiteDatabase db = null;  Cursor cursor = null;  try {  db = this.dbHelper.getReadableDatabase();  cursor = db.rawQuery(sql, selectionArgs);  if (cursor.getCount() > 0) {  return true;  }  } catch (Exception e) {  Log.e(this.TAG, "[isExist] from DB Exception.");  e.printStackTrace();  } finally {  if (cursor != null) {  cursor.close();  }  if (db != null) {  db.close();  }  }  return false;  }  public List<T> find() {  return find(null, null, null, null, null, null, null);  }  public List<T> find(String[] columns, String selection,  String[] selectionArgs, String groupBy, String having,  String orderBy, String limit) {  Log.d(TAG, "[find]");  List<T> list = new ArrayList<T>();  SQLiteDatabase db = null;  Cursor cursor = null;  try {  db = this.dbHelper.getReadableDatabase();  cursor = db.query(this.tableName, columns, selection,  selectionArgs, groupBy, having, orderBy, limit);  getListFromCursor(list, cursor);  } catch (Exception e) {  Log.e(this.TAG, "[find] from DB Exception");  e.printStackTrace();  } finally {  if (cursor != null) {  cursor.close();  }  if (db != null) {  db.close();  }  }  return list;  }  private void getListFromCursor(List<T> list, Cursor cursor)  throws IllegalAccessException, InstantiationException {  while (cursor.moveToNext()) {  T entity = this.clazz.newInstance();  for (Field field : this.allFields) {  Column column = null;  if (field.isAnnotationPresent(Column.class)) {  column = (Column) field.getAnnotation(Column.class);  field.setAccessible(true);  Class<?> fieldType = field.getType();  int c = cursor.getColumnIndex(column.name());  if (c < 0) {  continue; // 如果不存则循环下个属性值  } else if ((Integer.TYPE == fieldType)  || (Integer.class == fieldType)) {  field.set(entity, cursor.getInt(c));  } else if (String.class == fieldType) {  field.set(entity, cursor.getString(c));  } else if ((Long.TYPE == fieldType)  || (Long.class == fieldType)) {  field.set(entity, Long.valueOf(cursor.getLong(c)));  } else if ((Float.TYPE == fieldType)  || (Float.class == fieldType)) {  field.set(entity, Float.valueOf(cursor.getFloat(c)));  } else if ((Short.TYPE == fieldType)  || (Short.class == fieldType)) {  field.set(entity, Short.valueOf(cursor.getShort(c)));  } else if ((Double.TYPE == fieldType)  || (Double.class == fieldType)) {  field.set(entity, Double.valueOf(cursor.getDouble(c)));  } else if (Blob.class == fieldType) {  field.set(entity, cursor.getBlob(c));  } else if (Character.TYPE == fieldType) {  String fieldValue = cursor.getString(c);  if ((fieldValue != null) && (fieldValue.length() > 0)) {  field.set(entity, Character.valueOf(fieldValue  .charAt(0)));  }  }  }  }  list.add((T) entity);  }  }  public long insert(T entity) {  Log.d(TAG, "[insert]: inset into " + this.tableName + " "  + entity.toString());  SQLiteDatabase db = null;  try {  db = this.dbHelper.getWritableDatabase();  ContentValues cv = new ContentValues();  setContentValues(entity, cv, "create");  long row = db.insert(this.tableName, null, cv);  return row;  } catch (Exception e) {  Log.d(this.TAG, "[insert] into DB Exception.");  e.printStackTrace();  } finally {  if (db != null) {  db.close();  }  }  return 0L;  }  public void delete(int id) {  SQLiteDatabase db = this.dbHelper.getWritableDatabase();  String where = this.idColumn + " = ?";  String[] whereValue = { Integer.toString(id) };  Log.d(TAG, "[delete]: delelte from " + this.tableName + " where "  + where.replace("?", String.valueOf(id)));  db.delete(this.tableName, where, whereValue);  db.close();  }  public void delete(Integer... ids) {  if (ids.length > 0) {  StringBuffer sb = new StringBuffer();  for (int i = 0; i < ids.length; i++) {  sb.append('?').append(',');  }  sb.deleteCharAt(sb.length() - 1);  SQLiteDatabase db = this.dbHelper.getWritableDatabase();  String sql = "delete from " + this.tableName + " where "  + this.idColumn + " in (" + sb + ")";  Log.d(TAG, "[delete]: " + sql);  db.execSQL(sql, (Object[]) ids);  db.close();  }  }  public void update(T entity) {  SQLiteDatabase db = null;  try {  db = this.dbHelper.getWritableDatabase();  ContentValues cv = new ContentValues();  setContentValues(entity, cv, "update");  String where = this.idColumn + " = ?";  int id = Integer.parseInt(cv.get(this.idColumn).toString());  cv.remove(this.idColumn);  Log.d(TAG, "[update]: update " + this.tableName + " where "  + where.replace("?", String.valueOf(id)));  String[] whereValue = { Integer.toString(id) };  db.update(this.tableName, cv, where, whereValue);  } catch (Exception e) {  Log.d(this.TAG, "[update] DB Exception.");  e.printStackTrace();  } finally {  if (db != null)  db.close();  }  }  private void setContentValues(T entity, ContentValues cv, String type)  throws IllegalAccessException {  for (Field field : this.allFields) {  if (!field.isAnnotationPresent(Column.class)) {  continue;  }  Column column = (Column) field.getAnnotation(Column.class);  field.setAccessible(true);  Object fieldValue = field.get(entity);  if (fieldValue == null)  continue;  if (("create".equals(type))  && (field.isAnnotationPresent(Id.class))) {  continue;  }  cv.put(column.name(), fieldValue.toString());  }  }  /** * 将查询的结果保存为名值对map. *  * @param sql *            查询sql * @param selectionArgs *            参数值 * @return 返回的Map中的key全部是小写形式. */  public List<Map<String, String>> query2MapList(String sql,  String[] selectionArgs) {  Log.d(TAG, "[query2MapList]: " + sql);  SQLiteDatabase db = null;  Cursor cursor = null;  List<Map<String, String>> retList = new ArrayList<Map<String, String>>();  try {  db = this.dbHelper.getReadableDatabase();  cursor = db.rawQuery(sql, selectionArgs);  while (cursor.moveToNext()) {  Map<String, String> map = new HashMap<String, String>();  for (String columnName : cursor.getColumnNames()) {  map.put(columnName.toLowerCase(), cursor.getString(cursor  .getColumnIndex(columnName)));  }  retList.add(map);  }  } catch (Exception e) {  Log.e(TAG, "[query2MapList] from DB exception");  e.printStackTrace();  } finally {  if (cursor != null) {  cursor.close();  }  if (db != null) {  db.close();  }  }  return retList;  }  /** * 封装执行sql代码. *  * @param sql * @param selectionArgs */  public void execSql(String sql, Object[] selectionArgs) {  SQLiteDatabase db = null;  Log.d(TAG, "[execSql]: " + sql);  try {  db = this.dbHelper.getWritableDatabase();  if (selectionArgs == null) {  db.execSQL(sql);  } else {  db.execSQL(sql, selectionArgs);  }  } catch (Exception e) {  Log.e(TAG, "[execSql] DB exception.");  e.printStackTrace();  } finally {  if (db != null) {  db.close();  }  }  }  
}</span>