From d59a4921188753dbe4c0161081755a28112c3ef6 Mon Sep 17 00:00:00 2001 From: Nathan Gass Date: Thu, 22 Mar 2012 18:18:42 +0000 Subject: Branch itools/devel-utf8 created --- devel-utf8/it_dbi.class | 860 ++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 860 insertions(+) create mode 100644 devel-utf8/it_dbi.class (limited to 'devel-utf8/it_dbi.class') diff --git a/devel-utf8/it_dbi.class b/devel-utf8/it_dbi.class new file mode 100644 index 0000000..ba0606c --- /dev/null +++ b/devel-utf8/it_dbi.class @@ -0,0 +1,860 @@ +. +** +** dbi.class - UltraFlexible Database Interface 3000 +*/ + +class it_dbi +{ + # Default configuration of dbi class + var $_defaultconfig = array + ( + 'db' => null, + 'server' => "localhost", + 'server_update' => null, + 'user' => "itools", + 'pw' => "", + 'safety' => 1, # 0= never die, 1=die if query invalid, 2=die also if no results + #'keyfield' => 'ID', # Don't set to null here, filled later by _get_field_info() + #'charset' => # client charset (requires MySQL 5.0.7 or later) + 'classprefix' => "", + 'getfieldinfo' => true, # do not read schema. only select() allowed + 'localized_defaultlanguage' => "de", # Localize fields with this suffix, e.g. copy title_de to title on read + ); + + var $_key; # Key of currently loaded record or null (public readonly) + var $_fields; # Array of name => array(Field,Type,Null,Key,Default,Extra,Length) of fields (public readonly) + var $_convertfunc; # Array of name => convert function (currently intval and floatval) for this field's values + var $_link; # DB link identifier (private) + + +/** + * Constructor: Initialize the DBI interface + * @param $p optional array(key => value) of configuration data + * @param $query Optional initial query to run + */ +function it_dbi($p = array(), $query = null) +{ + # Shortcut: String config means use this table with default values + if (!is_array($p)) + $p = array('table' => $p); + + if ($p['home']) + $p['db'] = strtr(it::match('/www/([^/]*)', $p['home']), '.-', '__'); + + # If the global singleton defaults are for this db/server/server_update then use them. + $dp = (array)$GLOBALS['it_dbi']->_p; + if ((!isset($p['db']) || ($p['db'] == $dp['db'])) && (!isset($p['server']) || ($p['server'] == $dp['server'])) && (!isset($p['server_update']) || ($p['server_update'] == $dp['server_update']))) + $p += $dp; + + # Combine our settings with user's defaults and class defaults + $p += (array)$GLOBALS['it_dbi_defaultconfig'] + array('db' => $GLOBALS['ULTRADB']) + $this->_defaultconfig + array('charset' => strtr(strtolower(ini_get('default_charset')), array('iso-8859-1' => 'latin1', 'utf-8' => 'utf8'))); + unset($this->_defaultconfig); # to shorten ED() output + + $this->_p = $p; + + if ($p['table']) # Standard use: create a table object + { + if (!isset($GLOBALS['it_dbi'])) + new it_dbi; + + if ($p['getfieldinfo']) + $this->_p += $this->_get_field_info(); # Get $this->_fields and p[keyfield, autoincrement, randomid] + + if (is_array($query)) + { + # Call with all arguments except first one + $args = func_get_args(); + array_shift($args); + call_user_func_array(array($this, "select"), $args); + } + elseif (isset($query)) + $this->read($query); + } + else + $GLOBALS['it_dbi'] =& $this; +} + +/** + * function Tablename($query) + * Constructor. Returns record object from table Tablename. + * If $query is set, it encodes a SELECT to execute and store in the returned object, see select() + * Note: Old second parameter $config has been deprecated and will be removed + */ #:} + +/** + * Factory: Create classes of all database tables. Call statically. + * @param $p array(key => value) of configuration data + */ +function createclasses($p = array()) +{ + # Make sure singleton exists + $dbi = $GLOBALS['it_dbi'] ? $GLOBALS['it_dbi'] : new it_dbi($p); + + $p += $dbi->_p; + + $dbid = "{$p['user']}@{$p['server']}:{$p['db']}"; + $state = it_dbi::_state_get($dbid); + + if (!$tables = $state['tables']) + { + for ($tables = array(), $res = $dbi->query('SHOW TABLES', $p); $row = mysql_fetch_row($res);) + $tables[] = $row[0]; + + $state = it_dbi::_state_get($dbid); # State could have been modified by query above + $state['tables'] = $tables; + it_dbi::_state_put($dbid, $state); + } + + foreach ($tables as $table) + { + # Either create class in autoloader or manually just below + if (!class_exists($p['classprefix'] . $table)) + it_dbi::createclass(array('table' => $table) + $p); + } +} + + +/** + * Convert table given by name into a class + */ +function createclass($p) +{ + # Shortcut: String config means use this table with default values + if (!is_array($p)) + $p = array('table' => $p); + + # Make sure singleton exists + $dbi = $GLOBALS['it_dbi'] ? $GLOBALS['it_dbi'] : new it_dbi(array('table' => null) + $p); + $p += $dbi->_p; # FIXME: (has to be checked for side effects!) + $dbid = "{$p['user']}@{$p['server']}:{$p['db']}"; + + if (!isset($dbi->_tables[$dbid])) + { + $state = it_dbi::_state_get($dbid); + $dbi->_tables[$dbid] = array(); + + if (!($tables = $state['tables'])) + { + for ($tables = array(), $res = $dbi->query('SHOW TABLES', $p); $row = mysql_fetch_row($res);) + $tables[] = $row[0]; + + $state = it_dbi::_state_get($dbid); # State could have been modified by query above + $state['tables'] = $tables; + it_dbi::_state_put($dbid, $state); + } + + foreach ($tables as $table) + $dbi->_tables[$dbid][$table] = true; + } + + if ($p['forcecreate'] || $dbi->_tables[$dbid][$p['table']]) # Do not generate classes for non-existant tables (can be overridden by forcecreate => true, used in tests/it_dbi.t) + { + $classname = $p['classprefix'] . $p['table']; + + if (substr($classname, 0, 4) != 'PMA_') # It is designed behaviour that an error is generated if this class already exists! + { + $interface = function_exists("interface_exists") && interface_exists("Iterator", false) ? "implements Iterator" : ""; + $code = "class $classname extends it_dbi $interface + { + function $classname(/* \$query ... */) + { + \$args = func_get_args(); + \$query = array_shift(\$args); # Preserve type (scalar/array) in single parameter case + + foreach (\$args as \$arg) + \$query = array_merge((array)\$query, (array)\$arg); + + \$this->it_dbi(" . var_export($p, true) . ", \$query); + } + }"; + + debug("it_dbi::createclass('{$p['table']}'): creating class $classname, dbid=$dbid", 5); + eval($code); + } + } +} + + +/** + * INTERNAL: Connect to mysql server and maintain a global link cache + */ +function _connect($p = array()) +{ + $p += $this->_p; + $dbid = "{$p['user']}@{$p['server']}:{$p['db']}"; + $state = it_dbi::_state_get($dbid); + + if ($p['reconnect'] || !($this->_link = $state['link'])) + { + # Force new link if same server/user was seen before (mysql ignores selected db) + if ($GLOBALS['it_dbi']->_connected["{$p['server']}/{$p['user']}"]++) + $this->_link = @mysql_connect($p['server'], $p['user'], $p['pw'], true); + else + $this->_link = @mysql_connect($p['server'], $p['user'], $p['pw']); + + if (!$this->_link) + { + # One retry after a short delay + it::log('sqllog', "it_dbi(): retrying DB link (mysql_connect {$p['server']}, {$p['db']}): " . mysql_error()); + sleep(1); + $this->_link = @mysql_connect($p['server'], $p['user'], $p['pw'], true); + } + + if (!$this->_link) + $this->_fatal("_connect(): can't create DB link (mysql_connect {$p['user']}@{$p['server']}, {$p['db']})"); + + if (!(@mysql_select_db($p['db'], $this->_link))) + $this->_fatal("_connect(): can't select database \"{$p['db']}\""); + + # set charset used for this connection + if ($p['charset']) + if (!mysql_set_charset($p['charset'], $this->_link)) + $this->_fatal("_connect(): can't set charset \"{$p['charset']}\""); + + # NOTE: This overwrites old state but that is on purpose. New link means we should refetch all info about connection + $state['link'] = $this->_link; + it_dbi::_state_put($dbid, $state, false); # Store only locally as link is not shared anyway + } +} + + +/** + * INTERNAL: construct SQL SET clause of changed values from member vars and tags array. + */ +function _set($tags, $allfields = false) +{ + $r = array(); + foreach((array)$tags as $field => $value) + { + if (substr($field, 0, 1) == '-') # Unquoted value (always added) + $r[] = substr($field, 1)."=$value"; + else if ($allfields || ($value !== $this->_data[$field])) + $r[] = "`$field`=".(isset($value) ? $this->escape_string($value) : 'NULL'); + } + + return $r ? 'SET '.implode(', ', $r) : ''; +} + + +/** + * Create an SQL query (the stuff after 'WHERE') according to an array of selection criteria. + * + * Example: + * $sql = $table->_where(array('Type' => 'bar', + * 'Date >=' => '1999-01-01', '-Date <' => 'NOW()', + * 'User NI' => 'chris'), 'ORDER BY Date'); + * + * @param $params optional array of fieldname => value tupels. These are ANDed to form a WHERE clause. + * fieldname can contain an operator (separated by space), the default operator is '='. + * The special operator 'NI' specifies that the argument must be contained in a comma-separated list. + * @param $link DB link used to escape values (not used anymore) + * @param $omit_where Do not add 'WHERE ' to result + * @return The generated SQL clause + * @see select() + * @see iterate() + */ +function _where($params = "", $dummy_link = null, $omit_where = false) +{ + if (is_array($params) && (count($params) > 0)) + { + $query = ''; + $stringquery = ''; + $sep = ''; + + foreach($params as $field => $value) + { + if (is_int($field)) /* no key specified; just append */ + { + if (strcasecmp($value, 'OR')) + $stringquery .= " $value"; + else + $sep = ' OR '; + } + else + { + $needs_where = true; + + if (!isset($value)) + { + $op = 'IS'; + $qval = 'NULL'; + } + else + { + if (preg_match('/^(\S+)\s+(\S.*)$/', $field, $regs)) + { + $field = $regs[1]; + $op = strtoupper($regs[2]); + } + else + $op = '='; + + # If field name starts with '-', the raw value is taken, no escaping is done and no quotes are put around it. + if (substr($field, 0, 1) == '-') + { + $field = substr($field, 1); # Strip that '-' sign + $qval = $value; + } + else if (!is_array($value)) + $qval = $this->escape_string((string)$value); + } + + switch ($op) + { + case 'NI': + if ($value) + { + $parts = array(); + foreach ((array)$value as $val) + $parts[] = "CONCAT(',',$field,',') LIKE " . $this->escape_string("%,$val,%"); + + $query .= $sep . "(" . join(" OR ", $parts) . ")"; + } + else + $query .= $sep . "1"; + break; + + case 'MATCH': + $qval = join(' ', (array)$value); + $query .= "$sep$op ($field) AGAINST (" . $this->escape_string($qval) . " IN BOOLEAN MODE)"; + break; + + case 'IN': + case 'NOT IN': + if (is_array($value)) + { + if ($value) + { + $qvals = array(); + + foreach ($value as $val) + $qvals[] = $this->escape_string($val); + + $query .= "$sep$field $op (" . join(",", $qvals) . ")"; # null is mapped to '' + } + else + $query .= $sep . (($op == 'IN') ? "0" : "1"); + + break; + } + /* FALLTHROUGH */ + + default: + if (isset($qval)) + $query .= "$sep$field $op $qval"; + else + it::fatal('Undefined $qval when constructing query due to invalid $value (array)'); + break; + } + $sep = ' AND '; + } + } + + $query .= $stringquery; + + if ($needs_where && !$omit_where) + $query = "WHERE $query"; + } + + return $query; +} + + +/** + * Internal: Output class name::error message and terminate execution. + */ +function _fatal($text) +{ + $text = get_class($this).'::'.$text; + + if ($this->_link && ($errstr = mysql_error($this->_link))) + $text = "\"$errstr\" in $text [errno " . mysql_errno($this->_link) . "]"; + + if ($this->_link && ($res = @mysql_fetch_row(mysql_query('select database()', $this->_link)))) # dont create extra errs + $text .= ", DB: " . $res[0]; + + it::fatal($text . ", Server: " . $this->_p['server']); + /* NOT REACHED */ +} + + +/** + * Post-process data after reading a record. + * This is a stub-function that can be overloaded. + */ +function _read_post_process() +{ +} + + +/** + * Pre-process data before writing a record. + * This is a stub-function that can be overloaded. + * @param $tags Reference to update/create tags, can be modified as needed + * @param $command SQL command ('INSERT', 'REPLACE' or 'UPDATE') + */ +function _write_pre_process(&$tags, $command) # NOPHPLINT +{ +} + + +/** + * Clear record + */ +function clear($pp = true) +{ + foreach ((array)$this->_fields + (array)$this->_localizedfields as $field => $dummy) + unset($this->$field); + unset($this->_key, $this->_data); + + $pp && $this->_read_post_process(); +} + + +/** + * Semi-internal: send a raw SQL query and return mysql result value + * @param $query complete SQL query string + * @return raw MySQL result. May die if query fails and safety is big enough + */ +function query($query, $p = array()) +{ + $p += $this->_p; + $start = gettimeofday(true); + + if ($p['server_update'] && !preg_match('/^(EXPLAIN|SELECT|SHOW) /i', $query)) + { + debug("switching to update server \"{$p['server_update']}\"", 5); + $this->_p['server'] = $p['server'] = $p['server_update']; + unset($this->_p['server_update'], $p['server_update'], $this->_link); + } + + $this->_connect($p); # must be called after update server switching code + + debug("{$p['user']}@{$p['server']}:{$p['db']}" . '.' . get_class($this) . "::query(\"$query\")", 4); + + if (!($result = mysql_query($query, $this->_link)) && $p['safety']) + { + $errno = mysql_errno($this->_link); + if (($p['safety'] < 2) && ($errno == 1062)) # Duplicate entry + return false; + + if ($errno == 2006) # mysql server has gone away: retry + { + it::log('sqllog', "it_dbi(): reconnecting mysql_connect {$p['server']}, {$p['db']}"); + $this->_connect(array('reconnect' => true)); + $result = mysql_query($query, $this->_link); + } + + if (!$result) + $this->_fatal("query(\"$query\") failed"); + } + else if (preg_match('/^(CREATE|ALTER|DROP) /i', $query)) + { + # Purge cache for schema changes (after modifying table) + $dbid = "{$p['user']}@{$p['server']}:{$p['db']}"; + it_dbi::_state_purgeshared($dbid); + } + + + $msec = round(1000 * (gettimeofday(true) - $start)); + $slow = $msec >= 2000; + if ($GLOBALS['debug_sqllog'] || $GLOBALS['debug_sqltrace'] || $slow) + { + $backtrace = (EDC('sqltrace') || $slow) ? it_debug::backtrace(1) : null; + it::log('sqllog', "$msec\t$query\t$backtrace\t" . $this->_p['server'] . ($slow ? "\tSLOW" : "")); + + $this->_sqllog[] = array( + 'time' => $msec, + 'query' => $query, + ) + ($backtrace ? array('backtrace' => $backtrace) : array()); + } + + return $result; +} + + +/** + * Read a single record by primary key, not destroying old query result $this->_result + * @param $id primary key. If null, record is cleared + * @return True if record could be read, false if not. + */ +function read($id=null) +{ + $old_result = $this->_result; + $old_nofetch = $this->_nofetch; + $result = $this->select(array($this->_p['keyfield'] => $id)); + $this->_result = $old_result; + $this->_nofetch = $old_nofetch; + return $result; +} + + +/** + * Select a set of records from table and fetch the first one + * @param $query One or more optional arrays of (field => value) or sqlstring pairs. Defaults to null (select all records) + * Fields will be joined by AND + * Fields can contain a compare operator: 'name LIKE' => "j%" or 'amount >' => 100 + * Fields can start with - to prevent quoting of right side: '-modified' => "CURDATE()" + * $query can contain magic field 'SELECT' for things like 'COUNT(*)' or 'DISTINCT foo', defaults to '*' + * $query can contain magic field 'JOIN' for things like 'tableA LEFT JOIN tableB ON a=b', defaults to table name + * $query can contain 'CALC_FOUND_ROWS', if true member var _found_rows contains number of matching rows before LIMIT + * $query can contain 'NOFETCH', if true the first row is not prefetched (e.g. when directly using _result) + * @return Number of matching rows, use iterate() to fetch the next record + * @see iterate() + * @see _where() + */ +function select(/* $query = array|string, ... */) +{ + $query = array(); + foreach (func_get_args() as $arg) + $query = array_merge($query, (array)$arg); + + $this->_connect(); + + $result = 0; + $calc_found_rows = false; + + $what = '*'; + if (isset($query['SELECT'])) + { + $what = $query['SELECT']; + unset($query['SELECT']); + } + + $join = $this->_p['table']; + if (isset($query['JOIN'])) # WARNING: this field gets abused for "tablename USE INDEX (fast2) + { + $join = $query['JOIN']; + unset($query['JOIN']); + } + + unset($this->_found_rows); + if (isset($query['CALC_FOUND_ROWS']) && $query['CALC_FOUND_ROWS']) + { + $calc_found_rows = true; + $what = 'SQL_CALC_FOUND_ROWS '.$what; + } + unset($query['CALC_FOUND_ROWS']); # Always unset, so CALC_FOUND_ROWS => false doesn't generate bogus query + + if (EDC('nocache')) + $what = 'SQL_NO_CACHE ' . $what; + + $nofetch = $this->_nofetch = $query['NOFETCH']; + unset($query['NOFETCH']); + + $this->clear(false); + if ($this->_result = $this->query($sql = "SELECT $what FROM $join " . $this->_where($query, $this->_link))) + { + $result = mysql_num_rows($this->_result); + + if ($calc_found_rows) + { + list($count) = mysql_fetch_row($this->query('SELECT FOUND_ROWS()')); + $this->_found_rows = intval($count); + } + + if (!$this->iterate() && ($this->_p['safety'] >= 2)) + $this->_fatal("select(): query produced no results: \"$sql\""); + } + + $this->_nofetch = !$nofetch; + + return $result; +} + + +/** + * Puts next result from previous select() in member variables + * @return true if another record was fetched, false if no more records + * @see select() + */ +function iterate() +{ + if (!$this->_nofetch) + { + if ($this->_data = mysql_fetch_assoc($this->_result)) + { + if ($localizedfields = $this->_localizedfields) + foreach ($localizedfields as $field => $dummy) + unset($this->$field); + + foreach ($this->_data as $field => $value) + $this->$field = (isset($value) && $this->_convertfunc[$field]) ? ($this->_data[$field] = $this->_convertfunc[$field]($value)) : $value; + + if ($localizedfields) + { + $lang = T_lang(); + foreach ($localizedfields as $field => $dummy) + { + $value = $this->{$field . "_" . $lang}; + + if (!isset($value)) + $value = $this->{$field . "_" . $this->_p['localized_defaultlanguage']}; + + if (isset($value)) + { + if (isset($this->$field)) + it::fatal("Field name clash: Overwriting {$this->_p['table']}.$field with {$field}_{$lang}, only use one of those fields"); + else + $this->$field = $value; + } + } + } + + if (!empty($this->_p['keyfield'])) + $this->_key = $this->_data[$this->_p['keyfield']]; + } + else + $this->clear(false); + + $this->_read_post_process(); + } + else + $this->_nofetch = false; + + return (bool)$this->_data; +} + + +/** + * Insert a record into table. Values are taken from member vars and $tags. + * After inserting, all values are valid (record is read back). + * Does not destroy internal state of last select() call + * @param $tags Additional key => value pairs (these have priority over member vars) + */ +function insert($tags = array(), $command = "INSERT") +{ + $this->_connect(); + + /* Pre-processing, $tags is passed by reference and may be modified here */ + $this->_write_pre_process($tags, $command); + + if ($this->_p['randomid'] && !isset($tags[$this->_p['keyfield']])) + $tags[$this->_p['keyfield']] = md5(uniqid(mt_rand())); + + $set = $this->_set($tags, true); + + if ($result = $this->query("$command INTO {$this->_p['table']} " . $set)) + { + $id = ($this->_p['autoincrement'] && !isset($tags[$this->_p['keyfield']])) ? mysql_insert_id($this->_link) : $tags[$this->_p['keyfield']]; + if ($this->_p['keyfield'] && !$this->read($id) && $this->_p['safety']) + $this->_fatal("insert(): can't read record back (key truncated?), id=\"$id\""); + } + else + $this->clear(false); + + return $result; +} + + +/** + * Replace a record in a table + * @param $tags Additional key => value pairs (these have priority over member vars) + * Does not destroy internal state of last select() call + * @see insert() + */ +function replace($tags = array()) +{ + return $this->insert($tags, "REPLACE"); +} + + +/** + * Update current record or a number of records given by where condition + * @param $tags key => value pairs (these have priority over changes in member vars) + * @param $where condition to select records to be modified (if not current record) + * @return number of updated records (or false on error). WARNING: read LIMIT docs before using it + * Does not destroy internal state of last select() call + */ +function update($tags = array(), $where = null) +{ + $this->_connect(); + $result = true; + + /* Pre-processing, $tags is passed by reference and may be modified here */ + $this->_write_pre_process($tags, 'UPDATE'); + + if ($set = $this->_set($tags, isset($where))) + { + if (!isset($where)) + $where = array($this->_p['keyfield'] => $this->_data[$this->_p['keyfield']]); + + if ($result = $this->query("UPDATE {$this->_p['table']} $set " . $this->_where($where, $this->_link))) + { + $result = mysql_affected_rows($this->_link); + + if (array_key_exists($this->_p['keyfield'], $tags)) # Did we just update the key? + $this->_key = $tags[$this->_p['keyfield']]; + + if (isset($this->_key) && $this->read($this->_key)) + $this->_nofetch = false; # So we can do while(iterate()) update(); + } + } + + return $result; +} + + +/** + * Delete a record + * Does not destroy query result $this->_result + * @param $query optional query for WHERE, default: delete currently loaded record + * @return number of deleted records + */ +function delete($query = null) +{ + $this->_connect(); + $result = 0; + + if (!$query && $this->_p['keyfield']) + { + $query = array($this->_p['keyfield'] => $this->_key); + $this->clear(); + } + + if ($query && $this->query("DELETE FROM {$this->_p['table']} " . $this->_where($query, $this->_link))) + $result = mysql_affected_rows($this->_link); + + return $result; +} + + +/** + * Escapes a string for use in a DB query + * @param The string to be quoted + * @return The quoted value + */ +function escape_string($str) +{ + $this->_connect(); + return "'" . mysql_real_escape_string($str, $this->_link) . "'"; +} + + +/** + * INTERNAL: Store information about a table's fields in $this->_fields, possibly from cache. + * @return array(keyfield, autoincrement, randomid) + */ +function _get_field_info() +{ + $result = array(); + $dbid = "{$this->_p['user']}@{$this->_p['server']}:{$this->_p['db']}"; + $state = it_dbi::_state_get($dbid); + + if (!($this->_fields = $state['fields'][$this->_p['table']])) + { + debug("it_dbi(): no fields for {$dbid}.{$this->_p['table']}, calculating.", 5); + for ($res = $this->query('SHOW COLUMNS FROM ' . $this->_p['table']); $res && ($field = mysql_fetch_assoc($res)); ) + { + $this->_fields[$field['Field']] = $field + array('Length' => preg_match('/date|time/', $field['Type']) ? 20 : intval(it::match('\d+', $field['Type']))); + if (preg_match('/^(tiny|small|medium|)int|^float|^double/', $field['Type'])) + $this->_convertfunc[$field['Field']] = it::match('int', $field['Type']) ? "intval" : "floatval"; + } + + # Consider all fields which have _{localized_defaultlanguage} suffix as localized + foreach (preg_grep('/_' . $this->_p['localized_defaultlanguage'] . '$/', array_keys((array)$this->_fields)) as $field) + $this->_localizedfields[substr($field, 0, -1 - strlen($this->_p['localized_defaultlanguage']))] = true; + + $state = it_dbi::_state_get($dbid); # State could have been modified by query above + $state['fields'][$this->_p['table']] = $this->_fields; + $state['convertfunc'][$this->_p['table']] = $this->_convertfunc; + it_dbi::_state_put($dbid, $state); + } + else # Existing _fields, copy other info too + $this->_convertfunc = $state['convertfunc'][$this->_p['table']]; + + foreach((array)$this->_fields as $field) + { + if ($field['Key'] == 'PRI') + { + $result = array('keyfield' => $field['Field'], 'autoincrement' => (strpos($field['Extra'], "auto_increment") !== false), + 'randomid' => (strpos($field['Type'], "char") !== false)); + break; + } + } + + unset($GLOBALS['it_dbi']->_p['table'], $GLOBALS['it_dbi']->_p['keyfield']); # Remove cruft + return $result; +} + +function _state_get($dbid) +{ + if (!($result = $GLOBALS['it_dbi']->_state[$dbid])) + $result = $GLOBALS['it_dbi']->_state[$dbid] = (array)it_cache::get("dbi:$dbid"); + + #var_dump("get", $dbid, $result); + return $result; +} + +function _state_put($dbid, $state, $shared = true) +{ + #var_dump("put", $dbid, $state); + $GLOBALS['it_dbi']->_state[$dbid] = $state; + if ($shared) + it_cache::put("dbi:$dbid", array('link' => null) + (array)$state); # link is not transferable +} + +function _state_purgeshared($dbid) +{ + #var_dump("purgeshared", $dbid); + it_cache::put("dbi:$dbid", array()); # Nuke shared cache +} + +# +# Implement PHP 5 Iterator interface to make foreach work +# Example: foreach (new T_User('firstname' => "foo") as $foouser) { ... } +# +function current() +{ + return $this; +} + +function key() +{ + return isset($this->_key) ? $this->_key : $this->_iteratorkey++; +} + +function next() +{ + $this->iterate(); +} + +function rewind() +{ + if (!$this->_result) # Object without query used in foreach + $this->select(); + + # Only rewind if not already at start and results present + if (!$this->_nofetch && mysql_num_rows($this->_result)) + mysql_data_seek($this->_result, 0); + + $this->_iteratorkey = 0; + $this->iterate(); +} + +function valid() +{ + return (bool)$this->_data; +} + +} /* End class it_dbi */ + +?> -- cgit v1.2.3