generic-library/poco
1
0
Fork 0
mirror of https://github.com/pocoproject/poco.git synced 2025-10-30 13:47:10 +01:00
Code Issues Projects Releases Wiki Activity

Transactor documentation and test fix

Browse Source
This commit is contained in:
Aleksandar Fabijanic
2009-02-10 13:32:24 +00:00
parent d11f007d23
commit 60c8b0183e
2 changed files with 24 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
Data/ODBC/testsuite/src/SQLExecutor.cpp
View File

@@ -3659,20 +3659,20 @@ void SQLExecutor::transaction(const std::string& connect)
} }
struct TestCommitTransaction struct TestCommitTransactor
{ {
void operator () (Session& session) const void operator () (Session& session) const
{ {
session << "INSERT INTO PERSON VALUES (?,?,?,?)", bind("lastName"), bind("firstName"), bind("address"), bind("age"), now; session << "INSERT INTO PERSON VALUES ('lastName','firstName','address',10)", now;
} }
}; };
struct TestRollbackTransaction struct TestRollbackTransactor
{ {
void operator () (Session& session) const void operator () (Session& session) const
{ {
session << "INSERT INTO PERSON VALUES (?,?,?,?)", bind("lastName"), bind("firstName"), bind("address"), bind("age"), now; session << "INSERT INTO PERSON VALUES ('lastName','firstName','address',10)", now;
throw Poco::Exception("test"); throw Poco::Exception("test");
} }
}; };
@@ -3683,7 +3683,11 @@ void SQLExecutor::transactor()
std::string funct = "transaction()"; std::string funct = "transaction()";
int count = 0; int count = 0;
TestCommitTransaction ct; bool autoCommit = session().getFeature("autoCommit");
session().setFeature("autoCommit", false);
session().setTransactionIsolation(Session::TRANSACTION_READ_COMMITTED);
TestCommitTransactor ct;
Transaction t1(session()); Transaction t1(session());
t1.transact(ct); t1.transact(ct);
@@ -3692,15 +3696,27 @@ void SQLExecutor::transactor()
catch(StatementException& se){ std::cout << se.toString() << std::endl; fail (funct); } catch(StatementException& se){ std::cout << se.toString() << std::endl; fail (funct); }
assert (1 == count); assert (1 == count);
try { session() << "DELETE FROM PERSON", now; session().commit();}
catch(ConnectionException& ce){ std::cout << ce.toString() << std::endl; fail (funct); }
catch(StatementException& se){ std::cout << se.toString() << std::endl; fail (funct); }
try { session() << "SELECT count(*) FROM PERSON", into(count), now; }
catch(ConnectionException& ce){ std::cout << ce.toString() << std::endl; fail (funct); }
catch(StatementException& se){ std::cout << se.toString() << std::endl; fail (funct); }
assert (0 == count);
try try
{ {
TestRollbackTransaction rt; TestRollbackTransactor rt;
Transaction t2(session()); Transaction t2(session());
t2.transact(rt); t2.transact(rt);
fail ("must fail");
} catch (Poco::Exception&) { } } catch (Poco::Exception&) { }
try { session() << "SELECT count(*) FROM PERSON", into(count), now; } try { session() << "SELECT count(*) FROM PERSON", into(count), now; }
catch(ConnectionException& ce){ std::cout << ce.toString() << std::endl; fail (funct); } catch(ConnectionException& ce){ std::cout << ce.toString() << std::endl; fail (funct); }
catch(StatementException& se){ std::cout << se.toString() << std::endl; fail (funct); } catch(StatementException& se){ std::cout << se.toString() << std::endl; fail (funct); }
assert (0 == count); assert (0 == count);
session().setFeature("autoCommit", autoCommit);
} }

3
Data/include/Poco/Data/Transaction.h
View File

@@ -76,7 +76,8 @@ public:
/// }; /// };
/// ///
/// ATransaction t; /// ATransaction t;
/// Transaction at(session, t); // commits, if successful /// Transaction at(session);
/// at.transact(t); // commits, if successful
/// ///
/// See Transaction for more details on how to use Transactor. /// See Transaction for more details on how to use Transactor.
{ {