Android黑群出品：SQLite数据库的使用和升级

ycvodzf

　　SQLite数据库的基本使用及对返回结果进行简单的封装，可直接返回Object或List类型，省去自动转换成Object或List的麻烦。 主要代码如下： [code="java"] package com.juziku.demo.sqlite;   import java.lang.reflect.Field; import java.util.ArrayList; import java.util.List;     import android.content.ContentValues; import android.content.Context; import android.database.Cursor; import android.database.SQLException; import android.database.sqlite.SQLiteDatabase; import android.util.Log;     /**  * 基础DAO，每个DAO都要继承此类  *  * @author steven  *  * http://www.juziku.com/sunlightcs/  *  */ public class BaseDao {       private Context mContext;     private SQLiteDatabase db;       public Context getmContext() {         return mContext;     }       public BaseDao(Context context) {         this.mContext = context;         DBHelper dbHelper = new DBHelper(mContext, Configuration.DB_NAME,                 null, Configuration.DB_VERSION);         db = dbHelper.getWritableDatabase();     }       /**      * 增加、删除、修改表时，调用此方法      * @param sql  DDL语句      * @throws SQLException      */     public void execute(String sql){         db.execSQL(sql);     }       /**      * 删除表中的记录      * @param table   表名      * @param whereClause 删除条件   如：( id>? and time>?)      * @param whereArgs   条件里的参数    用来替换"?"    第1个参数，代表第1个问号；第2个参数，代表第2个问号；依此类推......      * @return  返回删除的条数      */     public int delete(String table, String whereClause, String[] whereArgs) {         return db.delete(table, whereClause, whereArgs);     }           /**      * 插入数据      * @param table 表名      * @param values    ContentValues对象      * @return          返回当前行ID值，如果失败返回-1      */     public long insert(String table,    ContentValues values){         return this.insert(table, null, values);     }                   /**      * 插入数据      * @param table 表名      * @param values    ContentValues对象      * @param nullColumnHack   空列      * @return          返回当前行ID值，如果失败返回-1      */     public long insert(String table, String nullColumnHack,             ContentValues values) throws SQLException {         return db.insertOrThrow(table, nullColumnHack, values);     }       /**      * 修改数据      * @param table         表名      * @param values        ContentValues对象          表示要修改的列，如： name="steven" 即 values.put("name", "steven");      * @param whereClause   修改条件   如：( id=?)      * @param whereArgs     条件里的参数    用来替换"?"    第1个参数，代表第1个问号；第2个参数，代表第2个问号；依此类推......      * @return              返回修改的条数      */     public int update(String table, ContentValues values,             String whereClause, String[] whereArgs) {         return db.update(table, values, whereClause, whereArgs);     }               /**      * 查询数据      * @param table             表名      * @param columns           要查询的列名      * @param selection         查询条件    如：( id=?)      * @param selectionArgs     条件里的参数，用来替换"?"      * @return                  返回Cursor      */     public Cursor query(String table, String[] columns, String selection,             String[] selectionArgs) {         return db.query(table, columns, selection, selectionArgs, null, null,                 null);     }                 /**      * 查询数据      * @param table             表名      * @param columns           要查询的列名      * @param selection         查询条件    如：( id=?)      * @param selectionArgs     条件里的参数，用来替换"?"      * @param orderBy           排序              如：id desc      * @return                  返回Cursor      */     public Cursor query(String table, String[] columns, String selection,             String[] selectionArgs, String orderBy) {         return db.query(table, columns, selection, selectionArgs, null, null,                 orderBy);     }           /**      * 查询数据      * @param distinct          每行是唯一     true:表示唯一       false:表示不唯一      * @param table             表名      * @param columns           要查询的列名      * @param selection         查询条件    如：( id=?)      * @param selectionArgs     条件里的参数，用来替换"?"      * @param orderBy           排序              如：id desc      * @param limit             查询的条数              如：10      * @return                  返回Cursor      */     public Cursor query(boolean distinct, String table, String[] columns, String selection,             String[] selectionArgs, String orderBy, String limit){         return db.query(distinct, table, columns, selection, selectionArgs, null, null, orderBy, limit);     }                             /**      * 查询某个字段       * @param classz            字节码      如：String.class      * @param table             表名      * @param columns           要查询的列名      * @param selection         查询条件    如：( id=?)      * @param selectionArgs     条件里的参数，用来替换"?"      * @return                  返回Object      */     public Object queryField(Class> classz, String table, String[] columns, String selection,             String[] selectionArgs){         Object o = null;         //查询单条记录         Cursor c = db.query(table, columns, selection, selectionArgs, null, null, null, "1");         if(c.moveToFirst()){             try {                 if(classz == Integer.TYPE) {   //int                     o = c.getInt(0);                 }else if(classz == String.class){   //String                     o = c.getString(0);                 }else if(classz == Long.TYPE){   //long                     o = c.getLong(0);                 }else if(classz == Float.TYPE){   //float                     o = c.getFloat(0);                 }else if(classz == Double.TYPE){   //double                     o = c.getDouble(0);                 }else if(classz == Short.TYPE){   //short                     o = c.getShort(0);                 }             } catch (Exception e) {                 Log.e("queryField", e.toString());             }         }         c.close();         return o;     }                 /**      * 查询数据    单个对象      * @param classz            字节码      如：String.class      * @param table             表名      * @param columns           要查询的列名      * @param selection         查询条件    如：( id=?)      * @param selectionArgs     条件里的参数，用来替换"?"      * @return                  返回Object      */     @SuppressWarnings("unchecked")     public T queryObject(Class> classz, String table, String[] columns, String selection,             String[] selectionArgs){                   //查询单条记录         Cursor c = db.query(table, columns, selection, selectionArgs, null, null, null, "1");         T t = null;         if(c.moveToFirst()){             try{                 //生成新的实例                 t = (T) classz.newInstance();                                   //把列的值，转换成对象里属性的值                 columnToField(t, c);                               }catch(Exception e){                 Log.e("newInstance error", "生成新实例时出错 ：" + e.toString());             }         }         c.close();         return t;     }                 /**      * 查询数据    带分页功能      * @param classz            字节码      如：String.class      * @param table             表名      * @param columns           要查询的列名      * @param selection         查询条件    如：( id=?)      * @param selectionArgs     条件里的参数，用来替换"?"      * @param orderBy           排序              如：id desc      * @param pageNo            页码              不分页时，为null      * @param pageSize          每页的个数        不分页时，为null      * @return                  返回List      */     @SuppressWarnings("unchecked")     public List queryList(Class> classz, String table, String[] columns, String selection,             String[] selectionArgs, String orderBy, Integer pageNo, Integer pageSize){                   //分页         if(!(pageNo == null || pageSize ==null)){             //分页的起始位置             int begin = (pageNo -1)*pageSize;             orderBy = orderBy + " limit " + begin + ", " + pageSize;         }                             //查询数据         Cursor c = db.query(table, columns, selection, selectionArgs, null, null, orderBy);                   List list = new ArrayList();         T t = null;         while (c.moveToNext()) {             try{                 //生成新的实例                 t = (T) classz.newInstance();             }catch(Exception e){                 Log.e("newInstance error", "生成新实例时出错 ：" + e.toString());             }                           //把列的值，转换成对象里属性的值             columnToField(t, c);                           list.add(t);         }         c.close();                   return list;     }                 /**      * 把列的值，转换成对象里属性的值      */     private void columnToField(T t, Cursor c){         //获取T里的所有属性         Field[] f = t.getClass().getDeclaredFields();         for (int i = 0; i   classz = f.getType();             //设置成可访问，否则不能set值             f.setAccessible(true);                           try {                 if(classz == Integer.TYPE) {   //int                     f.set(t, c.getInt(columnIndex));                 }else if(classz == String.class){   //String                     f.set(t, c.getString(columnIndex));                 }else if(classz == Long.TYPE){   //long                     f.set(t, c.getLong(columnIndex));                 }else if(classz == byte[].class){   //byte                     f.set(t, c.getBlob(columnIndex));                 }else if(classz == Float.TYPE){   //float                     f.set(t, c.getFloat(columnIndex));                 }else if(classz == Double.TYPE){   //double                     f.set(t, c.getDouble(columnIndex));                 }else if(classz == Short.TYPE){   //short                     f.set(t, c.getShort(columnIndex));                 }             } catch (Exception e) {                 Log.e("column to field error", "字段转换成对象时出错 ：" + e.toString());             }         }     }         /**      * 开始事务      */     protected void beginTransaction() {         db.beginTransaction();     }       /**      * 提交事务及结束事务      */     protected void commit() {         db.setTransactionSuccessful();         db.endTransaction();     }       /**      * 回滚事务      */     protected void rollback() {         db.endTransaction();     }       /**      * 关闭连接      */     public void close() {         if (db != null && db.isOpen())             db.close();     } }  数据库创建、升级 [code="java"] package com.juziku.demo.sqlite;   import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader;   import android.content.Context; import android.database.sqlite.SQLiteDatabase; import android.database.sqlite.SQLiteDatabase.CursorFactory; import android.database.sqlite.SQLiteOpenHelper; import android.util.Log;   public class DBHelper extends SQLiteOpenHelper {       private Context mContext;       public DBHelper(Context context, String databaseName,             CursorFactory factory, int version) {         super(context, databaseName, factory, version);         mContext = context;     }       /**      * 数据库第一次创建时调用      * */     @Override     public void onCreate(SQLiteDatabase db) {         executeSchema(db, "schema.sql");     }       /**      * 数据库升级时调用      * */     @Override     public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {         //数据库不升级         if (newVersion
人人编程
　　
http://www.renren.io/sql/