c++封装MYSQL数据库连接代码

#include "StdAfx.h" #include"conn.h" conn_mysql::conn_mysql() { } bool conn_mysql::Conn_sql(char* server,char* user,char* password,char* database)//数据库连接 { mysql_init(&connbase); //初始化connbase结构 if(mysql_real_connect(&connbase,server,user,password,database,0,NULL,0)) return true; else return false; } void conn_mysql::Conn_Close() { RowNumber=1; DataHome.clear();//清空容器数据 mysql_free_result(res); //释放结果集 mysql_close(&connbase); //释放连接 } bool conn_mysql::Base_Select(char *strSql)//查询操作 { mysql_query(&connbase, "set names utf8");//支持中文显示 if(mysql_query(&connbase,strSql)>=0) {//进行查询 res=mysql_store_result(&connbase); //获得结果集 Database_Vector(); return true; } else return false; } bool conn_mysql::Base_Insert(char *strSql)//插入操作 { mysql_query(&connbase, "set names utf8"); if(mysql_query(&connbase,strSql)>=0)//执行插入 { return true; } else return false; } bool conn_mysql::Base_Update(char *strSql)//修改操作 { mysql_query(&connbase, "set names utf8"); if(mysql_query(&connbase,strSql)>=0) { return true; } else return false; } bool conn_mysql::Base_Delete(char *strSql)//删除操作 { mysql_query(&connbase, "set names utf8"); if(mysql_query(&connbase,strSql)>=0)//执行删除 { return true; } else return false; } char* conn_mysql::GetNumber(int Icolums)//取某个行数的某个字段 { if(RowNumber>=1&&RowNumber<=CountRows) { std::vector<T_DataHouse>::iterator it =DataHome.begin()+RowNumber-1;//获取行数 database=it->base[Icolums-1];//对应的字段记录 return database; } else return NULL; } void conn_mysql::Database_Vector() { int i,j; CountNums=mysql_num_fields(res);//列数 char* database=NULL; RowNumber=1; T_DataHouse ItemThis;//结构体定义 // ItemThis.base=new char*[CountNums+1]; for(i=1;row= mysql_fetch_row(res);i++) { ItemThis.base=new char*[CountNums]; for(j=0;j<CountNums;j++) { ItemThis.ID=i; ItemThis.base[j] =row[j]; } if(DataHome.size()>0)//如果加载成功则判断 { std::vector<T_DataHouse>::iterator it = DataHome.begin();//判断该容器内ID是否有重名 for(; it != DataHome.end();it++) { if(ItemThis.base == it->base) { *it = ItemThis; } } } DataHome.push_back(ItemThis); } CountRows=--i; } int conn_mysql::GetFirstRow()//返回第一行 { RowNumber=1; return RowNumber; } int conn_mysql::GetEndRow()//返回最后一行 { RowNumber=CountRows; return RowNumber; } int conn_mysql::GetNextRow()//返回下一行 { if(RowNumber<=CountRows&&RowNumber>=0) { return RowNumber++; } else return 0; } char* conn_mysql::GetAttrible(int fields)//取字段属性 { int i=CountNums; if(fields>=0&&fields<CountNums) { MYSQL_FIELD *field; field=mysql_fetch_fields(res); return field[fields].name; } else return NULL; } int conn_mysql::GetOnline()//返回上一行 { if(RowNumber<=CountRows&&RowNumber>=0) { return RowNumber--; } else return 0; }