这篇文章主要介绍了用C++封装MySQL的API的教程,包括对语句拼装器SQLJoin的介绍,需要的朋友可以参考下

　　其实相信每个和mysql打过交道的程序员都应该会尝试去封装一套mysql的接口，这一次的封装已经记不清是我第几次了，但是每一次我希望都能做的比上次更好，更容易使用。

　　先来说一下这次的封装，遵守了几个原则，其中部分思想是从python借鉴过来的：

　　1.简单

　　简单，意味着不为了微小的效率提升，而去把接口搞的复杂。因为本身数据库存储效率的瓶颈并不是那一两次内存copy，代码中随处可以看到以这个为依据的设计。

　　2.低学习成本

　　使用一套新库通常意味着投入学习成本，而这次的封装并没有像django那样实现一套完整的模型系统，也没有做soci那样的语法分析器，我选择最简单易懂的方式：做sql语句拼接器，所以对习惯了使用原生mysql api的朋友，学习成本很低

　　3.模块化

　　代码实际包括了两个模块，一个是mysql client端的封装，一个是sql的拼接器，这两个模块是完全独立的，调用者可以任意组合或者独立使用。

　　4.尽量使用STL以及模板，简化代码编写

　　最大的特点就是大量使用了stringstream进行类型转化，减少了大量的重复代码。

　　OK，基于以上的简单介绍，我们先来看一下

　　一.mysql client端的封装:

　　?

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 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 class CMYSQLWrapper { /** * @brief 获取错误信息 * * @return 错误信息 */ char* GetErrMsg();   /** * @brief 连接MYSQL，已经支持了自动重连模式，即mysql server关闭链接会自动重连 * * @param ip IP * @param user 用户名 * @param pwd 密码(没有则传NULL) * @param db 库(没有则传NULL) * * @return 0 succ * else fail */ int Open(const char* ip,const char* user,const char* pwd,const char* strDb);   /** * @brief 关闭链接并释放result */ void Close();   /** * @brief 执行SQL语句 * * @param strSql 执行语句 * @param result 执行结果 * * @return 0 succ * else fail */ int Query(const char* strSql);   /** * @brief 针对Read(select)相关的的Query，可以支持blob了 * * @param strSql sql语句 * @param vecData rows * * @return 0 succ * else fail */ int Query(const char* strSql, vector<map<string, MYSQLValue> > &vecData);   /** * @brief 针对Write(insert,update,delete)相关的Query * * @param strSql sql语句 * @param affectRowsCount 影响的行的个数 * * @return 0 succ * else fail */ int Query(const char* strSql, int& affectRowsCount);     /** * @brief Select时获取数据，记得手工析构，或者用StMYSQLRes * * @param result 执行结果 * * @return 0 succ * else fail */ int Result(MYSQL_RES *&result);   /** * @brief 返回影响行数 * * @return >0 succ * 0 没有更新 * <0 fail */ int AffectedRows();   /** * @brief 主要是将blob转成字符串 * * @param src blob源 * @param len 长度 * * @return 转化后的字符串 */ string EscStr(const char* src,uint32_t len);   /** * @brief 将字符串中的某些字符转化(如') * * @param src 字符串 * * @return 转化后的字符串 */ string EscStr(const char* src); };   class CMYSQLWrapper { /** * @brief 获取错误信息 * * @return 错误信息 */ char* GetErrMsg();   /** * @brief 连接MYSQL，已经支持了自动重连模式，即mysql server关闭链接会自动重连 * * @param ip IP * @param user 用户名 * @param pwd 密码(没有则传NULL) * @param db 库(没有则传NULL) * * @retur