IN ('.$option_id_array.')';
$CS->DB->query(' DELETE FROM '.$config['table'].' WHERE '.$config['key'].'="'.$config['key_value'].'" '.$if_in.' ');
}
public function __construct() {
global $CONF;
$this->HOST = $CONF->DB_HOST;
$this->USER = $CONF->DB_USER;
$this->PASS = $CONF->DB_PASS;
$this->DB_NAME = $CONF->DB_DB_NAME;
$this->NAMES = $CONF->DB_NAMES;
$this->TYPE = $CONF->DB_TYPE;
$this->DB_CON = $CONF->DB_CON;
$this->connect();
}
public function connect() {
//echo $conn;
if(!empty($this->NAMES))
$aft_comm = array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES {$this->NAMES}");
$this->POLACZENIE = new PDO($this->DB_CON, $this->USER, $this->PASS, $aft_comm);
$this->POLACZENIE->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
}
public function disconnect() { return $this->close(); }
public function __destruct() {
return $this->close();
}
public function close() {}
public function query($query) {
global $CONF, $SQL_QU;
try {
if($CONF->SHOW_SQL)
$SQL_QU[]=$query;
$ret=$this->POLACZENIE->prepare($query);
$ret->execute();
if($ret==false) throw new Exception('sql_error');
} catch (Exception $e) {
$mysql_error=$e->getMessage();
if(stristr($mysql_error, 'marked as crashed') && $this->AFTER_REPAIR!=true) {
$this->repair_tables();
$this->AFTER_REPAIR=true;
return $this->query($query);
}
$err=$e->getTrace();
$errstr='Blad zapytania SQL
'.$query.'
'.$mysql_error.'';
$msg='
Code-Trace:
'.nl2br($e->getTraceAsString());
// if(!empty($err[1]['file'])) $errorek=$err[0]; else $errorek=$err[0];
$errorek=$err[0];
error_handler(-4096, $errstr, $errorek['file'], $errorek['line'], $msg);
}
return $ret;
}
public function fetch_array($sql) { return $sql->fetch(PDO::FETCH_BOTH); }
public function fetch_assoc($sql) { return $sql->fetch(PDO::FETCH_ASSOC); }
public function fetch_object($sql) { return $sql->fetch(PDO::FETCH_OBJ); }
public function num_rows($sql) { return $sql->rowCount(); }
public function num_cols($sql) { return $sql->columnCount();}
public function affected_rows() { return $sql->rowCount(); }
public function inserted_id($tbl) { $dane=$this->fetch_array($this->query(' SELECT id FROM '.$tbl.' ORDER BY id DESC LIMIT 1 ')); return $dane['id']; }
public function prepare($query, $arguments=array()) {
return $this->POLACZENIE->prepare($query,$arguments);
}
public function repair_tables() {
$sql=$this->query(' SHOW TABLES ');
while($fetch=$this->far($sql)) $tables[]=$fetch[0];
if(count($tables)==0) return false;
$this->query(' REPAIR TABLE '.@implode(',', $tables).' ');
}
public function mysql_real_escape_string($string)
{
return $this->POLACZENIE->quote($string);
}
public function optimize_tables() {
$sql=$this->query(' SHOW TABLES ');
while($fetch=$this->far($sql)) $tables[]=$fetch[0];
if(count($tables)==0) return false;
$this->query(' OPTIMIZE TABLE '.@implode(',', $tables).' ');
}
//aliases
public function q($query) { return $this->query($query); }
public function fa($sql) { return $this->fetch_assoc($sql); }
public function far($sql) { return $this->fetch_array($sql); }
public function fo($sql) { return $this->fetch_object($sql); }
public function nr($sql) { return $this->num_rows($sql); }
public function nc($sql) { return $this->num_cols($sql); }
public function ar() { return $this->affected_rows(); }
public function ii($table) { return $this->inserted_id($table); }
public function ls($table) { return $this->list_fields($table); }
public function lf($table, $ext=false) { return $this->list_fields($table,$ext); }
public function walk($query) {
$sql=$this->query($query);
$num_rows=$this->num_rows($sql);
while($fetch=$this->fa($sql)) $rows[]=$fetch;
if($num_rows==0) return array();
return $rows;
}
public function get_array($query) {
$sql=$this->query($query);
$num_rows=$this->num_rows($sql);
while($fetch=$this->far($sql)) $rows[]=$fetch[0];
if($num_rows==0) return false;
return $rows;
}
public function get_twin_array($query) {
$sql=$this->query($query);
$num_rows=$this->num_rows($sql);
while($fetch=$this->far($sql)) $rows[$fetch[0]]=$fetch[1];
if($num_rows==0) return array();
return $rows;
}
public function single($query) {
$sql=$this->query($query);
$dane=$this->fetch_array($sql);
if($this->num_cols($sql)==1) {
return $dane[0];
} else {
return $dane;
}
}
public function db_update_array() {
for($i=0;$iDB = new cs_db();
$this->DB->_PATH = C_PATH.'/'.cs_db;
$this->DB->PATH = C_PATH.'/'.cs_db;
$this->DB->_DIR = C_DIR.'/'.cs_db;
$this->DB->DIR = C_DIR.'/'.cs_db;
?>
Fatal error: Call to a member function query() on a non-object in /components/load.php on line 184