当前位置：首页 -> 基础 -> 数据库编程

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

2014-11-24 10:55:07 · 作者: · 浏览: 2
标签: Mysql 数据库 学习 常用 MysqlCAPI 介绍 使用 封装 一个 访问 MysqlDB
nd class MysqlDB;
public:
const string& GetItem(unsigned int nRow, unsigned int nCol) const
{
return rows_[nRow][nCol];
}

const string& GetItem(unsigned int nRow, const string& name) const
{
unsigned int index = GetFieldIndex(name);
return rows_[nRow][index];
}

unsigned int GetRows() const
{
return rows_.size();
}

unsigned int GetCols() const
{
return fields_.size();
}

unsigned int GetFieldIndex(const std::string &name) const
{
unsigned int index = -1;
for(unsigned int i = 0; i < fields_.size(); ++i)
{
if (fields_[i].name == name)
index = fields_[i].index;
}
return index;
}

void Clear()
{
rows_.clear();
fields_.clear();
}

typedef struct Field
{
string name; //列的字段名
unsigned int index; //字段名对应的下标
} FIELD;

typedef vector FIELDS; //所有列的字段结构体集合
typedef vector ROW; //每一行存储值

private:
vector rows_; // 总共存储多个行
FIELDS fields_;
};

class MysqlDB
{
public:
MysqlDB();
~MysqlDB();
void Open(const char* host,
const char* user,
const char* passwd,
const char* db,
unsigned int port);
void Close();

unsigned long long ExecSQL(const char* sql);
MysqlRecordset QuerySQL(const char* sql);

unsigned long long GetInsertId() const;
void StartTransaction();
void Commit();
void Rollback();


private:
MYSQL* mysql_;
};

}

#endif // _MYSQL_DB_H_
MysqlDB.cpp： C++ Code
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 		#include
#include "MysqlDB.h"

using namespace std;

MysqlDB::MysqlDB() : mysql_(NULL)
{
}

MysqlDB::~MysqlDB()
{
if (mysql_)
{
Close();
}
}
void MysqlDB::Open(const char* host,
const char* user,
const char* passwd,
const char* db,
unsigned int port)
{

mysql_ = mysql_init(NULL);
if (mysql_ == NULL)
{
string errmsg = mysql_error(mysql_);
throw Exception("DB ERROR:"+errmsg);
}

my_bool reconnect = true;
mysql_options(mysql_, MYSQL_OPT_RECONNECT, &reconnect);
mysql_options(mysql_, MYSQL_SET_CHARSET_NAME, "gbk");

if (!mysql_real_connect(mysql_, host, user,
passwd, db, 0, NULL, 0))
{
string errmsg = mysql_error(mysql_);
Close();
throw Exception("DB ERROR:"+errmsg);
}
}

void MysqlDB::Close()
{
if (NULL != mysql_)
{
mysql_close(mysql_);
mysql_ = NULL;
}
}

MysqlRecordset MysqlDB::QuerySQL(const char* sql)
{
if (mysql_query(mysql_, sql) != 0)
{
//int errno = mysql_errno(mysql_);
string errmsg = mysql_error(mysql_);
throw Exception("DB ERROR:"+errmsg);
}

MYSQL_RES* mysql_res;
mysql_res = mysql_store_result(mysql_);

//得到查询返回的行数
//unsigned long n = mysql_affected_rows(mysql_);

//指向 mysql 的查询字段集
MYSQL_FIELD* mysql_field = NULL;

MysqlRecordset rs;
unsigned int i = 0;
unsigned int nCols = mysql_num_fields(mysql_res);
while ((mysql_field = mysql_fetch_field(mysql_res)) != NULL)
{
MysqlRecordset::FIELD field;
field.name = mysql_field->name;
field.index = i;
++i;
rs.fields_.push_back(field); //压入某个列字段的结构体
}

MYSQL_ROW mysql_row;
while ((mysql_row = mysql_fetch_row(mysql_res)))
{
MysqlRecordset::ROW row(nCols);
for (unsigned int i = 0; i< nCols; ++i)
{
row[i] = mysql_row[i] mysql_row[i] : "";
}
rs.rows_.push_back(row); //压入某一行的存储值

}


mysql_free