diff options
author | Dan Goodliffe <dan@randomdan.homeip.net> | 2021-05-31 13:18:17 +0100 |
---|---|---|
committer | Dan Goodliffe <dan@randomdan.homeip.net> | 2021-05-31 13:18:17 +0100 |
commit | 63b2ca0dbdae190941d60a55c9cff99d4a75a0e1 (patch) | |
tree | d3766bcbc98fb5fb0fb2d8dddf2f194bedcb0325 /lib/input/mysqlRecordSet.h | |
parent | Map std::size_t to a sensible header (diff) | |
download | mygrate-63b2ca0dbdae190941d60a55c9cff99d4a75a0e1.tar.bz2 mygrate-63b2ca0dbdae190941d60a55c9cff99d4a75a0e1.tar.xz mygrate-63b2ca0dbdae190941d60a55c9cff99d4a75a0e1.zip |
Initial commit of prepstmt, selects, record sets
This is full of holes, but all the basics are covered.
Diffstat (limited to 'lib/input/mysqlRecordSet.h')
-rw-r--r-- | lib/input/mysqlRecordSet.h | 37 |
1 files changed, 37 insertions, 0 deletions
diff --git a/lib/input/mysqlRecordSet.h b/lib/input/mysqlRecordSet.h new file mode 100644 index 0000000..849a653 --- /dev/null +++ b/lib/input/mysqlRecordSet.h @@ -0,0 +1,37 @@ +#ifndef MYGRATE_INPUT_MYSQLRECORDSET_H +#define MYGRATE_INPUT_MYSQLRECORDSET_H + +#include "mysqlStmt.h" +#include <cstddef> +#include <dbRecordSet.h> +#include <dbTypes.h> +#include <memory> +#include <mysql.h> +#include <vector> + +namespace MyGrate::Input { + class ResultData; + + class MySQLRecordSet : public RecordSet { + public: + using ResPtr = std::unique_ptr<MYSQL_RES, decltype(&mysql_free_result)>; + using StmtResPtr = std::unique_ptr<MYSQL_STMT, decltype(&mysql_stmt_free_result)>; + using ResultDataPtr = std::unique_ptr<ResultData>; + + explicit MySQLRecordSet(StmtPtr s); + + std::size_t rows() const override; + + std::size_t columns() const override; + + DbValue at(std::size_t row, std::size_t col) const override; + + private: + StmtPtr stmt; + StmtResPtr stmtres; + std::vector<MYSQL_BIND> fields; + std::vector<ResultDataPtr> extras; + }; +} + +#endif |