From b1b663239741e95fc1087de186a10e5e762135db Mon Sep 17 00:00:00 2001 From: Damyan Ivanov Date: Sun, 24 Mar 2019 11:32:54 +0200 Subject: [PATCH] async database statement queue the idea is to take quick database updates outside the main (UI) thread this helps when the database is in a transaction updating accounts or transactions which can take considerable time --- .../net/ktnx/mobileledger/async/DbOpItem.java | 30 ++++++++++++ .../ktnx/mobileledger/async/DbOpQueue.java | 45 ++++++++++++++++++ .../ktnx/mobileledger/async/DbOpRunner.java | 47 +++++++++++++++++++ .../ui/activity/MainActivity.java | 1 + 4 files changed, 123 insertions(+) create mode 100644 app/src/main/java/net/ktnx/mobileledger/async/DbOpItem.java create mode 100644 app/src/main/java/net/ktnx/mobileledger/async/DbOpQueue.java create mode 100644 app/src/main/java/net/ktnx/mobileledger/async/DbOpRunner.java diff --git a/app/src/main/java/net/ktnx/mobileledger/async/DbOpItem.java b/app/src/main/java/net/ktnx/mobileledger/async/DbOpItem.java new file mode 100644 index 00000000..7ecce275 --- /dev/null +++ b/app/src/main/java/net/ktnx/mobileledger/async/DbOpItem.java @@ -0,0 +1,30 @@ +/* + * Copyright © 2019 Damyan Ivanov. + * This file is part of MoLe. + * MoLe is free software: you can distribute it and/or modify it + * under the term of the GNU General Public License as published by + * the Free Software Foundation, either version 3 of the License, or + * (at your opinion), any later version. + * + * MoLe is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License terms for details. + * + * You should have received a copy of the GNU General Public License + * along with MoLe. If not, see . + */ + +package net.ktnx.mobileledger.async; + +class DbOpItem { + String sql; + Object[] params; + public DbOpItem(String sql, Object[] params) { + this.sql = sql; + this.params = params; + } + public DbOpItem(String sql) { + this(sql, null); + } +} diff --git a/app/src/main/java/net/ktnx/mobileledger/async/DbOpQueue.java b/app/src/main/java/net/ktnx/mobileledger/async/DbOpQueue.java new file mode 100644 index 00000000..7bf5cec3 --- /dev/null +++ b/app/src/main/java/net/ktnx/mobileledger/async/DbOpQueue.java @@ -0,0 +1,45 @@ +/* + * Copyright © 2019 Damyan Ivanov. + * This file is part of MoLe. + * MoLe is free software: you can distribute it and/or modify it + * under the term of the GNU General Public License as published by + * the Free Software Foundation, either version 3 of the License, or + * (at your opinion), any later version. + * + * MoLe is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License terms for details. + * + * You should have received a copy of the GNU General Public License + * along with MoLe. If not, see . + */ + +package net.ktnx.mobileledger.async; + +import android.util.Log; + +import java.util.concurrent.BlockingQueue; +import java.util.concurrent.LinkedBlockingQueue; + +public class DbOpQueue { + static private final BlockingQueue queue = new LinkedBlockingQueue<>(); + static private DbOpRunner runner; + synchronized static public void init() { + if (runner != null) return; + Log.d("opQueue", "Starting runner thread"); + runner = new DbOpRunner(queue); + runner.start(); + } + static public void done() { + runner.interrupt(); + } + public static void add(String sql, Object[] params) { + init(); + Log.d("opQueue", "Adding " + sql); + queue.add(new DbOpItem(sql, params)); + } + static void add(String sql) { + queue.add(new DbOpItem(sql)); + } +} diff --git a/app/src/main/java/net/ktnx/mobileledger/async/DbOpRunner.java b/app/src/main/java/net/ktnx/mobileledger/async/DbOpRunner.java new file mode 100644 index 00000000..9404d7d0 --- /dev/null +++ b/app/src/main/java/net/ktnx/mobileledger/async/DbOpRunner.java @@ -0,0 +1,47 @@ +/* + * Copyright © 2019 Damyan Ivanov. + * This file is part of MoLe. + * MoLe is free software: you can distribute it and/or modify it + * under the term of the GNU General Public License as published by + * the Free Software Foundation, either version 3 of the License, or + * (at your opinion), any later version. + * + * MoLe is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License terms for details. + * + * You should have received a copy of the GNU General Public License + * along with MoLe. If not, see . + */ + +package net.ktnx.mobileledger.async; + +import android.database.sqlite.SQLiteDatabase; +import android.util.Log; + +import net.ktnx.mobileledger.utils.MLDB; + +import java.util.concurrent.BlockingQueue; + +class DbOpRunner extends Thread { + private final BlockingQueue queue; + public DbOpRunner(BlockingQueue queue) { + this.queue = queue; + } + @Override + public void run() { + while (!interrupted()) { + try { + DbOpItem item = queue.take(); + Log.d("opQrunner", "Got "+item.sql); + SQLiteDatabase db = MLDB.getDatabase(); + Log.d("opQrunner", "Executing "+item.sql); + db.execSQL(item.sql, item.params); + } + catch (InterruptedException e) { + break; + } + } + } +} diff --git a/app/src/main/java/net/ktnx/mobileledger/ui/activity/MainActivity.java b/app/src/main/java/net/ktnx/mobileledger/ui/activity/MainActivity.java index 3e8e9c56..cfceb7ca 100644 --- a/app/src/main/java/net/ktnx/mobileledger/ui/activity/MainActivity.java +++ b/app/src/main/java/net/ktnx/mobileledger/ui/activity/MainActivity.java @@ -38,6 +38,7 @@ import android.widget.Toast; import com.google.android.material.floatingactionbutton.FloatingActionButton; import net.ktnx.mobileledger.R; +import net.ktnx.mobileledger.async.DbOpQueue; import net.ktnx.mobileledger.async.RefreshDescriptionsTask; import net.ktnx.mobileledger.async.RetrieveTransactionsTask; import net.ktnx.mobileledger.model.Data; -- 2.39.2