?? sybase.php
字號:
} // }}} // {{{ affectedRows() /** * Gets the number of rows affected by the data manipulation * query. For other queries, this function returns 0. * * @return number of rows affected by the last query */ function affectedRows() { if (DB::isManip($this->last_query)) { $result = @sybase_affected_rows($this->connection); } else { $result = 0; } return $result; } // }}} // {{{ nextId() /** * Returns the next free id in a sequence * * @param string $seq_name name of the sequence * @param boolean $ondemand when true, the seqence is automatically * created if it does not exist * * @return int the next id number in the sequence. DB_Error if problem. * * @internal * @see DB_common::nextID() * @access public */ function nextId($seq_name, $ondemand = true) { $seqname = $this->getSequenceName($seq_name); if (!@sybase_select_db($this->_db, $this->connection)) { return $this->sybaseRaiseError(DB_ERROR_NODBSELECTED); } $repeat = 0; do { $this->pushErrorHandling(PEAR_ERROR_RETURN); $result = $this->query("INSERT INTO $seqname (vapor) VALUES (0)"); $this->popErrorHandling(); if ($ondemand && DB::isError($result) && ($result->getCode() == DB_ERROR || $result->getCode() == DB_ERROR_NOSUCHTABLE)) { $repeat = 1; $result = $this->createSequence($seq_name); if (DB::isError($result)) { return $this->raiseError($result); } } elseif (!DB::isError($result)) { $result =& $this->query("SELECT @@IDENTITY FROM $seqname"); $repeat = 0; } else { $repeat = false; } } while ($repeat); if (DB::isError($result)) { return $this->raiseError($result); } $result = $result->fetchRow(DB_FETCHMODE_ORDERED); return $result[0]; } /** * Creates a new sequence * * @param string $seq_name name of the new sequence * * @return int DB_OK on success. A DB_Error object is returned if * problems arise. * * @internal * @see DB_common::createSequence() * @access public */ function createSequence($seq_name) { $seqname = $this->getSequenceName($seq_name); return $this->query("CREATE TABLE $seqname ". '(id numeric(10,0) IDENTITY NOT NULL ,' . 'vapor int NULL)'); } // }}} // {{{ dropSequence() /** * Deletes a sequence * * @param string $seq_name name of the sequence to be deleted * * @return int DB_OK on success. DB_Error if problems. * * @internal * @see DB_common::dropSequence() * @access public */ function dropSequence($seq_name) { $seqname = $this->getSequenceName($seq_name); return $this->query("DROP TABLE $seqname"); } // }}} // {{{ getSpecialQuery() /** * Returns the query needed to get some backend info * @param string $type What kind of info you want to retrieve * @return string The SQL query string */ function getSpecialQuery($type) { switch ($type) { case 'tables': return "select name from sysobjects where type = 'U' order by name"; case 'views': return "select name from sysobjects where type = 'V'"; default: return null; } } // }}} // {{{ autoCommit() /** * Enable/disable automatic commits */ function autoCommit($onoff = false) { // XXX if $this->transaction_opcount > 0, we should probably // issue a warning here. $this->autocommit = $onoff ? true : false; return DB_OK; } // }}} // {{{ commit() /** * Commit the current transaction. */ function commit() { if ($this->transaction_opcount > 0) { if (!@sybase_select_db($this->_db, $this->connection)) { return $this->sybaseRaiseError(DB_ERROR_NODBSELECTED); } $result = @sybase_query('COMMIT', $this->connection); $this->transaction_opcount = 0; if (!$result) { return $this->sybaseRaiseError(); } } return DB_OK; } // }}} // {{{ rollback() /** * Roll back (undo) the current transaction. */ function rollback() { if ($this->transaction_opcount > 0) { if (!@sybase_select_db($this->_db, $this->connection)) { return $this->sybaseRaiseError(DB_ERROR_NODBSELECTED); } $result = @sybase_query('ROLLBACK', $this->connection); $this->transaction_opcount = 0; if (!$result) { return $this->sybaseRaiseError(); } } return DB_OK; } // }}} // {{{ tableInfo() /** * Returns information about a table or a result set. * * NOTE: only supports 'table' and 'flags' if <var>$result</var> * is a table name. * * @param object|string $result DB_result object from a query or a * string containing the name of a table * @param int $mode a valid tableInfo mode * @return array an associative array with the information requested * or an error object if something is wrong * @access public * @internal * @since 1.6.0 * @see DB_common::tableInfo() */ function tableInfo($result, $mode = null) { if (isset($result->result)) { /* * Probably received a result object. * Extract the result resource identifier. */ $id = $result->result; $got_string = false; } elseif (is_string($result)) { /* * Probably received a table name. * Create a result resource identifier. */ if (!@sybase_select_db($this->_db, $this->connection)) { return $this->sybaseRaiseError(DB_ERROR_NODBSELECTED); } $id = @sybase_query("SELECT * FROM $result WHERE 1=0", $this->connection); $got_string = true; } else { /* * Probably received a result resource identifier. * Copy it. * Depricated. Here for compatibility only. */ $id = $result; $got_string = false; } if (!is_resource($id)) { return $this->sybaseRaiseError(DB_ERROR_NEED_MORE_DATA); } if ($this->options['portability'] & DB_PORTABILITY_LOWERCASE) { $case_func = 'strtolower'; } else { $case_func = 'strval'; } $count = @sybase_num_fields($id); // made this IF due to performance (one if is faster than $count if's) if (!$mode) { for ($i=0; $i<$count; $i++) { $f = @sybase_fetch_field($id, $i); // column_source is often blank if ($got_string) { $res[$i]['table'] = $case_func($result); } else { $res[$i]['table'] = $case_func($f->column_source); } $res[$i]['name'] = $case_func($f->name); $res[$i]['type'] = $f->type; $res[$i]['len'] = $f->max_length; if ($res[$i]['table']) { $res[$i]['flags'] = $this->_sybase_field_flags( $res[$i]['table'], $res[$i]['name']); } else { $res[$i]['flags'] = ''; } } } else { // get full info $res['num_fields'] = $count; for ($i=0; $i<$count; $i++) { $f = @sybase_fetch_field($id, $i); // column_source is often blank if ($got_string) { $res[$i]['table'] = $case_func($result); } else { $res[$i]['table'] = $case_func($f->column_source); } $res[$i]['name'] = $case_func($f->name); $res[$i]['type'] = $f->type; $res[$i]['len'] = $f->max_length; if ($res[$i]['table']) { $res[$i]['flags'] = $this->_sybase_field_flags( $res[$i]['table'], $res[$i]['name']); } else { $res[$i]['flags'] = ''; } if ($mode & DB_TABLEINFO_ORDER) { $res['order'][$res[$i]['name']] = $i; } if ($mode & DB_TABLEINFO_ORDERTABLE) { $res['ordertable'][$res[$i]['table']][$res[$i]['name']] = $i; } } } // free the result only if we were called on a table if ($got_string) { @sybase_free_result($id); } return $res; } // }}} // {{{ _sybase_field_flags() /** * Get the flags for a field. * * Currently supports: * + <samp>unique_key</samp> (unique index, unique check or primary_key) * + <samp>multiple_key</samp> (multi-key index) * * @param string $table table name * @param string $column field name * @return string space delimited string of flags. Empty string if none. * @access private */ function _sybase_field_flags($table, $column) { static $tableName = null; static $flags = array(); if ($table != $tableName) { $flags = array(); $tableName = $table; // get unique/primary keys $res = $this->getAll("sp_helpindex $table", DB_FETCHMODE_ASSOC); if (!isset($res[0]['index_description'])) { return ''; } foreach ($res as $val) { $keys = explode(', ', trim($val['index_keys'])); if (sizeof($keys) > 1) { foreach ($keys as $key) { $this->_add_flag($flags[$key], 'multiple_key'); } } if (strpos($val['index_description'], 'unique')) { foreach ($keys as $key) { $this->_add_flag($flags[$key], 'unique_key'); } } } } if (array_key_exists($column, $flags)) { return(implode(' ', $flags[$column])); } return ''; } // }}} // {{{ _add_flag() /** * Adds a string to the flags array if the flag is not yet in there * - if there is no flag present the array is created. * * @param array $array reference of flags array to add a value to * @param mixed $value value to add to the flag array * @access private */ function _add_flag(&$array, $value) { if (!is_array($array)) { $array = array($value); } elseif (!in_array($value, $array)) { array_push($array, $value); } } // }}} // {{{ quoteIdentifier() /** * Quote a string so it can be safely used as a table / column name * * Quoting style depends on which database driver is being used. * * @param string $str identifier name to be quoted * * @return string quoted identifier string * * @since 1.6.0 * @access public */ function quoteIdentifier($str) { return '[' . str_replace(']', ']]', $str) . ']'; } // }}}}/* * Local variables: * tab-width: 4 * c-basic-offset: 4 * End: */?>
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -