Changeset 15601

Timestamp:

2008-05-20T15:58:55+12:00 (16 years ago)

Author:

mdewsnip

Message:

(Adding new DB support) Started adding sqliteclass internals, beginning with an sqlexec() function.

Location:

gsdl/trunk/lib

Files:

• sqliteclass.cpp (modified) (2 diffs)
• sqliteclass.h (modified) (1 diff)

gsdl/trunk/lib/sqliteclass.cpp

@@ -25 +25 @@
 
 #include "sqliteclass.h"
+
+
+#define SQLITE_MAX_RETRIES 8
 
 
@@ -124 +127 @@
   return g_EmptyText;
 }
+
+
+// sqlexec simply executes the given sql statement - it doesn't obtain a
+// result set - returns true if the sql statement was executed successfully
+// logerrors may be set to false to prevent this method from logging an
+// error if it fails - this is useful in some circumstances when we execute
+// an sql command specifically to see if it fails (e.g. when testing if a
+// table exists in the db)
+bool sqliteclass::sqlexec(const text_t &sql_cmd, bool logerrors)
+{
+  char *sql_cmd_cstr = sql_cmd.getcstr();
+
+  int rv = 0;
+  int tries = 0;
+  while ((rv = sqlite3_exec(sqlitefile, sql_cmd_cstr, NULL, NULL, NULL)) == SQLITE_BUSY)
+  {
+    sleep(1000);
+    tries++;
+    if (tries > SQLITE_MAX_RETRIES)
+    {
+      outconvertclass text_t2ascii;
+      (*logout) << text_t2ascii << "max_retries exceeded for sql query: " << sql_cmd << "\n";
+      break;
+    }
+  }
+
+  delete[] sql_cmd_cstr;
+
+  if (rv == SQLITE_OK) return true;
+
+  if (logerrors)
+  {
+    outconvertclass text_t2ascii;
+    (*logout) << text_t2ascii << "Error executing sql statement: " << sql_cmd << "\n";
+  }
+
+  return false;
+}
+
+
+// sleep for the given number of milliseconds
+void sleep(int m)
+{
+#ifdef __WIN32__
+  Sleep(m);
+#else
+  usleep(m);
+#endif
+}

gsdl/trunk/lib/sqliteclass.h

@@ -64 +64 @@
   text_t openfile;
   sqlite3* sqlitefile;
+
+  bool sqlexec(const text_t &sql_cmd, bool logerrors);
 };