<?php echo htmlspecialchars($title,ENT

> <?php echo htmlspecialchars($title,ENT_QUOTES)?>

a1 Error!: ' . $e->getMessage() . '

', 'Connect Error'); } //echo '

DBH: '.print_r($DBH,true).'

'; return $DBH; } /** * Connects to mysql server */ function sql_connect() { global $MYSQL_HOST, $MYSQL_USER, $MYSQL_PASSWORD, $MYSQL_DATABASE, $MYSQL_CONN, $MYSQL_HANDLER, $SQL_DBH; $SQL_DBH = NULL; try { if (strpos($MYSQL_HOST,':') === false) { $host = $MYSQL_HOST; $port = ''; } else { list($host,$port) = explode(":",$MYSQL_HOST); if (isset($port)) { $portnum = $port; $port = ';port='.trim($port); } else { $port = ''; $portnum = ''; } } switch ($MYSQL_HANDLER[1]) { case 'sybase': case 'dblib': if (is_numeric($portnum)) $port = ':'.intval($portnum); else $port = ''; $SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$MYSQL_DATABASE, $MYSQL_USER, $MYSQL_PASSWORD); break; case 'mssql': if (is_numeric($portnum)) $port = ','.intval($portnum); else $port = ''; $SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$MYSQL_DATABASE, $MYSQL_USER, $MYSQL_PASSWORD); break; case 'oci': if (is_numeric($portnum)) $port = ':'.intval($portnum); else $port = ''; $SQL_DBH = new PDO($MYSQL_HANDLER[1].':dbname=//'.$host.$port.'/'.$MYSQL_DATABASE, $MYSQL_USER, $MYSQL_PASSWORD); break; case 'odbc': if (is_numeric($portnum)) $port = ';PORT='.intval($portnum); else $port = ''; $SQL_DBH = new PDO($MYSQL_HANDLER[1].':DRIVER={IBM DB2 ODBC DRIVER};HOSTNAME='.$host.$port.';DATABASE='.$MYSQL_DATABASE.';PROTOCOL=TCPIP;UID='.$MYSQL_USER.';PWD='.$MYSQL_PASSWORD); break; case 'pgsql': if (is_numeric($portnum)) $port = ';port='.intval($portnum); else $port = ''; $SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$MYSQL_DATABASE, $MYSQL_USER, $MYSQL_PASSWORD); break; case 'sqlite': case 'sqlite2': if (is_numeric($portnum)) $port = ':'.intval($portnum); else $port = ''; $SQL_DBH = new PDO($MYSQL_HANDLER[1].':'.$MYSQL_DATABASE, $MYSQL_USER, $MYSQL_PASSWORD); break; default: //mysql $SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$MYSQL_DATABASE, $MYSQL_USER, $MYSQL_PASSWORD); break; } //$SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$MYSQL_DATABASE, $MYSQL_USER, $MYSQL_PASSWORD); // if (strpos($MYSQL_HANDLER[1], 'mysql') === 0) { $resource = $SQL_DBH->query("show variables LIKE 'character_set_database'"); $resource->bindColumn('Value', $charset); $resource->fetchAll(); $SQL_DBH->exec("SET CHARACTER SET " . $charset); } // */ } catch (PDOException $e) { $SQL_DBH = NULL; startUpError('

a2 Error!: ' . $e->getMessage() . '

', 'Connect Error'); } // echo '

DBH: '.print_r($SQL_DBH,true).'

'; $MYSQL_CONN &= $SQL_DBH; return $SQL_DBH; } /** * disconnects from SQL server */ function sql_disconnect(&$dbh=NULL) { global $SQL_DBH; if (is_null($dbh)) $SQL_DBH = NULL; else $dbh = NULL; } function sql_close(&$dbh=NULL) { global $SQL_DBH; if (is_null($dbh)) $SQL_DBH = NULL; else $dbh = NULL; } /** * executes an SQL query */ function sql_query($query,$dbh=NULL) { global $SQLCount,$SQL_DBH; $SQLCount++; //echo '

SQL_DBH: '; //print_r($SQL_DBH); //echo '

DBH: '; //print_r($dbh); //echo '

'; //echo $query.'

'; if (is_null($dbh)) $res = $SQL_DBH->query($query); else $res = $dbh->query($query); if ($res->errorCode() != '00000') { $errors = $res->errorInfo(); print("SQL error with query $query: " . $errors[0].'-'.$errors[1].' '.$errors[2] . '

'); } return $res; } /** * executes an SQL error */ function sql_error($dbh=NULL) { global $SQL_DBH; if (is_null($dbh)) $error = $SQL_DBH->errorInfo(); else $error = $dbh->errorInfo(); if ($error[0] != '00000') { return $error[0].'-'.$error[1].' '.$error[2]; } else return ''; } /** * executes an SQL db select */ function sql_select_db($db,&$dbh=NULL) { global $MYSQL_HOST, $MYSQL_USER, $MYSQL_PASSWORD, $MYSQL_DATABASE, $MYSQL_CONN, $MYSQL_HANDLER, $SQL_DBH; //echo '

'.print_r($dbh,true).'

'; //exit; if (is_null($dbh)) { try { $SQL_DBH = NULL; list($host,$port) = explode(":",$MYSQL_HOST); if (isset($port)) { $portnum = $port; $port = ';port='.trim($port); } else { $port = ''; $portnum = ''; } //$SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.trim($host).$port.';dbname='.$db, $MYSQL_USER, $MYSQL_PASSWORD); //$SQL_DBH = sql_connect(); switch ($MYSQL_HANDLER[1]) { case 'sybase': case 'dblib': if (is_numeric($portnum)) $port = ':'.intval($portnum); else $port = ''; $SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$db, $MYSQL_USER, $MYSQL_PASSWORD); break; case 'mssql': if (is_numeric($portnum)) $port = ','.intval($portnum); else $port = ''; $SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$db, $MYSQL_USER, $MYSQL_PASSWORD); break; case 'oci': if (is_numeric($portnum)) $port = ':'.intval($portnum); else $port = ''; $SQL_DBH = new PDO($MYSQL_HANDLER[1].':dbname=//'.$host.$port.'/'.$db, $MYSQL_USER, $MYSQL_PASSWORD); break; case 'odbc': if (is_numeric($portnum)) $port = ';PORT='.intval($portnum); else $port = ''; $SQL_DBH = new PDO($MYSQL_HANDLER[1].':DRIVER={IBM DB2 ODBC DRIVER};HOSTNAME='.$host.$port.';DATABASE='.$db.';PROTOCOL=TCPIP;UID='.$MYSQL_USER.';PWD='.$MYSQL_PASSWORD); break; case 'pgsql': if (is_numeric($portnum)) $port = ';port='.intval($portnum); else $port = ''; $SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$db, $MYSQL_USER, $MYSQL_PASSWORD); break; case 'sqlite': case 'sqlite2': if (is_numeric($portnum)) $port = ':'.intval($portnum); else $port = ''; $SQL_DBH = new PDO($MYSQL_HANDLER[1].':'.$db, $MYSQL_USER, $MYSQL_PASSWORD); break; default: //mysql $SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$db, $MYSQL_USER, $MYSQL_PASSWORD); break; } return 1; } catch (PDOException $e) { startUpError('

a3 Error!: ' . $e->getMessage() . '

', 'Connect Error'); return 0; } } else { if ($dbh->exec("USE $db") !== false) return 1; else return 0; } } /** * executes an SQL real escape */ function sql_real_escape_string($val,$dbh=NULL) { return addslashes($val); } /** * executes an PDO::quote() like escape, ie adds quotes arround the string and escapes chars as needed */ function sql_quote_string($val,$dbh=NULL) { global $SQL_DBH; if (is_null($dbh)) return $SQL_DBH->quote($val); else return $dbh->quote($val); } /** * executes an SQL insert id */ function sql_insert_id($dbh=NULL) { global $SQL_DBH; if (is_null($dbh)) return $SQL_DBH->lastInsertId(); else return $dbh->lastInsertId(); } /** * executes an SQL result request */ function sql_result($res, $row = 0, $col = 0) { $results = array(); if (intval($row) < 1) { $results = $res->fetch(PDO::FETCH_BOTH); return $results[$col]; } else { for ($i = 0; $i < intval($row); $i++) { $results = $res->fetch(PDO::FETCH_BOTH); } $results = $res->fetch(PDO::FETCH_BOTH); return $results[$col]; } } /** * frees sql result resources */ function sql_free_result($res) { $res = NULL; return true; } /** * returns number of rows in SQL result */ function sql_num_rows($res) { return $res->rowCount(); } /** * returns number of rows affected by SQL query */ function sql_affected_rows($res) { return $res->rowCount(); } /** * Get number of fields in result */ function sql_num_fields($res) { return $res->columnCount(); } /** * fetches next row of SQL result as an associative array */ function sql_fetch_assoc($res) { $results = array(); $results = $res->fetch(PDO::FETCH_ASSOC); return $results; } /** * Fetch a result row as an associative array, a numeric array, or both */ function sql_fetch_array($res) { $results = array(); $results = $res->fetch(PDO::FETCH_BOTH); return $results; } /** * fetches next row of SQL result as an object */ function sql_fetch_object($res) { $results = NULL; $results = $res->fetchObject(); return $results; } /** * Get a result row as an enumerated array */ function sql_fetch_row($res) { $results = array(); $results = $res->fetch(PDO::FETCH_NUM); return $results; } /** * Get column information from a result and return as an object */ function sql_fetch_field($res,$offset = 0) { $results = array(); $obj = NULL; $results = $res->getColumnMeta($offset); foreach($results as $key=>$value) { $obj->$key = $value; } return $obj; } /** * Get current system status (returns string) */ function sql_stat($dbh=NULL) { //not implemented global $SQL_DBH; if (is_null($dbh)) return ''; else return ''; } /** * Returns the name of the character set */ function sql_client_encoding($dbh=NULL) { //not implemented global $SQL_DBH; if (is_null($dbh)) return ''; else return ''; } /** * Get SQL client version */ function sql_get_client_info() { global $SQL_DBH; return $SQL_DBH->getAttribute(constant("PDO::ATTR_CLIENT_VERSION")); } /** * Get SQL server version */ function sql_get_server_info($dbh=NULL) { global $SQL_DBH; if (is_null($dbh)) return $SQL_DBH->getAttribute(constant("PDO::ATTR_SERVER_VERSION")); else return $dbh->getAttribute(constant("PDO::ATTR_SERVER_VERSION")); } /** * Returns a string describing the type of SQL connection in use for the connection or FALSE on failure */ function sql_get_host_info($dbh=NULL) { global $SQL_DBH; if (is_null($dbh)) return $SQL_DBH->getAttribute(constant("PDO::ATTR_SERVER_INFO")); else return $dbh->getAttribute(constant("PDO::ATTR_SERVER_INFO")); } /** * Returns the SQL protocol on success, or FALSE on failure. */ function sql_get_proto_info($dbh=NULL) { //not implemented global $SQL_DBH; if (is_null($dbh)) return false; else return false; } /** * Get the name of the specified field in a result */ function sql_field_name($res, $offset = 0) { $column = $res->getColumnMeta($offset); if ($column) { return $column['name']; } return false; } /************************************************************************** Unimplemented mysql_* functions # mysql_ data_ seek (maybe useful) # mysql_ errno (maybe useful) # mysql_ fetch_ lengths (maybe useful) # mysql_ field_ flags (maybe useful) # mysql_ field_ len (maybe useful) # mysql_ field_ name (maybe useful) # mysql_ field_ seek (maybe useful) # mysql_ field_ table (maybe useful) # mysql_ field_ type (maybe useful) # mysql_ info (maybe useful) # mysql_ list_ processes (maybe useful) # mysql_ ping (maybe useful) # mysql_ set_ charset (maybe useful, requires php >=5.2.3 and mysql >=5.0.7) # mysql_ thread_ id (maybe useful) # mysql_ db_ name (useful only if working on multiple dbs which we do not do) # mysql_ list_ dbs (useful only if working on multiple dbs which we do not do) # mysql_ pconnect (probably not useful and could cause some unintended performance issues) # mysql_ unbuffered_ query (possibly useful, but complicated and not supported by all database drivers (pdo)) # mysql_ change_ user (deprecated) # mysql_ create_ db (deprecated) # mysql_ db_ query (deprecated) # mysql_ drop_ db (deprecated) # mysql_ escape_ string (deprecated) # mysql_ list_ fields (deprecated) # mysql_ list_ tables (deprecated) # mysql_ tablename (deprecated) *******************************************************************/ /** * for JP installer only */ function at_sql_query($query,$dbh=NULL) { global $SQLCount,$SQL_DBH; $SQLCount++; if (is_null($dbh)) $res = $SQL_DBH->query($query); else $res = $dbh->query($query); /* if ($res->errorCode() != '00000') { $errors = $res->errorInfo(); print("SQL error with query $query: " . $errors[0].'-'.$errors[1].' '.$errors[2] . '

'); } */ return $res; } } ?>