summaryrefslogtreecommitdiff
path: root/lib/input/mysqlConn.cpp
diff options
context:
space:
mode:
authorDan Goodliffe <dan@randomdan.homeip.net>2021-05-22 17:06:42 +0100
committerDan Goodliffe <dan@randomdan.homeip.net>2021-05-22 17:06:42 +0100
commitc4db2be862a2a31361f7e0ff3a0a47e970ec2c48 (patch)
treebcc40cdf2a3d936c4ac7490dd9bc15c4bc407abb /lib/input/mysqlConn.cpp
parentPass linter checks (diff)
downloadmygrate-c4db2be862a2a31361f7e0ff3a0a47e970ec2c48.tar.bz2
mygrate-c4db2be862a2a31361f7e0ff3a0a47e970ec2c48.tar.xz
mygrate-c4db2be862a2a31361f7e0ff3a0a47e970ec2c48.zip
Wrap up mysql_query
Diffstat (limited to 'lib/input/mysqlConn.cpp')
-rw-r--r--lib/input/mysqlConn.cpp10
1 files changed, 9 insertions, 1 deletions
diff --git a/lib/input/mysqlConn.cpp b/lib/input/mysqlConn.cpp
index 6c00628..3a2c9f4 100644
--- a/lib/input/mysqlConn.cpp
+++ b/lib/input/mysqlConn.cpp
@@ -1,4 +1,6 @@
#include "mysqlConn.h"
+#include "helpers.h"
+#include <mysql.h>
#include <stdexcept>
namespace MyGrate::Input {
@@ -11,11 +13,17 @@ namespace MyGrate::Input {
mysql_close(this);
throw std::runtime_error("ConnectionError");
}
- mysql_query(this, "SET NAMES utf8");
+ verify<std::runtime_error>(!mysql_set_character_set(this, "utf8"), "Set character set");
}
MySQLConn::~MySQLConn()
{
mysql_close(this);
}
+
+ void
+ MySQLConn::query(const char * const q)
+ {
+ verify<std::runtime_error>(!mysql_query(this, q), q);
+ }
}