[Mysql]一个Mysql C API小型封装

#include  
数据挖掘研究院
 
typedef        std::string        string; 数据挖掘研究院 
struct        mysql_parm{
        string        host;
        string        user;
        string        password;
        string        database;
        string        unixsock;
};
class        DBSTMT;
class        DBMysql; 
数据挖掘研究院
 
class        DBSTMT{
        DBSTMT(const DBSTMT&);
        DBSTMT&        operator=(const DBSTMT&);
        MYSQL_STMT*        stmt_;
public:
        DBSTMT(pcsz_t        query,DBMysql&        mysql);
        void        execute(){
                if(mysql_stmt_execute(stmt_))
                        throw        mysql_stmt_error(stmt_);
        } 
数据挖掘实验室
 
        void        execute(MYSQL_BIND* bind){
                if(mysql_stmt_execute(stmt_))
                        throw        mysql_stmt_error(stmt_);
                if(mysql_stmt_bind_result(stmt_,bind)){
                        throw        mysql_stmt_error(stmt_);
                }
                if(mysql_stmt_store_result(stmt_)) 
数据挖掘实验室
 
                        throw        mysql_stmt_error(stmt_);
        } 数据挖掘研究院 
        //void        execute(){
        //        if(mysql_stmt_execute(stmt_))
        //                throw        mysql_stmt_error(stmt_);
        //} 
数据挖掘研究院
 
        void        bind(MYSQL_BIND* bind){
                if(mysql_stmt_bind_param(stmt_,bind) )
                        throw        mysql_stmt_error(stmt_);
        } 数据挖掘研究院 
        int        fetch(){
                return        mysql_stmt_fetch(stmt_)==0;
        }
        ~DBSTMT(){
                if(stmt_){
                        mysql_stmt_close(stmt_);
                }
        } 数据挖掘研究院 
}; 数据挖掘研究院 

class        DBMysql{
        DBMysql(const DBMysql&);
        DBMysql&operator=(const DBMysql&);
        MYSQL        *        mysqlPtr_; 
数据挖掘研究院
 
        uint32_t        errno_;
protected:
        friend        class        DBSTMT;
        MYSQL_STMT*        _createSTMT(){
                MYSQL_STMT        *ret=mysql_stmt_init(mysqlPtr_);
                if(ret)
                        return        ret;
                errno_=mysql_errno(mysqlPtr_);
                throw        mysql_error(mysqlPtr_); 数据挖掘实验室 
        }
public:
        const        char*        strerr(){
                return        mysql_error(mysqlPtr_);
        }
        DBMysql():mysqlPtr_(NULL){
                mysqlPtr_=mysql_init(NULL);
                if(NULL== mysqlPtr_)
                        throw        "Mysql :outof memory";
        }
        void        open(const        mysql_parm& parm){ 
数据挖掘实验室
 
                if(!mysql_real_connect(mysqlPtr_,
                        parm.host.c_str(),
                        parm.user.c_str(),
                        parm.password.c_str(),
                        parm.database.c_str(),
                        0,
                        parm.unixsock.c_str(), 数据挖掘研究院 
                        0        ))
                {
                        errno_=mysql_errno(mysqlPtr_);
                        throw(mysql_error(mysqlPtr_));
                }
        } 数据挖掘研究院 
        void        close(){
                if(mysqlPtr_)
                {
                        mysql_close(mysqlPtr_);
                        mysqlPtr_=NULL;
                }
        } 数据挖掘研究院 
}; 
数据挖掘研究院
 

DBSTMT::DBSTMT(pcsz_t        query,DBMysql&        mysql):stmt_(NULL){
        stmt_=mysql._createSTMT();
        if(!stmt_)
                throw        mysql.strerr();
        if( mysql_stmt_prepare(stmt_,query,strlen(query)) )
        {
                //const char*        err= 数据挖掘研究院 
                throw        mysql_stmt_error(stmt_);
        } 
数据挖掘研究院
 
} 
数据挖掘研究院
 
#define        DECL_BIND(h,n)
class bind_##h:public        h{
        typedef        h        parent;
        MYSQL_BIND                _bind[n];
        my_bool                        _is_null[n];
        unsigned        long        _length[n];
public:
        bind_##h(){
        int        i=0;
        bzero(_bind,sizeof(_bind)); 
数据挖掘研究院
 

#define        BIND_BIN(x,l)
        _bind[i].buffer_type= MYSQL_TYPE_STRING;
        _bind[i].buffer= (char *)&(parent::x);
        _bind[i].buffer_length= l;
        _bind[i].is_null= _is_null+i;
        _bind[i].length= _length+i;
        ++i; 数据挖掘研究院 
#define        BIND_INT(x)
        _bind[i].buffer_type= MYSQL_TYPE_LONG;
        _bind[i].buffer= (char *)&(parent::x);
        _bind[i].buffer_length= 0;
        _bind[i].is_null= _is_null+i;
        _bind[i].length= _length+i;
        ++i; 
数据挖掘研究院
 
#define        END_BIND(h)                }
        operator        MYSQL_BIND*(){
        return        _bind;
        }
}; 数据挖掘研究院 
  数据挖掘实验室 
  数据挖掘研究院 
使用方法; 数据挖掘研究院 
例如想查询的内容具有以下结构
struct account{
        char        user[36];
        byte        password[16];
        uint32_t        status;
        uint32_t        id;
}; 
数据挖掘研究院
 
//声明查询bind 结构account,参数4个
DECL_BIND(account,4)
        BIND_BIN(user,32)
        BIND_BIN(password,16)
        BIND_INT(status)
        BIND_INT(id)
END_BIND(account) 
数据挖掘研究院
 
int main(){ 数据挖掘研究院 
        try{
                
                DBMysql        mysql;
                mysql_parm        parm;
                parm.host="localhost";
                parm.user="root";
                parm.password="test";
                parm.unixsock="/var/lib/mysql/mysql.sock";
                parm.database="testdb"; 数据挖掘研究院 
                mysql.open(parm);//打开数据库
                
                DBSTMT        
smt("select user,password,status,id from account",mysql);
//生成一个查询语法
                DBSTMT       
 smt1("insert into account(user,password,status) value(?,?,?)",mysql);
//另外一个
        //
                
                bind_account        acc;
                 
数据挖掘研究院
 

                smt.execute(acc);//执行查询，并bind返回结果到account结构                
                while(smt.fetch()){
                printf("%s %d %d
",acc.user,acc.status,acc.id);
                        
                }; 
数据挖掘研究院
 
                smt1.bind(acc);//bind查询参数
                smt1.execute();//执行
                
                
                
        }catch(const char* err){
                printf("error:%s
",err);
        } 
数据挖掘研究院
 
} 
数据挖掘研究院