Changeset e662750 for src/sql/sqlengine.cpp

Timestamp:

01/21/10 10:49:41 (12 years ago)

Author:

timkoma <timkoma@…>

Branches:

master, qt5

Children:

72cd3af

Parents:

842f5f9

Message:

first working version of the search

File:

• src/sql/sqlengine.cpp (modified) (3 diffs)

src/sql/sqlengine.cpp

@@ -38 +38 @@
         result = createTables(database);
     }
-
-    database.open();
+    else
+    {
+        database.open();
+    }
 
     //LOG_INFO(QString("Opening '%1' database '%2'").arg(aDatabaseType).arg(aDatabaseName));
@@ -318 +320 @@
         return -1;
 
-    QString query = QString(
-        "DROP TABLE IF EXISTS SEARCH_EVENT;"
-        "CREATE TEMP TABLE SEARCH_EVENT ( xid_conference INTEGER  NOT NULL, id INTEGER NOT NULL );"
-        "INSERT INTO SEARCH_EVENT ( xid_conference, id) "
-            "SELECT xid_conference, id FROM EVENT AS e INNER JOIN VIRTUAL_EVENT AS ve USING (xid_conference, id) "
-            "WHERE xid_conference = %1 AND (").arg( aConferenceId );
-
+
+    // DROP
+    execQuery( db, "DROP TABLE IF EXISTS SEARCH_EVENT;");
+    // CREATE
+    execQuery( db, "CREATE TABLE SEARCH_EVENT ( xid_conference INTEGER  NOT NULL, id INTEGER NOT NULL );");
+    // INSERT
+    QString query = QString("INSERT INTO SEARCH_EVENT ( xid_conference, id) "
+                "SELECT xid_conference, id FROM EVENT AS e INNER JOIN VIRTUAL_EVENT AS ve USING (xid_conference, id) "
+                "WHERE xid_conference = %1 AND (").arg( aConferenceId );
     int i = 0;
     foreach (QString str, aColumns){
@@ -332 +336 @@
     query += QString(");");
 
-    qDebug() << "\nSQL: " << query;
-
-    db.exec();
-
-    if( db.lastError().isValid() && db.lastError().number() != 0 ){
-        qDebug() << "SQL ERR: " << db.lastError().number() << ", " << db.lastError().text();
-        return 0;
+    execQuery( db, query );
+
+    //TODO: retun number of rows from SEARCH_EVENT
+    return 1;
+}
+
+bool SqlEngine::execQuery(QSqlDatabase &aDatabase, const QString &aQuery)
+{
+    qDebug() << "\nSQL: " << aQuery;
+
+    QSqlQuery sqlQuery(aDatabase);
+    if( !sqlQuery.exec(aQuery) ){
+       qDebug() << "SQL ERR: " << sqlQuery.lastError().number() << ", " << sqlQuery.lastError().text();
+       return false;
     }
     else{
-        qDebug() << "SQL OK.\n";
-        return 1;
-    }
-
-}
+       qDebug() << "SQL OK.\n";
+       return true;
+    }
+}