// =============================================================================
// =============================================================================
int connect() {
  //
  // Create DB connection
  //

  if (  arguments.pdbUserSet      == false ) return 0;
  if (  arguments.pdbPasswordSet  == false ) return 0;
  if (  arguments.pdbConnectIdSet == false ) return 0;

  db = new OracleDB();
  try {
    db->connect(arguments.pdbUser, arguments.pdbPassword, arguments.pdbConnectId);
  } catch(SQLException& ea) {
    cout << ea.what() << endl;
    return 0;
  }

  arguments.pConnected = true;

  return 1;
}


// =============================================================================
// =============================================================================
int disconnect() {
  //
  // Stop DB connection
  //
  if ( arguments.pConnected == true ) {
    try {
      db->disconnect();
    } catch(SQLException& ea) {
      cout << ea.what() << endl;
      return 0;
    }
  }

  return 1;
}