diff --git a/phplib/db_mysqli.inc b/phplib/db_mysqli.inc index 5093fcd..c421509 100644 --- a/phplib/db_mysqli.inc +++ b/phplib/db_mysqli.inc @@ -1,581 +1,581 @@ array( "int", "tinyint", "smallint", "mediumint", "bigint" ), "string" => array( "char", "varchar", "enum" ), "blob" => array( "longblob", "mediumblob", "text" ), "real" => array( "decimal", "double" ) ); public $flag_mappings = array( "not_null" => array( "NO", ), "primary_key" => array( "PRI", ), "multiple_key" => array( "MUL" ), "unique_key" => array( "UNI" ), "binary" => array( "timestamp", "date", "datetime" ), "blob binary" => array( "longblob", "mediumblob", "blob" ), "blob" => array( "text" ), "unsigned zerofill" => array( "0000-00-00 00:00:00", "CURRENT_TIMESTAMP" ), "enum" => array( "enum" ) ); public $length_mappings = array( 16777215 => array("mediumblob"), 65535 => array("text","blob"), 22 => array("double"), 19 => array("timestamp","datetime"), 10 => array("date") ); public $extra_mappings = array( "unsigned zerofill" => array("on update CURRENT_TIMESTAMP") ); private function remap($arr) { $ret = array(); foreach ($arr as $key => $value) { foreach ($value as $name) { $ret[$name] = $key; } } return $ret; } /* public: constructor */ public function __construct($query = "") { $this->query($query); } /* public: some trivial reporting */ public function link_id() { return is_int($this->Link_ID) ? 0 : mysqli_thread_id($this->Link_ID); } public function query_id() { return $this->Query_ID; } /* public: connection management */ public function connect($Database = "", $Host = "", $User = "", $Password = "") { /* Handle defaults */ if ("" == $Database) { $Database = $this->Database; } if ("" == $Host) { $Host = $this->Host; } if ("" == $User) { $User = $this->User; } if ("" == $Password) { $Password = $this->Password; } /* establish connection, select database */ if (0 == $this->link_id()) { mysqli_report(MYSQLI_REPORT_OFF); $link = mysqli_init(); if (!$link) { die('mysqli_init failed'); } if (!mysqli_options($link, MYSQLI_OPT_CONNECT_TIMEOUT, 2)) { die('Setting MYSQLI_OPT_CONNECT_TIMEOUT failed'); } if (!mysqli_real_connect($link, "p:".$Host, $User, $Password)) { syslog(LOG_NOTICE, "Error in connect(): connect as $User to $Host failed"); $this->halt("connect as $User to $Host failed."); return 0; } $this->Link_ID = $link; debug("Connected to mysql with $User to $Host ".$this->link_id()); // print "Connected to mysql with $User to $Host ".$this->link_id(); if (!((bool)mysqli_query($this->Link_ID, "USE " . $Database))) { syslog(LOG_NOTICE, "Error in connect(): cannot use database"); $this->halt("cannot use database ".$this->Database); return 0; } } return $this->Link_ID; } /* public: discard the query result */ public function free() { if (isset($this->Query_ID) && is_resource($this->Query_ID)) { @mysqli_free_result($this->Query_ID); $this->Query_ID = 0; } } /* public: perform a query */ public function query($Query_String, $result_mode=MYSQLI_STORE_RESULT) { /* No empty queries, please, since PHP4 chokes on them. */ if ($Query_String == "") { /* The empty query string is passed on from the constructor, * when calling the class without a query, e.g. in situations * like these: '$db = new DB_Sql_Subclass;' */ return 0; } if (!$this->connect()) { return 0; /* we already complained in connect() about that. */ }; # New query, discard previous result. if ($this->Query_ID) { $this->free(); } try { $this->Query_ID = @mysqli_query($this->Link_ID, $Query_String, $result_mode); $this->Row = 0; $this->Errno = mysqli_errno($this->Link_ID); $this->Error = mysqli_error($this->Link_ID); if ($this->Errno) { throw new Exception($this->Errno); } } catch (Exception $e) { /* 2006= CR_SERVER_GONE_ERROR 2013= CR_SERVER_LOST */ $dbError = $e->getMessage(); if ($dbError=='2006' || $dbError=='2013') { warningAndPrint(sprintf("Warning: mysql connection %s lost with code %s", $this->link_id(), $dbError)); if ($this->Query_ID) { $this->free(); } mysqli_close($this->Link_ID); $this->Link_ID = 0; if (!$this->connect()) { syslog(LOG_NOTICE, "Error: failed to re-connect to the MySQL server"); return 0; } syslog(LOG_NOTICE, sprintf("Mysql connection re-created with %s", $this->link_id())); printf("Mysql connection re-created with %s\n", $this->link_id()); $this->Query_ID = @mysqli_query($this->Link_ID, $Query_String); $this->Row = 0; - $this->Errno = mysqli_errno(); - $this->Error = mysqli_error(); + $this->Errno = mysqli_errno($this->Link_ID); + $this->Error = mysqli_error($this->Link_ID); } else { $this->halt("Invalid SQL: ".$Query_String); } } # Will return nada if it fails. That's fine. return $this->Query_ID; } /* public: walk result set */ public function next_record() { if (!$this->Query_ID) { $this->halt("next_record called with no query pending."); return 0; } $this->Record = @mysqli_fetch_assoc($this->Query_ID); $this->Errno = mysqli_errno($this->Link_ID); $this->Error = mysqli_error($this->Link_ID); $this->Row += 1; $stat = is_array($this->Record); if (!$stat && $this->Auto_Free) { $this->free(); } return $stat; } /* public: position in result set */ public function seek($pos = 0) { $status = @mysqli_data_seek($this->Query_ID, $pos); if ($status) { $this->Row = $pos; } else { $this->halt("seek($pos) failed: result has ".$this->num_rows()." rows"); /* half assed attempt to save the day, * but do not consider this documented or even * desireable behaviour. */ @mysqli_data_seek($this->Query_ID, $this->num_rows()); $this->Row = $this->num_rows; return 0; } return 1; } /* public: table locking */ public function lock($table, $mode = "write") { $this->connect(); $query="lock tables "; if (is_array($table)) { while (list($key, $value) = each($table)) { if ($key=="read" && $key!=0) { $query.="$value read, "; } else { $query.="$value $mode, "; } } $query=substr($query, 0, -2); } else { $query.="$table $mode"; } $res = @mysqli_query($this->Link_ID, $query); if (!$res) { $this->halt("lock($table, $mode) failed."); return 0; } return $res; } public function unlock() { $this->connect(); $res = @mysqli_query($this->Link_ID, "unlock tables"); if (!$res) { $this->halt("unlock() failed."); return 0; } return $res; } /* public: evaluate the result (size, width) */ public function affected_rows() { return @mysqli_affected_rows($this->Link_ID); } public function num_rows() { if (isset($this->Query_ID)) { return @mysqli_num_rows($this->Query_ID); } return 0; } public function num_fields() { return @mysqli_num_fields($this->Query_ID); } /* public: shorthand notations */ public function nf() { return $this->num_rows(); } public function np() { print $this->num_rows(); } public function f($Name) { return $this->Record[$Name]; } public function p($Name) { print $this->Record[$Name]; } /* public: sequence numbers */ public function nextid($seq_name) { $this->connect(); if ($this->lock($this->Seq_Table)) { /* get sequence number (locked) and increment */ $q = sprintf( "select nextid from %s where seq_name = '%s'", $this->Seq_Table, $seq_name ); $id = @mysqli_query($this->Link_ID, $q); $res = @mysqli_fetch_array($id); /* No current value, make one */ if (!is_array($res)) { $currentid = 0; $q = sprintf( "insert into %s values('%s', %s)", $this->Seq_Table, $seq_name, $currentid ); $id = @mysqli_query($this->Link_ID, $q); } else { $currentid = $res["nextid"]; } $nextid = $currentid + 1; $q = sprintf( "update %s set nextid = '%s' where seq_name = '%s'", $this->Seq_Table, $nextid, $seq_name ); $id = @mysqli_query($this->Link_ID, $q); $this->unlock(); } else { $this->halt("cannot lock ".$this->Seq_Table." - has it been created?"); return 0; } return $nextid; } /* public: return table metadata */ public function metadata($table = '', $full = false) { $count = 0; $id = 0; $res = array(); $remapped = $this->remap($this->type_mappings); $remapped_flag = $this->remap($this->flag_mappings); $rlengths = $this->remap($this->length_mappings); $remapped_extra = $this->remap($this->extra_mappings); /* * Due to compatibility problems with Table we changed the behavior * of metadata(); * depending on $full, metadata returns the following values: * * - full is false (default): * $result[]: * [0]["table"] table name * [0]["name"] field name * [0]["type"] field type * [0]["len"] field length * [0]["flags"] field flags * * - full is true * $result[]: * ["num_fields"] number of metadata records * [0]["table"] table name * [0]["name"] field name * [0]["type"] field type * [0]["len"] field length * [0]["flags"] field flags * ["meta"][field name] index of field named "field name" * The last one is used, if you have a field name, but no index. * Test: if (isset($result['meta']['myfield'])) { ... */ // if no $table specified, assume that we are working with a query // result if ($table) { $this->connect(); //maybe we need escaping $q = sprintf("SHOW COLUMNS FROM %s.%s", $this->Database, $table); $id = (($___mysqli_tmp = mysqli_query($this->Link_ID, $q)) ? $___mysqli_tmp : false); if (!$id) { $this->halt("Metadata query failed."); } } else { $id = $this->Query_ID; if (!$id) { $this->halt("No query specified."); } } $i = 0; $meta = array(); while ($row = mysqli_fetch_object($id)) { list($type, $len, $ignore) = sscanf($row->Type, "%[^[(](%d) %[^[]]"); $res[$i]["table"] = $table; $res[$i]["name"] = $row->Field; $res[$i]["type"] = isset($remapped[$type]) ? $remapped[$type] : $type; $res[$i]['len'] = isset($len) ? $len : (isset($rlengths[$type]) ? $rlengths[$type] : -1); if ($type == 'enum') { preg_match("/^enum\(\'(.*)\'\)$/", $row->Type, $matches); $enum = explode("','", $matches[1]); $max = max(array_map('strlen', $enum)); $res[$i]['len'] = $max; } if (preg_match("/^decimal\((.*)\)$/", $row->Type, $matches)) { $len = explode("','", $matches[1]); $res[$i]['len'] = $len[0]+2; } $flags = array(); isset($remapped_flag[$row->Null])? $flags[]=$remapped_flag[$row->Null]: '' ; isset($remapped_flag[$row->Key])? $flags[]=$remapped_flag[$row->Key]: '' ; $ignore ? $flags[] = $ignore: ''; isset($remapped_extra[$row->Extra])? $flags[]=$remapped_extra[$row->Extra]: ($row->Extra ? $flags[] = $row->Extra: ''); isset($remapped_flag[$row->Default])? $flags[]=$remapped_flag[$row->Default]: '' ; isset($remapped_flag[$type])? $flags[]=$remapped_flag[$type]: '' ; if ($row->Extra == 'on update CURRENT_TIMESTAMP' || $row->Default == 'CURRENT_TIMESTAMP') { $flags[] = "timestamp"; } $res[$i]['flags'] = trim( sprintf( "%s", join(' ', array_unique($flags)) ) ); $meta[$row->Field] = $i; $i++; } // made this IF due to performance (one if is faster than $count if's) if ($full) { $res["num_fields"] = $i; $res["meta"]= $meta; } // free the result only if we were called on a table if ($table) { @mysqli_free_result($id); } return $res; } public function table_names() { $this->query("SHOW TABLES"); $i = 0; while ($info=mysqli_fetch_row($this->Query_ID)) { $return[$i]["table_name"]= $info[0]; $return[$i]["tablespace_name"]=$this->Database; $return[$i]["database"]=$this->Database; $i++; } return $return; } /* private: error handling */ private function halt($msg) { if (!mysqli_connect_errno()) { $this->Error = @mysqli_error($this->Link_ID); $this->Errno = @mysqli_errno($this->Link_ID); } if ($this->Halt_On_Error == "no") { return; } $this->haltmsg($msg); if ($this->Halt_On_Error != "report") { die("Session halted.\n"); } } private function haltmsg($msg) { $log=sprintf("Database error: %s\n", $msg); syslog(LOG_NOTICE, $log); if ($this->Errno) { $log=printf("MySQL error: %s (%s)\n", $this->Errno, $this->Error); syslog(LOG_NOTICE, $log); } } } ?>