diff options
| -rw-r--r-- | libpqpp/selectcommand.cpp | 6 | ||||
| -rw-r--r-- | libpqpp/selectcommand.h | 1 |
2 files changed, 6 insertions, 1 deletions
diff --git a/libpqpp/selectcommand.cpp b/libpqpp/selectcommand.cpp index cc92540..3798406 100644 --- a/libpqpp/selectcommand.cpp +++ b/libpqpp/selectcommand.cpp @@ -8,6 +8,7 @@ PQ::SelectCommand::SelectCommand(const Connection * conn, const std::string & sq DB::SelectCommand(sql), PQ::Command(conn, sql, no), executed(false), + txOpened(false), nTuples(0), tuple(0), execRes(NULL) @@ -16,8 +17,10 @@ PQ::SelectCommand::SelectCommand(const Connection * conn, const std::string & sq PQ::SelectCommand::~SelectCommand() { - if (executed) { + if (txOpened) { c->commitTx(); + } + if (executed) { PQclear(PQexec(c->conn, ("CLOSE " + stmntName).c_str())); if (execRes) { PQclear(execRes); @@ -54,6 +57,7 @@ PQ::SelectCommand::execute() } } c->beginTx(); + txOpened = true; c->checkResultFree( PQexecParams(c->conn, psql.c_str(), values.size(), NULL, &values.front(), &lengths.front(), &formats.front(), 0), PGRES_COMMAND_OK); diff --git a/libpqpp/selectcommand.h b/libpqpp/selectcommand.h index 932717d..507bf43 100644 --- a/libpqpp/selectcommand.h +++ b/libpqpp/selectcommand.h @@ -22,6 +22,7 @@ namespace PQ { unsigned int getOrdinal(const Glib::ustring&) const; private: mutable bool executed; + mutable bool txOpened; std::vector<Column *> fields; std::map<Glib::ustring, Column *> fieldsName; int nTuples, tuple; |