#include <stdio.h>
|
#include <iostream>
|
#include <stdlib.h>
|
#include <mysql.h>
|
#include <string.h>
|
#include <unistd.h>
|
#include <string>
|
|
using namespace std;
|
|
int main(int argc, char** argv)
|
{
|
MYSQL *mysql;
|
|
if ((mysql = mysql_init(NULL)) == NULL)
|
{
|
cout << "Failed initialize client library." << endl;
|
}
|
|
if (!mysql_real_connect(mysql, "127.0.0.1", "maxuser", "maxpwd", NULL, 4006, NULL,
|
CLIENT_MULTI_STATEMENTS | CLIENT_MULTI_RESULTS))
|
{
|
cout << "Failed to connect to database: " << mysql_error(mysql) << endl;
|
mysql_close(mysql);
|
return 1;
|
}
|
|
MYSQL_STMT *stmt = mysql_stmt_init(mysql);
|
std::string query = "SELECT * FROM test.t1";
|
unsigned long cursor_type = CURSOR_TYPE_READ_ONLY;
|
mysql_stmt_attr_set(stmt, STMT_ATTR_CURSOR_TYPE, &cursor_type);
|
|
if (mysql_stmt_prepare(stmt, query.c_str(), query.size()) ||
|
mysql_stmt_execute(stmt) ||
|
mysql_stmt_execute(stmt) ||
|
mysql_stmt_execute(stmt) ||
|
mysql_stmt_execute(stmt))
|
{
|
cout << "Prepared statement failure: " << mysql_stmt_error(stmt) << endl;
|
}
|
|
mysql_stmt_close(stmt);
|
mysql_close(mysql);
|
return 0;
|
}
|