1 files changed, 126 insertions, 0 deletions
diff --git a/SQLiteStudio3/coreSQLiteStudio/db/asyncqueryrunner.h b/SQLiteStudio3/coreSQLiteStudio/db/asyncqueryrunner.h
new file mode 100644
index 0000000..5f0e41c
--- /dev/null
+++ b/SQLiteStudio3/coreSQLiteStudio/db/asyncqueryrunner.h
@@ -0,0 +1,126 @@
+#ifndef ASYNCQUERYRUNNER_H
+#define ASYNCQUERYRUNNER_H
+
+#include "db.h"
+
+#include <QVariant>
+#include <QHash>
+#include <QRunnable>
+#include <QString>
+#include <QPointer>
+#include <QByteArray>
+
+/**
+ * @brief Direct query executor to be run in a thread.
+ *
+ * It's an implementation of QRunnable (so it can be run simply within QThread),
+ * that takes query string and arguments for the query and executes the query
+ * in separate thread (the one that is owning the runner).
+ *
+ * The runner is not deleted automatically. Instead the slot for finished() signal
+ * has to delete it. It's done like that because the slot will also be interested
+ * in execution results and asyncId, before the runner gets deleted.
+ *
+ * What it does is simply execute Db::exec() from another thread.
+ *
+ * It's a kind of helper class that is used to implement Db::asyncExec().
+ */
+class AsyncQueryRunner : public QObject, public QRunnable
+{
+    Q_OBJECT
+
+    public:
+        /**
+         * @brief Creates runner and defines basic parameters.
+         * @param query Query string to be executed.
+         * @param args Parameters to the query (can be either QHash or QList).
+         * @param flags Execution flags, that will be later passed to Db::exec().
+         *
+         * It's not enough to just create runner. You also need to define db with setDb()
+         * and asyncId with setAsyncId().
+         */
+        AsyncQueryRunner(const QString& query, const QVariant& args, Db::Flags flags);
+
+        /**
+         * @brief Executes query.
+         *
+         * This is the major method inherited from QRunnable. It's called from another thread
+         * and it executes the query.
+         */
+        void run();
+
+        /**
+         * @brief Provides result from execution.
+         * @return Execution results.
+         */
+        SqlQueryPtr getResults();
+
+        /**
+         * @brief Defines database for execution.
+         * @param db Database object.
+         */
+        void setDb(Db* db);
+
+        /**
+         * @brief Defines asynchronous ID for this execution.
+         * @param id Unique ID.
+         */
+        void setAsyncId(quint32 id);
+
+        /**
+         * @brief Provides previously defined asynchronous ID.
+         * @return Unique asynchronous ID.
+         */
+        quint32 getAsyncId();
+
+    private:
+        /**
+         * @brief Initializes default values.
+         */
+        void init();
+
+        /**
+         * @brief Database to execute the query on.
+         */
+        Db* db = nullptr;
+
+        /**
+         * @brief Query to execute.
+         */
+        QString query;
+
+        /**
+         * @brief Results from execution.
+         */
+        SqlQueryPtr results;
+
+        /**
+         * @brief Parameters for execution.
+         *
+         * It's either QList<QVariant> or QHash<QString,QVariant>. If it's anything else,
+         * then no execution will be performed and critical error will be logged.
+         */
+        QVariant args;
+
+        /**
+         * @brief The unique asynchronous ID for this query execution.
+         */
+        quint32 asyncId;
+
+        /**
+         * @brief Execution flags passed to Db::exec().
+         */
+        Db::Flags flags;
+
+    signals:
+        /**
+         * @brief Emitted after the runner has finished its job.
+         *
+         * Slot connected to this signal should at least delete the runner,
+         * but it can also extract execution results.
+         */
+        void finished(AsyncQueryRunner*);
+};
+
+
+#endif // ASYNCQUERYRUNNER_H