mysql_preparedstatement_parameter.cpp

Go to the documentation of this file.

#include "wx/database/wxprec.h"

#if wxUSE_DATABASE_MYSQL

// ctor
wxMysqlPreparedStatementParameter::wxMysqlPreparedStatementParameter(MYSQL_BIND* pBind)
 : wxDatabaseErrorReporter()
{
  m_pBind = pBind;
  // Default to NULL
  SetNull();
}

wxMysqlPreparedStatementParameter::wxMysqlPreparedStatementParameter(MYSQL_BIND* pBind, const wxString& strValue)
 : wxDatabaseErrorReporter()
{
  m_pBind = pBind;
  SetString(strValue);
}

wxMysqlPreparedStatementParameter::wxMysqlPreparedStatementParameter(MYSQL_BIND* pBind, int nValue)
 : wxDatabaseErrorReporter()
{
  m_pBind = pBind;
  SetInt(nValue);
}

wxMysqlPreparedStatementParameter::wxMysqlPreparedStatementParameter(MYSQL_BIND* pBind, double dblValue)
 : wxDatabaseErrorReporter()
{
  m_pBind = pBind;
  SetDouble(dblValue);
}

wxMysqlPreparedStatementParameter::wxMysqlPreparedStatementParameter(MYSQL_BIND* pBind, const void* pData, long nDataLength)
 : wxDatabaseErrorReporter()
{
  m_pBind = pBind;
  SetBlob(pData, nDataLength);
}

wxMysqlPreparedStatementParameter::wxMysqlPreparedStatementParameter(MYSQL_BIND* pBind, const wxDateTime& dateValue)
 : wxDatabaseErrorReporter()
{
  m_pBind = pBind;
  SetDate(dateValue);
}

wxMysqlPreparedStatementParameter::wxMysqlPreparedStatementParameter(MYSQL_BIND* pBind, bool bValue)
 : wxDatabaseErrorReporter()
{
  m_pBind = pBind;
  SetBool(bValue);
}

wxMysqlPreparedStatementParameter::wxMysqlPreparedStatementParameter(MYSQL_BIND* pBind, MYSQL_FIELD* pField)
 : wxDatabaseErrorReporter()
{
  m_pBind = pBind;
  m_pBind->is_null = &m_bIsNull;

  // Set the binding properties
  m_pBind->buffer_type = pField->type;
  m_pBind->buffer_length = pField->length + 1;
  //int nType = m_pBind->buffer_type;
  //if (nType == MYSQL_TYPE_STRING || nType == MYSQL_TYPE_VAR_STRING || nType == MYSQL_TYPE_BLOB
  //  || nType == MYSQL_TYPE_TINY_BLOB || nType == MYSQL_TYPE_MEDIUM_BLOB || nType == MYSQL_TYPE_LONG_BLOB)
  //{
    //wxLogDebug(_("Allocating %ld bytes in the MYSQL_BIND buffer\n"), pField->length);
    void* pBuffer = m_Data.bufferValue.GetWriteBuf(m_pBind->buffer_length);
    if (pBuffer == 0)
    {
      SetErrorCode(wxMysqlDatabase::TranslateErrorCode(0));
      SetErrorMessage(_("Error allocating buffer"));
      ThrowDatabaseException();
    }
    m_pBind->buffer = pBuffer;
    ClearBuffer();
  //  }
  //  else
  //  {
  //  pCurrentBinding->buffer = malloc(1);
  //  }

  int nType = m_pBind->buffer_type;
  if (nType == MYSQL_TYPE_BLOB || nType == MYSQL_TYPE_TINY_BLOB || nType == MYSQL_TYPE_MEDIUM_BLOB 
    || nType == MYSQL_TYPE_LONG_BLOB)
    m_pBind->length = &m_Data.nBufferLength;
}

// dtor
wxMysqlPreparedStatementParameter::~wxMysqlPreparedStatementParameter()
{
}

void wxMysqlPreparedStatementParameter::ClearBuffer()
{
  if (m_pBind && m_pBind->buffer && (m_pBind->buffer_length > 0))
  {
    memset(m_pBind->buffer, 0, m_pBind->buffer_length);
  }
}

void wxMysqlPreparedStatementParameter::SetInt(int nValue)
{
  m_Data.nValue = nValue;
  m_pBind->buffer_type = MYSQL_TYPE_LONG;
  m_pBind->buffer = (void*)&m_Data.nValue;
}

void wxMysqlPreparedStatementParameter::SetDouble(double dblValue)
{
  m_Data.dblValue = dblValue;
  m_pBind->buffer_type = MYSQL_TYPE_DOUBLE;
  m_pBind->buffer = (void*)&m_Data.dblValue;
}

void wxMysqlPreparedStatementParameter::SetString(const wxString& strValue)
{
  memset(m_pBind, 0, sizeof(MYSQL_BIND));
  m_Data.strValue = strValue;
  m_pBind->buffer_type = MYSQL_TYPE_STRING;
  m_Data.charBufferValue = ConvertToUnicodeStream(m_Data.strValue);
  m_pBind->buffer = (void*)(const char*)m_Data.charBufferValue;
  m_Data.nBufferLength = GetEncodedStreamLength(m_Data.strValue);
  m_pBind->length = &(m_Data.nBufferLength);
  m_pBind->buffer_length = m_Data.nBufferLength;
}

void wxMysqlPreparedStatementParameter::SetNull()
{
  m_bIsNull = 1;
  m_pBind->is_null = &m_bIsNull;
}

void wxMysqlPreparedStatementParameter::SetBlob(const void* pData, long nDataLength)
{
  void* pBuffer = m_Data.bufferValue.GetWriteBuf(nDataLength);
  memcpy(pBuffer, pData, nDataLength);
  m_pBind->buffer_type = MYSQL_TYPE_BLOB;
  m_pBind->buffer = pBuffer;
  m_pBind->buffer_length = nDataLength;
}

void wxMysqlPreparedStatementParameter::SetDate(const wxDateTime& dateValue)
{
  m_Data.dateValue.year = dateValue.GetYear();
  m_Data.dateValue.month = dateValue.GetMonth();
  m_Data.dateValue.day = dateValue.GetDay();
  m_Data.dateValue.hour = dateValue.GetHour();
  m_Data.dateValue.minute = dateValue.GetMinute();
  m_Data.dateValue.second = dateValue.GetSecond();
    
  m_pBind->buffer_type = MYSQL_TYPE_DATETIME;
  m_pBind->buffer = (void*)&m_Data.dateValue;
}

void wxMysqlPreparedStatementParameter::SetBool(bool bValue)
{
  m_Data.bValue = bValue;
  m_pBind->buffer_type = MYSQL_TYPE_TINY;
  m_pBind->buffer = (void*)&m_Data.bValue;
}

#endif//wxUSE_DATABASE_MYSQL