-
Notifications
You must be signed in to change notification settings - Fork 0
/
send_double_commit.cc
76 lines (66 loc) · 1.97 KB
/
send_double_commit.cc
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
#include <mysql.h>
#include <string>
#include <iostream>
#include "common.hh"
void sync_query(MYSQL* c, std::initializer_list<const char*> sync_queries)
{
for (auto query : sync_queries)
{
std::cout << "Query: " << query << std::endl;
if (mysql_query(c, query))
{
std::cout << query << ": " << mysql_error(c) << std::endl;
}
std::cout << "Result: " << query << std::endl;
}
}
void async_query(MYSQL* c, std::initializer_list<const char*> async_queries)
{
for (std::string query : async_queries) {
std::cout << "Query: " << query << std::endl;
if (mysql_send_query(c, query.c_str(), query.length()))
{
std::cout << "mysql_send_query: " << mysql_error(c) << std::endl;
}
}
for (auto query : async_queries) {
std::cout << "Result: " << query << std::endl;
if (mysql_read_query_result(c))
{
std::cout << "mysql_read_query_result: " << mysql_error(c) << std::endl;
}
else
{
mysql_free_result(mysql_use_result(c));
}
}
}
int main(int argc, char** argv)
{
Config cnf = parse(argc, argv);
MYSQL* c = mysql_init(nullptr);
if (!mysql_real_connect(c, cnf.host, cnf.user, cnf.password, cnf.db, cnf.port, nullptr, CLIENT_MULTI_STATEMENTS|CLIENT_MULTI_RESULTS|CLIENT_SESSION_TRACKING))
{
std::cout << "Connect: " << mysql_error(c) << std::endl;
}
else
{
// async_query(c, {
// "BEGIN",
// "SELECT @@server_id",
// "COMMIT"
// });
async_query(c, {
"START TRANSACTION READ ONLY",
"INSERT INTO test.t1 VALUES (1)",
//"COMMIT"
});
async_query(c, {
// "START TRANSACTION READ ONLY",
// "INSERT INTO test.t1 VALUES (1)",
"COMMIT"
});
}
mysql_close(c);
return 0;
}