db_mysql Class Reference

#include <db_mysql.h>

List of all members.

Public Member Functions
	db_mysql ()
	db_mysql (string host, string user, string passwd, string db="")
	~db_mysql ()
void	Init (string host, string user, string passwd, string db="")
void	SetQuery (string query)
bool	Connect (void)
bool	SelectDB (string db)
bool	Execute (string query="")
unsigned long	Num_Rows (void)
bool	GetRow (my_ulonglong row=NEXT_ROW)
string	GetField (unsigned int n)
string	GetField_name (unsigned int n)
void	Free_Result (void)
void	Close (void)
Public Attributes
unsigned int	Field_num
Private Attributes
MYSQL *	m_Mysql
MYSQL_RES *	m_Res
MYSQL_ROW	m_Row
MYSQL_FIELD *	m_field
string	m_strHost
string	m_strUser
string	m_strPasswd
string	m_strDB
string	m_strQuery
bool	m_bInit
bool	m_bConnect
bool	m_bSelectDB
bool	m_bExecute
bool	m_bGetRow
bool	m_result

---

Detailed Description

Definition at line 9 of file db_mysql.h.

---

Constructor & Destructor Documentation

db_mysql::db_mysql

(

)

Definition at line 3 of file db_mysql.cpp.

        :m_Mysql(NULL)
        ,m_Res(NULL)
        ,m_bConnect(false)
        ,m_bSelectDB(false)
        ,m_bExecute(false)
        ,m_bGetRow(false)
        ,m_bInit(false)
{
        ;       
}

db_mysql::db_mysql	(	string	host,
		string	user,
		string	passwd,
		string	db = ""
	)

Definition at line 14 of file db_mysql.cpp.

References Init().

        :m_Mysql(NULL)
        ,m_Res(NULL)
        ,m_bConnect(false)
        ,m_bSelectDB(false)
        ,m_bExecute(false)
        ,m_bGetRow(false)
{
        Init(host,user,passwd,db);
}       

db_mysql::~db_mysql

(

)

Definition at line 221 of file db_mysql.cpp.

References Close(), and Free_Result().

{
        Free_Result();
        Close();
}

---

Member Function Documentation

void db_mysql::Close

(

void

)

Definition at line 211 of file db_mysql.cpp.

References Free_Result(), m_bConnect, and m_Mysql.

Referenced by main(), WriteLumDB(), and ~db_mysql().

{
        if(m_bConnect)
        {
                Free_Result();
                mysql_close(m_Mysql);
                m_bConnect = false;
        }
}

bool db_mysql::Connect

(

void

)

Definition at line 41 of file db_mysql.cpp.

References m_bConnect, m_Mysql, m_strDB, m_strHost, m_strPasswd, and m_strUser.

Referenced by main(), and WriteLumDB().

{
        if(!m_bConnect)
        {
                my_bool b = 0;
                if(!(m_Mysql=mysql_init(NULL)))
                {
                        cout<<"Init mysql error!!"<<endl;
                        return false; 
                }
//              mysql_options(m_Mysql,MYSQL_REPORT_DATA_TRUNCATION,&b);
                if(!mysql_real_connect(m_Mysql,m_strHost.c_str(),m_strUser.c_str(),m_strPasswd.c_str(),m_strDB.c_str(),0,NULL,0))
                {
                        cout<<"Connect error!!"<<endl;
                        mysql_close(m_Mysql);
                        return false;
                }
        }
        else
        {
                cout<<"You are reconnecting!"<<endl;
                return false;   
        }
        m_bConnect = true;
        return true;
}

bool db_mysql::Execute

(

string

query = ""

)

Definition at line 84 of file db_mysql.cpp.

References Field_num, Free_Result(), m_bConnect, m_bExecute, m_bSelectDB, m_Mysql, m_Res, m_result, and m_strQuery.

Referenced by ReadFromDB(), ReWriteBeamParToDb(), WriteBeamParToDb(), WriteLumDB(), and WriteLumTauDB().

{
        if((!m_bConnect)||(!m_bSelectDB))
        {
                cout<<"You executing query before connection or select db!"<<endl;
                return false;
        }
        if(!query.empty())
        {
                m_strQuery=query;
        }
        if(m_strQuery.empty())
        {
                cout<<"Your haven't set query string!"<<endl;
                return false;   
        }
        else
        {
                Free_Result();
                if(mysql_real_query(m_Mysql,m_strQuery.c_str(),m_strQuery.size()))
                {
                        cout<<"Execute query error!"<<endl;
                        return false;   
                }       
        }
//zhaohs
        Field_num=mysql_field_count(m_Mysql);
        if(Field_num==0){
        m_result=false;
        }
        else {m_result=true;}
//zhaohs
        m_Res = mysql_store_result(m_Mysql);
        m_bExecute = true;
        return true;
}

void db_mysql::Free_Result

(

void

)

Definition at line 201 of file db_mysql.cpp.

References m_bExecute, m_bGetRow, and m_Res.

Referenced by Close(), Execute(), and ~db_mysql().

{
        if(m_bExecute)
        {
                mysql_free_result(m_Res);
                m_bExecute = false;
                m_bGetRow = false;      
        }
}

string db_mysql::GetField

(

unsigned int

n

)

Definition at line 148 of file db_mysql.cpp.

References m_bGetRow, m_Row, and deljobs::string.

Referenced by ReadFromDB(), ReWriteBeamParToDb(), and WriteLumDB().

{
        
        if(!m_bGetRow)
        {
                cout<<"You must get a row before getfield value!"<<endl;
                return "";
        }
        if(m_Row[n]!=NULL){ return (string)m_Row[n];}
        else return "";
}

string db_mysql::GetField_name

(

unsigned int

n

)

Definition at line 171 of file db_mysql.cpp.

References m_field, m_Res, m_result, and deljobs::string.

{
        if(!m_result)
                {
                 cout<<"error:no select!"<<endl;
                return "";
                }
        m_field = mysql_fetch_field_direct(m_Res, n);
        return string(m_field->name);


//      num_fields = mysql_num_fields(result);
//      m_field = mysql_fetch_fields(m_Res);
  //      std::cout<<m_field[n].name<<std::endl;
//      return m_field[n].name;

           
}

bool db_mysql::GetRow

(

my_ulonglong

row = NEXT_ROW

)

Definition at line 121 of file db_mysql.cpp.

References m_bExecute, m_bGetRow, m_Res, m_Row, and NEXT_ROW.

Referenced by ReadFromDB(), ReWriteBeamParToDb(), and WriteLumDB().

{
        if(!m_bExecute)
        {
                cout<<"You must execute query before get row!"<<endl;
                return false;
        }
        if(row!=NEXT_ROW)
        {
                if(row>=mysql_num_rows(m_Res)||row<0)
                {
//                      cout<<"Select row error! Row number must be set in range!"<<endl;
                        return false;
                }
                mysql_data_seek(m_Res,row);     
        }
        m_Row=mysql_fetch_row(m_Res);
        if(m_Row==NULL)
        {
                cout<<"fetch_row error!"<<endl; 
                return false;
        }
        
        m_bGetRow = true;
        return true;
}

void db_mysql::Init	(	string	host,
		string	user,
		string	passwd,
		string	db = ""
	)

Definition at line 25 of file db_mysql.cpp.

References m_bInit, m_bSelectDB, m_strDB, m_strHost, m_strPasswd, and m_strUser.

Referenced by db_mysql(), main(), and WriteLumDB().

{
        m_strHost = host;
        m_strUser = user;
        m_strPasswd = passwd;
        m_strDB = db;
        m_bInit = true;
        if(!db.empty())
        {
                m_bSelectDB = true;
        }
}

unsigned long db_mysql::Num_Rows

(

void

)

Definition at line 191 of file db_mysql.cpp.

References m_bExecute, and m_Res.

{
        if(!m_bExecute)
        {
                cout<<"You are get number of rows before execute!"<<endl;
                return 0;
        }
        return mysql_num_rows(m_Res);
}

bool db_mysql::SelectDB

(

string

db

)

Definition at line 67 of file db_mysql.cpp.

References m_bConnect, m_bSelectDB, m_Mysql, and m_strDB.

Referenced by main(), and WriteLumDB().

{
        if(!m_bConnect)
        {
                cout<<"You must connect before select db!";
                return false;
        }
        if(mysql_select_db(m_Mysql,db.c_str()))
        {
                cout<<"Select database error!"<<endl;
                return false;
        }
        m_strDB = db;
        m_bSelectDB = true;
        return true;
}

void db_mysql::SetQuery

(

string

query

)

Definition at line 37 of file db_mysql.cpp.

References m_strQuery.

{
        m_strQuery=query;
}

---

Member Data Documentation

unsigned int db_mysql::Field_num

Definition at line 36 of file db_mysql.h.

Referenced by Execute().

bool db_mysql::m_bConnect [private]

Definition at line 25 of file db_mysql.h.

Referenced by Close(), Connect(), Execute(), and SelectDB().

bool db_mysql::m_bExecute [private]

Definition at line 27 of file db_mysql.h.

Referenced by Execute(), Free_Result(), GetRow(), and Num_Rows().

bool db_mysql::m_bGetRow [private]

Definition at line 28 of file db_mysql.h.

Referenced by Free_Result(), GetField(), and GetRow().

bool db_mysql::m_bInit [private]

Definition at line 24 of file db_mysql.h.

Referenced by Init().

bool db_mysql::m_bSelectDB [private]

Definition at line 26 of file db_mysql.h.

Referenced by Execute(), Init(), and SelectDB().

MYSQL_FIELD* db_mysql::m_field [private]

Definition at line 15 of file db_mysql.h.

Referenced by GetField_name().

MYSQL* db_mysql::m_Mysql [private]

Definition at line 12 of file db_mysql.h.

Referenced by Close(), Connect(), Execute(), and SelectDB().

MYSQL_RES* db_mysql::m_Res [private]

Definition at line 13 of file db_mysql.h.

Referenced by Execute(), Free_Result(), GetField_name(), GetRow(), and Num_Rows().

bool db_mysql::m_result [private]

Definition at line 29 of file db_mysql.h.

Referenced by Execute(), and GetField_name().

MYSQL_ROW db_mysql::m_Row [private]

Definition at line 14 of file db_mysql.h.

Referenced by GetField(), and GetRow().

string db_mysql::m_strDB [private]

Definition at line 20 of file db_mysql.h.

Referenced by Connect(), Init(), and SelectDB().

string db_mysql::m_strHost [private]

Definition at line 17 of file db_mysql.h.

Referenced by Connect(), and Init().

string db_mysql::m_strPasswd [private]

Definition at line 19 of file db_mysql.h.

Referenced by Connect(), and Init().

string db_mysql::m_strQuery [private]

Definition at line 21 of file db_mysql.h.

Referenced by Execute(), and SetQuery().

string db_mysql::m_strUser [private]

Definition at line 18 of file db_mysql.h.

Referenced by Connect(), and Init().

---