| | |
| | | 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 |
| | | { |
| | |
| | | if (!$this->db_handle || $this->db_mode=='r') |
| | | return FALSE; |
| | | |
| | | // find sequence name |
| | | if ($table && $this->db_provider == 'pgsql') |
| | | $table = get_sequence_name($table); |
| | | |
| | | 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; |
| | |
| | | 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); |