mysql C++ API 实现

/* * MySQLDB.cpp * * Created on: 2011-3-18 * Author: root */ #include "MySQLDB.h" MySQLDB::MySQLDB() { isConnected = false; } void MySQLDB::open(string strHost,string strUser,string strPass,string strDBName,unsigned int port,unsigned long client_flag) { if (isConnected) { std::cout << "Connected MySQL server." << std::endl; return; } mysql_init(&m_mysql); if (!mysql_real_connect(&m_mysql,strHost.c_str(),strUser.c_str(),strPass.c_str(),strDBName.c_str(),port,NULL,client_flag)) { std::cout <<"Connect to mysql server fail:%s\n"<< mysql_error(&m_mysql) << std::endl; } isConnected=true; } bool MySQLDB::checkDBConnected() { return isConnected; } /* *Testing mysql server if it is alive *return: 0-->success;-1--> fail */ int MySQLDB::ping() { if (!mysql_ping(&m_mysql)) return 0; else return -1; } /* * Support InnoDB or BDB table type */ int MySQLDB::startTransaction() { if (!mysql_real_query(&m_mysql,"START TRANSACTION", (unsigned long)strlen("START TRANSACTION"))) { return 0; //success } else { return -1; //fail } } int MySQLDB::commit() { if (!mysql_real_query(&m_mysql,"COMMIT", (unsigned long)strlen("COMMIT"))) { return 0; //success } else { return -1; //fail } } int MySQLDB::rollback() { if (!mysql_real_query(&m_mysql,"ROLLBACK", (unsigned long)strlen("ROLLBACK"))) { return 0; //success } else { return -1; //fail } } int MySQLDB::execute(string sql) { if (!isConnected) { std::cout<<"Not connect to mysql server."<<std::endl; return -1; } if (sql.empty()) { std::cout<<"sql statement is null."<<std::endl; return -1; } if (!mysql_real_query(&m_mysql,sql.c_str(),(unsigned int)strlen(sql.c_str()))) { return (int)mysql_affected_rows(&m_mysql); } { std::cout << "Query fail from database:%s\n" << mysql_error(&m_mysql) << std::endl; return -1; } } void MySQLDB::close() { mysql_close(&m_mysql); this->isConnected = false; } MySQLDB::~MySQLDB() { // TODO Auto-generated destructor stub this->close(); } /* * Get mysql handler */ MYSQL MySQLDB::getMysql() const { return m_mysql; }