C++连接使用MySQL的方法
程序员文章站
2022-03-23 18:57:18
c++连接使用mysql,供大家参考,具体内容如下定义mysqlcon类class mysqlcon{ mysql mysql;public: int errornum; string errorte...
c++连接使用mysql,供大家参考,具体内容如下
定义mysqlcon类
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); } }
连接到mysql服务器
//参数分别为主机,用户名,密码,数据库名,端口号 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; }
获取mysql错误信息
void mysqlcon::geterrortext() { //获取错误代码 errornum = mysql_errno(&mysql); //获取错误文本 errortext = mysql_error(&mysql); //打印错误代码 cout << "error num: " << errornum << std::endl; //打印错误文本 cout << "error text: " << errortext << std::endl; getchar(); }
c++中使用sql语句
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; }
输出内容
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
上一篇: 内容运营基本功:怎么变着花样写产品软文?