diff options
Diffstat (limited to 'libmysqlpp/connection.h')
| -rw-r--r-- | libmysqlpp/connection.h | 42 |
1 files changed, 42 insertions, 0 deletions
diff --git a/libmysqlpp/connection.h b/libmysqlpp/connection.h new file mode 100644 index 0000000..a88d758 --- /dev/null +++ b/libmysqlpp/connection.h @@ -0,0 +1,42 @@ +#ifndef MY_CONNECTION_H +#define MY_CONNECTION_H + +#include "../libdbpp/connection.h" +#include "error.h" +#include <mysql.h> + +namespace MySQL { + class Connection : public DB::Connection { + public: + Connection(const std::string & info); + ~Connection(); + + void finish() const; + int beginTx() const; + int commitTx() const; + int rollbackTx() const; + bool inTx() const; + void ping() const; + DB::BulkDeleteStyle bulkDeleteStyle() const; + DB::BulkUpdateStyle bulkUpdateStyle() const; + + DB::SelectCommand * newSelectCommand(const std::string & sql) const; + DB::ModifyCommand * newModifyCommand(const std::string & sql) const; + + void beginBulkUpload(const char *, const char *) const; + void endBulkUpload(const char *) const; + size_t bulkUploadData(const char *, size_t) const; + + mutable MYSQL conn; + + private: + my_bool my_true; + + void checkResult(my_bool actual, my_bool expected) const; + mutable unsigned int txDepth; + mutable bool rolledback; + }; +} + +#endif + |