1. 程式人生 > >android-一個檔案搞定SQLite資料庫的建立與更新以及增刪查改

android-一個檔案搞定SQLite資料庫的建立與更新以及增刪查改

一、SQLite簡介

1、簡介
Android嵌入式關係型資料庫——SQLite。SQLite 是一款輕量級的關係型資料庫,它運算速度快, 佔用資源很少,通常只需要幾百 K 的記憶體就足夠了,因而特別適合在移動裝置上使用。SQLite 支援標準的 SQL 語法,還遵循了資料庫的 ACID 事務。SQLite的使用 一般的資料庫要簡單得多,資料庫中所有的資訊(比如表、檢視等)都包含在一個檔案內。這個檔案可以自由複製到其它目錄或其它機器上。

2、資料型別

資料型別 描述
INTEGER 值為整數
TEXT 字串
REAL 浮動的數值,被儲存為8位元組的IEEE浮動標記序號
VARCHAR 字串長度不超過4000
CHAR 字串長度不超過254
BLOB 以輸入的資料格式進行儲存,不會改變格式
DATA 年月日
TIME 時分秒
NULL 值為空

二、使用

1.SQLiteOpenHelper

Android 為了讓我們能夠更加方便地管理資料庫,專門提供了一個 幫 助類SQLiteOpenHelper,藉助這個類就可以非常簡單地對資料庫進行建立和升級。當在程式當中呼叫這個類的方法getWritableDatabase()或者getReadableDatabase()方法的時候,如果當時沒有資料,那麼Android系統就會自動生成一個數據庫。

 private static class DataBaseManagementHelper extends SQLiteOpenHelper {

    private
static final String DB_NAME = "user_data"; private static final String TABLE_NAME = "users"; //建立使用者book表 private static final String DB_CREATE = "CREATE TABLE " + TABLE_NAME + " (" + ID + " INTEGER PRIMARY KEY AUTOINCREMENT," + USER_NAME + " TEXT," + USER_PWD + " TEXT" + ");"; DataBaseManagementHelper(Context context) { super(context, DB_NAME, null, DB_VERSION); } //這裡要實現實現SQLiteOpenHelper裡面的3個函式: @Override public void onCreate(SQLiteDatabase db) { Log.i(TAG,"db.getVersion()="+db.getVersion()); db.execSQL("DROP TABLE IF EXISTS " + TABLE_NAME + ";"); db.execSQL(DB_CREATE); Log.i(TAG, "db.execSQL(DB_CREATE)"); Log.e(TAG, DB_CREATE); } @Override public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) { Log.i(TAG, "DataBaseManagementHelper onUpgrade"); onCreate(db); } @Override public void onOpen(SQLiteDatabase db) { super.onOpen(db); //這個不常用 } }

2.下面是具體的一個程式碼管理資料庫類

/**
 * @author daxue
 * @version 建立時間:2018-08-23 上午11:27:01
 */

public class RunRecordManager {
    private static final String TAG = "RunRecordManager";
    private static final String DB_NAME = "runrecord_data";//資料庫名
    private static final String TABLE_NAME = "runrecord";//表名
    //資料庫更新時候用的
    private static String CREATE_TEMP_BOOK = "alter table runrecord rename to _temp";
    private static String INSERT_DATA = "insert into runrecord select *,' ',' ',' ' from _temp";
    private static String DROP_BOOK = "drop table _temp";

    private static final int DB_VERSION = 2;//資料庫版本號
    private Context mContext = null;

    private SQLiteDatabase mSQLiteDatabase = null;
    private DataBaseManagementHelper mDatabaseHelper = null;

    public RunRecordManager(Context context) {
        mContext = context;
        Log.i(TAG, "UserDataManager construction!");
    }

    //DataBaseManagementHelper繼承自SQLiteOpenHelper
    private static class DataBaseManagementHelper extends SQLiteOpenHelper {

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

        @Override
        public void onCreate(SQLiteDatabase db) {
            Log.i(TAG,"db.getVersion()="+db.getVersion());
            db.execSQL(getSql());
        }

        //onUpgrade這個方法是資料庫更新的時候用到的,根據上面定義的newVersion,來判斷是否更新
        @Override
        public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
            Log.i(TAG, "DataBaseManagementHelper onUpgrade");
                switch (newVersion) {
                    case 2:
                        db.execSQL(CREATE_TEMP_BOOK);
                        db.execSQL(getSql());
                        db.execSQL(INSERT_DATA);
                        db.execSQL(DROP_BOOK);
                        break;
                }

        }
    }
    //建立資料庫表的sql語句
    private static String getSql(){
        String sql = String.format("create table %s ( %s INTEGER PRIMARY KEY AUTOINCREMENT,"
                        + " %s TEXT, %s TEXT,%s TEXT, %s TEXT, %s TEXT);",
                TABLE_NAME,
                PcrConfig.Columns._ID,
                PcrConfig.Columns.USER_NAME,
                PcrConfig.Columns.EXPER_ID,
                PcrConfig.Columns.EXPER_NAME,
                PcrConfig.Columns.CREAT_TIME,
                PcrConfig.Columns.RUN_TIME);

        if(PcrConfig.debug) {
            Log.d(TAG, "sql:"+ sql);
        }
        return sql;
    }


    //開啟資料庫
    public void openDataBase() throws SQLException {
        mDatabaseHelper = new DataBaseManagementHelper(mContext);
        mSQLiteDatabase = mDatabaseHelper.getWritableDatabase();
    }
    //關閉資料庫
    public void closeDataBase() throws SQLException {
        mDatabaseHelper.close();
    }
    //新增記錄(插入資料)
    public long insertRecordData(RunRecordBean data) {
        ContentValues values = new ContentValues();
        values.put(PcrConfig.Columns.USER_NAME, data.getUserName());
        values.put(PcrConfig.Columns.EXPER_NAME, data.getExperName());
        values.put(PcrConfig.Columns.EXPER_ID, data.getId());
        values.put(PcrConfig.Columns.CREAT_TIME, data.getCreatTime());
        values.put(PcrConfig.Columns.RUN_TIME, data.getRunTime());
        return mSQLiteDatabase.insert(TABLE_NAME, PcrConfig.Columns._ID, values);
    }

    public Cursor fetchUserData(int id) throws SQLException {
        Cursor mCursor = mSQLiteDatabase.query(false, TABLE_NAME, null, PcrConfig.Columns._ID
                + "=" + id, null, null, null, null, null);
        if (mCursor != null) {
            mCursor.moveToFirst();
        }
        return mCursor;
    }
    //
    public Cursor fetchAllUserDatas() {
        return mSQLiteDatabase.query(TABLE_NAME, null, null, null, null, null,
                null);
    }
    //根據id刪除使用者
    public boolean deleteUserData(int id) {
        return mSQLiteDatabase.delete(TABLE_NAME, PcrConfig.Columns._ID + "=" + id, null) > 0;
    }
    //根據使用者名稱登出
    public boolean deleteUserDatabyname(String name) {
        return mSQLiteDatabase.delete(TABLE_NAME, PcrConfig.Columns.USER_NAME + "='" + name+"'", null) > 0;
    }
    //刪除所有使用者
    public boolean deleteAllUserDatas() {
        return mSQLiteDatabase.delete(TABLE_NAME, null, null) > 0;
    }
   //更新使用者資訊,如修改密碼
    public boolean updateUserData(UserData userData) {
        //int id = userData.getUserId();
        String userName = userData.getUserName();
        String userPwd = userData.getUserPwd();
        ContentValues values = new ContentValues();
        values.put(USER_NAME, userName);
        values.put(USER_PWD, userPwd);
        return mSQLiteDatabase.update(TABLE_NAME, values,null, null) > 0;
        //return mSQLiteDatabase.update(TABLE_NAME, values, ID + "=" + id, null) > 0;
    }
    //獲取全部記錄
    public List<RunRecordBean> getAllUserDatas() {
        List<RunRecordBean> ret=new ArrayList<RunRecordBean>();
        try{
            Cursor cursor = mSQLiteDatabase.query(TABLE_NAME, null, null, null, null, null,
                    null);
            if(cursor != null){
                while(cursor.moveToNext()){
                    RunRecordBean value = new RunRecordBean();
                    String str = cursor.getString(cursor.getColumnIndex(PcrConfig.Columns.EXPER_ID));
                    value.setExperId(str);
                    str = cursor.getString(cursor.getColumnIndex(PcrConfig.Columns._ID));
                    value.setId(str);
                    str = cursor.getString(cursor.getColumnIndex(PcrConfig.Columns.USER_NAME));
                    value.setUserName(str);
                    str = cursor.getString(cursor.getColumnIndex(PcrConfig.Columns.EXPER_NAME));
                    value.setExperName(str);
                    str = cursor.getString(cursor.getColumnIndex(PcrConfig.Columns.CREAT_TIME));
                    value.setCreatTime(str);
                    str = cursor.getString(cursor.getColumnIndex(PcrConfig.Columns.RUN_TIME));
                    value.setRunTime(str);
                    ret.add(value);
                }
                cursor.close();
            }
        } catch (Exception e){
            Log.d(TAG, "getAllUserDatas Execption "+e.toString());
        }

        return ret;
    }

}

3. 使用資料庫

  private RunRecordManager runrecManger=null;
  private void recRun() {
        if(runrecManger == null) {
            runrecManger = new RunRecordManager(this);
            runrecManger.openDataBase();
        }
        data.setUserName("daxue");
        data.setCreatTime("123");
        long flag = runrecManger.insertRecordData(data);

    }

4.清除資料庫

public void clearDatabases() {
        deleteFilesByDirectory(new File("/data/data/"
                + context.getPackageName() + "/databases"));
    }