Create empty C++ solution
Select x64
Project > C++ > General > Additional include Path > Add include path "C:\Program Files\MySQL\MySQL Server 5.7\include"
From C:\Program Files\MySQL\MySQL Server 5.7\lib, copy below 3 files
libmysql.dll
libmysql.lib
mysqlclient.lib
main.cpp
#include "mysql.h"
#pragma comment(lib,"libmysql.lib")
#include <iostream>
int main() {
try
{
MYSQL mysql = { 0 };
mysql_init(&mysql);
if (!mysql_real_connect(&mysql, "localhost", "root", "Tin.netS1", "", 3306, NULL, 0))
{
std::cerr << mysql_error(&mysql) << '\n';
return -1;
}
const char* q1 = "create database if not exists test;";
std::cout << q1 << '\n';
if (mysql_real_query(&mysql, q1, strlen(q1)) != 0)
{
std::cerr << mysql_error(&mysql) << '\n';
return -1;
}
const char* q2 = "create table if not exists test.temp_table( ID CHAR(10), Name VARCHAR(255), Descs VARCHAR(255), PRIMARY KEY (ID))";
std::cout << q2 << '\n';
if (mysql_real_query(&mysql, q2, strlen(q2)) != 0)
{
std::cerr << mysql_error(&mysql) << '\n';
return -1;
}
std::cout << "SQL completed successfully" << '\n';
}
catch (std::exception& e)
{
std::cerr << e.what() << '\n';
return -1;
}
catch (...)
{
std::cerr << "Unknown exception" << '\n';
return -1;
}
return 0;
}
query.cpp
#include "winsock.h"
#include "mysql.h"
#pragma comment(lib,"libmysql.lib")
#include
int main() {
try
{
MYSQL *mysql;
MYSQL_RES *result;
MYSQL_ROW row;
my_bool reconnect = 0;
MYSQL_STMT *stmt;
MYSQL_BIND bind[1];
MYSQL_BIND bResult[1];
unsigned long length[1];
int int_data;
mysql = mysql_init(NULL);
mysql_options(mysql, MYSQL_OPT_RECONNECT, &reconnect);
mysql_real_connect(mysql, "localhost", "root", "Tin.netS1", "test", 3306, NULL, 0);
mysql_query(mysql, "drop table test2");
mysql_query(mysql, "create table test2(n int, m int)");
mysql_query(mysql, "insert into test2 values (1,2), (1,3), (1,4), (1,5)");
const char *normalSql = "select m from test2 where n = 1";
// 1. normal buffer
mysql_query(mysql, normalSql);
result = mysql_store_result(mysql);
while (row = mysql_fetch_row(result)) {
printf("1 - %d\n", atoi(row[0]));
}
mysql_free_result(result);
// 2. normal unbuffer
mysql_query(mysql, normalSql);
result = mysql_use_result(mysql);
while (row = mysql_fetch_row(result)) {
printf("2 - %d\n", atoi(row[0]));
}
mysql_free_result(result);
const char *stmtSql = "select m from test2 where n = ?";
//3. stmt buffer
stmt = mysql_stmt_init(mysql);
mysql_stmt_prepare(stmt, stmtSql, strlen(stmtSql));
memset(bind, 0, sizeof(bind));
bind[0].buffer_type = MYSQL_TYPE_LONG;
bind[0].buffer = (char *)&int_data;
mysql_stmt_bind_param(stmt, bind);
memset(bResult, 0, sizeof(bResult));
bResult[0].buffer_type = MYSQL_TYPE_LONG;
bResult[0].buffer = (char *)&int_data;
mysql_stmt_bind_result(stmt, bResult);
int_data = 1;
mysql_stmt_execute(stmt);
mysql_stmt_store_result(stmt);
while (!mysql_stmt_fetch(stmt)) {
printf("3 - %d \n", int_data);
}
mysql_stmt_close(stmt);
// 4. stmt unbuffer
stmt = mysql_stmt_init(mysql);
mysql_stmt_prepare(stmt, stmtSql, strlen(stmtSql));
memset(bind, 0, sizeof(bind));
bind[0].buffer_type = MYSQL_TYPE_LONG;
bind[0].buffer = (char *)&int_data;
mysql_stmt_bind_param(stmt, bind);
memset(bResult, 0, sizeof(bResult));
bResult[0].buffer_type = MYSQL_TYPE_LONG;
bResult[0].buffer = (char *)&int_data;
mysql_stmt_bind_result(stmt, bResult);
int_data = 1;
mysql_stmt_execute(stmt);
while (!mysql_stmt_fetch(stmt)) {
printf("4 - %d \n", int_data);
}
mysql_stmt_close(stmt);
// 5. stmt server cursor default
stmt = mysql_stmt_init(mysql);
mysql_stmt_prepare(stmt, stmtSql, strlen(stmtSql));
unsigned long type = (unsigned long)CURSOR_TYPE_READ_ONLY;
mysql_stmt_attr_set(stmt, STMT_ATTR_CURSOR_TYPE, (void*)&type);
memset(bind, 0, sizeof(bind));
bind[0].buffer_type = MYSQL_TYPE_LONG;
bind[0].buffer = (char *)&int_data;
mysql_stmt_bind_param(stmt, bind);
memset(bResult, 0, sizeof(bResult));
bResult[0].buffer_type = MYSQL_TYPE_LONG;
bResult[0].buffer = (char *)&int_data;
mysql_stmt_bind_result(stmt, bResult);
int_data = 1;
mysql_stmt_execute(stmt);
while (!mysql_stmt_fetch(stmt)) {
printf("5 - %d \n", int_data);
}
mysql_stmt_close(stmt);
// 6. stmt server cursor setting
stmt = mysql_stmt_init(mysql);
mysql_stmt_prepare(stmt, stmtSql, strlen(stmtSql));
type = (unsigned long)CURSOR_TYPE_READ_ONLY;
mysql_stmt_attr_set(stmt, STMT_ATTR_CURSOR_TYPE, (void*)&type);
unsigned long prefetch_rows = 2;
mysql_stmt_attr_set(stmt, STMT_ATTR_PREFETCH_ROWS, (void*)&prefetch_rows);
memset(bind, 0, sizeof(bind));
bind[0].buffer_type = MYSQL_TYPE_LONG;
bind[0].buffer = (char *)&int_data;
mysql_stmt_bind_param(stmt, bind);
memset(bResult, 0, sizeof(bResult));
bResult[0].buffer_type = MYSQL_TYPE_LONG;
bResult[0].buffer = (char *)&int_data;
mysql_stmt_bind_result(stmt, bResult);
int_data = 1;
mysql_stmt_execute(stmt);
while (!mysql_stmt_fetch(stmt)) {
printf("6 - %d \n", int_data);
}
mysql_stmt_close(stmt);
mysql_close(mysql);
std::cout << "SQL completed successfully" << '\n';
std::cin.get();
}
catch (std::exception& e)
{
std::cerr << e.what() << '\n';
return -1;
}
catch (...)
{
std::cerr << "Unknown exception" << '\n';
return -1;
}
return 0;
}
End
