db_helper.class.cpp

Go to the documentation of this file.

/*
 *
 * class db_helper
 *
 * copyright: (c) Philippe De Brouwer 2014
 *
 * last modification:
 *
 */

class db_helper
{
public:

  sql::Driver            *driver;
  sql::Connection        *con;
  sql::Statement         *stmt;
  sql::ResultSet         *res;
  sql::ResultSet         *res2;  // spare one to use when eg. pulling the drop-down list while res refers to the master object
  sql::PreparedStatement *pstmt;

  //string host = "tcp://127.0.0.1:3306";
  //string user = "efp";
  //string pwd  = "efp.cger";
  string db   = "efp";

  db_helper();
  ~db_helper();
  bool runSQL(string s);

  float getFloat(string s);
  int getInt(string s);

private:
};

/* **********************************************
 * CONSTRUCTOR
 * **********************************************/
db_helper::db_helper()
{
  try {
    /* Create a connection */
    driver = get_driver_instance();
    con = driver->connect(oConfig.db_host,oConfig.db_user,oConfig.db_pwd);
    //  con->setSchema("efp");
    con->setSchema(oConfig.db_name);
    stmt = con->createStatement();

 /*   res = stmt->executeQuery("SELECT 'Hello World!' AS _message");
    while (res->next()) {
      cout << "\t... MySQL replies: ";
      // Access column data by alias or column name
      cout << res->getString("_message") << endl;
      cout << "\t... MySQL says it again: ";
      // Access column fata by numeric offset, 1 is the first column
      cout << res->getString(1) << endl;
 */
 /* '?' is the supported placeholder syntax */
 /*pstmt = con->prepareStatement("INSERT INTO test(id) VALUES (?)");
 for (int i = 1; i <= 10; i++) {
   pstmt->setInt(1, i);
   pstmt->executeUpdate();

 delete pstmt;
 */

 /* //Select in ascending order
 pstmt = con->prepareStatement("SELECT id FROM test ORDER BY id ASC");
 res = pstmt->executeQuery();
 //Fetch in reverse = descending order!
 res->afterLast();
 while (res->previous())
   cout << "\t... MySQL counts: " << res->getInt("id") << endl;
 delete res;
 delete pstmt;
 delete con
 */
  } catch (sql::SQLException &e) {
    cout << "# ERR: SQLException in " << __FILE__;
    cout << "(" << __FUNCTION__ << ") on line " << __LINE__ << endl;
    cout << "# ERR: " << e.what();
    cout << " (MySQL error code: " << e.getErrorCode();
    cout << ", SQLState: " << e.getSQLState() << " )" << endl;
  }
}

/* **********************************************
 * DESTRUCTOR
 * **********************************************/
db_helper::~db_helper()
{
  delete res;
  delete stmt;
  delete con;
}

/* **********************************************
 * runSQL
 *
 * **********************************************/
bool db_helper::runSQL(string s)
{
  bool bSuccess = true;
try
  {

    sql::Driver *driver;
    sql::Connection *con;
    sql::Statement *stmt;
    //sql::ResultSet *res;
    //sql::PreparedStatement *pstmt;
    // Create a connection
    driver = get_driver_instance();
    con = driver->connect(oConfig.db_host,oConfig.db_user,oConfig.db_pwd);
    con->setSchema(oConfig.db_name);


    stmt = con->createStatement();
    //res = stmt->executeQuery(s);   // ===> if it is supposed to return a resultset
    stmt->execute(s);                // ===> if it is NOT supposed to return a resultset
  } //try

  catch (sql::SQLException &e)
    {
      bSuccess = false;
#ifdef DEBUG
    cout << "# ERR: SQLException in " << __FILE__;
    cout << "(" << __FUNCTION__ << ") on line " << __LINE__ << endl;
    cout << "# ERR: " << e.what();
    cout << " (MySQL error code: " << e.getErrorCode();
    cout << ", SQLState: " << e.getSQLState() << " )" << endl;
#endif
    }
//  if (EXIT_SUCCESS == 0) {return true;}  else  {return false;}   // return EXIT_SUCCESS;
if (bSuccess) {return true;}  else  {return false;}
}

inline float db_helper::getFloat(string s)
{
  return atof(this->res->getString(s).c_str());
}

inline int db_helper::getInt(string s)
{
  return atoi(this->res->getString(s).c_str());
}