| | |
| | | |
| | | var $a_query_results = array('dummy'); |
| | | var $last_res_id = 0; |
| | | |
| | | private $tables; |
| | | |
| | | |
| | | /** |
| | |
| | | if (!filesize($dsn_array['database']) && !empty($this->sqlite_initials)) |
| | | $this->_sqlite_create_database($dbh, $this->sqlite_initials); |
| | | } |
| | | else if ($this->db_provider!='mssql') |
| | | else if ($this->db_provider!='mssql' && $this->db_provider!='sqlsrv') |
| | | $dbh->setCharset('utf8'); |
| | | |
| | | return $dbh; |
| | |
| | | $result = $this->db_handle->setLimit($numrows,$offset); |
| | | |
| | | if (empty($params)) |
| | | $result = $this->db_handle->query($query); |
| | | $result = $mode=='r' ? $this->db_handle->query($query) : $this->db_handle->exec($query); |
| | | else |
| | | { |
| | | $params = (array)$params; |
| | | $q = $this->db_handle->prepare($query); |
| | | $q = $this->db_handle->prepare($query, null, $mode=='w' ? MDB2_PREPARE_MANIP : null); |
| | | if ($this->db_handle->isError($q)) |
| | | { |
| | | $this->db_error = TRUE; |
| | | $this->db_error_msg = $q->userinfo; |
| | | |
| | | raise_error(array('code' => 500, 'type' => 'db', 'line' => __LINE__, 'file' => __FILE__, |
| | | 'message' => $this->db_error_msg), TRUE, TRUE); |
| | | raise_error(array('code' => 500, 'type' => 'db', |
| | | 'line' => __LINE__, 'file' => __FILE__, |
| | | 'message' => $this->db_error_msg), TRUE, TRUE); |
| | | } |
| | | else |
| | | { |
| | |
| | | * Get last inserted record ID |
| | | * For Postgres databases, a sequence name is required |
| | | * |
| | | * @param string Sequence name for increment |
| | | * @param string Table name (to find the incremented sequence) |
| | | * @return mixed ID or FALSE on failure |
| | | * @access public |
| | | */ |
| | | function insert_id($sequence = '') |
| | | function insert_id($table = '') |
| | | { |
| | | if (!$this->db_handle || $this->db_mode=='r') |
| | | return FALSE; |
| | | |
| | | $id = $this->db_handle->lastInsertID($sequence); |
| | | if ($table) { |
| | | if ($this->db_provider == 'pgsql') |
| | | // find sequence name |
| | | $table = get_sequence_name($table); |
| | | else |
| | | // resolve table name |
| | | $table = get_table_name($table); |
| | | } |
| | | |
| | | $id = $this->db_handle->lastInsertID($table); |
| | | |
| | | return $this->db_handle->isError($id) ? null : $id; |
| | | } |
| | |
| | | |
| | | return $result->fetchRow($mode); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * Wrapper for the SHOW TABLES command |
| | | * |
| | | * @return array List of all tables of the current database |
| | | */ |
| | | function list_tables() |
| | | { |
| | | // get tables if not cached |
| | | if (!$this->tables) { |
| | | $this->db_handle->loadModule('Manager'); |
| | | if (!PEAR::isError($result = $this->db_handle->listTables())) |
| | | $this->tables = $result; |
| | | else |
| | | $this->tables = array(); |
| | | } |
| | | |
| | | return $this->tables; |
| | | } |
| | | |
| | | |
| | | /** |
| | |
| | | switch($this->db_provider) |
| | | { |
| | | case 'mssql': |
| | | case 'sqlsrv': |
| | | return "getdate()"; |
| | | |
| | | default: |
| | |
| | | break; |
| | | |
| | | case 'mssql': |
| | | case 'sqlsrv': |
| | | return "DATEDIFF(second, '19700101', $field) + DATEDIFF(second, GETDATE(), GETUTCDATE())"; |
| | | |
| | | default: |
| | |
| | | { |
| | | $this->db_error = TRUE; |
| | | $this->db_error_msg = $res->getMessage(); |
| | | raise_error(array('code' => 500, 'type' => 'db', 'line' => __LINE__, 'file' => __FILE__, |
| | | raise_error(array('code' => 500, 'type' => 'db', |
| | | 'line' => __LINE__, 'file' => __FILE__, |
| | | 'message' => $res->getMessage() . " Query: " |
| | | . substr(preg_replace('/[\r\n]+\s*/', ' ', $res->userinfo), 0, 512)), |
| | | TRUE, FALSE); |