Android多線程下安全訪問數據庫

 // Thread 2
 Context context = getApplicationContext();
 DatabaseHelper helper = new DatabaseHelper(context);
 SQLiteDatabase database = helper.getWritableDatabase();
 database.insert(…);
 database.close();

        而後在你的Logcat中將輸出相似下面的日誌信息,而你的寫數據操做將會無效。java

android.database.sqlite.SQLiteDatabaseLockedException: database is locked (code 5)

       上面問題的出現,源於你每建立一個 SQLiteOpenHelper  對象時,實際上也是在新建一個數據庫鏈接。若是你嘗試經過多個鏈接同時對數據庫進行寫數據操做,其必定會失敗。android

       爲確保咱們能在多線程中安全地操做數據庫,咱們須要保證只有一個數據庫鏈接被佔用。git

       咱們先編寫一個負責管理單個 SQLiteOpenHelper 對象的單例 DatabaseManager 。 github

public class DatabaseManager {

    private static DatabaseManager instance;
    private static SQLiteOpenHelper mDatabaseHelper;

    public static synchronized void initialize(Context context, SQLiteOpenHelper helper) {
        if (instance == null) {
            instance = new DatabaseManager();
            mDatabaseHelper = helper;
        }
    }

    public static synchronized DatabaseManager getInstance() {
        if (instance == null) {
            throw new IllegalStateException(DatabaseManager.class.getSimpleName() +
                    " is not initialized, call initialize(..) method first.");
        }

        return instance;
    }

    public synchronized SQLiteDatabase getDatabase() {
        return new mDatabaseHelper.getWritableDatabase();
    }}

        爲了能在多線程中進行寫數據操做,咱們得修改一下代碼,具體以下: sql

// In your application class
 DatabaseManager.initializeInstance(getApplicationContext());

 // Thread 1
 DatabaseManager manager = DatabaseManager.getInstance();
 SQLiteDatabase database = manager.getDatabase()
 database.insert(…);
 database.close();

 // Thread 2
 DatabaseManager manager = DatabaseManager.getInstance();
 SQLiteDatabase database = manager.getDatabase()
 database.insert(…);
 database.close();

        而後又致使另個崩毀數據庫

java.lang.IllegalStateException: attempt to re-open an already-closed object: SQLiteDatabase

        既然咱們只有一個數據庫鏈接,Thread1 和 Thread2 對方法 getDatabase() 的調用就會取得同樣的 SQLiteDatabase 對象實例。以後的事情就是,當 Thread1 嘗試管理數據庫鏈接時,Thread2 卻仍然在使用該數據庫鏈接。這也就是致使 IllegalStateException 崩毀的緣由。安全

        所以咱們只能在確保數據庫沒有再被佔用的狀況下,纔去關閉它。在 stackoveflow 上有一些討論推薦「永不關閉」你的 SQLiteDatabase 。  若是你這樣作,你的logcat將會出現如下的信息,所以我不認爲這是一個好主意。多線程

Leak foundCaused by: java.lang.IllegalStateException: SQLiteDatabase created and never closed

       示例:併發

public class DatabaseManager {

    private AtomicInteger mOpenCounter = new AtomicInteger();

    private static DatabaseManager instance;
    private static SQLiteOpenHelper mDatabaseHelper;
    private SQLiteDatabase mDatabase;

    public static synchronized void initializeInstance(SQLiteOpenHelper helper) {
        if (instance == null) {
            instance = new DatabaseManager();
            mDatabaseHelper = helper;
        }
    }

    public static synchronized DatabaseManager getInstance() {
        if (instance == null) {
            throw new IllegalStateException(DatabaseManager.class.getSimpleName() +
                    " is not initialized, call initializeInstance(..) method first.");
        }

        return instance;
    }

    public synchronized SQLiteDatabase openDatabase() {
        if(mOpenCounter.incrementAndGet() == 1) {
            // Opening new database
            mDatabase = mDatabaseHelper.getWritableDatabase();
        }
        return mDatabase;
    }

    public synchronized void closeDatabase() {
        if(mOpenCounter.decrementAndGet() == 0) {
            // Closing database
            mDatabase.close();

        }
    }}

         而後你能夠怎樣子去調用它:app

SQLiteDatabase database = DatabaseManager.getInstance().openDatabase();database.insert(...);// database.close(); Don't close it directly!DatabaseManager.getInstance().closeDatabase(); // correct way

         之後每當你須要使用數據庫鏈接,你能夠經過調用類 DatabaseManager 的方法openDatabase()。在方法裏面,內置一個標誌數據庫被打開多少次的計數器。若是計數爲1,表明咱們須要打開一個新的數據庫鏈接,不然,數據庫鏈接已經存在。

在方法 closeDatabase() 中,狀況也同樣。每次咱們調用 closeDatabase() 方法,計數器都會遞減,直到計數爲0,咱們就須要關閉數據庫鏈接了。

         提示: 你應該使用 AtomicInteger 來處理併發的狀況

         如今你能夠線程安全地使用你的數據庫鏈接了。


         原文: https://github.com/dmytrodanylyk/dmytrodanylyk/blob/gh-pages/articles/Concurrent%20Database%20Access.md

相關文章
相關標籤/搜索