src/data/MySqlCommand.cpp

/*
 *   This file is part of the Standard Portable Library (SPL).
 *
 *   SPL 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 3 of the License, or
 *   (at your option) any later version.
 *
 *   SPL 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 SPL.  If not, see <http://www.gnu.org/licenses/>.
 */
#include <spl/text/StringBuffer.h>
#include <spl/data/MySqlConnection.h>

#if defined(HAVE_MYSQL_H) || defined(HAVE_MYSQL_MYSQL_H)

#ifdef HAVE_MYSQL_H
#include <mysql.h>
#else
#include <mysql/mysql.h>
#endif

extern RecordSet *_LoadMySqlRecordSet(MYSQL *mysql, MYSQL_RES *result);

MySqlCommand::MySqlCommand(MySqlConnection *mysql)
: Command(), m_mysql(mysql)
{
}

MySqlCommand::MySqlCommand(MySqlConnection *mysql, const String& cmdtxt)
: Command(cmdtxt), m_mysql(mysql)
{
}

MySqlCommand::~MySqlCommand()
{
}

String MySqlCommand::ToSQL()
{
        StringBuffer buf(255);

        buf.Append("CALL ");
        buf.Append(&m_cmdtxt);

        int count = m_prm.Count();
        for ( int x = 0; x < count; x++ )
        {
                CommandParameterPtr& prm = m_prm.ElementAtRef(x);
                prm.ValidateMem();
                if ( x > 0 )
                {
                        buf.Append(',');
                }
                if ( !prm->IsNumeric() )
                {
                        buf.Append('\'');
                }
                buf.Append(prm->ToString()->GetChars());
                if ( !prm->IsNumeric() )
                {
                        buf.Append('\'');
                }
        }
        return *buf.ToString();
}

void MySqlCommand::CommandTextSet(const String& txt)
{
        m_cmdtxt.Set(txt);
}

void MySqlCommand::Prepare()
{
        throw new NotImplementedException();
}

int MySqlCommand::ExecuteNonQuery()
{
        String sql = ToSQL();
        return m_mysql->ExecuteNonQuery(sql.GetChars());
}

RecordSetPtr MySqlCommand::ExecuteQuery()
{
        String sql = ToSQL();
        return m_mysql->ExecuteQuery(sql.GetChars());
}

#if defined(DEBUG)
void MySqlCommand::CheckMem() const
{
        Command::CheckMem();
}

void MySqlCommand::ValidateMem() const
{
        Command::ValidateMem();
}
#endif

#endif