---

MyMySQLPPConnection.cpp

Go to the documentation of this file.

/*
        MyMySQL++ - Another MySQL++ API providing basic and easy access to MySQL functionality.
    Copyright (C) 2003 Stefan Schadt

    This program is free software; you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation; either version 2 of the License, or
    (at your option) any later version.

    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with this program; if not, write to the Free Software
    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
*/

#include "pch.h"
#include "MyMySQLPPConnection.h"


CMyMySQLPPConnection::CMyMySQLPPConnection(void)
{
        m_con = NULL;
}

CMyMySQLPPConnection::~CMyMySQLPPConnection(void)
{
        Close();
}

BOOL CMyMySQLPPConnection::Connect(const char* host, const char* user, const char* password,
                                                          const char* database, unsigned int port, const char* unix_socket,
                                                          unsigned int client_flag)
{
        m_con = mysql_init(NULL);
        if(mysql_real_connect(m_con, host, user, password, database, port, unix_socket, client_flag) != m_con)
        {
                mysql_close(m_con);
                m_con = NULL;
                return FALSE;
        }
        return TRUE;
}

void CMyMySQLPPConnection::Close(void)
{
        if(m_con != NULL)
                mysql_close(m_con);
        m_con = NULL;
}

BOOL CMyMySQLPPConnection::Ping(void)
{
        if(m_con == NULL)
                return FALSE;
        return (mysql_ping(m_con) == 0);
}

char* CMyMySQLPPConnection::GetClientInfo(void)
{
        return mysql_get_client_info();
}

char* CMyMySQLPPConnection::GetHostInfo(void)
{
        if(m_con == NULL)
                return NULL;
        return mysql_get_host_info(m_con);
}

unsigned int CMyMySQLPPConnection::GetProtocolInfo(void)
{
        if(m_con == NULL)
                return NULL;
        return mysql_get_proto_info(m_con);
}

char* CMyMySQLPPConnection::GetServerInfo(void)
{
        if(m_con == NULL)
                return NULL;
    return mysql_get_server_info(m_con);
}

__int64 CMyMySQLPPConnection::AffectedRows(void)
{
        if(m_con == NULL)
                return 0;
        return mysql_affected_rows(m_con);
}

BOOL CMyMySQLPPConnection::ChangeUser(const char* user, const char* password, const char* db)
{
        if(m_con == NULL)
                return FALSE;
    return (mysql_change_user(m_con, user, password, db) == 0);
}

const char* CMyMySQLPPConnection::CharacterSetName(void)
{
        if(m_con == NULL)
                return NULL;
        return mysql_character_set_name(m_con);
}

unsigned int CMyMySQLPPConnection::ErrorNumber(void)
{
        if(m_con == NULL)
                return 0;
        return mysql_errno(m_con);
}

char* CMyMySQLPPConnection::Error(void)
{
        if(m_con == NULL)
                return 0;
        return mysql_error(m_con);
}

__int64 CMyMySQLPPConnection::InsertID(void)
{
        if(m_con == NULL)
                return 0;
        return mysql_insert_id(m_con);
}

char* CMyMySQLPPConnection::Info(void)
{
        if(m_con == NULL)
                return 0;
        return mysql_info(m_con);
}

BOOL CMyMySQLPPConnection::Kill(unsigned long pid)
{
        if(m_con == NULL)
                return FALSE;
        return mysql_kill(m_con, pid);
}

BOOL CMyMySQLPPConnection::ListDatabases(CMyMySQLPPResult* result, const char* wild)
{
        result->Free();
        if(m_con == NULL)
                return FALSE;
        MYSQL_RES *res = mysql_list_dbs(m_con, wild);
        if(res == NULL)
                return FALSE;
        result->Attach(res);
        return TRUE;
}

BOOL CMyMySQLPPConnection::ListFields(CMyMySQLPPResult* result, const char* table, const char* wild)
{
        result->Free();
        if(m_con == NULL)
                return FALSE;
        MYSQL_RES *res = mysql_list_fields(m_con, table, wild);
        if(res == NULL)
                return FALSE;
        result->Attach(res);
        return TRUE;
}

BOOL CMyMySQLPPConnection::DropDatabase(const char* db)
{
        if(m_con == NULL)
                return FALSE;
        return (mysql_drop_db(m_con, db) == 0);
}

BOOL CMyMySQLPPConnection::ListProcesses(CMyMySQLPPResult* result)
{
        result->Free();
        if(m_con == NULL)
                return FALSE;
        MYSQL_RES *res = mysql_list_processes(m_con);
        if(res == NULL)
                return FALSE;
        result->Attach(res);
        return TRUE;
}

BOOL CMyMySQLPPConnection::ListTables(CMyMySQLPPResult* result, const char* wild)
{
        result->Free();
        if(m_con == NULL)
                return FALSE;
        MYSQL_RES *res = mysql_list_tables(m_con, wild);
        if(res == NULL)
                return FALSE;
        result->Attach(res);
        return TRUE;
}

BOOL CMyMySQLPPConnection::Options(enum mysql_option option, const char* arg)
{
        if(m_con == NULL)
                return FALSE;
        return (mysql_options(m_con, option, arg) == 0);
}

BOOL CMyMySQLPPConnection::Query(const char* query)
{
        if(m_con == NULL)
                return FALSE;
        return (mysql_query(m_con, query) == 0);
}

unsigned long CMyMySQLPPConnection::RealEscape(char* to, char* from, unsigned long length)
{
        if(m_con == NULL)
                return 0;
        return mysql_real_escape_string(m_con, to, from, length);
}

BOOL CMyMySQLPPConnection::RealQuery(const char* query, unsigned long length)
{
        if(m_con == NULL)
                return FALSE;
        return (mysql_real_query(m_con, query, length) == 0);
}

BOOL CMyMySQLPPConnection::Reload(void)
{
        if(m_con == NULL)
                return FALSE;
        return (mysql_reload(m_con) == 0);
}

BOOL CMyMySQLPPConnection::SelectDatabase(const char* db)
{
        if(m_con == NULL)
                return FALSE;
        return (mysql_select_db(m_con, db) == 0);
}

BOOL CMyMySQLPPConnection::Shutdown(void)
{
        if(m_con == NULL)
                return FALSE;
        return (mysql_shutdown(m_con) == 0);
}

char* CMyMySQLPPConnection::Status(void)
{
        if(m_con == NULL)
                return NULL;
        return mysql_stat(m_con);
}

BOOL CMyMySQLPPConnection::StoreResult(CMyMySQLPPResult* result)
{
        result->Free();
        if(m_con == NULL)
                return FALSE;
        MYSQL_RES *res = mysql_store_result(m_con);
        if((res == NULL) && (ErrorNumber() > 0))
                return FALSE; 

        if(res != NULL)
                result->Attach(res);
        return TRUE;
}

unsigned long CMyMySQLPPConnection::ThreadID(void)
{
        if(m_con == NULL)
                return FALSE;
        return mysql_thread_id(m_con);
}

BOOL CMyMySQLPPConnection::UseResult(CMyMySQLPPResult* result)
{
        result->Free();
        if(m_con == NULL)
                return FALSE;
        MYSQL_RES *res = mysql_use_result(m_con);
        if(res == NULL)
                return FALSE;
        result->Attach(res);
        return TRUE;
}

---