aboutsummaryrefslogtreecommitdiff
path: root/odb/pgsql
diff options
context:
space:
mode:
authorConstantin Michael <constantin@codesynthesis.com>2011-05-06 11:44:02 +0200
committerConstantin Michael <constantin@codesynthesis.com>2011-05-09 16:52:07 +0200
commit74d9ab3518d50ebafb12e8252c01fa904b089481 (patch)
tree456be9c02055d01f27614bf6cb204f0c78c2a848 /odb/pgsql
parent77bbae6038d20576a4807ed8ca834685a1e85afa (diff)
Add error support
Diffstat (limited to 'odb/pgsql')
-rw-r--r--odb/pgsql/error.cxx78
-rw-r--r--odb/pgsql/error.hxx33
-rw-r--r--odb/pgsql/exceptions.cxx35
-rw-r--r--odb/pgsql/exceptions.hxx30
-rw-r--r--odb/pgsql/makefile3
5 files changed, 176 insertions, 3 deletions
diff --git a/odb/pgsql/error.cxx b/odb/pgsql/error.cxx
new file mode 100644
index 0000000..2dd4f03
--- /dev/null
+++ b/odb/pgsql/error.cxx
@@ -0,0 +1,78 @@
+// file : odb/pgsql/errors.cxx
+// author : Constantin Michael <constantin@codesynthesis.com>
+// copyright : Copyright (c) 2005-2011 Code Synthesis Tools CC
+// license : GNU GPL v2; see accompanying LICENSE file
+
+#include <string>
+#include <cassert>
+
+#include <odb/pgsql/error.hxx>
+#include <odb/pgsql/exceptions.hxx>
+
+using namespace std;
+
+namespace odb
+{
+ namespace pgsql
+ {
+ void
+ translate_error (connection& c)
+ {
+ PGconn* h (0); // @@ c.handle ();
+
+ assert (CONNECTION_BAD == PQstatus (h));
+
+ if (const char* m = PQerrorMessage (h))
+ throw database_exception (m);
+ else
+ throw database_exception ("unknown error");
+ }
+
+ void
+ translate_error (connection& c, PGresult* r)
+ {
+ PGconn* h (0); // @@ c.handle ();
+
+ if (!r)
+ {
+ if (CONNECTION_BAD == PQstatus (h))
+ throw connection_lost ();
+ else
+ throw bad_alloc ();
+ }
+
+ switch (PQresultStatus (r))
+ {
+ case PGRES_BAD_RESPONSE:
+ {
+ if (const char* m = PQresultErrorMessage (r))
+ throw database_exception (m);
+ else
+ throw database_exception ("bad server response");
+ }
+
+ case PGRES_FATAL_ERROR:
+ {
+ // PG_DIAG_SQLSTATE field is always present.
+ //
+ string s (PQresultErrorField (r, PG_DIAG_SQLSTATE));
+
+ // Deadlock detected.
+ //
+ if ("40P01" == s)
+ throw deadlock ();
+
+ else if (CONNECTION_BAD == PQstatus (h))
+ throw connection_lost ();
+
+ else
+ throw database_exception (s, PQresultErrorMessage (r));
+ }
+
+ default:
+ assert (0);
+ break;
+ };
+ }
+ }
+}
diff --git a/odb/pgsql/error.hxx b/odb/pgsql/error.hxx
new file mode 100644
index 0000000..3de9e78
--- /dev/null
+++ b/odb/pgsql/error.hxx
@@ -0,0 +1,33 @@
+// file : odb/pgsql/errors.hxx
+// author : Constantin Michael <constantin@codesynthesis.com>
+// copyright : Copyright (c) 2005-2011 Code Synthesis Tools CC
+// license : GNU GPL v2; see accompanying LICENSE file
+
+#ifndef ODB_PGSQL_ERRORS_HXX
+#define ODB_PGSQL_ERRORS_HXX
+
+#include <odb/pre.hxx>
+
+#include <libpq-fe.h>
+
+#include <odb/pgsql/version.hxx>
+
+#include <odb/pgsql/details/export.hxx>
+
+namespace odb
+{
+ namespace pgsql
+ {
+ class connection;
+
+ LIBODB_PGSQL_EXPORT void
+ translate_error (connection&);
+
+ LIBODB_PGSQL_EXPORT void
+ translate_error (connection& c, PGresult* r);
+ }
+}
+
+#include <odb/post.hxx>
+
+#endif // ODB_PGSQL_ERRORS_HXX
diff --git a/odb/pgsql/exceptions.cxx b/odb/pgsql/exceptions.cxx
index bea0870..bec4ba7 100644
--- a/odb/pgsql/exceptions.cxx
+++ b/odb/pgsql/exceptions.cxx
@@ -3,6 +3,8 @@
// copyright : Copyright (c) 2005-2011 Code Synthesis Tools CC
// license : GNU GPL v2; see accompanying LICENSE file
+#include <sstream>
+
#include <odb/pgsql/exceptions.hxx>
using namespace std;
@@ -12,12 +14,41 @@ namespace odb
namespace pgsql
{
//
+ // database_exception
+ //
+
+ database_exception::
+ database_exception (const string& message)
+ : message_ (message), what_ (message)
+ {
+ }
+
+ database_exception::
+ database_exception (const string& sqlstate,
+ const string& message)
+ : sqlstate_ (sqlstate), message_ (message)
+ {
+ what_ = sqlstate_ + ": " + message_;
+ }
+
+ database_exception::
+ ~database_exception () throw ()
+ {
+ }
+
+ const char* database_exception::
+ what () const throw ()
+ {
+ return what_.c_str ();
+ }
+
+ //
// cli_exception
//
cli_exception::
- cli_exception (const std::string& what)
- : what_ (what)
+ cli_exception (const string& w)
+ : what_ (w)
{
}
diff --git a/odb/pgsql/exceptions.hxx b/odb/pgsql/exceptions.hxx
index 0ceb83c..d6cae70 100644
--- a/odb/pgsql/exceptions.hxx
+++ b/odb/pgsql/exceptions.hxx
@@ -20,6 +20,36 @@ namespace odb
{
namespace pgsql
{
+ struct LIBODB_PGSQL_EXPORT database_exception: odb::database_exception
+ {
+ database_exception (const std::string& message);
+
+ database_exception (const std::string& sqlstate,
+ const std::string& message);
+
+ ~database_exception () throw ();
+
+ const std::string&
+ message () const
+ {
+ return message_;
+ }
+
+ const std::string&
+ sqlstate () const
+ {
+ return sqlstate_;
+ }
+
+ virtual const char*
+ what () const throw ();
+
+ private:
+ std::string sqlstate_;
+ std::string message_;
+ std::string what_;
+ };
+
struct LIBODB_PGSQL_EXPORT cli_exception: odb::exception
{
cli_exception (const std::string& what);
diff --git a/odb/pgsql/makefile b/odb/pgsql/makefile
index 11e8762..bf911db 100644
--- a/odb/pgsql/makefile
+++ b/odb/pgsql/makefile
@@ -8,7 +8,8 @@ include $(dir $(lastword $(MAKEFILE_LIST)))../../build/bootstrap.make
cxx := \
database.cxx \
-exceptions.cxx
+error.cxx \
+exceptions.cxx
cli_tun := details/options.cli
cxx_tun := $(cxx)