C++连接使用MySQL的方法

class mysqlcon
{
 mysql mysql;
public:
 int errornum;
 string errortext;
public:
 //初始化
 mysqlcon();
 //关闭数据库
 ~mysqlcon();
 //链接数据库
 bool openconn(const char* host,const char* username,const char* pwd,const char* dbname,unsigned port=0);
 void geterrortext();//获取错误文本
 void close();//关闭数据库
 bool executesql(const char* sql);//使用sql语句,无法接收数据
 bool qureysql(const char* sql, vector<vector<string>>& resultset);//使用sql语句并接收数据(select语句)
};

mysqlcon::mysqlcon()
{
 if (mysql_library_init(0, nullptr, nullptr)) 
 {
 cout << "capi初始化失败" << std::endl;
 getchar();
 exit(1);
 }
 if (mysql_init(&mysql)==nullptr)
 {
 cout << "初始化数据库变量失败" << std::endl;
 getchar();
 exit(1);
 }
 if (mysql_options(&mysql, mysql_set_charset_name, "gbk"))
 {
 cout << "设置连接选项失败" << std::endl;
 getchar();
 exit(1);
 }
}

//参数分别为主机,用户名,密码,数据库名,端口号
bool mysqlcon::openconn(const char* host, const char* username, const char* pwd, const char* dbname, unsigned port)
{
 //连接数据库
 if (mysql_real_connect(&mysql, host, username, pwd, dbname, port, nullptr, 0)==nullptr)
 {
 cout << "连接到mysql服务器失败" << std::endl;
 //获取错误文本
 geterrortext();
 exit(1);
 return false;
 }
 return true;
 
}

void mysqlcon::geterrortext()
{
 //获取错误代码
 errornum = mysql_errno(&mysql);
 //获取错误文本
 errortext = mysql_error(&mysql);
 //打印错误代码
 cout << "error num: " << errornum << std::endl;
 //打印错误文本
 cout << "error text: " << errortext << std::endl;
 getchar();
}

bool mysqlcon::executesql(const char* sql)
{
 //使用sql语句但无法接收数据
 if (mysql_real_query(&mysql, sql, strlen(sql)))
 {
 geterrortext();
 return false;
 }
 return true;
}

bool mysqlcon::qureysql(const char* sql, vector<vector<string>>& resultset)
{
 //使用sql语句并接收数据至vector容器
 if (mysql_real_query(&mysql, sql, strlen(sql)))
 {
 geterrortext();
 return false;
 }
 //创建一个mysql结果集
 mysql_res* result = mysql_store_result(&mysql);
 //获取行和列的总数
 unsigned int rows = mysql_num_rows(result);
 unsigned int cols = mysql_num_fields(result);
 //用于记录结果集中的一条数据
 mysql_row row;
 while (row = mysql_fetch_row(result))
 {
 //创建一个vector容器用于储存row中的数据
 vector<string> linedate;
 for (int i = 0; i < cols; i++)
 {
 if (row[i])
 {
 //将row中每一列的数据存入linedate中
 linedate.push_back(row[i]);
 }
 else
 {
 linedate.push_back("");
 }
 }
 //在resultset中存入整行数据
 resultset.push_back(linedate);
 }
 //释放结果集
 mysql_free_result(result);
 return true;
}

void mysqlcon::close()
{
 mysql_close(&mysql);
}
mysqlcon::~mysqlcon()
{
 close();
 mysql_library_end();
}

int main()
{
 mysqlcon c_apiconn;
 c_apiconn.openconn("127.0.0.1", "root", "136119", "fancy");
 string sql = "use fancy;";
 vector<vector<string>> data;
 c_apiconn.executesql(sql.c_str());
 sql = "select * from fancy.info;";
 c_apiconn.qureysql(sql.c_str(), data);
 for (int i = 0; i < data.size(); i++)
 {
 for (int j = 0; j < data[i].size(); j++)
 {
 cout << data[i][j] << "\t";
 }
 cout << endl;
 }
 return 0;
}