android-一個檔案搞定SQLite資料庫的建立與更新以及增刪查改
阿新 • • 發佈:2018-11-14
一、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"));
}