| | |
|---|
| | | var $dbName = ''; // logical database name on that server |
|---|
| | | var $dbUser = ''; // database authorized user |
|---|
| | | var $dbPass = ''; // user's password |
|---|
| | | var $dbCharset = 'utf8';// Database charset |
|---|
| | | var $dbNewLink = false; // Return a new linkID when connect is called again |
|---|
| | | var $dbClientFlags = 0; // MySQL Client falgs |
|---|
| | | var $linkId = 0; // last result of mysql_connect() |
|---|
| | | var $queryId = 0; // last result of mysql_query() |
|---|
| | | var $record = array(); // last record fetched |
|---|
| | |
|---|
| | | var $show_error_messages = true; |
|---|
| | | |
|---|
| | | // constructor |
|---|
| | | function db() |
|---|
| | | { |
|---|
| | | public function __construct() { |
|---|
| | | |
|---|
| | | global $conf; |
|---|
| | | $this->dbHost = $conf['db_host']; |
|---|
| | |
|---|
| | | $this->dbUser = $conf['db_user']; |
|---|
| | | $this->dbPass = $conf['db_password']; |
|---|
| | | $this->dbCharset = $conf['db_charset']; |
|---|
| | | $this->dbNewLink = $conf['db_new_link']; |
|---|
| | | $this->dbClientFlags = $conf['db_client_flags']; |
|---|
| | | //$this->connect(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | public function __destruct() { |
|---|
| | | $this->closeConn(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // error handler |
|---|
| | | function updateError($location) |
|---|
| | | { |
|---|
| | | global $app; |
|---|
| | | $this->errorNumber = mysql_errno($this->linkId); |
|---|
| | | $this->errorMessage = mysql_error($this->linkId); |
|---|
| | | $this->errorNumber = @mysql_errno($this->linkId); |
|---|
| | | $this->errorMessage = @mysql_error($this->linkId); |
|---|
| | | $this->errorLocation = $location; |
|---|
| | | if($this->errorNumber && $this->show_error_messages && method_exists($app,'log')) |
|---|
| | | { |
|---|
| | |
|---|
| | | { |
|---|
| | | if($this->linkId == 0) |
|---|
| | | { |
|---|
| | | $this->linkId = mysql_connect($this->dbHost, $this->dbUser, $this->dbPass); |
|---|
| | | $this->linkId = @mysql_connect($this->dbHost, $this->dbUser, $this->dbPass, $this->dbNewLink, $this->dbClientFlags); |
|---|
| | | if(!$this->linkId) |
|---|
| | | { |
|---|
| | | $this->updateError('DB::connect()-> mysql_connect'); |
|---|
| | |
|---|
| | | //print_r($diff_num); |
|---|
| | | //print_r($diffrec_full); |
|---|
| | | $diffstr = $app->db->quote(serialize($diffrec_full)); |
|---|
| | | $username = $app->db->quote($_SESSION['s']['user']['username']); |
|---|
| | | if(isset($_SESSION)) { |
|---|
| | | $username = $app->db->quote($_SESSION['s']['user']['username']); |
|---|
| | | } else { |
|---|
| | | $username = 'admin'; |
|---|
| | | } |
|---|
| | | $dbidx = $primary_field.':'.$primary_id; |
|---|
| | | |
|---|
| | | if($action == 'INSERT') $action = 'i'; |
|---|
| | |
|---|
| | | return $this->query($sql); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // gibt Array mit Tabellennamen zurück |
|---|
| | | // gibt Array mit Tabellennamen zur�ck |
|---|
| | | function getTables($database_name = '') { |
|---|
| | | |
|---|
| | | if($database_name == '') $database_name = $this->dbName; |
|---|
| | |
|---|
| | | return $tb_names; |
|---|
| | | } |
|---|
| | | |
|---|
| | | // gibt Feldinformationen zur Tabelle zurück |
|---|
| | | // gibt Feldinformationen zur Tabelle zur�ck |
|---|
| | | /* |
|---|
| | | $columns = array(action => add | alter | drop |
|---|
| | | name => Spaltenname |
|---|
