Simple MemSQL connector with pool of connections for c++
http://download.memsql.com/clients/mariadb-connector-c-3.0.9-linux-x86_64.tar.gz
#include <iostream>
#include <sstream>
#include "connection_pool.h"
#include <boost/format.hpp>
using namespace std;
int main(int argc, char **argv) {
std::ostringstream sqlQuery;
std::shared_ptr<connection_pool> m_pool;
m_pool = std::make_shared<connection_pool>("x.x.x.x", "root", "pwd", "database", 3306, 1, false);
sqlQuery << boost::format("INSERT INTO xxxx (x,x,x, x) VALUES ('%1%', '%2%', '%3%', '%4%')")
% "a"
% "b"
% "c";
shared_ptr<MysqlConnection> con = m_pool->get_connection();
if (con) {
try {
con->execute(sqlQuery.str(), false, true);
m_pool->release_connection(*con);
} catch (...) {
m_pool->release_connection(*con);
}
}
return 0;
}It's simple, ready to go...
You can for example check the affected rows using
std::shared_ptr<my_ulonglong> affectRowsPtr = std::make_shared<my_ulonglong>();
con->execute(sqlQuery.str(), false, true, affectRowsPtr.get());
if (*affectRowsPtr == 0) {
cout << "No changes" << endl;
}or you can simple select data:
#include <iostream>
#include <sstream>
#include "connection_pool.h"
#include <boost/format.hpp>
using namespace std;
int main(int argc, char **argv) {
std::ostringstream sqlQuery;
auto product_id = 2;
sqlQuery << boost::format(
"select * venue from products where product_id=%1%")
% product_id;
shared_ptr<MysqlConnection> con = m_pool->get_connection();
if (con) {
auto data = con->open(sqlQuery.str());
if (!data->is_valid()) {
return false;
}
auto row = data->next();
unsigned int row_idx = 0;
while (row) {
row_idx++;
cout << row->get_value(0) << endl;
row = data->next();
}
m_pool->release_connection(*con);
}
return 0;
}