* @copyright 2002-8 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 */ 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(); /** * 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 */ var $tz_offset_s; /** * Current time as timestamp in user-time * * @var int */ var $now; /** * 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 /setup/tables_current.inc.php * @param string $table should be set if table-defs to be read from /setup/tables_current.inc.php * @param object/db $db database object, if not the one in $GLOBALS['egw']->db should be used, eg. for an other database * @param string $colum_prefix='' column prefix to automatic remove from the column-name, if the column name starts with it * @param boolean $no_clone=false can we avoid to clone the db-object, default no * new code using appnames and foreach(select(...,$app) can set it to avoid an extra instance of the db object * * @return so_sql */ function __construct($app='',$table='',$db=null,$column_prefix='',$no_clone=false) { if ($no_clone) { $this->db = is_object($db) ? $db : $GLOBALS['egw']->db; } else { $this->db = is_object($db) ? clone($db) : clone($GLOBALS['egw']->db); } $this->db_cols = $this->db_key_cols + $this->db_data_cols; if ($app) { $this->app = $app; if (!$no_clone) $this->db->set_app($app); if ($table) $this->setup_table($app,$table,$column_prefix); } $this->init(); if ((int) $this->debug >= 4) { echo "

so_sql('$app','$table')

\n"; _debug_array($this); } $this->tz_offset_s = $GLOBALS['egw']->datetime->tz_offset; $this->now = time() + $this->tz_offset_s; // time() is server-time and we need a user-time } /** * php4 constructor * * @deprecated use __construct */ function so_sql($app='',$table='',$db=null,$column_prefix='',$no_clone=false) { self::__construct($app,$table,$db,$column_prefix,$no_clone); } /** * sets up the class for an app and table (by using the table-definition of $app/setup/tables_current.inc.php * * If you need a more complex conversation then just removing the column_prefix, you have to do so in a derifed class !!! * * @param string $app app-name $table belongs too * @param string $table table-name * @param string $colum_prefix='' column prefix to automatic remove from the column-name, if the column name starts with it */ function setup_table($app,$table,$colum_prefix='') { $this->table_name = $table; $this->table_def = $this->db->get_table_definitions($app,$table); if (!$this->table_def || !is_array($this->table_def['fd'])) { echo "

so_sql::setup_table('$app','$table'): No table definitions found !!!
\n".function_backtrace()."

\n"; } $this->db_key_cols = $this->db_data_cols = $this->db_cols = array(); $this->autoinc_id = ''; $len_prefix = strlen($colum_prefix); foreach($this->table_def['fd'] as $col => $def) { $name = $col; if ($len_prefix && substr($name,0,$len_prefix) == $colum_prefix) { $name = substr($col,$len_prefix); } if (in_array($col,$this->table_def['pk'])) { $this->db_key_cols[$col] = $name; } else { $this->db_data_cols[$col] = $name; } $this->db_cols[$col] = $name; if ($def['type'] == 'auto') { $this->autoinc_id = $col; } foreach($this->table_def['uc'] as $k => $uni_index) { if (is_array($uni_index) && in_array($name,$uni_index)) { $this->db_uni_cols[$k][$col] = $name; } elseif($name === $uni_index) { $this->db_uni_cols[$col] = $name; } } } } /** * merges in new values from the given new data-array * * @param $new array in form col => new_value with values to set */ function data_merge($new) { if ((int) $this->debug >= 4) echo "

so_sql::data_merge(".print_r($new,true).")

\n"; if (!is_array($new) || !count($new)) { return; } foreach($this->db_cols as $db_col => $col) { if (array_key_exists($col,$new)) { $this->data[$col] = $new[$col]; } } foreach($this->non_db_cols as $db_col => $col) { if (array_key_exists($col,$new)) { $this->data[$col] = $new[$col]; } } if ((int) $this->debug >= 4) _debug_array($this->data); } /** * changes the data from the db-format to your work-format * * It gets called everytime when data is read from the db. * This default implementation only converts the timestamps mentioned in $this->timestampfs from server to user time. * You can reimplement it in a derived class * * @param array $data if given works on that array and returns result, else works on internal data-array */ function db2data($data=null) { if (!is_array($data)) { $data = &$this->data; } if ($this->tz_offset_s && $this->timestamps) { foreach($this->timestamps as $name) { if (isset($data[$name]) && $data[$name]) $data[$name] += $this->tz_offset_s; } } // do the necessare changes here return $data; } /** * changes the data from your work-format to the db-format * * It gets called everytime when data gets writen into db or on keys for db-searches. * This default implementation only converts the timestamps mentioned in $this->timestampfs from user to server time. * You can reimplement it in a derived class * * @param array $data if given works on that array and returns result, else works on internal data-array */ function data2db($data=null) { if ($intern = !is_array($data)) { $data = &$this->data; } if ($this->tz_offset_s && $this->timestamps) { foreach($this->timestamps as $name) { if (isset($data[$name]) && $data[$name]) $data[$name] -= $this->tz_offset_s; } } // do the necessary changes here return $data; } /** * initializes data with the content of key * * @param array $keys array with keys in form internalName => value * @return array internal data after init */ function init($keys=array()) { $this->data = array(); $this->db2data(); $this->data_merge($keys); return $this->data; } /** * reads row matched by key and puts all cols in the data array * * @param array $keys array with keys in form internalName => value, may be a scalar value if only one key * @param string/array $extra_cols string or array of strings to be added to the SELECT, eg. "count(*) as num" * @param string $join sql to do a join, added as is after the table-name, eg. ", table2 WHERE x=y" or * @return array/boolean data if row could be retrived else False */ function read($keys,$extra_cols='',$join='') { if (!is_array($keys)) { $pk = array_values($this->db_key_cols); if ($pk) $keys = array($pk[0] => $keys); } $this->init($keys); $this->data2db(); $query = false; foreach ($this->db_key_cols as $db_col => $col) { if ($this->data[$col] != '') { $query[$db_col] = $this->data[$col]; } } if (!$query) // no primary key in keys, lets try the data_cols for a unique key { foreach($this->db_uni_cols as $db_col => $col) { if (!is_array($col) && $this->data[$col] != '') { $query[$db_col] = $this->data[$col]; } elseif(is_array($col)) { $q = array(); foreach($col as $db_c => $c) { if ($this->data[$col] == '') { $q = null; break; } $q[$db_c] = $this->data[$c]; } if ($q) $query += $q; } } } if (!$query) // no unique key in keys, lets try everything else { foreach($this->db_data_cols as $db_col => $col) { if ($this->data[$col] != '') { $query[$db_col] = $this->data[$col]; } } } if (!$query) // keys has no cols { $this->db2data(); return False; } if ($join) // Prefix the columns with the table-name, as they might exist in the join { foreach($query as $col => $val) { if (is_int($col) || strpos($join,$col) === false) continue; $query[] = $this->db->expression($this->table_name,$this->table_name.'.',array($col=>$val)); unset($query[$col]); } } foreach($this->db->select($this->table_name,'*'.($extra_cols?','.(is_array($extra_cols)?implode(',',$extra_cols):$extra_cols):''), $query,__LINE__,__FILE__,False,'',$this->app,0,$join) as $row) { $cols = $this->db_cols; if ($extra_cols) // extra columns to report { foreach(is_array($extra_cols) ? $extra_cols : array($extra_cols) as $col) { if (FALSE!==stripos($col,' as ')) $col = preg_replace('/^.* as *([a-z0-9_]+) *$/i','\\1',$col); $cols[$col] = $col; } } foreach ($cols as $db_col => $col) { $this->data[$col] = $row[$db_col]; } $this->db2data(); if ((int) $this->debug >= 4) { echo "data =\n"; _debug_array($this->data); } return $this->data; } if ($this->autoinc_id) { unset($this->data[$this->db_key_cols[$this->autoinc_id]]); } if ((int) $this->debug >= 4) echo "nothing found !!!

\n"; $this->db2data(); return False; } /** * saves the content of data to the db * * @param array $keys if given $keys are copied to data before saveing => allows a save as * @param string|array $extra_where=null extra where clause, eg. to check an etag, returns true if no affected rows! * @return int|boolean 0 on success, or errno != 0 on error, or true if $extra_where is given and no rows affected */ function save($keys=null,$extra_where=null) { if (is_array($keys) && count($keys)) $this->data_merge($keys); $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] = (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 0 on success, errno != 0 otherwise */ function update($fields,$merge=true) { if ($merge) $backup_data = $this->data ? $this->data : array(); if ($this->autoinc_id && !isset($fields[$this->autoinc_id]) || $this->db_key_cols && count(array_intersect(array_keys($this->db_key_cols),array_keys($fields)) != count($this->db_key_cols))) { foreach($this->db_key_cols as $col => $name) { if (!isset($fields[$name])) { $fields[$name] = $this->data[$name]; } } } $this->init($fields); $ret = $this->save(); if ($merge) { $this->init($backup_data); $this->data_merge($fields); } return $ret; } /** * deletes row representing keys in internal data or the supplied $keys if != null * * @param array $keys if given array with col => value pairs to characterise the rows to delete * @return int affected rows, should be 1 if ok, 0 if an error */ function delete($keys=null) { 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]; } $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 a SQL query (content for WHERE), fully quoted (!) * @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 * @return boolean/array of matching rows (the row is an array of the cols) or False */ 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 (!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'].' '; if ($criteria[$col][0] == '!') { $cmp_op = ' NOT'.$cmp_op; $criteria[$col] = substr($criteria[$col],1); } $query[] = $db_col.$cmp_op.$this->db->quote($wildcard.str_replace(array('%','_','*','?'),array('\\%','\\_','%','_'),$criteria[$col]).$wildcard); } 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()."
\n"; echo "filter=";_debug_array($filter); echo "data2db(filter)=";_debug_array($data2db_filter); } foreach($data2db_filter as $col => $val) { if ($val !== '') { // check if a db-internal name conversation necessary if (!is_int($col) && ($c = array_search($col,$this->db_cols))) { $col = $c; } if(is_int($col)) { $db_filter[] = $val; } elseif ($val === "!''") { $db_filter[] = $col." != ''"; } else { $db_filter[$col] = $val; } } } if ($query) { if ($op != 'AND') { $db_filter[] = '('.$this->db->column_data_implode(' '.$op.' ',$query).')'; } else { $db_filter = array_merge($db_filter,$query); } } $query = $db_filter; } if ((int) $this->debug >= 4) { echo "

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 "
criteria = "; _debug_array($criteria); } if ($only_keys === true) { $colums = implode(',',array_keys($this->db_key_cols)); } elseif (is_array($only_keys)) { $colums = array(); foreach($only_keys as $key => $col) { $colums[] = ($db_col = array_search($col,$this->db_cols)) ? $db_col : $col; } $colums = implode(',',$colums); } elseif (!$only_keys) { $colums = '*'; } else { $colums = $only_keys; } if ($extra_cols) $colums .= ($colums ? ',' : '').(is_array($extra_cols) ? implode(',',$extra_cols) : $extra_cols); $num_rows = 0; // as spec. in max_matches in the user-prefs if (is_array($start)) list($start,$num_rows) = $start; if ($order_by && stripos($order_by,'ORDER BY')===false && stripos($order_by,'GROUP BY')===false) { $order_by = 'ORDER BY '.$order_by; } static $union = array(); static $union_cols = array(); if ($start === 'UNION' || $union) { if ($start === 'UNION') { $union[] = array( 'table' => $this->table_name, 'cols' => $colums, 'where' => $query, 'append' => $order_by, 'join' => $join, ); if (!$union_cols) // union used the colum-names of the first query { $union_cols = $this->_get_columns($only_keys,$extra_cols); } return true; // waiting for further calls, before running the union-query } // running the union query now if ($start !== false && $num_rows != 1) // need to get the total too, saved in $this->total { if ($this->db->Type == 'mysql' && $this->db->ServerInfo['version'] >= 4.0) { $union[0]['cols'] = ($mysql_calc_rows = 'SQL_CALC_FOUND_ROWS ').$union[0]['cols']; } else // cant do a count, have to run the query without limit { $this->total = $this->db->union($union,__LINE__,__FILE__)->NumRows(); } } $rs = $this->db->union($union,__LINE__,__FILE__,$order_by,$start,$num_rows); $cols = $union_cols; $union = $union_cols = array(); } else // no UNION { if ($start !== false && $num_rows != 1) // need to get the total too, saved in $this->total { if ($this->db->Type == 'mysql' && $this->db->ServerInfo['version'] >= 4.0) { $mysql_calc_rows = 'SQL_CALC_FOUND_ROWS '; } elseif (!$need_full_no_count && (!$join || stripos($join,'LEFT JOIN')!==false)) { $this->total = $this->db->select($this->table_name,'COUNT(*)',$query,__LINE__,__FILE__,false,'',$this->app,0,$join)->fetchSingle(); } else // cant do a count, have to run the query without limit { $this->total = $this->db->select($this->table_name,$colums,$query,__LINE__,__FILE__,false,$order_by,false,0,$join)->NumRows(); } } $rs = $this->db->select($this->table_name,$mysql_calc_rows.$colums,$query,__LINE__,__FILE__, $start,$order_by,$this->app,$num_rows,$join); $cols = $this->_get_columns($only_keys,$extra_cols); } if ((int) $this->debug >= 4) echo "

sql='{$this->db->Query_ID->sql}'

\n"; if ($mysql_calc_rows) { $this->total = $this->db->query('SELECT FOUND_ROWS()')->fetchSingle(); } $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 : False; } /** * 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 * @return int total number of rows */ function get_rows($query,&$rows,&$readonlys,$join='',$need_full_no_count=false,$only_keys=false) { if ((int) $this->debug >= 4) { echo "

so_sql::get_rows(".print_r($query,true).",,)

\n"; } $criteria = array(); if ($query['search']) { foreach($this->db_cols as $col) // we search all cols { $criteria[$col] = $query['search']; } } $rows = $this->search($criteria,$only_keys,$query['order']?$query['order'].' '.$query['sort']:'', '','%',false,'OR',$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 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]); } if (list($other) = $this->search($query,false,'','','',false,'AND',false,null,'')) { 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; } }