Mysql数据库学习（四）：常用Mysql C API 介绍和使用、封装一个访问Mysql数据库的类MysqlDB

古城微笑少年丶 2022-08-25 09:23 20阅读 0赞

首先，环境是windows + vs2008，Mysql数据库已经[安装][Link 1]好，在使用之前，需要配置工程属性，附加包含目录添加

D:\\Program Files\\MySQL\\MySQL Server 5.6\\include （Mysql安装目录），附加库目录添加 D:\\Program Files\\MySQL\\MySQL Server 5.6\\lib ，附加依赖项添加 mysqlib.lib，当然mysqllib.lib 只是包含符号而已，可执行文件运行的时候需要mysqllib.dll（lib目录下）， 将其拷贝到exe同目录下。

一、常用Mysql C API 介绍和使用

1.mysql\_init

MYSQL结构代表一个连接句柄

MYSQL\*mysql\_init(MYSQL\*mysql);

如果mysql是NULL指针，该函数将分配、初始化、并返回新对象。否则，将初始化对象，并返回对象的地址。如果mysql\_init()分配了新的对象，当调用mysql\_close()来关闭连接时。将释放该对象。

2.mysql\_real\_connect

// 连接数据库

MYSQL \*mysql\_real\_connect(MYSQL \*mysql, const char \*host, const char \*user, const char \*passwd, const char \*db, unsigned int port, const char \*unix\_socket, unsigned long client\_flag)  
  
//设置数据库  
my\_bool reconnect = true;  
mysql\_options(mysql, MYSQL\_OPT\_RECONNECT, &reconnect);  
mysql\_options(mysql, MYSQL\_SET\_CHARSET\_NAME, "gbk");

3.mysql\_query

int mysql\_query(MYSQL \*mysql, const char \*query)  
mysql\_affected\_rows  
mysql\_store\_result  
mysql\_num\_fields  
mysql\_num\_rows  
mysql\_fetch\_field  
mysql\_fetch\_row  
mysql\_free\_result

示例代码如下：

C++ Code

输出结果如下，因为各字段值长短不一，虽然加了tab，输出还是有点别扭：

![Center][]

二、下面封装MysqlDB类

使用的基本是上面演示过的函数，就不多解释了，直接看代码吧。

MysqlDB.h：

C++ Code

<table style="width:100%; font-family:'Consolas','Courier New'; font-size:12px; vertical-align:text-top; line-height:15px"> 
 <tbody> 
 <tr> 
 <td style="color:#008284; background-color:#e3e3e3; vertical-align:text-top"> 
 <div style="margin:7px; text-align:right; white-space:nowrap">
 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 
 
 </div> </td> 
 <td style="background-color:#008284; padding:1px"> 
 <div style="border:1px #008284 solid"></div> </td> 
 <td style="background-color:rgb(239,239,239); width:100%; vertical-align:text-top"> 
 <div style="margin:7px"> 
 #ifndef&nbsp;_MYSQL_DB_H_ 
 
 #define&nbsp;_MYSQL_DB_H_ 
 
 
 //#define&nbsp;WIN32_LEAN_AND_MEAN 
 #include&nbsp;&lt;winsock2.h&gt; 
 
 #include&nbsp;&lt;mysql.h&gt; 
 
 
 #include&nbsp;&lt;vector&gt; 
 
 #include&nbsp;&lt;string&gt; 
 
 using&nbsp; 
 namespace&nbsp;std; 
 
 
 namespace&nbsp;DAL 
 { 
 
 
 class&nbsp;MysqlDB; 
 
 class&nbsp;MysqlRecordset 
 { 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 friend&nbsp; 
 class&nbsp;MysqlDB; 
 
 public: 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 const&nbsp;string&amp;&nbsp;GetItem( 
 unsigned&nbsp; 
 int&nbsp;nRow,&nbsp; 
 unsigned&nbsp; 
 int&nbsp;nCol)&nbsp; 
 const 
 &nbsp;&nbsp;&nbsp;&nbsp;{ 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 return&nbsp;rows_[nRow][nCol]; 
 &nbsp;&nbsp;&nbsp;&nbsp;} 
 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 const&nbsp;string&amp;&nbsp;GetItem( 
 unsigned&nbsp; 
 int&nbsp;nRow,&nbsp; 
 const&nbsp;string&amp;&nbsp;name)&nbsp; 
 const 
 &nbsp;&nbsp;&nbsp;&nbsp;{ 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 unsigned&nbsp; 
 int&nbsp;index&nbsp;=&nbsp;GetFieldIndex(name); 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 return&nbsp;rows_[nRow][index]; 
 &nbsp;&nbsp;&nbsp;&nbsp;} 
 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 unsigned&nbsp; 
 int&nbsp;GetRows()&nbsp; 
 const 
 &nbsp;&nbsp;&nbsp;&nbsp;{ 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 return&nbsp;rows_.size(); 
 &nbsp;&nbsp;&nbsp;&nbsp;} 
 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 unsigned&nbsp; 
 int&nbsp;GetCols()&nbsp; 
 const 
 &nbsp;&nbsp;&nbsp;&nbsp;{ 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 return&nbsp;fields_.size(); 
 &nbsp;&nbsp;&nbsp;&nbsp;} 
 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 unsigned&nbsp; 
 int&nbsp;GetFieldIndex( 
 const&nbsp;std::string&nbsp;&amp;name)&nbsp; 
 const 
 &nbsp;&nbsp;&nbsp;&nbsp;{ 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 unsigned&nbsp; 
 int&nbsp;index&nbsp;=&nbsp;- 
 1; 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 for( 
 unsigned&nbsp; 
 int&nbsp;i&nbsp;=&nbsp; 
 0;&nbsp;i&nbsp;&lt;&nbsp;fields_.size();&nbsp;++i) 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 if&nbsp;(fields_[i].name&nbsp;==&nbsp;name) 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;index&nbsp;=&nbsp;fields_[i].index; 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 return&nbsp;index; 
 &nbsp;&nbsp;&nbsp;&nbsp;} 
 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 void&nbsp;Clear() 
 &nbsp;&nbsp;&nbsp;&nbsp;{ 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;rows_.clear(); 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;fields_.clear(); 
 &nbsp;&nbsp;&nbsp;&nbsp;} 
 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 typedef&nbsp; 
 struct&nbsp;Field 
 &nbsp;&nbsp;&nbsp;&nbsp;{ 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;string&nbsp;name;&nbsp; 
 //列的字段名 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 unsigned&nbsp; 
 int&nbsp;index;&nbsp; 
 //字段名对应的下标 &nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;FIELD; 
 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 typedef&nbsp;vector&lt;FIELD&gt;&nbsp;FIELDS;&nbsp; 
 //所有列的字段结构体集合 &nbsp;&nbsp;&nbsp;&nbsp; 
 typedef&nbsp;vector&lt;string&gt;&nbsp;ROW;&nbsp;&nbsp; 
 //每一行存储值 
 
 private: 
 &nbsp;&nbsp;&nbsp;&nbsp;vector&lt;ROW&gt;&nbsp;rows_;&nbsp; 
 //&nbsp;总共存储多个行 &nbsp;&nbsp;&nbsp;&nbsp;FIELDS&nbsp;fields_; 
 }; 
 
 
 class&nbsp;MysqlDB 
 { 
 
 public: 
 &nbsp;&nbsp;&nbsp;&nbsp;MysqlDB(); 
 &nbsp;&nbsp;&nbsp;&nbsp;~MysqlDB(); 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 void&nbsp;Open( 
 const&nbsp; 
 char*&nbsp;host, 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 const&nbsp; 
 char*&nbsp;user, 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 const&nbsp; 
 char*&nbsp;passwd, 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 const&nbsp; 
 char*&nbsp;db, 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 unsigned&nbsp; 
 int&nbsp;port); 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 void&nbsp;Close(); 
 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 unsigned&nbsp; 
 long&nbsp; 
 long&nbsp;ExecSQL( 
 const&nbsp; 
 char*&nbsp;sql); 
 &nbsp;&nbsp;&nbsp;&nbsp;MysqlRecordset&nbsp;QuerySQL( 
 const&nbsp; 
 char*&nbsp;sql); 
 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 unsigned&nbsp; 
 long&nbsp; 
 long&nbsp;GetInsertId()&nbsp; 
 const; 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 void&nbsp;StartTransaction(); 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 void&nbsp;Commit(); 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 void&nbsp;Rollback(); 
 
 
 
 private: 
 &nbsp;&nbsp;&nbsp;&nbsp;MYSQL*&nbsp;mysql_; 
 }; 
 
 } 
 
 
 #endif&nbsp; 
 //&nbsp;_MYSQL_DB_H_ 
 </div> </td> 
 </tr> 
 </tbody> 
</table>

MysqlDB.cpp：

C++ Code

<table style="width:100%; font-family:'Consolas','Courier New'; font-size:12px; vertical-align:text-top; line-height:15px"> 
 <tbody> 
 <tr> 
 <td style="color:#008284; background-color:#e3e3e3; vertical-align:text-top"> 
 <div style="margin:7px; text-align:right; white-space:nowrap">
 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 
 
 </div> </td> 
 <td style="background-color:#008284; padding:1px"> 
 <div style="border:1px #008284 solid"></div> </td> 
 <td style="background-color:rgb(239,239,239); width:100%; vertical-align:text-top"> 
 <div style="margin:7px"> 
 #include&nbsp;&lt;exception&gt; 
 
 #include&nbsp; 
 "MysqlDB.h" 
 
 
 using&nbsp; 
 namespace&nbsp;std; 
 
 using namespace DAL; 
 </div> 
 <div style="margin:7px"> 
 MysqlDB::MysqlDB()&nbsp;:&nbsp;mysql_( 
 NULL) 
 { 
 } 
 
 MysqlDB::~MysqlDB() 
 { 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 if&nbsp;(mysql_) 
 &nbsp;&nbsp;&nbsp;&nbsp;{ 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Close(); 
 &nbsp;&nbsp;&nbsp;&nbsp;} 
 } 
 
 void&nbsp;MysqlDB::Open( 
 const&nbsp; 
 char*&nbsp;host, 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 const&nbsp; 
 char*&nbsp;user, 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 const&nbsp; 
 char*&nbsp;passwd, 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 const&nbsp; 
 char*&nbsp;db, 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 unsigned&nbsp; 
 int&nbsp;port) 
 { 
 
 &nbsp;&nbsp;&nbsp;&nbsp;mysql_&nbsp;=&nbsp;mysql_init( 
 NULL); 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 if&nbsp;(mysql_&nbsp;==&nbsp; 
 NULL) 
 &nbsp;&nbsp;&nbsp;&nbsp;{ 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;string&nbsp;errmsg&nbsp;=&nbsp;mysql_error(mysql_); 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 throw&nbsp;Exception( 
 "DB&nbsp;ERROR:"+errmsg); 
 &nbsp;&nbsp;&nbsp;&nbsp;} 
 
 &nbsp;&nbsp;&nbsp;&nbsp;my_bool&nbsp;reconnect&nbsp;=&nbsp; 
 true; 
 &nbsp;&nbsp;&nbsp;&nbsp;mysql_options(mysql_,&nbsp;MYSQL_OPT_RECONNECT,&nbsp;&amp;reconnect); 
 &nbsp;&nbsp;&nbsp;&nbsp;mysql_options(mysql_,&nbsp;MYSQL_SET_CHARSET_NAME,&nbsp; 
 "gbk"); 
 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 if&nbsp;(!mysql_real_connect(mysql_,&nbsp;host,&nbsp;user, 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;passwd,&nbsp;db,&nbsp; 
 0,&nbsp; 
 NULL,&nbsp; 
 0)) 
 &nbsp;&nbsp;&nbsp;&nbsp;{ 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;string&nbsp;errmsg&nbsp;=&nbsp;mysql_error(mysql_); 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Close(); 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 throw&nbsp;Exception( 
 "DB&nbsp;ERROR:"+errmsg); 
 &nbsp;&nbsp;&nbsp;&nbsp;} 
 } 
 
 
 void&nbsp;MysqlDB::Close() 
 { 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 if&nbsp;( 
 NULL&nbsp;!=&nbsp;mysql_) 
 &nbsp;&nbsp;&nbsp;&nbsp;{ 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;mysql_close(mysql_); 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;mysql_&nbsp;=&nbsp; 
 NULL; 
 &nbsp;&nbsp;&nbsp;&nbsp;} 
 } 
 
 MysqlRecordset&nbsp;MysqlDB::QuerySQL( 
 const&nbsp; 
 char*&nbsp;sql) 
 { 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 if&nbsp;(mysql_query(mysql_,&nbsp;sql)&nbsp;!=&nbsp; 
 0) 
 &nbsp;&nbsp;&nbsp;&nbsp;{ 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 //int&nbsp;errno&nbsp;=&nbsp;mysql_errno(mysql_); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;string&nbsp;errmsg&nbsp;=&nbsp;mysql_error(mysql_); 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 throw&nbsp;Exception( 
 "DB&nbsp;ERROR:"+errmsg); 
 &nbsp;&nbsp;&nbsp;&nbsp;} 
 
 &nbsp;&nbsp;&nbsp;&nbsp;MYSQL_RES*&nbsp;&nbsp;mysql_res; 
 &nbsp;&nbsp;&nbsp;&nbsp;mysql_res&nbsp;=&nbsp;mysql_store_result(mysql_); 
 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 //得到查询返回的行数 &nbsp;&nbsp;&nbsp;&nbsp; 
 //unsigned&nbsp;long&nbsp;n&nbsp;=&nbsp;mysql_affected_rows(mysql_);&nbsp;&nbsp;&nbsp;&nbsp; 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 //指向&nbsp;&nbsp;mysql&nbsp;的查询字段集 &nbsp;&nbsp;&nbsp;&nbsp;MYSQL_FIELD*&nbsp;mysql_field&nbsp;=&nbsp; 
 NULL; 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 &nbsp;&nbsp;&nbsp;&nbsp;MysqlRecordset&nbsp;rs; 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 unsigned&nbsp; 
 int&nbsp;i&nbsp;=&nbsp; 
 0; 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 unsigned&nbsp; 
 int&nbsp;nCols&nbsp;=&nbsp;mysql_num_fields(mysql_res); 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 while&nbsp;((mysql_field&nbsp;=&nbsp;mysql_fetch_field(mysql_res))&nbsp;!=&nbsp; 
 NULL) 
 &nbsp;&nbsp;&nbsp;&nbsp;{ 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;MysqlRecordset::FIELD&nbsp;field; 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;field.name&nbsp;=&nbsp;mysql_field-&gt;name; 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;field.index&nbsp;=&nbsp;i; 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;++i; 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;rs.fields_.push_back(field);&nbsp; 
 //压入某个列字段的结构体 &nbsp;&nbsp;&nbsp;&nbsp;} 
 &nbsp; 
 &nbsp;&nbsp;&nbsp;&nbsp;MYSQL_ROW&nbsp;mysql_row; 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 while&nbsp;((mysql_row&nbsp;=&nbsp;mysql_fetch_row(mysql_res))) 
 &nbsp;&nbsp;&nbsp;&nbsp;{ 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;MysqlRecordset::ROW&nbsp;row(nCols); 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 for&nbsp;( 
 unsigned&nbsp; 
 int&nbsp;i&nbsp;=&nbsp; 
 0;&nbsp;i&lt;&nbsp;nCols;&nbsp;++i) 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;row[i]&nbsp;=&nbsp;mysql_row[i]&nbsp;?&nbsp;mysql_row[i]&nbsp;:&nbsp; 
 ""; 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;rs.rows_.push_back(row);&nbsp; 
 //压入某一行的存储值 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 &nbsp;&nbsp;&nbsp;&nbsp;} 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 
 &nbsp;&nbsp;&nbsp;&nbsp;mysql_free_result(mysql_res); 
 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 return&nbsp;rs; 
 
 } 
 
 
 unsigned&nbsp; 
 long&nbsp; 
 long&nbsp;MysqlDB::ExecSQL( 
 const&nbsp; 
 char*&nbsp;sql) 
 { 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 if&nbsp;(mysql_query(mysql_,&nbsp;sql)&nbsp;!=&nbsp; 
 0) 
 &nbsp;&nbsp;&nbsp;&nbsp;{ 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 //int&nbsp;errno&nbsp;=&nbsp;mysql_errno(mysql_); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;string&nbsp;errmsg&nbsp;=&nbsp;mysql_error(mysql_); 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 throw&nbsp;Exception( 
 "DB&nbsp;ERROR:"+errmsg); 
 &nbsp;&nbsp;&nbsp;&nbsp;} 
 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 return&nbsp;mysql_affected_rows(mysql_); 
 
 } 
 
 
 void&nbsp;MysqlDB::StartTransaction() 
 { 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 if&nbsp;(mysql_query(mysql_,&nbsp; 
 "START&nbsp;TRANSACTION")&nbsp;!=&nbsp; 
 0) 
 &nbsp;&nbsp;&nbsp;&nbsp;{ 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 //int&nbsp;errno&nbsp;=&nbsp;mysql_errno(mysql_); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;string&nbsp;errmsg&nbsp;=&nbsp;mysql_error(mysql_); 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 throw&nbsp;Exception( 
 "DB&nbsp;ERROR:"+errmsg); 
 &nbsp;&nbsp;&nbsp;&nbsp;} 
 } 
 
 
 void&nbsp;MysqlDB::Commit() 
 { 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 if&nbsp;(mysql_query(&nbsp;mysql_,&nbsp; 
 "COMMIT")&nbsp;!=&nbsp; 
 0) 
 &nbsp;&nbsp;&nbsp;&nbsp;{ 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 //int&nbsp;errno&nbsp;=&nbsp;mysql_errno(mysql_); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;string&nbsp;errmsg&nbsp;=&nbsp;mysql_error(mysql_); 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 throw&nbsp;Exception( 
 "DB&nbsp;ERROR:"+errmsg); 
 &nbsp;&nbsp;&nbsp;&nbsp;} 
 } 
 
 
 void&nbsp;MysqlDB::Rollback() 
 { 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 if&nbsp;(mysql_query(mysql_,&nbsp; 
 "ROLLBACK")&nbsp;==&nbsp; 
 0) 
 &nbsp;&nbsp;&nbsp;&nbsp;{ 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 //int&nbsp;errno&nbsp;=&nbsp;mysql_errno(mysql_); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;string&nbsp;errmsg&nbsp;=&nbsp;mysql_error(mysql_); 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
 throw&nbsp;Exception( 
 "DB&nbsp;ERROR:"+errmsg); 
 &nbsp;&nbsp;&nbsp;&nbsp;} 
 } 
 
 
 
 unsigned&nbsp; 
 long&nbsp; 
 long&nbsp;MysqlDB::GetInsertId()&nbsp; 
 const 
 { 
 &nbsp;&nbsp;&nbsp;&nbsp; 
 return&nbsp;mysql_insert_id(mysql_);&nbsp;&nbsp; 
 //auto_increment字段 } 
 </div> </td> 
 </tr> 
 </tbody> 
</table>

具体使用方法就很简单了，包含MysqlDB.h，比如

MysqlDB mysqldb;

mysqldb.open(...);

mysqldb.QuerySQL(...);

...

参考：

《数据库系统概论》

mysql 5.1 参考手册

[Link 1]: http://blog.csdn.net/jnu_simba/article/details/19400375
[Center]: /images/20220824/8411805447e745b69335a2b8fc7c79be.png