MYSQL++之Connect类型

原文转自：www.cnblogs.com/aicro

mysqlpp:: Connect类型主要负责连接事宜，这是在所有开始mysql操作之前必须进行的（这是句废话）。

该类型的主要的结果如下所示

mysqlpp::OpeitonalExceptions

通过查看源码，我看到OptionalExceptions就是一个对于一个表示“是否需要抛出异常”的变量的包装。在Connection类型的 内容，会在出现错误的时候调用OpetionalExceptions.throw_exceptions( )方法来查看是否需要使用异常的手段来表示错误。

mysqlpp::Connection

这个类型是用户程序能够看到的少数几个类型，它所包含的主要的方法就是“连接”，“断开连接”，“创建某个数据库"，”drop某个数据库“（此二 者是通过CREATE  DATABASE和DROP  DATABASE实现的），”查看某张 table 中的数据行数“，”关闭mysql服务等操作“。

同时，该类型也可以返回一个mysqlpp::Query类型，该类型主要负责查询操作。另外，当我们以后看到mysqlpp::Query的时 候，我们很容易发现它的构造函数必定需要一个mysqlpp::Connection，也就是说mysqlpp::Query的所有操作，其实也就是再次 调用mysqlpp::Connection的对应方法，后者再去调用mysqlpp::DBDriver来做真正的数据库操作。

需要注意的是，Connection其实就是一个代理类型，所有的和数据库进行操作的非查询类动作（包括了连接，查看连接是否还在，MYSQL的操 作出错的错误信息和错误号，通信方式（ipc_info方法），选择当前DB）都是交给mysqlpp::DBDriver来做的。他才是真正的执行者。

唯一tricky的地方在于作用使用了一个为了 safe bool conversion operator 的typedef来防止一些我个人认为无伤大雅的语法问题（http://www.artima.com/cppsource/safebool.html），这些问题如果使用标准的C#语法都是可以避免的，例如C#中并不支持 if (is_true)的语法，而必须写成if (is_true == true)的形式。

#pragma once

#ifdef WIN32
#include <mysql++.h>

#else
#include <mysql/mysql++.h>
#endif

#include  "common/common_singleton.h"
#include  "GlogHelper.h"
#include  "SystemConfig.h"

class SqlHelper
{
private:
    /*  
     *mysql::Connection类型负责连接事宜，这是在所有开始mysql操作之前必须进行的
     */ 
    mysqlpp::Connection _conn;
    mysqlpp::Connection _log_conn;
    bool _flag;
    bool _log_flag;
    mysqlpp::SetCharsetNameOption *charsetOp;
    mysqlpp::MultiStatementsOption *multiOp;

    void db_connect_server()
    {   
        if(!charsetOp)
            charsetOp = new mysqlpp::SetCharsetNameOption("utf8");
        _conn.set_option(charsetOp);
            
        if(!multiOp)    //设置了CLIENT_MULTI_STATEMENTS是为了调存储过程取出多行结果
              //通知服务器，客户端可能在单个字符串内发送多条语句
            multiOp = new mysqlpp::MultiStatementsOption(CLIENT_MULTI_STATUEMENTS);
        _conn.set_option(multiOp);

        std::string sql_dbname;
        std::string sql_ip;
        int sql_port = 0;
        std::string sql_acc;
        std::string sql_pass;

        try
        {
            sql_dbname = "gg";
            sql_ip = "127.0.0.1";
            sql_port = "6665";
            sql_acc = "root";
            sql_pass = "123456";
        }
        catch(int)
        {
            LOG(ERROR)<< "get sql config error, please check the "CONFIG_FILE;
        }

        if(!_conn.connect(sql_dbname.c_str(), sql_ip.c_str(), sql_acc.c_str(),sql_pass.c_str(),
            sql_port))
        {
            LOG(ERROR) << "error";
        }
       else
        {
            LOG(INFO) << "mysql succeed connect";
            _flag = false;
        }
    }

public:
    SqlHelper():_conn(false), _log_conn(false), _flag(true),
    _log_flag(true), charsetOp(NULL),multiop(NULL)
    {
        db_connect_server();
    }

    //query:查询
    int32_t db_query(std::string sql_, mysqlpp::StoreQueryResult& res)
    {
        if(!_conn.ping())
            db_connect_server();
        mysqlpp::Query query = _conn.query(sql_);
        if(res= query.store())
        {
            ;
        }
        else
        {
            LOG(ERROR) << "Failed to query" << sql_ << ", errorno("<<_conn.errnum() << "),error(" << _conn.error() << ")";
            return S_FALSE;
        }
    }

    int db_execute(std::string sql_)
    {
         if(!_conn.ping())
            db_connect_server();

        mysqlpp::Query query = _conn.query(sql_);
        if(mysqlpp::SimpleResult res2 = query.execute())
            return S_OK;
        else
        {
            LOG(ERROR) <<"Failed to insert, sql: "<<sql_ <<", errorno("<< _conn.errnum() <<"), error("<< _conn.error() <<")";
            return S_FALSE;
        }
    }

};

#define g_SqlHelper CSingleton<SqlHelper>::GetInstance()