quickfix-ffi 0.2.1

/* -*- C++ -*- */

/****************************************************************************
** Copyright (c) 2001-2014
**
** This file is part of the QuickFIX FIX Engine
**
** This file may be distributed under the terms of the quickfixengine.org
** license as defined by quickfixengine.org and appearing in the file
** LICENSE included in the packaging of this file.
**
** This file is provided AS IS with NO WARRANTY OF ANY KIND, INCLUDING THE
** WARRANTY OF DESIGN, MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
**
** See http://www.quickfixengine.org/LICENSE for licensing information.
**
** Contact ask@quickfixengine.org if any conditions of this licensing are
** not clear to you.
**
****************************************************************************/

#ifndef HAVE_ODBC
#error OdbcConnection.h included, but HAVE_ODBC not defined
#endif

#ifdef HAVE_ODBC
#ifndef FIX_ODBCCONNECTION_H
#define FIX_ODBCCONNECTION_H

#ifdef _MSC_VER
#pragma warning(disable : 4503 4355 4786 4290)
#pragma comment(lib, "Odbc32")
#endif

#include "DatabaseConnectionID.h"
#include "DatabaseConnectionPool.h"
#include "Exceptions.h"
#include "Mutex.h"
#include "Utility.h"
#include <sql.h>
#include <sqlext.h>
#include <sqltypes.h>
#include <sstream>

namespace FIX {

inline std::string odbcError(SQLSMALLINT statementType, SQLHANDLE handle) {
  SQLCHAR state[6];
  SQLINTEGER error;
  SQLCHAR text[SQL_MAX_MESSAGE_LENGTH];
  SQLSMALLINT textLength;
  RETCODE result = SQLGetDiagRec(statementType, handle, 1, state, &error, text, sizeof(text), &textLength);
  if (result == SQL_SUCCESS || result == SQL_SUCCESS_WITH_INFO) {
    return std::string((char *)text);
  }
  return "";
}

inline bool odbcSuccess(RETCODE result) { return result == SQL_SUCCESS || result == SQL_SUCCESS_WITH_INFO; }

class OdbcQuery {
public:
  OdbcQuery(const std::string &query)
      : m_statement(0),
        m_result(0),
        m_query(query) {}

  ~OdbcQuery() { close(); }

  void close() {
    if (m_statement) {
      SQLFreeHandle(SQL_HANDLE_STMT, m_statement);
      m_statement = 0;
      m_result = 0;
    }
  }

  bool execute(HDBC connection) {
    if (m_statement) {
      SQLFreeHandle(SQL_HANDLE_STMT, m_statement);
    }
    SQLAllocHandle(SQL_HANDLE_STMT, connection, &m_statement);
    m_result = SQLExecDirect(m_statement, (SQLCHAR *)m_query.c_str(), (SQLINTEGER)m_query.size());
    if (success() || m_result == SQL_NO_DATA) {
      return true;
    }
    m_reason = odbcError(SQL_HANDLE_STMT, m_statement);
    SQLFreeHandle(SQL_HANDLE_STMT, m_statement);
    m_statement = 0;
    return success();
  }

  bool success() { return odbcSuccess(m_result); }

  /*int rows()
  {
    return (int)mysql_num_rows( m_result );
  }*/

  const std::string &reason() { return m_reason; }

  bool fetch() { return odbcSuccess(SQLFetch(m_statement)); }

  /*char* getValue( int row, int column )
  {
    if( m_rows.empty() )
    {
      MYSQL_ROW row = 0;
      while( row = mysql_fetch_row( m_result ) )
        m_rows.push_back(row);
    }
    return m_rows[row][column];
  }*/

  HSTMT statement() { return m_statement; }

  void throwException() EXCEPT(IOException) {
    if (!success()) {
      throw IOException("Query failed [" + m_query + "] " + reason());
    }
  }

private:
  HSTMT m_statement;
  RETCODE m_result;
  std::string m_query;
  std::string m_reason;
};

class OdbcConnection {
public:
  OdbcConnection(const DatabaseConnectionID &id)
      : m_environment(0),
        m_connection(0),
        m_connectionID(id) {
    connect();
  }

  OdbcConnection(const std::string &user, const std::string &password, const std::string &connectionString)
      : m_environment(0),
        m_connection(0),
        m_connectionID("", user, password, connectionString, 0) {
    connect();
  }

  ~OdbcConnection() {
    if (m_connection) {
      SQLDisconnect(m_connection);
      SQLFreeHandle(SQL_HANDLE_DBC, m_connection);
      SQLFreeHandle(SQL_HANDLE_ENV, m_environment);
    }
  }

  const DatabaseConnectionID &connectionID() { return m_connectionID; }

  bool connected() {
    Locker locker(m_mutex);
    return m_connected;
  }

  bool reconnect() {
    Locker locker(m_mutex);
    SQLDisconnect(m_connection);
    SQLFreeHandle(SQL_HANDLE_DBC, m_connection);
    m_connection = 0;
    connect();
    return true;
  }

  bool execute(OdbcQuery &pQuery) {
    Locker locker(m_mutex);
    if (!pQuery.execute(m_connection)) {
      reconnect();
      return pQuery.execute(m_connection);
    }
    return true;
  }

private:
  void connect() {
    m_connected = false;

    RETCODE result;
    if (!m_environment) {
      result = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &m_environment);
      if (!odbcSuccess(result)) {
        throw ConfigError("Unable to allocate ODBC environment");
      }

      result = SQLSetEnvAttr(m_environment, SQL_ATTR_ODBC_VERSION, (void *)SQL_OV_ODBC3, 0);
      if (!odbcSuccess(result)) {
        throw ConfigError("Unable to find ODBC version 3.0");
      }
    }

    result = SQLAllocHandle(SQL_HANDLE_DBC, m_environment, &m_connection);
    if (!odbcSuccess(result)) {
      throw ConfigError("Unable to allocate ODBC connection");
    }

    std::stringstream connectionStream;
    std::string connectionString = m_connectionID.getHost();
    if (m_connectionID.getHost().find("UID=") == std::string::npos) {
      connectionStream << "UID=" << m_connectionID.getUser() << ";";
    }
    if (m_connectionID.getHost().find("PWD=") == std::string::npos) {
      connectionStream << "PWD=" << m_connectionID.getPassword() << ";";
    }
    connectionStream << m_connectionID.getHost();
    connectionString = connectionStream.str();

    SQLCHAR connectionStringOut[255];

    result = SQLDriverConnect(
        m_connection,
        NULL,
        (SQLCHAR *)connectionString.c_str(),
        SQL_NTS,
        connectionStringOut,
        255,
        0,
        SQL_DRIVER_NOPROMPT);

    if (!odbcSuccess(result)) {
      std::string error = odbcError(SQL_HANDLE_DBC, m_connection);
      throw ConfigError(error);
    }

    m_connected = true;
  }

  HENV m_environment;
  HDBC m_connection;
  bool m_connected;
  DatabaseConnectionID m_connectionID;
  Mutex m_mutex;
};
} // namespace FIX

#endif
#endif