X-Git-Url: https://git.ktnx.net/?a=blobdiff_plain;f=app%2Fsrc%2Fmain%2Fjava%2Fnet%2Fktnx%2Fmobileledger%2Fasync%2FDbOpRunner.java;fp=app%2Fsrc%2Fmain%2Fjava%2Fnet%2Fktnx%2Fmobileledger%2Fasync%2FDbOpRunner.java;h=0000000000000000000000000000000000000000;hb=68065ad8c5267a82c9d3e024a98e1adb3c3bdfd0;hp=f8ea577554a1511c96691d614334d0e567a7097d;hpb=6e815a8613c191e76a4346f0e23b88bf50a8b02c;p=mobile-ledger.git diff --git a/app/src/main/java/net/ktnx/mobileledger/async/DbOpRunner.java b/app/src/main/java/net/ktnx/mobileledger/async/DbOpRunner.java deleted file mode 100644 index f8ea5775..00000000 --- a/app/src/main/java/net/ktnx/mobileledger/async/DbOpRunner.java +++ /dev/null @@ -1,69 +0,0 @@ -/* - * Copyright © 2020 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 net.ktnx.mobileledger.App; -import net.ktnx.mobileledger.BuildConfig; - -import java.util.concurrent.BlockingQueue; - -import static net.ktnx.mobileledger.utils.Logger.debug; - -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(); - debug("opQRunner", "Got " + item.sql); - { - SQLiteDatabase db = App.getDatabase(); - if (BuildConfig.DEBUG) { - StringBuilder b = new StringBuilder("Executing "); - b.append(item.sql); - if (item.params.length > 0) { - boolean first = true; - b.append(" ["); - for (Object p : item.params) { - if (first) - first = false; - else - b.append(", "); - b.append(p.toString()); - } - b.append("]"); - } - debug("opQRunner", b.toString()); - } - db.execSQL(item.sql, item.params); - } - if (item.onReady != null) - item.onReady.run(); - } - catch (InterruptedException e) { - break; - } - } - } -}