Viewing file: DBIDrizzle.class.php (21.94 KB) -rw-rw-rw- Select action/file-type: (+) | (+) | (+) | Code (+) | Session (+) | (+) | SDB (+) | (+) | (+) | (+) | (+) | (+) |
<?php /* vim: set expandtab sw=4 ts=4 sts=4: */ /** * Interface to the Drizzle extension * * WARNING - EXPERIMENTAL, never use in production, * drizzle module segfaults often and when you least expect it to * * TODO: This file and drizzle-wrappers.lib.php should be devoid * of any segault related hacks. * TODO: Crashing versions of drizzle module and/or libdrizzle * should be blacklisted * * @package PhpMyAdmin-DBI * @subpackage Drizzle */ if (! defined('PHPMYADMIN')) { exit; }
require_once './libraries/logging.lib.php'; require_once './libraries/dbi/drizzle-wrappers.lib.php'; require_once './libraries/dbi/DBIExtension.int.php';
/** * MySQL client API */ if (! defined('PMA_MYSQL_CLIENT_API')) { define('PMA_MYSQL_CLIENT_API', (int)drizzle_version()); }
/** * Interface to the Drizzle extension * * @package PhpMyAdmin-DBI * @subpackage Drizzle */ class PMA_DBI_Drizzle implements PMA_DBI_Extension { /** * Helper function for connecting to the database server * * @param PMA_Drizzle $drizzle connection handle * @param string $host Drizzle host * @param integer $port Drizzle port * @param string $uds server socket * @param string $user username * @param string $password password * @param string $db database name * @param integer $options connection options * * @return PMA_DrizzleCon */ private function _realConnect($drizzle, $host, $port, $uds, $user, $password, $db = null, $options = 0 ) { if ($uds) { $con = $drizzle->addUds($uds, $user, $password, $db, $options); } else { $con = $drizzle->addTcp($host, $port, $user, $password, $db, $options); }
return $con; }
/** * connects to the database server * * @param string $user drizzle user name * @param string $password drizzle user password * @param bool $is_controluser whether this is a control user connection * @param array $server host/port/socket/persistent * @param bool $auxiliary_connection (when true, don't go back to login if * connection fails) * * @return mixed false on error or a mysqli object on success */ public function connect($user, $password, $is_controluser = false, $server = null, $auxiliary_connection = false ) { global $cfg;
if ($server) { $server_port = (empty($server['port'])) ? false : (int)$server['port']; $server_socket = (empty($server['socket'])) ? '' : $server['socket']; $server['host'] = (empty($server['host'])) ? 'localhost' : $server['host']; } else { $server_port = (empty($cfg['Server']['port'])) ? false : (int) $cfg['Server']['port']; $server_socket = (empty($cfg['Server']['socket'])) ? null : $cfg['Server']['socket']; }
if (strtolower($GLOBALS['cfg']['Server']['connect_type']) == 'tcp') { $GLOBALS['cfg']['Server']['socket'] = ''; }
$drizzle = new PMA_Drizzle();
$client_flags = 0;
/* Optionally compress connection */ if ($GLOBALS['cfg']['Server']['compress']) { $client_flags |= DRIZZLE_CAPABILITIES_COMPRESS; }
/* Optionally enable SSL */ if ($GLOBALS['cfg']['Server']['ssl']) { $client_flags |= DRIZZLE_CAPABILITIES_SSL; }
if (! $server) { $link = @$this->_realConnect( $drizzle, $cfg['Server']['host'], $server_port, $server_socket, $user, $password, false, $client_flags ); // Retry with empty password if we're allowed to if ($link == false && isset($cfg['Server']['nopassword']) && $cfg['Server']['nopassword'] && ! $is_controluser ) { $link = @$this->_realConnect( $drizzle, $cfg['Server']['host'], $server_port, $server_socket, $user, null, false, $client_flags ); } } else { $link = @$this->_realConnect( $drizzle, $server['host'], $server_port, $server_socket, $user, $password ); }
if ($link != false) { $GLOBALS['dbi']->postConnect($link, $is_controluser); return $link; }
if ($is_controluser) { trigger_error( __( 'Connection for controluser as defined' . ' in your configuration failed.' ), E_USER_WARNING ); return false; } // we could be calling $GLOBALS['dbi']->connect() to connect to another // server, for example in the Synchronize feature, so do not // go back to main login if it fails if ($auxiliary_connection) { return false; }
PMA_logUser($user, 'drizzle-denied'); global $auth_plugin; $auth_plugin->authFails();
return $link; }
/** * selects given database * * @param string $dbname database name to select * @param PMA_DrizzleCom $link connection object * * @return bool */ public function selectDb($dbname, $link = null) { if (empty($link)) { if (isset($GLOBALS['userlink'])) { $link = $GLOBALS['userlink']; } else { return false; } } return $link->selectDb($dbname); }
/** * runs a query and returns the result * * @param string $query query to execute * @param PMA_DrizzleCon $link connection object * @param int $options query options * * @return PMA_DrizzleResult */ public function realQuery($query, $link, $options) { $buffer_mode = $options & PMA_DatabaseInterface::QUERY_UNBUFFERED ? PMA_Drizzle::BUFFER_ROW : PMA_Drizzle::BUFFER_RESULT; $res = $link->query($query, $buffer_mode); return $res; }
/** * Run the multi query and output the results * * @param object $link connection object * @param string $query multi query statement to execute * * @return result collection | boolean(false) */ public function realMultiQuery($link, $query) { return false; }
/** * returns array of rows with associative and numeric keys from $result * * @param PMA_DrizzleResult $result Drizzle result object * * @return array */ public function fetchArray($result) { return $result->fetchRow(PMA_Drizzle::FETCH_BOTH); }
/** * returns array of rows with associative keys from $result * * @param PMA_DrizzleResult $result Drizzle result object * * @return array */ public function fetchAssoc($result) { return $result->fetchRow(PMA_Drizzle::FETCH_ASSOC); }
/** * returns array of rows with numeric keys from $result * * @param PMA_DrizzleResult $result Drizzle result object * * @return array */ public function fetchRow($result) { return $result->fetchRow(PMA_Drizzle::FETCH_NUM); }
/** * Adjusts the result pointer to an arbitrary row in the result * * @param PMA_DrizzleResult $result Drizzle result object * @param int $offset offset to seek * * @return boolean true on success, false on failure */ public function dataSeek($result, $offset) { return $result->seek($offset); }
/** * Frees memory associated with the result * * @param PMA_DrizzleResult $result database result * * @return void */ public function freeResult($result) { if ($result instanceof PMA_DrizzleResult) { $result->free(); } }
/** * Check if there are any more query results from a multi query * * @param object $link the connection object * * @return bool false */ public function moreResults($link = null) { // N.B.: PHP's 'mysql' extension does not support // multi_queries so this function will always // return false. Use the 'mysqli' extension, if // you need support for multi_queries. return false; }
/** * Prepare next result from multi_query * * @param object $link the connection object * * @return bool false */ public function nextResult($link = null) { // N.B.: PHP's 'mysql' extension does not support // multi_queries so this function will always // return false. Use the 'mysqli' extension, if // you need support for multi_queries. return false; }
/** * Returns a string representing the type of connection used * * @param PMA_DrizzleCon $link connection object * * @return string type of connection used */ public function getHostInfo($link = null) { if (null === $link) { if (isset($GLOBALS['userlink'])) { $link = $GLOBALS['userlink']; } else { return false; } }
$str = $link->port() ? $link->host() . ':' . $link->port() . ' via TCP/IP' : 'Localhost via UNIX socket'; return $str; }
/** * Returns the version of the Drizzle protocol used * * @param PMA_DrizzleCon $link connection object * * @return int version of the Drizzle protocol used */ public function getProtoInfo($link = null) { if (null === $link) { if (isset($GLOBALS['userlink'])) { $link = $GLOBALS['userlink']; } else { return false; } }
return $link->protocolVersion(); }
/** * returns a string that represents the client library version * * @return string Drizzle client library version */ public function getClientInfo() { return 'libdrizzle (Drizzle ' . drizzle_version() . ')'; }
/** * returns last error message or false if no errors occurred * * @param PMA_DrizzleCon $link connection object * * @return string|bool $error or false */ public function getError($link = null) { $GLOBALS['errno'] = 0;
/* Treat false same as null because of controllink */ if ($link === false) { $link = null; }
if (null === $link && isset($GLOBALS['userlink'])) { $link =& $GLOBALS['userlink']; // Do not stop now. We still can get the error code // with mysqli_connect_errno() // } else { // return false; }
if (null !== $link) { $error_number = drizzle_con_errno($link->getConnectionObject()); $error_message = drizzle_con_error($link->getConnectionObject()); } else { $error_number = drizzle_errno(); $error_message = drizzle_error(); } if (0 == $error_number) { return false; }
// keep the error number for further check after // the call to getError() $GLOBALS['errno'] = $error_number;
return $GLOBALS['dbi']->formatError($error_number, $error_message); }
/** * returns the number of rows returned by last query * * @param PMA_DrizzleResult $result Drizzle result object * * @return string|int */ public function numRows($result) { // see the note for $GLOBALS['dbi']->tryQuery(); if (!is_bool($result)) { return @$result->numRows(); } else { return 0; } }
/** * returns last inserted auto_increment id for given $link * or $GLOBALS['userlink'] * * @param PMA_DrizzleCon $link connection object * * @return string|int */ public function insertId($link = null) { if (empty($link)) { if (isset($GLOBALS['userlink'])) { $link = $GLOBALS['userlink']; } else { return false; } }
// copied from mysql and mysqli
// When no controluser is defined, using mysqli_insert_id($link) // does not always return the last insert id due to a mixup with // the tracking mechanism, but this works: return $GLOBALS['dbi']->fetchValue('SELECT LAST_INSERT_ID();', 0, 0, $link); // Curiously, this problem does not happen with the mysql extension but // there is another problem with BIGINT primary keys so insertId() // in the mysql extension also uses this logic. }
/** * returns the number of rows affected by last query * * @param PMA_DrizzleResult $link connection object * @param bool $get_from_cache whether to retrieve from cache * * @return string|int */ public function affectedRows($link = null, $get_from_cache = true) { if (empty($link)) { if (isset($GLOBALS['userlink'])) { $link = $GLOBALS['userlink']; } else { return false; } } if ($get_from_cache) { return $GLOBALS['cached_affected_rows']; } else { return $link->affectedRows(); } }
/** * returns metainfo for fields in $result * * @param PMA_DrizzleResult $result Drizzle result object * * @return array meta info for fields in $result */ public function getFieldsMeta($result) { // Build an associative array for a type look up $typeAr = array(); /*$typeAr[DRIZZLE_COLUMN_TYPE_DECIMAL] = 'real'; $typeAr[DRIZZLE_COLUMN_TYPE_NEWDECIMAL] = 'real'; $typeAr[DRIZZLE_COLUMN_TYPE_BIT] = 'int'; $typeAr[DRIZZLE_COLUMN_TYPE_TINY] = 'int'; $typeAr[DRIZZLE_COLUMN_TYPE_SHORT] = 'int'; $typeAr[DRIZZLE_COLUMN_TYPE_LONG] = 'int'; $typeAr[DRIZZLE_COLUMN_TYPE_FLOAT] = 'real'; $typeAr[DRIZZLE_COLUMN_TYPE_DOUBLE] = 'real'; $typeAr[DRIZZLE_COLUMN_TYPE_NULL] = 'null'; $typeAr[DRIZZLE_COLUMN_TYPE_TIMESTAMP] = 'timestamp'; $typeAr[DRIZZLE_COLUMN_TYPE_LONGLONG] = 'int'; $typeAr[DRIZZLE_COLUMN_TYPE_INT24] = 'int'; $typeAr[DRIZZLE_COLUMN_TYPE_DATE] = 'date'; $typeAr[DRIZZLE_COLUMN_TYPE_TIME] = 'date'; $typeAr[DRIZZLE_COLUMN_TYPE_DATETIME] = 'datetime'; $typeAr[DRIZZLE_COLUMN_TYPE_YEAR] = 'year'; $typeAr[DRIZZLE_COLUMN_TYPE_NEWDATE] = 'date'; $typeAr[DRIZZLE_COLUMN_TYPE_ENUM] = 'unknown'; $typeAr[DRIZZLE_COLUMN_TYPE_SET] = 'unknown'; $typeAr[DRIZZLE_COLUMN_TYPE_VIRTUAL] = 'unknown'; $typeAr[DRIZZLE_COLUMN_TYPE_TINY_BLOB] = 'blob'; $typeAr[DRIZZLE_COLUMN_TYPE_MEDIUM_BLOB] = 'blob'; $typeAr[DRIZZLE_COLUMN_TYPE_LONG_BLOB] = 'blob'; $typeAr[DRIZZLE_COLUMN_TYPE_BLOB] = 'blob'; $typeAr[DRIZZLE_COLUMN_TYPE_VAR_STRING] = 'string'; $typeAr[DRIZZLE_COLUMN_TYPE_VARCHAR] = 'string'; $typeAr[DRIZZLE_COLUMN_TYPE_STRING] = 'string'; $typeAr[DRIZZLE_COLUMN_TYPE_GEOMETRY] = 'geometry';*/
$typeAr[DRIZZLE_COLUMN_TYPE_DRIZZLE_BLOB] = 'blob'; $typeAr[DRIZZLE_COLUMN_TYPE_DRIZZLE_DATE] = 'date'; $typeAr[DRIZZLE_COLUMN_TYPE_DRIZZLE_DATETIME] = 'datetime'; $typeAr[DRIZZLE_COLUMN_TYPE_DRIZZLE_DOUBLE] = 'real'; $typeAr[DRIZZLE_COLUMN_TYPE_DRIZZLE_ENUM] = 'unknown'; $typeAr[DRIZZLE_COLUMN_TYPE_DRIZZLE_LONG] = 'int'; $typeAr[DRIZZLE_COLUMN_TYPE_DRIZZLE_LONGLONG] = 'int'; $typeAr[DRIZZLE_COLUMN_TYPE_DRIZZLE_MAX] = 'unknown'; $typeAr[DRIZZLE_COLUMN_TYPE_DRIZZLE_NULL] = 'null'; $typeAr[DRIZZLE_COLUMN_TYPE_DRIZZLE_TIMESTAMP] = 'timestamp'; $typeAr[DRIZZLE_COLUMN_TYPE_DRIZZLE_TINY] = 'int'; $typeAr[DRIZZLE_COLUMN_TYPE_DRIZZLE_VARCHAR] = 'string';
// array of DrizzleColumn $columns = $result->getColumns(); // columns in a standarized format $std_columns = array();
foreach ($columns as $k => $column) { $c = new stdClass(); $c->name = $column->name(); $c->orgname = $column->origName(); $c->table = $column->table(); $c->orgtable = $column->origTable(); $c->def = $column->defaultValue(); $c->db = $column->db(); $c->catalog = $column->catalog(); // $column->maxSize() returns always 0 while size() seems // to return a correct value (drizzle extension v.0.5, API v.7) $c->max_length = $column->size(); $c->decimals = $column->decimals(); $c->charsetnr = $column->charset(); $c->type = $typeAr[$column->typeDrizzle()]; $c->_type = $column->type(); $c->flags = $this->fieldFlags($result, $k); $c->_flags = $column->flags();
$c->multiple_key = (int) (bool) ( $c->_flags & DRIZZLE_COLUMN_FLAGS_MULTIPLE_KEY ); $c->primary_key = (int) (bool) ( $c->_flags & DRIZZLE_COLUMN_FLAGS_PRI_KEY ); $c->unique_key = (int) (bool) ( $c->_flags & DRIZZLE_COLUMN_FLAGS_UNIQUE_KEY ); $c->not_null = (int) (bool) ( $c->_flags & DRIZZLE_COLUMN_FLAGS_NOT_NULL ); $c->unsigned = (int) (bool) ( $c->_flags & DRIZZLE_COLUMN_FLAGS_UNSIGNED ); $c->zerofill = (int) (bool) ( $c->_flags & DRIZZLE_COLUMN_FLAGS_ZEROFILL ); $c->numeric = (int) (bool) ( $c->_flags & DRIZZLE_COLUMN_FLAGS_NUM ); $c->blob = (int) (bool) ( $c->_flags & DRIZZLE_COLUMN_FLAGS_BLOB );
$std_columns[] = $c; }
return $std_columns; }
/** * return number of fields in given $result * * @param PMA_DrizzleResult $result Drizzle result object * * @return int field count */ public function numFields($result) { return $result->numColumns(); }
/** * returns the length of the given field $i in $result * * @param PMA_DrizzleResult $result Drizzle result object * @param int $i field * * @return int length of field */ public function fieldLen($result, $i) { $colums = $result->getColumns(); return $colums[$i]->size(); }
/** * returns name of $i. field in $result * * @param PMA_DrizzleResult $result Drizzle result object * @param int $i field * * @return string name of $i. field in $result */ public function fieldName($result, $i) { $colums = $result->getColumns(); return $colums[$i]->name(); }
/** * returns concatenated string of human readable field flags * * @param PMA_DrizzleResult $result Drizzle result object * @param int $i field * * @return string field flags */ public function fieldFlags($result, $i) { $columns = $result->getColumns(); $f = $columns[$i]; $type = $f->typeDrizzle(); $charsetnr = $f->charset(); $f = $f->flags(); $flags = ''; if ($f & DRIZZLE_COLUMN_FLAGS_UNIQUE_KEY) { $flags .= 'unique '; } if ($f & DRIZZLE_COLUMN_FLAGS_NUM) { $flags .= 'num '; } if ($f & DRIZZLE_COLUMN_FLAGS_PART_KEY) { $flags .= 'part_key '; } if ($f & DRIZZLE_COLUMN_FLAGS_SET) { $flags .= 'set '; } if ($f & DRIZZLE_COLUMN_FLAGS_TIMESTAMP) { $flags .= 'timestamp '; } if ($f & DRIZZLE_COLUMN_FLAGS_AUTO_INCREMENT) { $flags .= 'auto_increment '; } if ($f & DRIZZLE_COLUMN_FLAGS_ENUM) { $flags .= 'enum '; } // See http://dev.mysql.com/doc/refman/6.0/en/c-api-datatypes.html: // to determine if a string is binary, we should not use MYSQLI_BINARY_FLAG // but instead the charsetnr member of the MYSQL_FIELD // structure. Watch out: some types like DATE returns 63 in charsetnr // so we have to check also the type. // Unfortunately there is no equivalent in the mysql extension. if (($type == DRIZZLE_COLUMN_TYPE_DRIZZLE_BLOB || $type == DRIZZLE_COLUMN_TYPE_DRIZZLE_VARCHAR) && 63 == $charsetnr ) { $flags .= 'binary '; } if ($f & DRIZZLE_COLUMN_FLAGS_ZEROFILL) { $flags .= 'zerofill '; } if ($f & DRIZZLE_COLUMN_FLAGS_UNSIGNED) { $flags .= 'unsigned '; } if ($f & DRIZZLE_COLUMN_FLAGS_BLOB) { $flags .= 'blob '; } if ($f & DRIZZLE_COLUMN_FLAGS_MULTIPLE_KEY) { $flags .= 'multiple_key '; } if ($f & DRIZZLE_COLUMN_FLAGS_UNIQUE_KEY) { $flags .= 'unique_key '; } if ($f & DRIZZLE_COLUMN_FLAGS_PRI_KEY) { $flags .= 'primary_key '; } if ($f & DRIZZLE_COLUMN_FLAGS_NOT_NULL) { $flags .= 'not_null '; } return trim($flags); }
/** * Store the result returned from multi query * * @return false */ public function storeResult() { return false; } } ?>
|