From 7167ce41b61d2ba2cdb526777a4233eb84a3b66a Mon Sep 17 00:00:00 2001
From: Unit 193 <unit193@ubuntu.com>
Date: Sat, 6 Dec 2014 17:33:25 -0500
Subject: Imported Upstream version 2.99.6

---
 .../coreSQLiteStudio/db/asyncqueryrunner.cpp       | 62 ++++++++++++++++++++++
 1 file changed, 62 insertions(+)
 create mode 100644 SQLiteStudio3/coreSQLiteStudio/db/asyncqueryrunner.cpp

(limited to 'SQLiteStudio3/coreSQLiteStudio/db/asyncqueryrunner.cpp')

diff --git a/SQLiteStudio3/coreSQLiteStudio/db/asyncqueryrunner.cpp b/SQLiteStudio3/coreSQLiteStudio/db/asyncqueryrunner.cpp
new file mode 100644
index 0000000..ff7e51a
--- /dev/null
+++ b/SQLiteStudio3/coreSQLiteStudio/db/asyncqueryrunner.cpp
@@ -0,0 +1,62 @@
+#include "db/asyncqueryrunner.h"
+#include "db/sqlquery.h"
+#include "db/db.h"
+#include <QDebug>
+
+AsyncQueryRunner::AsyncQueryRunner(const QString &query, const QVariant& args, Db::Flags flags)
+    : query(query), args(args), flags(flags)
+{
+    init();
+}
+
+void AsyncQueryRunner::init()
+{
+    setAutoDelete(false);
+}
+
+void AsyncQueryRunner::run()
+{
+    if (!db || !db->isValid())
+    {
+        qCritical() << "No Db or invalid Db defined in AsyncQueryRunner!";
+        emit finished(this);
+    }
+
+    SqlQueryPtr res;
+    if (args.userType() == QVariant::List)
+    {
+        res = db->exec(query, args.toList(), flags);
+    }
+    else if (args.userType() == QVariant::Hash)
+    {
+        res = db->exec(query, args.toHash(), flags);
+    }
+    else
+    {
+        qCritical() << "Invalid argument type in AsyncQueryRunner::run():" << args.userType();
+    }
+
+    results = SqlQueryPtr(res);
+    emit finished(this);
+}
+
+SqlQueryPtr AsyncQueryRunner::getResults()
+{
+    return results;
+}
+
+
+void AsyncQueryRunner::setDb(Db *db)
+{
+    this->db = db;
+}
+
+void AsyncQueryRunner::setAsyncId(quint32 id)
+{
+    asyncId = id;
+}
+
+quint32 AsyncQueryRunner::getAsyncId()
+{
+    return asyncId;
+}
-- 
cgit v1.2.3