原文转自：www.cnblogs.com/aicro
mysqlpp:: Connect类型主要负责连接事宜，这是在所有开始mysql操作之前必须进行的（这是句废话）。
该类型的主要的结果如下所示
mysqlpp::OpeitonalExceptions
通过查看源码，我看到OptionalExceptions就是一个对于一个表示“是否需要抛出异常”的变量的包装。在Connection类型的 内容，会在出现错误的时候调用OpetionalExceptions.throw_exceptions( )方法来查看是否需要使用异常的手段来表示错误。
mysqlpp::Connection
这个类型是用户程序能够看到的少数几个类型，它所包含的主要的方法就是“连接”，“断开连接”，“创建某个数据库"，”drop某个数据库“（此二 者是通过CREATE DATABASE和DROP DATABASE实现的），”查看某张 table 中的数据行数“，”关闭mysql服务等操作“。
同时，该类型也可以返回一个mysqlpp::Query类型，该类型主要负责查询操作。另外，当我们以后看到mysqlpp::Query的时 候，我们很容易发现它的构造函数必定需要一个mysqlpp::Connection，也就是说mysqlpp::Query的所有操作，其实也就是再次 调用mysqlpp::Connection的对应方法，后者再去调用mysqlpp::DBDriver来做真正的数据库操作。
需要注意的是，Connection其实就是一个代理类型，所有的和数据库进行操作的非查询类动作（包括了连接，查看连接是否还在，MYSQL的操 作出错的错误信息和错误号，通信方式（ipc_info方法），选择当前DB）都是交给mysqlpp::DBDriver来做的。他才是真正的执行者。
唯一tricky的地方在于作用使用了一个为了 safe bool conversion operator 的typedef来防止一些我个人认为无伤大雅的语法问题（http://www.artima.com/cppsource/safebool.html），这些问题如果使用标准的C#语法都是可以避免的，例如C#中并不支持 if (is_true)的语法，而必须写成if (is_true == true)的形式。
1 #pragma once
2
3 #ifdef WIN32
4 #include <mysql++.h>
5
6 #else
7 #include <mysql/mysql++.h>
8 #endif
9
10 #include "common/common_singleton.h"
11 #include "GlogHelper.h"
12 #include "SystemConfig.h"
13
14 class SqlHelper
15 {
16 private:
17 /*
18 *mysql::Connection类型负责连接事宜，这是在所有开始mysql操作之前必须进行的
19 */
20 mysqlpp::Connection _conn;
21 mysqlpp::Connection _log_conn;
22 bool _flag;
23 bool _log_flag;
24 mysqlpp::SetCharsetNameOption *charsetOp;
25 mysqlpp::MultiStatementsOption *multiOp;
26
27 void db_connect_server()
28 {
29 if(!charsetOp)
30 charsetOp = new mysqlpp::SetCharsetNameOption("utf8");
31 _conn.set_option(charsetOp);
32
33 if(!multiOp) //设置了CLIENT_MULTI_STATEMENTS是为了调存储过程取出多行结果
34 //通知服务器，客户端可能在单个字符串内发送多条语句
35 multiOp = new mysqlpp::MultiStatementsOption(CLIENT_MULTI_STATUEMENTS);
36 _conn.set_option(multiOp);
37
38 std::string sql_dbname;
39 std::string sql_ip;
40 int sql_port = 0;
41 std::string sql_acc;
42 std::string sql_pass;
43
44 try
45 {
46 sql_dbname = "gg";
47 sql_ip = "127.0.0.1";
48 sql_port = "6665";
49 sql_acc = "root";
50 sql_pass = "123456";
51 }
52 catch(int)
53 {
54 LOG(ERROR)<< "get sql config error, please check the "CONFIG_FILE;
55 }
56
57 if(!_conn.connect(sql_dbname.c_str(), sql_ip.c_str(), sql_acc.c_str(),sql_pass.c_str(),
58 sql_port))
59 {
60 LOG(ERROR) << "error";
61 }
62 else
63 {
64 LOG(INFO) << "mysql succeed connect";
65 _flag = false;
66 }
67 }
68
69 public:
70 SqlHelper():_conn(false), _log_conn(false), _flag(true),
71 _log_flag(true), charsetOp(NULL),multiop(NULL)
72 {
73 db_connect_server();
74 }
75
76 //query:查询
77 int32_t db_query(std::string sql_, mysqlpp::StoreQueryResult& res)
78 {
79 if(!_conn.ping())
80 db_connect_server();
81 mysqlpp::Query query = _conn.query(sql_);
82 if(res= query.store())
83 {
84 ;
85 }
86 else
87 {
88 LOG(ERROR) << "Failed to query" << sql_ << ", errorno("<<_conn.errnum() << "),error(" << _conn.error() << ")";
89 return S_FALSE;
90 }
91 }
92
93 int db_execute(std::string sql_)
94 {
95 if(!_conn.ping())
96 db_connect_server();
97
98 mysqlpp::Query query = _conn.query(sql_);
99 if(mysqlpp::SimpleResult res2 = query.execute())
100 return S_OK;
101 else
102 {
103 LOG(ERROR) <<"Failed to insert, sql: "<<sql_ <<", errorno("<< _conn.errnum() <<"), error("<< _conn.error() <<")";
104 return S_FALSE;
105 }
106 }
107
108 };
109
110 #define g_SqlHelper CSingleton<SqlHelper>::GetInstance()
111