* @copyright 2002-9 by RalfBecker@outdoor-training.de
* @version $Id$
*/
/**
* generalized SQL Storage Object
*
* the class can be used in following ways:
* 1) by calling the constructor with an app and table-name or
* 2) by setting the following documented class-vars in a class derifed from this one
* Of cause can you derife the class and call the constructor with params.
*
* @package etemplate
* @subpackage api
* @author RalfBecker-AT-outdoor-training.de
* @license http://opensource.org/licenses/gpl-license.php GPL - GNU General Public License
* @todo modify search() to return an interator instead of an array
*/
class so_sql
{
/**
* need to be set in the derived class to the db-table-name
*
* @var string
*/
var $table_name;
/**
* db-col-name of autoincrement id or ''
*
* @var string
*/
var $autoinc_id = '';
/**
* all cols in data which are not (direct)in the db, for data_merge
*
* @var array
*/
var $non_db_cols = array();
/**
* 4 turns on the so_sql debug-messages, default 0
*
* @var int
*/
var $debug = 0;
/**
* string to be written to db if a col-value is '', eg. "''" or 'NULL' (default)
*
* @var string
*/
var $empty_on_write = 'NULL';
/**
* total number of entries of last search with start != false
*
* @var int|boolean
*/
var $total = false;
/**
* protected instance or reference (depeding on $no_clone param of constructor) of the db-object
*
* @var egw_db
*/
protected $db;
/**
* unique keys/index, set by derived class or via so_sql($app,$table)
*
* @var array
*/
var $db_uni_cols = array();
/**
* db-col-name / internal-name pairs, set by derived calls or via so_sql($app,$table)
*
* @var array
*/
var $db_key_cols = array();
/**
* db-col-name / internal-name pairs, set by derived calls or via so_sql($app,$table)
*
* @var array
*/
var $db_data_cols = array();
/**
* @var array $db_cols all columns = $db_key_cols + $db_data_cols, set in the constructor
*/
var $db_cols = array();
/**
* eGW table definition
*
* @var array
*/
var $table_def = array();
/**
* Appname to use in all queries, set via constructor
*
* @var string
*/
var $app;
/**
* holds the content of all columns
*
* @var array
*/
var $data = array();
/**
* Timestaps that need to be adjusted to user-time on reading or saving
*
* @var array
*/
var $timestamps = array();
/**
* Type of timestamps returned by this class (read and search methods), default null means leave them unchanged
*
* Possible values:
* - 'ts'|'integer' convert every timestamp to an integer unix timestamp
* - 'string' convert every timestamp to a 'Y-m-d H:i:s' string
* - 'object' convert every timestamp to a egw_time object
*
* @var string
*/
public $timestamp_type;
/**
* Offset in secconds between user and server-time, it need to be add to a server-time to get the user-time
* or substracted from a user-time to get the server-time
*
* @var int
* @deprecated use egw_time methods instead, as the offset between user and server time is only valid for current time
*/
var $tz_offset_s;
/**
* Current time in user timezone
*
* @var int|string|DateTime format depends on $this->timestamp_type
*/
var $now;
/**
* Which columns should be searched, if a non-empty string is passed to criteria parameter of search()
*
* If not set (by extending class), all data columns will be searched.
*
* @var array
*/
var $columns_to_search;
/**
* Should search return an iterator (true) or an array (false = default)
*
* @var boolean
*/
public $search_return_iterator = false;
/**
* constructor of the class
*
* NEED to be called from the constructor of the derived class !!!
*
* @param string $app should be set if table-defs to be read from so_sql('$app','$table') so_sql::setup_table('$app','$table'): No table definitions found !!! so_sql::data_merge(".print_r($new,true).")
\n".function_backtrace()."
".__METHOD__."() User change TZ since read! tz-read=".$this->data[self::USER_TIMEZONE_READ].' != current-tz='.egw_time::$user_timezone->getName()." --> fixing
\n"; error_log(__METHOD__."() User changed TZ since read! tz-read=".$this->data[self::USER_TIMEZONE_READ].' != current-tz='.egw_time::$user_timezone->getName()." --> fixing"); $GLOBALS['egw_info']['user']['preferences']['common']['tz'] = $this->data[self::USER_TIMEZONE_READ]; egw_time::setUserPrefs($this->data[self::USER_TIMEZONE_READ]); $this->set_times(); } $this->data2db(); if ((int) $this->debug >= 4) { echo "so_sql::save(".print_r($keys,true).") autoinc_id='$this->autoinc_id', data="; _debug_array($this->data); } if ($this->autoinc_id && !$this->data[$this->db_key_cols[$this->autoinc_id]]) // insert with auto id { foreach($this->db_cols as $db_col => $col) { if (!$this->autoinc_id || $db_col != $this->autoinc_id) // not write auto-inc-id { if (!array_key_exists($col,$this->data) && // handling of unset columns in $this->data (isset($this->table_def['fd'][$db_col]['default']) || // we have a default value !isset($this->table_def['fd'][$db_col]['nullable']) || $this->table_def['fd'][$db_col]['nullable'])) // column is nullable { continue; // no need to write that (unset) column } $data[$db_col] = (string) $this->data[$col] === '' && $this->empty_on_write == 'NULL' ? null : $this->data[$col]; } } $this->db->insert($this->table_name,$data,false,__LINE__,__FILE__,$this->app); if ($this->autoinc_id) { $this->data[$this->db_key_cols[$this->autoinc_id]] = $this->db->get_last_insert_id($this->table_name,$this->autoinc_id); } } else // insert in table without auto id or update of existing row, dont write colums unset in $this->data { foreach($this->db_data_cols as $db_col => $col) { // we need to update columns set to null: after a $this->data[$col]=null: // - array_key_exits($col,$this->data) === true // - isset($this->data[$col]) === false if (!array_key_exists($col,$this->data) && // handling of unset columns in $this->data ($this->autoinc_id || // update of table with auto id or isset($this->table_def['fd'][$db_col]['default']) || // we have a default value or !isset($this->table_def['fd'][$db_col]['nullable']) || $this->table_def['fd'][$db_col]['nullable'])) // column is nullable { continue; // no need to write that (unset) column } $data[$db_col] = !is_object($this->data[$col]) && (string) $this->data[$col] === '' && $this->empty_on_write == 'NULL' ? null : $this->data[$col]; } // allow to add direct sql updates, eg. "etag=etag+1" with int keys if (is_array($keys) && isset($keys[0])) { for($n=0; isset($keys[$n]); ++$n) { $data[] = $keys[$n]; } } $keys = $extra_where; foreach($this->db_key_cols as $db_col => $col) { $keys[$db_col] = $this->data[$col]; } if (!$data && !$this->autoinc_id) // happens if all columns are in the primary key { $data = $keys; $keys = False; } if ($this->autoinc_id) { $this->db->update($this->table_name,$data,$keys,__LINE__,__FILE__,$this->app); if (($nothing_affected = !$this->db->Errno && !$this->db->affected_rows()) && $extra_where) { return true; // extra_where not met, eg. etag wrong } } // always try an insert if we have no autoinc_id, as we dont know if the data exists if (!$this->autoinc_id || $nothing_affected) { $this->db->insert($this->table_name,$data,$keys,__LINE__,__FILE__,$this->app); } } $this->db2data(); return $this->db->Errno; } /** * Update only the given fields, if the primary key is not given, it will be taken from $this->data * * @param array $fields * @param boolean $merge=true if true $fields will be merged with $this->data (after update!), otherwise $this->data will be just $fields * @return int|boolean 0 on success, or errno != 0 on error, or true if $extra_where is given and no rows affected */ function update($fields,$merge=true) { if ($merge) $this->data_merge($fields); $fields = $this->data2db($fields); // extract the keys from $fields or - if not set there - from $this->data $keys = array(); foreach($this->db_key_cols as $col => $name) { $keys[$col] = isset($fields[$name]) ? $fields[$name] : $this->data[$name]; unset($fields[$name]); } // extract the data from $fields $data = array(); foreach($this->db_data_cols as $col => $name) { if (array_key_exists($name,$fields)) { $data[$col] = $fields[$name]; unset($fields[$name]); } } // add direct sql like 'etag=etag+1' (it has integer keys) foreach($fields as $key => $value) { if (is_int($key)) { $data[] = $value; } } if (!$data) { return 0; // nothing to update } if (!$this->db->update($this->table_name,$data,$keys,__LINE__,__FILE__,$this->app)) { return $this->db->Errno; } return 0; } /** * deletes row representing keys in internal data or the supplied $keys if != null * * @param array|int $keys=null if given array with col => value pairs to characterise the rows to delete, or integer autoinc id * @param boolean $only_return_query=false return $query of delete call to db object, but not run it (used by so_sql_cf!) * @return int|array affected rows, should be 1 if ok, 0 if an error or array with id's if $only_return_ids */ function delete($keys=null,$only_return_query=false) { if ($this->autoinc_id && $keys && !is_array($keys)) { $keys = array($this->autoinc_id => $keys); } if (!is_array($keys) || !count($keys)) // use internal data { $data = $this->data; $keys = $this->db_key_cols; } else // data and keys are supplied in $keys { $data = $keys; $keys = array(); foreach($this->db_cols as $db_col => $col) { if (isset($data[$col])) { $keys[$db_col] = $col; } } } $data = $this->data2db($data); foreach($keys as $db_col => $col) { $query[$db_col] = $data[$col]; } if ($only_return_query) return $query; $this->db->delete($this->table_name,$query,__LINE__,__FILE__,$this->app); return $this->db->affected_rows(); } /** * searches db for rows matching searchcriteria * * '*' and '?' are replaced with sql-wildcards '%' and '_' * * For a union-query you call search for each query with $start=='UNION' and one more with only $order_by and $start set to run the union-query. * * @param array|string $criteria array of key and data cols, OR string with search pattern (incl. * or ? as wildcards) * @param boolean|string|array $only_keys=true True returns only keys, False returns all cols. or * comma seperated list or array of columns to return * @param string $order_by='' fieldnames + {ASC|DESC} separated by colons ',', can also contain a GROUP BY (if it contains ORDER BY) * @param string|array $extra_cols='' string or array of strings to be added to the SELECT, eg. "count(*) as num" * @param string $wildcard='' appended befor and after each criteria * @param boolean $empty=false False=empty criteria are ignored in query, True=empty have to be empty in row * @param string $op='AND' defaults to 'AND', can be set to 'OR' too, then criteria's are OR'ed together * @param mixed $start=false if != false, return only maxmatch rows begining with start, or array($start,$num), or 'UNION' for a part of a union query * @param array $filter=null if set (!=null) col-data pairs, to be and-ed (!) into the query without wildcards * @param string $join='' sql to do a join, added as is after the table-name, eg. "JOIN table2 ON x=y" or * "LEFT JOIN table2 ON (x=y AND z=o)", Note: there's no quoting done on $join, you are responsible for it!!! * @param boolean $need_full_no_count=false If true an unlimited query is run to determine the total number of rows, default false * @todo return an interator instead of an array * @return array|NULL array of matching rows (the row is an array of the cols) or NULL */ function &search($criteria,$only_keys=True,$order_by='',$extra_cols='',$wildcard='',$empty=False,$op='AND',$start=false,$filter=null,$join='',$need_full_no_count=false) { if ((int) $this->debug >= 4) echo "so_sql::search(".print_r($criteria,true).",'$only_keys','$order_by',".print_r($extra_cols,true).",'$wildcard','$empty','$op','$start',".print_r($filter,true).",'$join')
\n"; // if extending class or instanciator set columns to search, convert string criteria to array if ($criteria && !is_array($criteria)) { $search = $this->search2criteria($criteria,$wildcard,$op); $criteria = array($search); } if (!is_array($criteria)) { $query = $criteria; } else { $criteria = $this->data2db($criteria); foreach($criteria as $col => $val) { if (is_int($col)) { $query[] = $val; } elseif ($empty || $val != '') { if (!($db_col = array_search($col,$this->db_cols))) { $db_col = $col; } if ($wildcard || $criteria[$col][0] == '!' || is_string($criteria[$col]) && (strpos($criteria[$col],'*')!==false || strpos($criteria[$col],'?')!==false)) { $cmp_op = ' '.$this->db->capabilities['case_insensitive_like'].' '; $negate = false; if ($criteria[$col][0] == '!') { $cmp_op = ' NOT'.$cmp_op; $criteria[$col] = substr($criteria[$col],1); $negate = true; } foreach(explode(' ',$criteria[$col]) as $crit) { $query[] = ($negate ? ' ('.$db_col.' IS NULL OR ' : '').$db_col.$cmp_op. $this->db->quote($wildcard.str_replace(array('%','_','*','?'),array('\\%','\\_','%','_'),$crit).$wildcard). ($negate ? ') ' : ''); } } elseif (strpos($db_col,'.') !== false) // we have a table-name specified { list($table,$only_col) = explode('.',$db_col); $table_def = $this->db->get_table_definitions(true,$table); if (is_array($val) && count($val) > 1) { array_walk($val,array($this->db,'quote'),$table_def['fd'][$only_col]['type']); $query[] = $sql = $db_col.' IN (' .implode(',',$val).')'; } else { $query[] = $db_col.'='.$this->db->quote(is_array($val)?array_shift($val):$val,$table_def['fd'][$only_col]['type']); } } else { $query[$db_col] = $criteria[$col]; } } } if (is_array($query) && $op != 'AND') $query = $this->db->column_data_implode(' '.$op.' ',$query); } if (is_array($filter)) { $db_filter = array(); $data2db_filter = $this->data2db($filter); if (!is_array($data2db_filter)) { echo function_backtrace()."so_sql::search(,only_keys=$only_keys,order_by='$order_by',wildcard='$wildcard',empty=$empty,$op,start='$start',".print_r($filter,true).") query=".print_r($query,true).", total='$this->total'
\n"; echo "sql='{$this->db->Query_ID->sql}'
\n"; if ($mysql_calc_rows) { $this->total = $this->db->query('SELECT FOUND_ROWS()')->fetchColumn(); } // ToDo: Implement that as an iterator, as $rs is also an interator and we could return one instead of an array if ($this->search_return_iterator) { return new so_sql_db2data_iterator($this,$rs); } $arr = array(); if ($rs) foreach($rs as $row) { $data = array(); foreach($cols as $db_col => $col) { $data[$col] = $row[$db_col]; } $arr[] = $this->db2data($data); $n++; } return $n ? $arr : null; } /** * Return criteria array for a given search pattern * * @param string $pattern search pattern incl. * or ? as wildcard, if no wildcards used we append and prepend one! * @param string &$wildcard='' on return wildcard char to use, if pattern does not already contain wildcards! * @param string &$op='AND' on return boolean operation to use, if pattern does not start with ! we use OR else AND * @param string $extra_col=null extra column to search * @param array $search_cols=array() List of columns to search. If not provided, all columns in $this->db_cols will be considered * @return array or column => value pairs */ public function search2criteria($pattern,&$wildcard='',&$op='AND',$extra_col=null, $search_cols = array()) { // This function can get called multiple times. Make sure it doesn't re-process. if (empty($pattern) || is_array($pattern)) return $pattern; if(strpos($pattern, 'CONCAT') !== false) { return $pattern; } $pattern = trim($pattern); $criteria = array(); $filter = array(); $columns = ''; /* * Special handling for numeric columns. They are only considered if the pattern is numeric. * If the pattern is numeric, an equality search is used instead. */ $numeric_types = array('auto', 'int', 'float', 'double'); $numeric_columns = array(); if(!$search_cols) { $search_cols = $this->get_default_search_columns(); } if(!$search_cols) { return array(); } // Concat all fields to be searched together, so the conditions operate across the whole record foreach($search_cols as $col) { if($this->table_def['fd'][$col] && in_array($this->table_def['fd'][$col]['type'], $numeric_types)) { $numeric_columns[] = $col; continue; } $columns .= "CAST(COALESCE($col,'') AS char),"; } if(strlen($columns) > 0) { $columns = 'CONCAT(' . substr($columns, 0, -1) . ')'; } // Break the search string into tokens $break = ' '; $token = strtok($pattern, $break); while($token) { if($token == strtoupper(lang('AND'))) { $token = '+'.strtok($break); } elseif ($token == strtoupper(lang('OR'))) { continue; } elseif ($token == strtoupper(lang('NOT'))) { $token = '-'.strtok($break); } if ($token[0]=='"') { $token = substr($token, 1,strlen($token)); $token .= ' '.strtok('"'); } // prepend and append extra wildcard %, if pattern does NOT already contain wildcards if (strpos($token,'*') === false && strpos($token,'?') === false) { $wildcard = '%'; // if pattern contains no wildcards, add them before AND after the pattern } else { $wildcard = ''; // no extra wildcard, if pattern already contains some } switch($token[0]) { case '+': $op = 'AND'; $token = substr($token, 1, strlen($token)); break; case '-': case '!': $op = 'NOT'; $token = substr($token, 1, strlen($token)); break; default: $op = 'OR'; break; } $token_filter = " $columns LIKE " . $GLOBALS['egw']->db->quote($wildcard.str_replace(array('%','_','*','?'),array('\\%','\\_','%','_'),$token).$wildcard); // Compare numeric token as equality for numeric columns if(is_numeric(str_replace(array('%','_','*','?'), '', $token))) { $numeric_filter = array(); foreach($numeric_columns as $col) { if($wildcard == '') { // Token has a wildcard from user, use LIKE $numeric_filter[] = "($col IS NOT NULL AND CAST($col AS CHAR) LIKE " . $GLOBALS['egw']->db->quote(str_replace(array('%','_','*','?'),array('\\%','\\_','%','_'),$token)) . ')'; } else { $numeric_filter[] = "($col IS NOT NULL AND $col = $token)"; } } if(count($numeric_filter) > 0) { $token_filter = '(' . $token_filter . ' OR ' . implode(' OR ', $numeric_filter) . ')'; } } $criteria[$op][] = $token_filter; $token = strtok($break); } if($criteria['NOT']) { $filter[] = 'NOT (' . implode(' OR ', $criteria['NOT']) . ') '; } if($criteria['AND']) { $filter[] = implode(' AND ', $criteria['AND']) . ' '; } if($criteria['OR']) { $filter[] = '(' . implode(' OR ', $criteria['OR']) . ') '; } if(count($filter)) { $result = '(' . implode(' AND ', $filter) . ')'; } // OR extra column on the end so a null or blank won't block a hit in the main columns if ($extra_col) { $result .= (strlen($result) ? ' OR ' : ' ') . "$extra_col = $pattern"; } $op = 'OR'; return array('(' . $result . ')'); } /** * Get a default list of columns to search * This is to be used as a fallback, for when the extending class does not define * $this->columns_to_search. All the columns are considered, and any with $skip_columns_with in * their name are discarded because these columns are expected to be foreign keys or other numeric * values with no meaning to the user. * * @return array of column names */ protected function get_default_search_columns() { $skip_columns_with = array('_id', 'modified', 'modifier', 'status', 'cat_id', 'owner'); $search_cols = is_null($this->columns_to_search) ? $this->db_cols : $this->columns_to_search; $numeric_types = array('auto', 'int', 'float', 'double'); // Skip some numeric columns that don't make sense to search if we have to default to all columns if(is_null($this->columns_to_search)) { foreach($search_cols as $key => $col) { if(in_array($this->table_def['fd'][$col]['type'], $numeric_types)) { foreach($skip_columns_with as $bad) { if(strpos($col, $bad) !== false) { unset($search_cols[$key]); continue 2; } } } } } return $search_cols; } /** * extract the requested columns from $only_keys and $extra_cols param of a search * * @internal * @param boolean|string $only_keys=true True returns only keys, False returns all cols. comma seperated list of keys to return * @param string|array $extra_cols='' string or array of strings to be added to the SELECT, eg. "count(*) as num" * @return array with columns as db-name => internal-name pairs */ function _get_columns($only_keys,$extra_cols) { //echo "_get_columns() only_keys="; _debug_array($only_keys); echo "extra_cols="; _debug_array($extra_cols); if ($only_keys === true) // only primary key { $cols = $this->db_key_cols; } else { $cols = array(); foreach(is_array($only_keys) ? $only_keys : explode(',',str_replace(array('DISTINCT ','distinct '),'',$only_keys)) as $col) { if (!$col || $col == '*' || $col == $this->table_name.'.*') // all columns { $cols = array_merge($cols,$this->db_cols); } else // only the specified columns { if (stripos($col,'as')!==false) $col = preg_replace('/^.*as +([a-z0-9_]+) *$/i','\\1',$col); if (($db_col = array_search($col,$this->db_cols)) !== false) { $cols[$db_col] = $col; } else { $cols[$col] = isset($this->db_cols[$col]) ? $this->db_cols[$col] : $col; } } } } if ($extra_cols) // extra columns to report { foreach(is_array($extra_cols) ? $extra_cols : explode(',',$extra_cols) as $col) { if (stripos($col,'as ')!==false) $col = preg_replace('/^.*as +([a-z0-9_]+) *$/i','\\1',$col); if (($db_col = array_search($col,$this->db_cols)) !== false) { $cols[$db_col] = $col; } else { $cols[$col] = isset($this->db_cols[$col]) ? $this->db_cols[$col] : $col; } } } return $cols; } /** * query rows for the nextmatch widget * * @param array $query with keys 'start', 'search', 'order', 'sort', 'col_filter' * For other keys like 'filter', 'cat_id' you have to reimplement this method in a derived class. * @param array &$rows returned rows/competitions * @param array &$readonlys eg. to disable buttons based on acl, not use here, maybe in a derived class * @param string $join='' sql to do a join, added as is after the table-name, eg. ", table2 WHERE x=y" or * "LEFT JOIN table2 ON (x=y)", Note: there's no quoting done on $join! * @param boolean $need_full_no_count=false If true an unlimited query is run to determine the total number of rows, default false * @param mixed $only_keys=false, see search * @param string|array $extra_cols=array() * @return int total number of rows */ function get_rows($query,&$rows,&$readonlys,$join='',$need_full_no_count=false,$only_keys=false,$extra_cols=array()) { if ((int) $this->debug >= 4) { echo "so_sql::get_rows(".print_r($query,true).",,)
\n"; } $criteria = array(); $op = 'AND'; if ($query['search']) { $criteria = $query['search']; } $rows = $this->search($criteria,$only_keys,$query['order']?$query['order'].' '.$query['sort']:'',$extra_cols, $wildcard,false,$op,$query['num_rows']?array((int)$query['start'],$query['num_rows']):(int)$query['start'], $query['col_filter'],$join,$need_full_no_count); if (!$rows) $rows = array(); // otherwise false returned from search would be returned as array(false) return $this->total; } /** * Check if values for unique keys and the primary keys are unique are unique * * @param array $data=null data-set to check, defaults to $this->data * @return int 0: all keys are unique, 1: first key not unique, 2: ... */ function not_unique($data=null) { if (!is_array($data)) { $data = $this->data; } $n = 1; $uni_keys = $this->db_uni_cols; // add the primary key, only if it's NOT an auto id if (!$this->autoinc_id) { $uni_keys[] = $this->db_key_cols; } foreach($uni_keys as $db_col => $col) { if (is_array($col)) { $query = array(); foreach($col as $db_c => $c) { $query[$db_c] = $data[$c]; } } else { $query = array($db_col => $data[$col]); } foreach($this->db->select($this->table_name,$this->db_key_cols,$query,__LINE__,__FILE__,false,'',$this->app) as $other) { foreach($this->db_key_cols as $db_key_col => $key_col) { if ($data[$key_col] != $other[$key_col]) { if ((int) $this->debug >= 4) { echo "not_unique in ".array2string($col)." as for '$key_col': '${data[$key_col]}' != '${other[$key_col]}'
\n"; } return $n; // different entry => $n not unique } } } ++$n; } return 0; } /** * Query DB for a list / array with one colum as key and an other one(s) as value, eg. id => title pairs * * We do some caching as these kind of function is usualy called multiple times, eg. for option-lists. * * @param string $value_col array of column-names for the values of the array, can also be an expression aliased with AS, * if more then one column given, an array with keys identical to the given ones is returned and not just the value of the column * @param string $key_col='' column-name for the keys, default '' = same as (first) $value_col: returns a distinct list * @param array $filter=array() to filter the entries * @param string $order='' order, default '' = same as (first) $value_col * @return array with key_col => value_col pairs or array if more then one value_col given (keys as in value_col) */ function query_list($value_col,$key_col='',$filter=array(),$order='') { static $cache = array(); $cache_key = serialize($value_col).'-'.$key_col.'-'.serialize($filter).'-'.$order; if (isset($cache[$cache_key])) { return $cache[$cache_key]; } if (!is_array($value_col)) $value_col = array($value_col); $cols = array(); foreach($value_col as $key => $col) { $cols[$key] = preg_match('/AS ([a-z_0-9]+)$/i',$col,$matches) ? $matches[1] : $col; } if (!$order) $order = current($cols); if (($search =& $this->search(array(),($key_col ? $key_col.',' : 'DISTINCT ').implode(',',$value_col),$order,'','',false,'AND',false,$filter))) { if (preg_match('/AS ([a-z_0-9]+)$/i',$key_col,$matches)) { $key_col = $matches[1]; } elseif (!$key_col) { $key_col = current($cols); } foreach($search as $row) { if (count($cols) > 1) { $data = array(); foreach($cols as $key => $col) { $data[$key] = $row[$col]; } } else { $data = $row[current($cols)]; } $ret[$row[$key_col]] = $data; } } return $cache[$cache_key] =& $ret; } /** * Get comments for all columns or a specific one * * @param $column=null name of column or null for all (default) * @return array|string array with internal-name => comment pairs, or string with comment, if $column given */ public function get_comments($column=null) { static $comments; if (is_null($comments)) { foreach($this->db_cols as $db_col => $col) { $comments[$col] = $this->table_def['fd'][$db_col]['comment']; } } return is_null($column) ? $comments : $comments[$column]; } } /** * Iterator applying a so_sql's db2data method on each element retrived * */ class so_sql_db2data_iterator implements Iterator { /** * Reference of so_sql class to use it's db2data method * * @var so_sql */ private $so_sql; /** * Instance of ADOdb record set to iterate * * @var Iterator */ private $rs; /** * Total count of entries * * @var int */ public $total; /** * Constructor * * @param so_sql $so_sql * @param Traversable $rs */ public function __construct(so_sql $so_sql,Traversable $rs=null) { $this->so_sql = $so_sql; $this->total = $so_sql->total; if (is_a($rs,'IteratorAggregate')) { $this->rs = $rs->getIterator(); } else { $this->rs = $rs; } } /** * Return the current element * * @return array */ public function current() { if (is_a($this->rs,'iterator')) { $data = $this->rs->current(); return $this->so_sql->data2db($data); } return null; } /** * Return the key of the current element * * @return int */ public function key() { if (is_a($this->rs,'iterator')) { return $this->rs->key(); } return 0; } /** * Move forward to next element (called after each foreach loop) */ public function next() { if (is_a($this->rs,'iterator')) { return $this->rs->next(); } } /** * Rewind the Iterator to the first element (called at beginning of foreach loop) */ public function rewind() { if (is_a($this->rs,'iterator')) { return $this->rs->rewind(); } } /** * Checks if current position is valid * * @return boolean */ public function valid () { if (is_a($this->rs,'iterator')) { return $this->rs->valid(); } return false; } }