1 files changed, 94 insertions, 0 deletions
diff --git a/libodb-sqlite/odb/sqlite/error.cxx b/libodb-sqlite/odb/sqlite/error.cxx
new file mode 100644
index 0000000..ae6bbe3
--- /dev/null
+++ b/libodb-sqlite/odb/sqlite/error.cxx
@@ -0,0 +1,94 @@
+// file      : odb/sqlite/error.cxx
+// license   : GNU GPL v2; see accompanying LICENSE file
+
+#include <sqlite3.h>
+
+#include <new>    // std::bad_alloc
+#include <string>
+
+#include <odb/sqlite/connection.hxx>
+#include <odb/sqlite/exceptions.hxx>
+
+#include <odb/sqlite/details/config.hxx> // LIBODB_SQLITE_HAVE_UNLOCK_NOTIFY
+
+using namespace std;
+
+namespace odb
+{
+  namespace sqlite
+  {
+    void
+    translate_error (int e, connection& c)
+    {
+      sqlite3* h (c.handle ());
+
+      // Extended error codes are only available in 3.6.5 and later.
+      //
+#if SQLITE_VERSION_NUMBER >= 3006005
+      int ee (sqlite3_extended_errcode (h));
+#else
+      int ee (0);
+#endif
+      string m;
+
+      switch (e)
+      {
+      case SQLITE_NOMEM:
+        {
+          throw bad_alloc ();
+        }
+      case SQLITE_MISUSE:
+        {
+          // In case of SQLITE_MISUSE, error code/message may or may not
+          // be set.
+          //
+          ee = e;
+          m = "SQLite API misuse";
+          break;
+        }
+#ifdef SQLITE_ABORT_ROLLBACK
+      case SQLITE_ABORT:
+        {
+          if (ee == SQLITE_ABORT_ROLLBACK)
+            throw forced_rollback ();
+
+          break;
+        }
+#endif
+      case SQLITE_LOCKED:
+        {
+#ifdef LIBODB_SQLITE_HAVE_UNLOCK_NOTIFY
+          if (ee != SQLITE_LOCKED_SHAREDCACHE)
+            throw deadlock (); // The DROP TABLE special case.
+#endif
+          // Getting SQLITE_LOCKED_SHAREDCACHE here means we don't have
+          // the unlock notify support. Translate this to timeout.
+          //
+          throw timeout ();
+        }
+      case SQLITE_BUSY:
+      case SQLITE_IOERR:
+        {
+#if SQLITE_VERSION_NUMBER >= 3006005
+          if (e != SQLITE_IOERR || ee == SQLITE_IOERR_BLOCKED)
+            throw timeout ();
+#endif
+          break;
+        }
+      default:
+        break;
+      }
+
+      if (m.empty ())
+        m = sqlite3_errmsg (h);
+
+      // Get rid of a trailing newline if there is one.
+      //
+      string::size_type n (m.size ());
+      if (n != 0 && m[n - 1] == '\n')
+        m.resize (n - 1);
+
+      throw database_exception (e, ee, m);
+    }
+  }
+}