如何多次调用 SQLiteOpenHelper 作为单个原子事务？

Question

我有一个SQLiteOpenHelper 类，它实现了单例模式并具有三个方法：addLogs()、getLogs() 和deleteLogs()。七个线程（由 BroadcastReceiver 在某些调度下触发）访问数据库——其中六个只使用addLogs()，另一个使用getLogs() 并在完成之前调用deleteLogs()。

我的问题是，因为最后一个线程对 SQLite 数据库进行了两次不同的调用，所以其他线程甚至可以在调用 deleteLogs() 之前调用 addLogs()，这会破坏我的输出。如何让一个线程将两个对 SQLiteOpenHelper 的调用视为单个原子事务？

我尝试过：在SQLiteOpenHelper 中创建一个静态ReentrantLock 成员，并在事务前后从七个线程中的每个线程调用lock() 和unlock()。即使最后一个线程仍然拥有锁，其他六个线程仍然可以通过，它在getLogs() 之前调用并在deleteLogs() 之后释放。

更新：这是访问这两种方法的第七个线程。

public class Uploader extends Thread {

    private Context context;

    public Uploader(Context context) {
        this.context = context;
    }

    @Override
    public void run() {
        Logger.d("STARTED: Uploader");
        DB db = DB.getInstance(context);
        List<JsonLog> logs = db.getLogs(); // FIRST CALL
        String json = new Gson().toJson(logs); // convert to JSON

        // connect to the server and upload
        HttpClient client = new DefaultHttpClient();
        HttpPost post = new HttpPost(This.URL);
        post.setHeader("content-type", "application/json");
        try {
            Logger.d("to upload: " + json);
            StringEntity se = new StringEntity(json);
            post.setEntity(se);
            StatusLine status = client.execute(post).getStatusLine();
            // if upload is successful
            if (status.getStatusCode() == HttpStatus.SC_OK) {
                db.deleteLogs(); // SECOND CALL
            } else {
                Logger.d("Uploader failed. " + status.getStatusCode() + ": " + status.getReasonPhrase());
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        Logger.d("FINISHED: Uploader");
    }

}

Answer 1

SQLite 有db.beginTransaction()、db.setTransactionSuccessful() 中的事务，用于标记要提交的 Tx，db.endTransaction() 最终将 Tx 标记为完成。

因此，您可以在 getLogs() 中执行 beginTransaction 并在 deleteLogs 中将其标记为已完成（并且成功）。

[更新] 现在，使用您的代码 sn-p，您可能希望在第一次调用之前调用 beginTransaction，并在 finally 块中调用，这会将 try-catch 块调用添加到 endTransaction。在try 部分结束时，如果状态正常，您将调用setTransactionSuccessful（在delete 调用之后。