2. 程式人生 > >Android SQLite使用詳解和多執行緒併發訪問

Android SQLite使用詳解和多執行緒併發訪問

阿新 • • 發佈：2019-02-02

Android中資料持久化技術包括檔案儲存、SharedPreferences以及資料庫儲存，對於大量複雜的關係型資料，資料庫無疑是最合適的選擇。

SQLite是一個輕量級的關係型資料庫，運算速度快，佔用資源少，適合在移動裝置上使用。SQLite不僅支援SQL語法，還遵循資料庫的ACID事務，使得本地持久化產生了質的飛躍。

首先我們建立類繼承SQliteOpenHelper抽象類，重寫onCreate和onUpgrade方法實現資料庫的建立和升級。

這裡為了方便多執行緒併發訪問資料庫，將類設計為單例模式。

package com.sdu.runningsdu.Utils;

import android.content.Context;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteOpenHelper;
import android.os.Build;
import android.util.Log;

/**
 * Created by FTDsm on 2018/6/4.
 */

public class DatabaseHelper extends SQLiteOpenHelper {

    private static String DB_NAME = "xxx.db";
    private static final int DB_VERSION = 1;
    private static DatabaseHelper databaseHelper;

    public DatabaseHelper(Context context, String name) {
        super(context, name, null, DB_VERSION);
        if(Build.VERSION.SDK_INT >= 11){
            getWritableDatabase().enableWriteAheadLogging();
        }
    }

    /**
     * 單例模式
     * @param context
     * @param name
     * @return DatabaseHelper
     */
    public static synchronized DatabaseHelper getInstance(Context context, String name) {
        if (databaseHelper == null) {
            databaseHelper = new DatabaseHelper(context, name);
        }
        return databaseHelper;
    }

    @Override
    public void onCreate(SQLiteDatabase sqLiteDatabase) {
        String userSQL = "create table if not exists user " +
                "(sid varchar(20) primary key, " +
                "name varchar(255), " +
                "password varchar(255), " +
                "imagePath varchar(255), " +
                "image blob)";
        sqLiteDatabase.execSQL(userSQL);
        Log.d("database", "create table user");

        String friendSQL = "create table if not exists friend " +
                "(sid varchar(20) primary key, " +
                "name varchar(255), " +
                "imagePath varchar(255), " +
                "unread integer, " +
                "image blob)";
        sqLiteDatabase.execSQL(friendSQL);
        Log.d("database", "create table friend");

        String groupSQL = "create table if not exists groups " +
                "(gid integer primary key, " +
                "name varchar(255), " +
                "creator varchar(255), " +
                "imagePath varchar(255), " +
                "unread varchar(255), " +
                "image blob)";
        sqLiteDatabase.execSQL(groupSQL);
        Log.d("database", "create table groups");

        String groupMemberSQL = "create table if not exists groupmember " +
                "(gid integer, " +
                "sid varchar(20)," +
                "primary key(gid, sid) )";
        sqLiteDatabase.execSQL(groupMemberSQL);
        Log.d("database", "create table groupmember");

        String friendMessageSQL = "create table if not exists friendmessage " +
                "(mid integer primary key, " +
                "sid varchar(20), " +
                "type integer, " +  /* 0接收 1傳送 */
                "content varchar(255), " +
                "time timestamp)";
        sqLiteDatabase.execSQL(friendMessageSQL);
        Log.d("database", "create table friendmessage");

        String groupMessageSQL = "create table if not exists groupmessage " +
                "(mid integer primary key, " +
                "gid integer, " +
                "sid varchar(20), " +
                "type integer, " +
                "content varchar(255), " +
                "time timestamp)";
        sqLiteDatabase.execSQL(groupMessageSQL);
        Log.d("database", "create table groupmessage");

        String requestSQL = "create table if not exists request " +
                "(rid integer primary key, " +
                "receiver varchar(20), " +
                "sender varchar(20), " +
                "message varchar(255), " +
                "time timestamp, " +
                "state integer)";
        sqLiteDatabase.execSQL(requestSQL);
        Log.d("database", "create table request");
    }

    @Override
    public void onUpgrade(SQLiteDatabase sqLiteDatabase, int i, int i1) {
        String userSQL = "drop table if exists user";
        sqLiteDatabase.execSQL(userSQL);
        String friendSQL = "drop table if exists friend";
        sqLiteDatabase.execSQL(friendSQL);
        String groupSQL = "drop table if exists group";
        sqLiteDatabase.execSQL(groupSQL);
        String groupMemberSQL = "drop table if exists groupmember";
        sqLiteDatabase.execSQL(groupMemberSQL);
        String friendMessageSQL = "drop table if exists friendmessage";
        sqLiteDatabase.execSQL(friendMessageSQL);
        String groupMessageSQL = "drop table if exists groupmessage";
        sqLiteDatabase.execSQL(groupMessageSQL);
        String requestSQL = "drop table if exists request";
        sqLiteDatabase.execSQL(requestSQL);
        onCreate(sqLiteDatabase);
    }

    @Override
    public synchronized void close() {
        super.close();
    }
}

然後我們建立Database Access Object類，完成資料增刪改查等操作，藉助SQLiteOpenHelper的getReadableDatabase()和getWritableDatabase()方法獲取對資料庫可讀或可寫操作物件。為了確保資料庫可併發訪問，有兩種解決方案，一是以單例模式例項化SQLiteOpenHelper，每次使用完不執行db.close()，以免另一個操作正在進行時關閉資料庫導致操作失敗，二是每次例項化新的SQLiteOpenHelper，並在使用結束後呼叫db.close()，這裡推薦第一種，效能更高且節省資源。

這裡以user為例，介紹資料庫的增刪改查操作。

package com.sdu.runningsdu.Utils;

import android.content.ContentValues;
import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.util.Log;

import com.sdu.runningsdu.JavaBean.Friend;
import com.sdu.runningsdu.JavaBean.Group;
import com.sdu.runningsdu.JavaBean.Message;
import com.sdu.runningsdu.JavaBean.Request;
import com.sdu.runningsdu.JavaBean.User;

import java.util.ArrayList;
import java.util.List;

/**
 * Created by FTDsm on 2018/6/4.
 */

public class MyDAO {

    private Context context;

    private String name;

    private DatabaseHelper databaseHelper;

    public MyDAO(Context context, String name) {
        this.context = context;
        this.name = name;
        this.databaseHelper = DatabaseHelper.getInstance(context, name);
        Log.d("database", "database name: " + databaseHelper.getDatabaseName());
    }

    /**
     * 查詢所有表格
     */
    public void findTable() {
        SQLiteDatabase db = this.databaseHelper.getReadableDatabase();
        Cursor cursor = db.rawQuery("select name from sqlite_master where type='table' order by name", null);
        Log.d("database", "table:\n");
        while (cursor.moveToNext()) {
            Log.d("database", cursor.getString(0));
        }
        cursor.close();
    }

    /**
     * 新增使用者
     * @param user User物件
     */
    public void addUser(User user) {
        SQLiteDatabase db = this.databaseHelper.getWritableDatabase();
        Object[] objects = new Object[3];
        objects[0] = user.getSid();
        objects[1] = user.getName();
        objects[2] = user.getPassword();
        String sql = "insert into user(sid, name, password) values(?,?,?)";
        db.execSQL(sql, objects);
        Log.d("database", "add user: " + user.getName());
    }

    /**
     * 刪除使用者
     * @param sid 使用者id
     */
    public void deleteUser(String sid) {
        SQLiteDatabase db = this.databaseHelper.getWritableDatabase();
        String sql = "delete from user where sid = ?";
        db.execSQL(sql, new Object[]{sid});
        Log.d("database", "delete user: " + sid);
    }

    /**
     * 更新使用者資訊
     * @param user User物件
     */
    public void updateUser(User user) {
        SQLiteDatabase db = this.databaseHelper.getWritableDatabase();
        Object[] objects = new Object[3];
        objects[0] = user.getName();
        objects[1] = user.getPassword();
        objects[2] = user.getSid();
        String sql = "update user set name=?, password=? where sid=?";
        db.execSQL(sql, objects);
        Log.d("database", "update user: " + user.getName());
    }

    /**
     * 查詢是否有使用者
     * @return 當前是否存在使用者
     */
    public boolean hasUser() {
        SQLiteDatabase db = this.databaseHelper.getReadableDatabase();
        Cursor cursor = db.query("user",
                null, null, null, null, null, null);
        Log.w("has user", ""+cursor.getCount());
        if (cursor.getCount() > 0) {
            return true;
        }
        cursor.close();
        return false;
    }

    /**
     * 查詢使用者資訊
     * @param sid 使用者id
     * @return User物件
     */
    public User findUser(String sid) {
        User user = new User();
        SQLiteDatabase db = this.databaseHelper.getReadableDatabase();
        Cursor cursor = db.query("user",
                new String[]{"sid", "name", "password", "imagePath"},
                "sid = ?",
                new String[]{sid},
                null, null, null);
        if (cursor.moveToNext()) {
            user.setSid(cursor.getString(cursor.getColumnIndex("sid")));
            user.setName(cursor.getString(cursor.getColumnIndex("name")));
            user.setPassword(cursor.getString(cursor.getColumnIndex("password")));
            user.setImagePath(cursor.getString(cursor.getColumnIndex("imagePath")));
        }
        Log.d("database", "find user: " + user.toString());
        cursor.close();
        return user;
    }

    /**
     * 查詢所有使用者
     * @return User列表
     */
    public List<User> findAllUser() {
        List<User> users = new ArrayList<>();
        SQLiteDatabase db = this.databaseHelper.getReadableDatabase();
        Cursor cursor = db.query("user",
                new String[]{"sid", "name", "password", "imagePath"},
                null, null, null, null, null);
        while (cursor.moveToNext()) {
            User user = new User();
            user.setSid(cursor.getString(cursor.getColumnIndex("sid")));
            user.setName(cursor.getString(cursor.getColumnIndex("name")));
            user.setPassword(cursor.getString(cursor.getColumnIndex("password")));
            user.setImagePath(cursor.getString(cursor.getColumnIndex("imagePath")));
            Log.d("database", "find user: " + user.toString());
            users.add(user);
        }
        cursor.close();
        return users;
    }
}

正如groupmember表中所定義，SQLite聯合主鍵採用如下寫法：

String sql= "create table if not exists groupmember " +
        "(gid integer, " +
        "sid varchar(20)," +
        "primary key(gid, sid) )";
sqLiteDatabase.execSQL(sql);

SQLite允許儲存varchar、char、integer、real、text、blob、date、time等型別，儲存圖片通常使用blob儲存byte陣列

/**
 * 更新使用者頭像
 * @param sid
 * @param image
 */
public void updateUserImage(String sid, String imagePath, byte[] image) {
    SQLiteDatabase db = this.databaseHelper.getWritableDatabase();
    ContentValues cv = new ContentValues();
    cv.put("imagePath", imagePath);
    cv.put("image", image);
    db.update("user", cv, "sid = ?", new String[]{sid});
}

相關推薦

Android SQLite使用詳解和多執行緒併發訪問

Android中資料持久化技術包括檔案儲存、SharedPreferences以及資料庫儲存，對於大量複雜的關係型資料，資料庫無疑是最合適的選擇。SQLite是一個輕量級的關係型資料庫，運算速度快，佔用資源少，適合在移動裝置上使用。SQLite不僅支援SQL語法，還遵循資料庫

Java資深架構師詳解大廠多執行緒面試題，細談併發程式設計深造歷程

  多執行緒、執行緒池 多執行緒是實現併發機制的一種有效手段。程序和執行緒一樣，都是實現併發的一個基本單位。執行緒是比程序更小的執行單位，執行緒是程序的基礎之上進行進一步的劃分。所謂多執行緒是指一個程序在執行過程中可以產生多個更小的程式單元，這些更小的單元稱為執行緒，這

Java 高併發程式設計詳解：多執行緒與架構設計

內容簡介 本書主要包含四個部分： 部分主要闡述 Thread 的基礎知識，詳細介紹執行緒的 API 使用、執行緒安全、執行緒間資料通訊，以及如何保護共享資源等內容，它是深入學習多執行緒內容的基礎。 第二部分引入了 ClassLoader，這是因為 ClassLoader 與執行緒不無關係

muduo網路庫——詳解muduo多執行緒模型

6.3     非阻塞網路程式設計應該用邊沿觸發（ET）還是電平觸發（LT）？如果是電平觸發，那麼什麼時候關注POLLOUT事件？會不會造成busy-loop?如果是邊沿觸發，如果和防止漏讀造成的飢餓？ epoll一定比poll快麼？ 6.4        在fi

lock Mutex Monitor 之間的區別與詳解, .net 多執行緒 同步非同步操作,鎖

Framework為我們提供了三個加鎖的機制，分別是Monitor類、Lock關 鍵字和Mutex類。 　　總體而言，lock和monitor可以鎖定物件，也可以鎖定函式；而mutex一般用於鎖定函式，並保證不同執行緒間同步呼叫函式，而不會受執行緒優先順序影響。使用lo

Linux 網路程式設計 全解（四）--------多程序併發伺服器和多執行緒併發伺服器

寫在前面：這個系列也是停滯了20多天了，從今天開始再次步入正軌，以後每個週末都會陸陸續續的更新，這個系列預計完結的時間還會在大約一個月左右，今天靜下心來多整理幾篇。QQ：993650814 正文： 一、多程序併發伺服器     設計思路：當有新的客戶端連線到

詳解Java多執行緒之記憶體可見性

可見性：一個執行緒對共享變數值的修改，能夠及時的被其他執行緒看到。  共享變數：如果一個電量在多個執行緒的工作記憶體中都存在副本，那麼這個變數就是這幾個執行緒的共享變數。 JAVA記憶體模型（Java Memory Model）描述了Java程式中各種變數（執行緒共享變

詳解Java多執行緒鎖之synchronized

synchronized是Java中解決併發問題的一種最常用的方法，也是最簡單的一種方法。 synchronized的四種使用方式 修飾程式碼塊：被修飾的程式碼塊稱為同步語句塊，其作用的範圍是大括號{}括起來的程式碼，作用於呼叫物件 修飾方法：被修飾的方法稱為同步方法，其作用的範圍是整個方法，作用於呼叫物件

Storm 的流量控制和多執行緒併發處理

面臨問題： storm多執行緒的時候，會遇到併發修改的問題，會報concurrentModificationException，如下圖所示 解決方法： 第一種治標不治本的方法： 一方面，對傳送到kafka的資料進行控制，將執行緒sleep的時

【多執行緒併發訪問的安全性問題】

【多執行緒併發訪問的安全性問題】 今天重新溫習了一下多執行緒併發訪問的問題，加強下記憶，決定寫一些東西記錄下來。【持續更新】 多執行緒併發訪問的安全性問題 首先要知道的是：多執行緒安全性問題產生的原因是什麼？ 多執行緒併發訪問是指當多個執行緒無序的訪問同一個共享資源時，這個

多執行緒併發訪問可能出現的崩潰問題

出現這個崩潰的現象是， 進入一個介面時，該介面會同時發起三個非同步請求操作。每個操作在發起資料請求時，都可能會調某一方法進行存取某一屬性值。 如屬性comName; 該屬性宣告為:@Property (nonatomic, strong) NSString *comName

自己在之前做兩個專案中遇到多執行緒併發訪問如何解決的一個簡單demo程式

package com.geloin.main; public class TestMoreThread { public static void main(String[] args) { final test t0=new test(); final te

同一資源多執行緒併發訪問時的完整性

  　　在Java中一共有四種方法支援同步，其中前三個是同步方法，一個是管道方法。管道方法不建議使用，阻塞佇列方法在問題4已有描述，現只提供前兩種實現方法。   - wait()/notify()方法   - await()/signal()方法  

Java併發程式設計(03)：多執行緒併發訪問，同步控制

本文原始碼：[GitHub·點這裡](https://github.com/cicadasmile/java-base-parent) || [GitEE·點這裡](https://gitee.com/cicadasmile/java-base-parent) # 一、併發問題 多執行緒學習的時候，要面

入坑JAVA多執行緒併發(八）詳解ThreadLocal使用和原理

　　ThreadLocal是一個用於儲存多執行緒變數的類，它可以把執行緒與設定的值對應起來，因為它為變數在每個執行緒都建立了一個副本。訪問的時候每個執行緒只能訪問到自己的副本變數。 例項 看如下程式碼： public class Main {

阻塞式和多執行緒 BIO 詳解 ServerSocket例項

1.什麼是IO流是一種抽象概念，它代表了資料的無結構化傳遞。按照流的方式進行輸入輸出，資料被當成無結構的位元組或字元序列。從流中取得資料的操作稱為讀取，而向流中新增資料的操作稱為寫入。用來進行輸入輸出操作的流就稱為IO流。換句話說，IO流就是以流的方式進行輸入輸出。用通俗的話

詳解多執行緒MT和多執行緒MD的區別

區別1：全域性堆控制代碼不一樣。 網上有一個說法，就是一個執行緒一個棧，一個模組一個堆。前者很容易有理解，每個執行緒建立的時候在CreateThread中都能制定預設棧大小，只是很多情況下都取了預設值。而一個模組一個堆呢？其實很簡單測試，如果是一個多執行緒MT編譯方式的程

Android多執行緒-----併發和同步（volatile）

volatile是Java提供的一種輕量級的同步機制，在併發程式設計中，它也扮演著比較重要的角色。同synchronized相比（synchronized通常稱為重量級鎖），volatile更輕量級，相比使用synchronized所帶來的龐大開銷，倘若能恰當的合理的使用volatile，自然是好事

Android多執行緒-----併發和同步（Lock）

一、為什麼需要Lock 如果一個程式碼塊被synchronized修飾了，當一個執行緒獲取了對應的鎖，並執行該程式碼塊時，其他執行緒便只能一直等待，等待獲取鎖的執行緒釋放鎖，而這裡獲取鎖的執行緒釋放鎖只會有兩種情況： 1）獲取鎖的執行緒執行完了該程式碼塊，然後執行緒釋放對鎖的佔有； 2）執行緒執

Android多執行緒-----併發和同步（synchronized）

一、鎖 物件的內建鎖和物件的狀態之間是沒有內在的關聯的，雖然大多數類都將內建鎖用做一種有效的加鎖機制，但物件的域並不一定通過內建鎖來保護。當獲取到與物件關聯的內建鎖時，並不能阻止其他執行緒訪問該物件，當某個執行緒獲得物件的鎖之後，只能阻止其他執行緒獲得同一個鎖。之所以每個物件都有一個內建鎖，是為