Search Site ~Database~  Designer  ~ C++ ~  mysql C++   sqlite C++   odbc C++   sql2class   Tutorial  ~Contact~ message board  email author   visit project   homepage at   freshmeat.net

Query Class Reference SQL Statement execute / result set helper class. More... #include <Query.h> Collaboration diagram for Query: List of all members. Public Member Functions   Query (Database &dbin)   Constructor accepting reference to database object.   Query (Database &dbin, const std::string &sql)   Constructor accepting reference to database object and query to execute. virtual  ~Query () bool  Connected ()   Check to see if database object is connectable. Database &  GetDatabase () const   Return reference to database object. const std::string &  GetLastQuery ()   Return string of last query executed. short  execute (const std::string &sql)   Execute sql query that does not return a result. bool  get_result (const std::string &sql, char **attrs=NULL)   execute query and store result. void  free_result ()   free stored result, must be called after get_result() bool  fetch_row ()   Fetch next result row. long  insert_id ()   Get id of last insert - not implemented. long  num_rows ()   Returns 0 if there are no rows to fetch. int  num_cols ()   Number of columns in current result. const std::string &  GetError ()   Last error string. int  GetErrno ()   Last error code. bool  is_null (int x)   Check if column x in current row is null. bool  is_null (const std::string &x) bool  is_null () const char *  get_string (const std::string &sql)   Execute query and return first result as a string. long  get_count (const std::string &sql)   Execute query and return first result as a long integer. double  get_num (const std::string &sql)   Execute query and return first result as a double. const char *  getstr (const std::string &x) const char *  getstr (int x)   Return value of column number x as a string value. const char *  getstr () long  getval (const std::string &x) long  getval (int x)   Return value of column number x as a long integer. long  getval () _int64  getbigint (const std::string &x) _int64  getbigint (int x)   Return value of column number x as a 64-bit integer. _int64  getbigint () double  getnum (const std::string &x) double  getnum (int x)   Return value of column number x as a double. double  getnum () SQL_INTERVAL_STRUCT *  getinterval (const std::string &x)   ODBC Query specific. SQL_INTERVAL_STRUCT *  getinterval (int x) SQL_INTERVAL_STRUCT *  getinterval () bool  GetColumnInfo (short, SQLHCOL &) bool  get_result (SQLSMALLINT func) bool  get_result (SQLSMALLINT func, const std::string &catalog, const std::string &schema, const std::string &tablename) void  ReturnRowAsXML (std::string &, const std::string &="", long=DQ_XML_ENDTAG) bool  GotMore () bool  getcol (std::string &colname, std::string &coltype, int &width, int &dec, int &nullable) bool  getcol (int x, std::string &colname, std::string &coltype, int &width, int &dec, int &nullable) Private Member Functions bool  odbc_store_result () void  error (const std::string &text) Private Attributes Database &  m_db Session *  m_odb SQLHSTMT  m_hstmt DSQLHRES *  m_hres short  m_currentcolumn long  m_results long  m_fetchrows int  m_qcols int  m_currentcol std::string  m_tmpstr std::string  m_last_query std::string  m_sql_state std::string  m_errtext std::map< std::string, int >  m_nmap Detailed Description SQL Statement execute / result set helper class. Definition at line 129 of file Query.h. Constructor & Destructor Documentation Query::Query (  Database &  dbin  )    Constructor accepting reference to database object. Definition at line 43 of file Query.cpp. :m_db(dbin) ,m_odb(m_db.grabdb()) ,m_hstmt(NULL) ,m_hres(NULL) ,m_currentcolumn(0) ,m_results(0) ,m_fetchrows(0) ,m_qcols(0) ,m_currentcol(0) { } Query::Query (  Database &  dbin, const std::string &  sql )    Constructor accepting reference to database object and query to execute. Definition at line 57 of file Query.cpp. References execute(). :m_db(dbin) ,m_odb(m_db.grabdb()) ,m_hstmt(NULL) ,m_hres(NULL) ,m_currentcolumn(0) ,m_results(0) ,m_fetchrows(0) ,m_qcols(0) ,m_currentcol(0) { execute(sql); } Query::~Query (   )  [virtual]   Definition at line 72 of file Query.cpp. References Database::freedb(), m_db, m_hres, m_hstmt, and m_odb. { if (m_hstmt) { SQLFreeHandle(SQL_HANDLE_STMT, m_hstmt); } if (m_hres) { delete m_hres; } if (m_odb) { m_db.freedb(m_odb); } } Member Function Documentation bool Query::Connected (   )    Check to see if database object is connectable. Definition at line 1232 of file Query.cpp. { return true; // TODO: implement } void Query::error (  const std::string &  text  )  [private]   Definition at line 1223 of file Query.cpp. References Database::GetErrHandler(), and m_db. Referenced by execute(), get_result(), getbigint(), getinterval(), getnum(), getstr(), getval(), is_null(), and odbc_store_result(). { if (m_db.GetErrHandler()) { m_db.GetErrHandler() -> error(m_db, *this, text); } } short Query::execute (  const std::string &  sql  )    Execute sql query that does not return a result. Returns: true if query is successful Definition at line 89 of file Query.cpp. References error(), m_currentcol, m_fetchrows, m_hres, m_hstmt, m_last_query, m_odb, m_qcols, m_results, and num_rows(). Referenced by get_result(), and Query(). { SQLRETURN retcode; m_last_query = sql; if (m_odb && m_hres) { error("Query::execute(): Query busy"); } if (m_odb && !m_hres) { m_results = 0; m_fetchrows = 0; m_qcols = 0; m_currentcol = 0; // Free statement handle if (m_hstmt) { SQLFreeHandle(SQL_HANDLE_STMT, m_hstmt); } // Allocate statement handle (STMT) retcode = SQLAllocHandle(SQL_HANDLE_STMT, static_cast<SQLHDBC>(m_odb -> GetHandle()), &m_hstmt); if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) { error("Query::execute(): Allocate statement handle (STMT) failed"); return 0; // 0 failed } retcode = SQLExecDirect(m_hstmt, (unsigned char *)sql.c_str(), sql.size()); if (retcode == SQL_ERROR || retcode == SQL_SUCCESS_WITH_INFO) { Session *tmp = dynamic_cast<Session *>(m_odb); if (tmp) { tmp -> ShowErrorInfo(retcode, SQL_HANDLE_STMT, m_hstmt); } } if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) { error("Query::execute(): SQL Query failed:"); error(sql); return 0; // 0 failed } m_results = num_rows(); return 1; } return 0; } bool Query::fetch_row (   )    Fetch next result row. Returns: false if there was no row to fetch (end of rows) Definition at line 366 of file Query.cpp. References m_currentcolumn, m_fetchrows, m_hres, m_hstmt, and m_odb. Referenced by get_count(), get_num(), and get_string(). { m_currentcolumn = 0; // ODBC columns start at 1 m_fetchrows++; if (m_odb && m_hstmt && m_hres) { SQLRETURN retcode = SQLFetch(m_hstmt); if (retcode == SQL_SUCCESS) { return true; } } return false; } void Query::free_result (   )    free stored result, must be called after get_result() Definition at line 162 of file Query.cpp. References m_hres, m_nmap, and m_odb. Referenced by get_count(), get_num(), and get_string(). { if (m_odb && m_hres) { delete m_hres; m_hres = NULL; } while (m_nmap.size()) { std::map<std::string,int>::iterator it = m_nmap.begin(); m_nmap.erase(it); } } long Query::get_count (  const std::string &  sql  )    Execute query and return first result as a long integer. Definition at line 834 of file Query.cpp. References fetch_row(), free_result(), get_result(), and getval(). { long l = 0; if (get_result(sql)) { if (fetch_row()) { l = getval(); } free_result(); } return l; } double Query::get_num (  const std::string &  sql  )    Execute query and return first result as a double. Definition at line 818 of file Query.cpp. References fetch_row(), free_result(), get_result(), and getnum(). { double l = 0; if (get_result(sql)) { if (fetch_row()) { l = getnum(); } free_result(); } return l; } bool Query::get_result (  SQLSMALLINT  func, const std::string &  catalog, const std::string &  schema, const std::string &  tablename )    Definition at line 280 of file Query.cpp. References error(), m_currentcol, m_fetchrows, m_hres, m_hstmt, m_odb, m_qcols, m_results, odbc_store_result(), SQLGET_COLUMNS, SQLGET_PRIMARYKEYS, and SQLGET_SPECIALCOLUMNS. { if (m_odb && m_hres) { error("Query::get_result(): Query busy"); } if (m_odb && !m_hres) { SQLRETURN retcode = SQL_ERROR; bool result = false; m_results = 0; m_fetchrows = 0; m_qcols = 0; m_currentcol = 0; // Free statement handle if (m_hstmt) { SQLFreeHandle(SQL_HANDLE_STMT, m_hstmt); } // Allocate statement handle (STMT) retcode = SQLAllocHandle(SQL_HANDLE_STMT, static_cast<SQLHDBC>(m_odb -> GetHandle()), &m_hstmt); if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) { error("Query::execute(): Allocate statement handle (STMT) failed"); return 0; // 0 failed } switch (func) { case SQLGET_COLUMNS: retcode = SQLColumns(m_hstmt, (unsigned char *) (catalog.size() ? catalog.c_str() : NULL), (SQLSMALLINT) (catalog.size() ? SQL_NTS : 0), (unsigned char *) (schema.size() ? schema.c_str() : NULL), (SQLSMALLINT) (schema.size() ? SQL_NTS : 0), (unsigned char *)tablename.c_str(), (SQLSMALLINT)SQL_NTS, (unsigned char *)NULL, (SQLSMALLINT)0); break; case SQLGET_SPECIALCOLUMNS: retcode = SQLSpecialColumns(m_hstmt, SQL_BEST_ROWID, // SQL_ROWVER, (unsigned char *) (catalog.size() ? catalog.c_str() : NULL), (SQLSMALLINT) (catalog.size() ? SQL_NTS : 0), (unsigned char *) (schema.size() ? schema.c_str() : NULL), (SQLSMALLINT) (schema.size() ? SQL_NTS : 0), (unsigned char *)tablename.c_str(), (SQLSMALLINT)SQL_NTS, SQL_SCOPE_TRANSACTION, // SQL_SCOPE_SESSION, SQL_NULLABLE); break; case SQLGET_PRIMARYKEYS: retcode = SQLPrimaryKeys(m_hstmt, (unsigned char *) (catalog.size() ? catalog.c_str() : NULL), (SQLSMALLINT) (catalog.size() ? SQL_NTS : 0), (unsigned char *) (schema.size() ? schema.c_str() : NULL), (SQLSMALLINT) (schema.size() ? SQL_NTS : 0), (unsigned char *)tablename.c_str(), (SQLSMALLINT)SQL_NTS ); break; } if (retcode == SQL_ERROR || retcode == SQL_SUCCESS_WITH_INFO) { Session *tmp = dynamic_cast<Session *>(m_odb); if (tmp) { tmp -> ShowErrorInfo(retcode, SQL_HANDLE_STMT, m_hstmt); } } if (retcode == SQL_SUCCESS || retcode == SQL_SUCCESS_WITH_INFO) { result = true; } else { } if (result) { return odbc_store_result(); } else { error("Query::get_result(): Query failed"); } } return false; } bool Query::get_result (  SQLSMALLINT  func  )    Definition at line 177 of file Query.cpp. References error(), m_currentcol, m_fetchrows, m_hres, m_hstmt, m_odb, m_qcols, m_results, odbc_store_result(), SQLGET_CATALOGS, SQLGET_SCHEMAS, SQLGET_TABLES, SQLGET_TABLETYPES, and SQLGET_VIEWS. { if (m_odb && m_hres) { error("Query::get_result(): Query busy"); } if (m_odb && !m_hres) { SQLRETURN retcode = SQL_ERROR; bool result = false; m_results = 0; m_fetchrows = 0; m_qcols = 0; m_currentcol = 0; // Free statement handle if (m_hstmt) { SQLFreeHandle(SQL_HANDLE_STMT, m_hstmt); } // Allocate statement handle (STMT) retcode = SQLAllocHandle(SQL_HANDLE_STMT, static_cast<SQLHDBC>(m_odb -> GetHandle()), &m_hstmt); if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) { error("Query::execute(): Allocate statement handle (STMT) failed"); return 0; // 0 failed } switch (func) { case SQLGET_CATALOGS: retcode = SQLTables(m_hstmt, // catalogs, schemas, tables, table types (unsigned char *)SQL_ALL_CATALOGS, SQL_NTS, (unsigned char *)NULL, 0, (unsigned char *)NULL, 0, (unsigned char *)NULL, 0 ); break; case SQLGET_SCHEMAS: retcode = SQLTables(m_hstmt, // catalogs, schemas, tables, table types (unsigned char *)NULL, 0, (unsigned char *)SQL_ALL_SCHEMAS, SQL_NTS, (unsigned char *)NULL, 0, (unsigned char *)NULL, 0 ); break; case SQLGET_TABLES: retcode = SQLTables(m_hstmt, // catalogs, schemas, tables, table types (unsigned char *)SQL_ALL_CATALOGS, SQL_NTS, (unsigned char *)NULL, 0, (unsigned char *)"%%", SQL_NTS, // TODO: single %? (unsigned char *)"TABLE", 5 ); break; case SQLGET_VIEWS: retcode = SQLTables(m_hstmt, // catalogs, schemas, tables, table types (unsigned char *)SQL_ALL_CATALOGS, SQL_NTS, (unsigned char *)NULL, 0, (unsigned char *)"%%", SQL_NTS, // TODO: single %? (unsigned char *)"VIEW", 4 ); break; case SQLGET_TABLETYPES: retcode = SQLTables(m_hstmt, // catalogs, schemas, tables, table types (unsigned char *)"", 0, (unsigned char *)"", 0, (unsigned char *)"", 0, (unsigned char *)SQL_ALL_TABLE_TYPES, SQL_NTS ); break; } if (retcode == SQL_ERROR || retcode == SQL_SUCCESS_WITH_INFO) { Session *tmp = dynamic_cast<Session *>(m_odb); if (tmp) { tmp -> ShowErrorInfo(retcode, SQL_HANDLE_STMT, m_hstmt); } } if (retcode == SQL_SUCCESS || retcode == SQL_SUCCESS_WITH_INFO) { result = true; } else { } if (result) { return odbc_store_result(); } else { error("Query::get_result(): Query failed"); } } return false; } bool Query::get_result (  const std::string &  sql, char **  attrs = NULL )    execute query and store result. Definition at line 140 of file Query.cpp. References error(), execute(), m_hres, m_odb, and odbc_store_result(). Referenced by get_count(), get_num(), and get_string(). { UNUSED_ALWAYS(attrs); if (m_odb && m_hres) { error("Query::get_result(): Query busy"); } if (m_odb && !m_hres) { if (execute(sql)) { return odbc_store_result(); } else { error("Query::get_result(): Query failed"); } } return false; } const char * Query::get_string (  const std::string &  sql  )    Execute query and return first result as a string. Definition at line 803 of file Query.cpp. References fetch_row(), free_result(), get_result(), getstr(), and m_tmpstr. { m_tmpstr = ""; if (get_result(sql)) { if (fetch_row()) { m_tmpstr = getstr(); } free_result(); } return m_tmpstr.c_str(); } _int64 Query::getbigint (   )    Definition at line 741 of file Query.cpp. References m_currentcolumn. Referenced by getbigint(). { return getbigint(m_currentcolumn++); } _int64 Query::getbigint (  int  x  )    Return value of column number x as a 64-bit integer. Parameters: x  0-based column index Definition at line 661 of file Query.cpp. References error(), m_hres, m_hstmt, and m_odb. { SQLHCOL *col; if (m_odb && m_hstmt && m_hres && x >= 0 && x < m_hres -> m_num_cols) { col = m_hres -> m_cols[x + 1]; switch (col -> nCType) { case SQL_C_SBIGINT: return col -> buffer -> bigint; default: { char msg[200]; sprintf(msg, "Query::getbigint(): Conversion not supported (%s)\n",col -> szTypeName); error(msg); } break; } } return 0L; } _int64 Query::getbigint (  const std::string &  x  )    Definition at line 783 of file Query.cpp. References error(), getbigint(), and m_nmap. { int index = m_nmap[x] - 1; if (index >= 0) return getbigint(index); error("Column name lookup failure: " + x); return 0; } bool Query::getcol (  int  x, std::string &  colname, std::string &  coltype, int &  width, int &  dec, int &  nullable )    Definition at line 1202 of file Query.cpp. References m_hres, and m_qcols. { if (x < m_qcols) { SQLHCOL *col; col = m_hres -> m_cols[x + 1]; colname = (char *)(col -> szColumnName); coltype = col -> szTypeName; width = col -> nColumnSizePtr; dec = col -> nDecimalDigitsPtr; nullable = col -> nNullablePtr; return true; } else { return false; } } bool Query::getcol (  std::string &  colname, std::string &  coltype, int &  width, int &  dec, int &  nullable )    Definition at line 1196 of file Query.cpp. References m_currentcol. { return getcol(m_currentcol++, colname, coltype, width, dec, nullable); } bool Query::GetColumnInfo (  short  , SQLHCOL &  )    Definition at line 1040 of file Query.cpp. References m_hres, m_hstmt, and m_odb. { if (m_odb && m_hstmt && m_hres && x >= 0 && x < m_hres -> m_num_cols) { memmove(&hc, m_hres -> m_cols[x + 1], sizeof(SQLHCOL)); hc.next = NULL; hc.buffer = NULL; hc.tmpstr = NULL; return true; } return false; } Database & Query::GetDatabase (   )  const   Return reference to database object. Definition at line 1238 of file Query.cpp. References m_db. { return m_db; } int Query::GetErrno (   )    Last error code. Definition at line 1261 of file Query.cpp. References Session::GetLastError(), m_errtext, m_odb, and m_sql_state. Referenced by StderrLog::error(). { if (m_odb) { return m_odb->GetLastError(m_sql_state, m_errtext); } return -1; } const std::string & Query::GetError (   )    Last error string. Definition at line 1250 of file Query.cpp. References Session::GetLastError(), m_errtext, m_odb, and m_sql_state. Referenced by StderrLog::error(). { m_errtext = ""; if (m_odb) { m_odb->GetLastError(m_sql_state, m_errtext); } return m_errtext; } SQL_INTERVAL_STRUCT * Query::getinterval (   )    Definition at line 747 of file Query.cpp. References m_currentcolumn. Referenced by getinterval(). { return getinterval(m_currentcolumn++); } SQL_INTERVAL_STRUCT * Query::getinterval (  int  x  )    Definition at line 686 of file Query.cpp. References error(), m_hres, m_hstmt, and m_odb. { SQLHCOL *col; if (m_odb && m_hstmt && m_hres && x >= 0 && x < m_hres -> m_num_cols) { col = m_hres -> m_cols[x + 1]; switch (col -> nCType) { case SQL_INTERVAL_MONTH: case SQL_INTERVAL_YEAR: case SQL_INTERVAL_YEAR_TO_MONTH: case SQL_INTERVAL_DAY: case SQL_INTERVAL_HOUR: case SQL_INTERVAL_MINUTE: case SQL_INTERVAL_SECOND: case SQL_INTERVAL_DAY_TO_HOUR: case SQL_INTERVAL_DAY_TO_MINUTE: case SQL_INTERVAL_DAY_TO_SECOND: case SQL_INTERVAL_HOUR_TO_MINUTE: case SQL_INTERVAL_HOUR_TO_SECOND: case SQL_INTERVAL_MINUTE_TO_SECOND: return &col -> buffer -> interval; default: { char msg[200]; sprintf(msg, "Query::getinterval(): Conversion not supported (%s)\n",col -> szTypeName); error(msg); } break; } } return NULL; } SQL_INTERVAL_STRUCT * Query::getinterval (  const std::string &  x  )    ODBC Query specific. Definition at line 793 of file Query.cpp. References error(), getinterval(), and m_nmap. { int index = m_nmap[x] - 1; if (index >= 0) return getinterval(index); error("Column name lookup failure: " + x); return 0; } const std::string & Query::GetLastQuery (   )    Return string of last query executed. Definition at line 1244 of file Query.cpp. References m_last_query. Referenced by StderrLog::error(). { return m_last_query; } double Query::getnum (   )    Definition at line 729 of file Query.cpp. References m_currentcolumn. Referenced by get_num(), and getnum(). { return getnum(m_currentcolumn++); } double Query::getnum (  int  x  )    Return value of column number x as a double. Parameters: x  0-based column index Definition at line 587 of file Query.cpp. References error(), m_hres, m_hstmt, and m_odb. { SQLHCOL *col; if (m_odb && m_hstmt && m_hres && x >= 0 && x < m_hres -> m_num_cols) { col = m_hres -> m_cols[x + 1]; switch (col -> nCType) { case SQL_C_FLOAT: return col -> buffer -> f; case SQL_C_DOUBLE: return col -> buffer -> d; case SQL_C_CHAR: if (!strcmp(col -> szTypeName,"SQL_DECIMAL")) { double d = atof(col -> buffer -> String); return d; } { char msg[200]; sprintf(msg, "Query::getnum(): Conversion not supported (%s)\n",col -> szTypeName); error(msg); } break; default: { char msg[200]; sprintf(msg, "Query::getnum(): Conversion not supported (%s)\n",col -> szTypeName); error(msg); } break; } } return 0; } double Query::getnum (  const std::string &  x  )    Definition at line 763 of file Query.cpp. References error(), getnum(), and m_nmap. { int index = m_nmap[x] - 1; if (index >= 0) return getnum(index); error("Column name lookup failure: " + x); return 0; } const char * Query::getstr (   )    Definition at line 723 of file Query.cpp. References m_currentcolumn. Referenced by get_string(), getstr(), and ReturnRowAsXML(). { return getstr(m_currentcolumn++); } const char * Query::getstr (  int  x  )    Return value of column number x as a string value. Parameters: x  0-based column index Definition at line 435 of file Query.cpp. References error(), Database::GetDecimalChar(), m_db, m_hres, m_hstmt, and m_odb. { SQLHCOL *col; char slask[80]; // sprintf format if (m_odb && m_hstmt && m_hres && x >= 0 && x < m_hres -> m_num_cols) { col = m_hres -> m_cols[x + 1]; if (col -> nCType == SQL_C_CHAR && !strcmp(col -> szTypeName,"SQL_DECIMAL")) { double d = atof(col -> buffer -> String); char *s; if (!col -> tmpstr) { col -> tmpstr = new char[80]; } sprintf(slask,"%%%d.%df",col -> nColumnSizePtr,col -> nDecimalDigitsPtr); sprintf(col -> tmpstr, slask, d); if ((s = strstr(col -> tmpstr,".")) != NULL) { *s = m_db.GetDecimalChar(); } return col -> tmpstr; } else switch (col -> nCType) { case SQL_C_CHAR: return col -> buffer -> String; case SQL_C_WCHAR: // unicode return col -> buffer -> String; // case SQL_C_TCHAR: // return col -> buffer -> String; case SQL_C_FLOAT: if (!col -> tmpstr) { col -> tmpstr = new char[80]; } sprintf(slask,"%%%d.%df",col -> nColumnSizePtr,col -> nDecimalDigitsPtr); sprintf(col -> tmpstr, slask, col -> buffer -> f); return col -> tmpstr; case SQL_C_DOUBLE: if (!col -> tmpstr) { col -> tmpstr = new char[80]; } sprintf(slask,"%%%d.%df",col -> nColumnSizePtr,col -> nDecimalDigitsPtr); sprintf(col -> tmpstr, slask, col -> buffer -> d); return col -> tmpstr; case SQL_C_BIT: if (!col -> tmpstr) { col -> tmpstr = new char[80]; } sprintf(col -> tmpstr,"%u",col -> buffer -> c & 1); return col -> tmpstr; case SQL_C_STINYINT: if (!col -> tmpstr) { col -> tmpstr = new char[20]; } sprintf(slask,"%%%dd",col -> nColumnSizePtr); sprintf(col -> tmpstr, slask, col -> buffer -> c); return col -> tmpstr; case SQL_C_SSHORT: if (!col -> tmpstr) { col -> tmpstr = new char[20]; } sprintf(slask,"%%%dd",col -> nColumnSizePtr); sprintf(col -> tmpstr, slask, col -> buffer -> s); return col -> tmpstr; case SQL_C_SLONG: if (!col -> tmpstr) { col -> tmpstr = new char[20]; } strcpy(slask,"%ld"); sprintf(col -> tmpstr, slask, col -> buffer -> l); return col -> tmpstr; case SQL_C_SBIGINT: // _int64 if (!col -> tmpstr) { col -> tmpstr = new char[80]; } sprintf(slask,"%%%dI64d",col -> nColumnSizePtr); sprintf(col -> tmpstr, slask, col -> buffer -> bigint); return col -> tmpstr; case SQL_C_BINARY: return col -> buffer -> String; case SQL_C_TYPE_DATE: // SQL_DATE_STRUCT if (!col -> tmpstr) { col -> tmpstr = new char[20]; } sprintf(col -> tmpstr,"%d-%02d-%02d", col -> buffer -> date.year, col -> buffer -> date.month, col -> buffer -> date.day); return col -> tmpstr; case SQL_C_TYPE_TIME: if (!col -> tmpstr) { col -> tmpstr = new char[20]; } sprintf(col -> tmpstr,"%02d:%02d:%02d", col -> buffer -> time.hour, col -> buffer -> time.minute, col -> buffer -> time.second); return col -> tmpstr; case SQL_C_TYPE_TIMESTAMP: if (!col -> tmpstr) { col -> tmpstr = new char[80]; } sprintf(col -> tmpstr,"%d-%02d-%02d %02d:%02d:%02d", //.%u", col -> buffer -> timestamp.year, col -> buffer -> timestamp.month, col -> buffer -> timestamp.day, col -> buffer -> timestamp.hour, col -> buffer -> timestamp.minute, col -> buffer -> timestamp.second); return col -> tmpstr; case SQL_INTERVAL_MONTH: case SQL_INTERVAL_YEAR: case SQL_INTERVAL_YEAR_TO_MONTH: case SQL_INTERVAL_DAY: case SQL_INTERVAL_HOUR: case SQL_INTERVAL_MINUTE: case SQL_INTERVAL_SECOND: case SQL_INTERVAL_DAY_TO_HOUR: case SQL_INTERVAL_DAY_TO_MINUTE: case SQL_INTERVAL_DAY_TO_SECOND: case SQL_INTERVAL_HOUR_TO_MINUTE: case SQL_INTERVAL_HOUR_TO_SECOND: case SQL_INTERVAL_MINUTE_TO_SECOND: break; default: { char msg[200]; sprintf(msg, "Query::getstr(): Conversion not supported (%s)\n",col -> szTypeName); error(msg); } break; } } return NULL; } const char * Query::getstr (  const std::string &  x  )    Definition at line 753 of file Query.cpp. References error(), getstr(), and m_nmap. { int index = m_nmap[x] - 1; if (index >= 0) return getstr(index); error("Column name lookup failure: " + x); return ""; } long Query::getval (   )    Definition at line 735 of file Query.cpp. References m_currentcolumn. Referenced by get_count(), and getval(). { return getval(m_currentcolumn++); } long Query::getval (  int  x  )    Return value of column number x as a long integer. Parameters: x  0-based column index Definition at line 626 of file Query.cpp. References error(), m_hres, m_hstmt, and m_odb. { SQLHCOL *col; long l; if (m_odb && m_hstmt && m_hres && x >= 0 && x < m_hres -> m_num_cols) { col = m_hres -> m_cols[x + 1]; switch (col -> nCType) { case SQL_C_BIT: return col -> buffer -> c & 1; case SQL_C_STINYINT: return col -> buffer -> c; case SQL_C_SSHORT: return col -> buffer -> s; case SQL_C_SLONG: return col -> buffer -> l; case SQL_C_SBIGINT: l = (long)col -> buffer -> bigint; return static_cast<long>(col -> buffer -> bigint); default: { char msg[200]; sprintf(msg, "Query::getval(): Conversion not supported (%s)\n",col -> szTypeName); error(msg); } break; } } return 0L; } long Query::getval (  const std::string &  x  )    Definition at line 773 of file Query.cpp. References error(), getval(), and m_nmap. { int index = m_nmap[x] - 1; if (index >= 0) return getval(index); error("Column name lookup failure: " + x); return 0; } bool Query::GotMore (   )    Definition at line 1054 of file Query.cpp. References m_fetchrows, and m_results. { return (m_fetchrows < m_results) ? true : false; } long Query::insert_id (   )    Get id of last insert - not implemented. Definition at line 382 of file Query.cpp. { return -1; } bool Query::is_null (   )    Definition at line 419 of file Query.cpp. References m_currentcolumn. Referenced by is_null(). { return is_null(m_currentcolumn++); } bool Query::is_null (  const std::string &  x  )    Definition at line 425 of file Query.cpp. References error(), is_null(), and m_nmap. { int index = m_nmap[x] - 1; if (index >= 0) return is_null(index); error("Column name lookup failure: " + x); return false; } bool Query::is_null (  int  x  )    Check if column x in current row is null. Definition at line 407 of file Query.cpp. References m_hres, m_hstmt, and m_odb. { if (m_odb && m_hstmt && m_hres && x >= 0 && x < m_hres -> m_num_cols) { SQLHCOL *col = m_hres -> m_cols[x + 1]; if (col -> cbBuffer == SQL_NULL_DATA) return true; } return false; } int Query::num_cols (   )    Number of columns in current result. Definition at line 1190 of file Query.cpp. References m_qcols. { return m_qcols; } long Query::num_rows (   )    Returns 0 if there are no rows to fetch. Definition at line 388 of file Query.cpp. References m_hstmt. Referenced by execute(). { SQLINTEGER rowCount; if (m_hstmt) { SQLRETURN retcode = SQLRowCount(m_hstmt, &rowCount); if (retcode == SQL_SUCCESS || retcode == SQL_SUCCESS_WITH_INFO) { } } else { rowCount = -1; } return rowCount; } bool Query::odbc_store_result (   )  [private]   Definition at line 850 of file Query.cpp. References BUF_LEN, error(), m_hres, m_hstmt, m_nmap, m_qcols, and STR_LEN. Referenced by get_result(). { SQLRETURN retcode; SQLHCOL *tmp; SQLSMALLINT q; long buf_len; retcode = SQLNumResultCols(m_hstmt, &q); m_qcols = q; m_hres = new DSQLHRES(q); for (int i = 1; i <= m_hres -> m_num_cols; i++) { tmp = new SQLHCOL; retcode = SQLDescribeCol(m_hstmt, (SQLSMALLINT)i, tmp -> szColumnName, STR_LEN, &tmp -> nNameLengthPtr,&tmp -> nDataTypePtr,&tmp -> nColumnSizePtr, &tmp -> nDecimalDigitsPtr,&tmp -> nNullablePtr); m_nmap[ (char *)tmp -> szColumnName] = i; if (tmp -> nColumnSizePtr == 0x7fffffff) { buf_len = BUF_LEN; } else { buf_len = (tmp -> nColumnSizePtr > BUF_LEN ? tmp -> nColumnSizePtr : BUF_LEN) + 1; } tmp -> buffer = (SQLUNIONBUFFER *)new char[buf_len]; *tmp -> szTypeName = 0; switch (tmp -> nDataTypePtr) { case SQL_CHAR: strcpy(tmp -> szTypeName, "SQL_CHAR"); tmp -> nCType = SQL_C_TCHAR; // SQL_C_CHAR; break; case SQL_VARCHAR: strcpy(tmp -> szTypeName, "SQL_VARCHAR"); tmp -> nCType = SQL_C_TCHAR; // SQL_C_CHAR; break; case SQL_LONGVARCHAR: strcpy(tmp -> szTypeName, "SQL_LONGVARCHAR"); tmp -> nCType = SQL_C_TCHAR; // SQL_C_CHAR; break; case SQL_WCHAR: strcpy(tmp -> szTypeName, "SQL_WCHAR"); tmp -> nCType = SQL_C_TCHAR; // SQL_C_WCHAR; break; case SQL_WVARCHAR: strcpy(tmp -> szTypeName, "SQL_WVARCHAR"); tmp -> nCType = SQL_C_TCHAR; // SQL_C_WCHAR; break; case SQL_WLONGVARCHAR: strcpy(tmp -> szTypeName, "SQL_WLONGVARCHAR"); tmp -> nCType = SQL_C_TCHAR; // SQL_C_WCHAR; break; case SQL_DECIMAL: strcpy(tmp -> szTypeName, "SQL_DECIMAL"); tmp -> nCType = SQL_C_CHAR; break; case SQL_NUMERIC: strcpy(tmp -> szTypeName, "SQL_NUMERIC"); tmp -> nCType = SQL_C_CHAR; break; case SQL_SMALLINT: strcpy(tmp -> szTypeName, "SQL_SMALLINT"); tmp -> nCType = SQL_C_SSHORT; // SQL_C_USHORT break; case SQL_INTEGER: strcpy(tmp -> szTypeName, "SQL_INTEGER"); tmp -> nCType = SQL_C_SLONG; // SQL_C_ULONG break; case SQL_REAL: strcpy(tmp -> szTypeName, "SQL_REAL"); tmp -> nCType = SQL_C_FLOAT; break; case SQL_FLOAT: strcpy(tmp -> szTypeName, "SQL_FLOAT"); tmp -> nCType = SQL_C_DOUBLE; break; case SQL_DOUBLE: strcpy(tmp -> szTypeName, "SQL_DOUBLE"); tmp -> nCType = SQL_C_DOUBLE; break; case SQL_BIT: strcpy(tmp -> szTypeName, "SQL_BIT"); tmp -> nCType = SQL_C_BIT; break; case SQL_TINYINT: strcpy(tmp -> szTypeName, "SQL_TINYINT"); tmp -> nCType = SQL_C_STINYINT; // SQL_C_UTINYINT break; case SQL_BIGINT: strcpy(tmp -> szTypeName, "SQL_BIGINT"); tmp -> nCType = SQL_C_SBIGINT; // SQL_C_UBININT break; case SQL_BINARY: strcpy(tmp -> szTypeName, "SQL_BINARY"); tmp -> nCType = SQL_C_BINARY; break; case SQL_VARBINARY: strcpy(tmp -> szTypeName, "SQL_VARBINARY"); tmp -> nCType = SQL_C_BINARY; break; case SQL_LONGVARBINARY: strcpy(tmp -> szTypeName, "SQL_LONGVARBINARY"); tmp -> nCType = SQL_C_BINARY; break; case SQL_TYPE_DATE: strcpy(tmp -> szTypeName, "SQL_TYPE_DATE"); tmp -> nCType = SQL_C_TYPE_DATE; break; case SQL_TYPE_TIME: strcpy(tmp -> szTypeName, "SQL_TYPE_TIME"); tmp -> nCType = SQL_C_TYPE_TIME; break; case SQL_TYPE_TIMESTAMP: strcpy(tmp -> szTypeName, "SQL_TYPE_TIMESTAMP"); tmp -> nCType = SQL_C_TYPE_TIMESTAMP; break; case SQL_INTERVAL_MONTH: strcpy(tmp -> szTypeName, "SQL_INTERVAL_MONTH"); tmp -> nCType = SQL_C_INTERVAL_MONTH; break; case SQL_INTERVAL_YEAR: strcpy(tmp -> szTypeName, "SQL_INTERVAL_YEAR"); tmp -> nCType = SQL_C_INTERVAL_YEAR; break; case SQL_INTERVAL_YEAR_TO_MONTH: strcpy(tmp -> szTypeName, "SQL_INTERVAL_YEAR_TO_MONTH"); tmp -> nCType = SQL_C_INTERVAL_YEAR_TO_MONTH; break; case SQL_INTERVAL_DAY: strcpy(tmp -> szTypeName, "SQL_INTERVAL_DAY"); tmp -> nCType = SQL_C_INTERVAL_DAY; break; case SQL_INTERVAL_HOUR: strcpy(tmp -> szTypeName, "SQL_INTERVAL_HOUR"); tmp -> nCType = SQL_C_INTERVAL_HOUR; break; case SQL_INTERVAL_MINUTE: strcpy(tmp -> szTypeName, "SQL_INTERVAL_MINUTE"); tmp -> nCType = SQL_C_INTERVAL_MINUTE; break; case SQL_INTERVAL_SECOND: strcpy(tmp -> szTypeName, "SQL_INTERVAL_SECOND"); tmp -> nCType = SQL_C_INTERVAL_SECOND; break; case SQL_INTERVAL_DAY_TO_HOUR: strcpy(tmp -> szTypeName, "SQL_INTERVAL_DAY_TO_HOUR"); tmp -> nCType = SQL_C_INTERVAL_DAY_TO_HOUR; break; case SQL_INTERVAL_DAY_TO_MINUTE: strcpy(tmp -> szTypeName, "SQL_INTERVAL_DAY_TO_MINUTE"); tmp -> nCType = SQL_C_INTERVAL_DAY_TO_MINUTE; break; case SQL_INTERVAL_DAY_TO_SECOND: strcpy(tmp -> szTypeName, "SQL_INTERVAL_DAY_TO_SECOND"); tmp -> nCType = SQL_C_INTERVAL_DAY_TO_SECOND; break; case SQL_INTERVAL_HOUR_TO_MINUTE: strcpy(tmp -> szTypeName, "SQL_INTERVAL_HOUR_TO_MINUTE"); tmp -> nCType = SQL_C_INTERVAL_HOUR_TO_MINUTE; break; case SQL_INTERVAL_HOUR_TO_SECOND: strcpy(tmp -> szTypeName, "SQL_INTERVAL_HOUR_TO_SECOND"); tmp -> nCType = SQL_C_INTERVAL_HOUR_TO_SECOND; break; case SQL_INTERVAL_MINUTE_TO_SECOND: strcpy(tmp -> szTypeName, "SQL_INTERVAL_MINUTE_TO_SECOND"); tmp -> nCType = SQL_C_INTERVAL_MINUTE_TO_SECOND; break; case SQL_GUID: strcpy(tmp -> szTypeName, "SQL_GUID"); tmp -> nCType = SQL_C_CHAR; break; default: sprintf(tmp -> szTypeName, "<Unknown type id#%d>", tmp -> nDataTypePtr); tmp -> nCType = -1; error("Query::get_result(): Unknown result set column data type"); } memset(tmp -> buffer -> String, 0, buf_len); m_hres -> add_col(tmp); tmp -> cbBuffer = buf_len; tmp -> tmpstr = NULL; retcode = SQLBindCol(m_hstmt, (SQLSMALLINT)i, tmp -> nCType, (SQLPOINTER)tmp -> buffer, buf_len, &tmp -> cbBuffer); } return true; } void Query::ReturnRowAsXML (  std::string &  , const std::string &  = "", long  = DQ_XML_ENDTAG )    Definition at line 1115 of file Query.cpp. References DQ_XML_APPEND, DQ_XML_BEGIN, DQ_XML_CDATASTRINGS, DQ_XML_END, DQ_XML_ENDTAG, DQ_XML_TYPEINFO, getstr(), m_db, m_hres, m_hstmt, m_odb, and Database::xmlsafestr(). { SQLHCOL *col; std::string typ; std::string str; bool endtag = (dwFlags & DQ_XML_ENDTAG) ? true : false; bool cdata = (dwFlags & DQ_XML_CDATASTRINGS) ? true : false; bool typeinfo = (dwFlags & DQ_XML_TYPEINFO) ? true : false; bool append = (dwFlags & DQ_XML_APPEND) ? true : false; bool xmlbegin = (dwFlags & DQ_XML_BEGIN) ? true : false; bool xmlend = (dwFlags & DQ_XML_END) ? true : false; char slask[32000]; if (m_odb && m_hstmt && m_hres) { if (!append) { xml = ""; } if (xmlbegin) { xml += "<xml version=\"1.0\" encoding=\"ISO-8859-1\">\n"; } if (strObjectName != "") { xml += "<"; xml += strObjectName; xml += ">\n"; } for (int x = 0; x < m_hres -> m_num_cols; x++) { col = m_hres -> m_cols[x + 1]; // xml'safe data std::string // --- if (typeinfo) { sprintf(slask," TYPE=\"%s\"", col -> szTypeName); typ = slask; } else { typ = ""; } if (!*getstr(x)) { sprintf(slask,"<%s%s/>", col -> szColumnName, typ); str = slask; } else if (cdata && (col -> nCType == SQL_C_CHAR || col -> nCType == SQL_C_TCHAR)) { sprintf(slask,"<%s%s><![CDATA[%s]]></%s>\n", col -> szColumnName, typ, m_db.xmlsafestr(getstr(x)), col -> szColumnName); str = slask; } else { sprintf(slask,"<%s%s>%s</%s>\n", col -> szColumnName, typ, m_db.xmlsafestr(getstr(x)), col -> szColumnName); str = slask; } xml += str; } if (endtag && strObjectName != "") { xml += "</"; xml += strObjectName; xml += ">\n"; } if (xmlend) { xml += "</xml>\n"; } } } Member Data Documentation int Query::m_currentcol [private]   Definition at line 230 of file Query.h. Referenced by execute(), get_result(), and getcol(). short Query::m_currentcolumn [private]   Definition at line 226 of file Query.h. Referenced by fetch_row(), getbigint(), getinterval(), getnum(), getstr(), getval(), and is_null(). Database& Query::m_db [private]   Definition at line 222 of file Query.h. Referenced by error(), GetDatabase(), getstr(), ReturnRowAsXML(), and ~Query(). std::string Query::m_errtext [private]   Definition at line 234 of file Query.h. Referenced by GetErrno(), and GetError(). long Query::m_fetchrows [private]   Definition at line 228 of file Query.h. Referenced by execute(), fetch_row(), get_result(), and GotMore(). DSQLHRES* Query::m_hres [private]   Definition at line 225 of file Query.h. Referenced by execute(), fetch_row(), free_result(), get_result(), getbigint(), getcol(), GetColumnInfo(), getinterval(), getnum(), getstr(), getval(), is_null(), odbc_store_result(), ReturnRowAsXML(), and ~Query(). SQLHSTMT Query::m_hstmt [private]   Definition at line 224 of file Query.h. Referenced by execute(), fetch_row(), get_result(), getbigint(), GetColumnInfo(), getinterval(), getnum(), getstr(), getval(), is_null(), num_rows(), odbc_store_result(), ReturnRowAsXML(), and ~Query(). std::string Query::m_last_query [private]   Definition at line 232 of file Query.h. Referenced by execute(), and GetLastQuery(). std::map<std::string,int> Query::m_nmap [private]   Definition at line 235 of file Query.h. Referenced by free_result(), getbigint(), getinterval(), getnum(), getstr(), getval(), is_null(), and odbc_store_result(). Session* Query::m_odb [private]   Definition at line 223 of file Query.h. Referenced by execute(), fetch_row(), free_result(), get_result(), getbigint(), GetColumnInfo(), GetErrno(), GetError(), getinterval(), getnum(), getstr(), getval(), is_null(), ReturnRowAsXML(), and ~Query(). int Query::m_qcols [private]   Definition at line 229 of file Query.h. Referenced by execute(), get_result(), getcol(), num_cols(), and odbc_store_result(). long Query::m_results [private]   Definition at line 227 of file Query.h. Referenced by execute(), get_result(), and GotMore(). std::string Query::m_sql_state [private]   Definition at line 233 of file Query.h. Referenced by GetErrno(), and GetError(). std::string Query::m_tmpstr [private]   Definition at line 231 of file Query.h. Referenced by get_string(). The documentation for this class was generated from the following files: Query.h Query.cpp

Page, code, and content Copyright (C) 2006 by Anders Hedström