C++ ODBC MS SQL SERVER

#include <sql.h>
#include <sqlext.h>
#include <sqlex>
 
SQLHENV henv;
SQLHDBC hdbc;
 
//------------------------------------------------------------------------------
// Подключение к базы данных
 
void dbConnect(const char* addr) {
  SQLRETURN  retcode;
 
  retcode = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &henv);
  if(retcode == SQL_SUCCESS || retcode == SQL_SUCCESS_WITH_INFO) {
   retcode = SQLSetEnvAttr(henv, SQL_ATTR_ODBC_VERSION, (void*)SQL_OV_ODBC3, 
0);
   if (retcode == SQL_SUCCESS || retcode == SQL_SUCCESS_WITH_INFO) {
      retcode = SQLAllocHandle(SQL_HANDLE_DBC, (void*)henv, &hdbc);
     if (retcode == SQL_SUCCESS || retcode == SQL_SUCCESS_WITH_INFO) {
     SQLSetConnectAttr(hdbc, SQL_LOGIN_TIMEOUT, (void*)5, 0);
        char buf[1024];
        short buf_len;
        retcode = SQLDriverConnect(hdbc, GetDesktopWindow(), (SQLCHAR*)addr, 
SQL_NTS, (SQLCHAR*)buf, 1024, &buf_len, 
SQL_DRIVER_COMPLETE|SQL_DRIVER_NOPROMPT);
 
     if(retcode == SQL_SUCCESS || retcode == SQL_SUCCESS_WITH_INFO)
          return;
 
     SQLFreeHandle(SQL_HANDLE_DBC, hdbc);
        hdbc=0;
      }
    }
   SQLFreeHandle(SQL_HANDLE_ENV, henv);
    henv=0;
  }
  exception e("Connect error");
  throw e;
}
 
//------------------------------------------------------------------------------
// Отключение от базы данных
 
void dbDisconnect() {
  if(hdbc==0) return;
  SQLDisconnect(hdbc);
  SQLFreeHandle(SQL_HANDLE_DBC, hdbc);
  hdbc=0;
  SQLFreeHandle(SQL_HANDLE_ENV, henv);
  henv=0;
}
 
//------------------------------------------------------------------------------
 
// Выполнение запрсоов и возврат результатов
 
class Recordset {
public:
  SQLHSTMT hstmt;
  bool lastNull;
 
  Recordset();
 
  void execute(const char* str); // Выполнить запрос
  int getFieldsCount(); // Узнать кол-во колонок
 
  // Получить следующую строку таблицы
  inline bool fetch() {
    assert(hstmt!=0);
    int r=SQLFetch(hstmt);
    return r==SQL_SUCCESS || r==SQL_SUCCESS_WITH_INFO;
  }
 
  // Получить ячейку строки таблицы
  inline int getI(int x) {
    assert(hstmt!=0);
    int i;
    int t,r = SQLGetData(hstmt,x+1,SQL_C_LONG,&i,0,(long*)&t);
    if(r!=SQL_SUCCESS && r!=SQL_SUCCESS_WITH_INFO) raise("Can't get integer 
field");
    lastNull = t==SQL_NULL_DATA;
    return i;
  }
 
  // Получить ячейку строки таблицы
  inline bool getB(int x) {
    int i;
    assert(hstmt!=0);
    int t,r = SQLGetData(hstmt,x+1,SQL_C_LONG,&i,0,(long*)&t);
    lastNull = t==SQL_NULL_DATA;
    if(r!=SQL_SUCCESS && r!=SQL_SUCCESS_WITH_INFO) raise("Can't get boolean 
field");
    return i!=0;
  }
 
  // Получить ячейку строки таблицы
  inline string getS(int x) {
    //! Неоптимально
    assert(hstmt!=0);
    string str;
    int t = 1024;
    str.resize(t);
    int r = SQLGetData(hstmt,x+1,SQL_C_CHAR,(void*)str.c_str(),t,(long*)&t);
    lastNull = t==SQL_NULL_DATA;
    if((r!=SQL_SUCCESS && r!=SQL_SUCCESS_WITH_INFO) || t<0) return "";
    str.resize(t);
    if(t>=1024) {
      t-=1023;
      int r = 
SQLGetData(hstmt,x+1,SQL_C_CHAR,(void*)(str.c_str()+1023),t,(long*)&t);
      if((r!=SQL_SUCCESS && r!=SQL_SUCCESS_WITH_INFO) || t<0) return "";
    }
    return str;
  }
 
  ~Recordset();
};
 
//------------------------------------------------------------------------------
 
Recordset::Recordset() {
  int r=SQLAllocHandle(SQL_HANDLE_STMT, hdbc, &hstmt);
  if(r!=SQL_SUCCESS && r!=SQL_SUCCESS_WITH_INFO) {
    hstmt=0;
    raise("Recordset.Recordset Ошибка "+i2s(r)+" при создании датасета");
  }
}
 
//------------------------------------------------------------------------------
 
void Recordset::execute(const char* cmd) {
  if(!hstmt) raise("Датасет не инициализирован");
  int r=SQLExecDirect(hstmt, (SQLCHAR*)cmd, SQL_NTS);
  if(r!=SQL_SUCCESS && r!=SQL_SUCCESS_WITH_INFO && r!=SQL_NO_DATA) 
raise("Ошибка "+i2s(r)+" при выполнении 
запроса\n"+((string)cmd).substr(0,64));
}
 
//------------------------------------------------------------------------------
 
int Recordset::getFieldsCount() {
  if(!hstmt) raise("Датасет не инициализирован");
  short cnt;
  int r=SQLNumResultCols(hstmt, &cnt);
  if(r!=SQL_SUCCESS && r!=SQL_SUCCESS_WITH_INFO) raise("Ошибка "+i2s(r)+" 
при получении кол-ва полей датасета");
  return cnt;
}
 
//------------------------------------------------------------------------------
 
Recordset::~Recordset() {
  if(hstmt) SQLFreeHandle(SQL_HANDLE_STMT, hstmt);
}
 
//------------------------------------------------------------------------------
 
void main() {
  dbConnect("большая и страшная строка подключения");
  Recordset r;
  r.execute("sp_tables");
  cout << r.getFieldsCount() << endl;
  while(r.fetch())
    cout << r.getS(0) << endl;
}