X-Git-Url: https://scripts.mit.edu/gitweb/autoinstallsdev/mediawiki.git/blobdiff_plain/19e297c21b10b1b8a3acad5e73fc71dcb35db44a..6932310fd58ebef145fa01eb76edf7150284d8ea:/includes/db/DatabasePostgres.php diff --git a/includes/db/DatabasePostgres.php b/includes/db/DatabasePostgres.php deleted file mode 100644 index bc71a9a5..00000000 --- a/includes/db/DatabasePostgres.php +++ /dev/null @@ -1,1019 +0,0 @@ -tableName( $table ); - $res = $db->query( - sprintf( $q, - $db->addQuotes( $wgDBmwschema ), - $db->addQuotes( $table ), - $db->addQuotes( $field ) - ) - ); - $row = $db->fetchObject( $res ); - if ( !$row ) { - return null; - } - $n = new PostgresField; - $n->type = $row->typname; - $n->nullable = ( $row->attnotnull == 'f' ); - $n->name = $field; - $n->tablename = $table; - $n->max_length = $row->attlen; - $n->deferrable = ( $row->deferrable == 't' ); - $n->deferred = ( $row->deferred == 't' ); - $n->conname = $row->conname; - return $n; - } - - function name() { - return $this->name; - } - - function tableName() { - return $this->tablename; - } - - function type() { - return $this->type; - } - - function isNullable() { - return $this->nullable; - } - - function maxLength() { - return $this->max_length; - } - - function is_deferrable() { - return $this->deferrable; - } - - function is_deferred() { - return $this->deferred; - } - - function conname() { - return $this->conname; - } - -} - -/** - * @ingroup Database - */ -class DatabasePostgres extends DatabaseBase { - var $mInsertId = null; - var $mLastResult = null; - var $numeric_version = null; - var $mAffectedRows = null; - - function getType() { - return 'postgres'; - } - - function cascadingDeletes() { - return true; - } - function cleanupTriggers() { - return true; - } - function strictIPs() { - return true; - } - function realTimestamps() { - return true; - } - function implicitGroupby() { - return false; - } - function implicitOrderby() { - return false; - } - function searchableIPs() { - return true; - } - function functionalIndexes() { - return true; - } - - function hasConstraint( $name ) { - global $wgDBmwschema; - $SQL = "SELECT 1 FROM pg_catalog.pg_constraint c, pg_catalog.pg_namespace n WHERE c.connamespace = n.oid AND conname = '" . - pg_escape_string( $this->mConn, $name ) . "' AND n.nspname = '" . pg_escape_string( $this->mConn, $wgDBmwschema ) ."'"; - $res = $this->doQuery( $SQL ); - return $this->numRows( $res ); - } - - static function newFromParams( $server, $user, $password, $dbName, $flags = 0 ) { - return new DatabasePostgres( $server, $user, $password, $dbName, $flags ); - } - - /** - * Usually aborts on failure - */ - function open( $server, $user, $password, $dbName ) { - # Test for Postgres support, to avoid suppressed fatal error - if ( !function_exists( 'pg_connect' ) ) { - throw new DBConnectionError( $this, "Postgres functions missing, have you compiled PHP with the --with-pgsql option?\n (Note: if you recently installed PHP, you may need to restart your webserver and database)\n" ); - } - - global $wgDBport; - - if ( !strlen( $user ) ) { # e.g. the class is being loaded - return; - } - $this->close(); - $this->mServer = $server; - $this->mPort = $port = $wgDBport; - $this->mUser = $user; - $this->mPassword = $password; - $this->mDBname = $dbName; - - $connectVars = array( - 'dbname' => $dbName, - 'user' => $user, - 'password' => $password - ); - if ( $server != false && $server != '' ) { - $connectVars['host'] = $server; - } - if ( $port != false && $port != '' ) { - $connectVars['port'] = $port; - } - $connectString = $this->makeConnectionString( $connectVars, PGSQL_CONNECT_FORCE_NEW ); - - $this->installErrorHandler(); - $this->mConn = pg_connect( $connectString ); - $phpError = $this->restoreErrorHandler(); - - if ( !$this->mConn ) { - wfDebug( "DB connection error\n" ); - wfDebug( "Server: $server, Database: $dbName, User: $user, Password: " . substr( $password, 0, 3 ) . "...\n" ); - wfDebug( $this->lastError() . "\n" ); - throw new DBConnectionError( $this, str_replace( "\n", ' ', $phpError ) ); - } - - $this->mOpened = true; - - global $wgCommandLineMode; - # If called from the command-line (e.g. importDump), only show errors - if ( $wgCommandLineMode ) { - $this->doQuery( "SET client_min_messages = 'ERROR'" ); - } - - $this->doQuery( "SET client_encoding='UTF8'" ); - - global $wgDBmwschema, $wgDBts2schema; - if ( isset( $wgDBmwschema ) && isset( $wgDBts2schema ) - && $wgDBmwschema !== 'mediawiki' - && preg_match( '/^\w+$/', $wgDBmwschema ) - && preg_match( '/^\w+$/', $wgDBts2schema ) - ) { - $safeschema = $this->addIdentifierQuotes( $wgDBmwschema ); - $this->doQuery( "SET search_path = $safeschema, $wgDBts2schema, public" ); - } - - return $this->mConn; - } - - function makeConnectionString( $vars ) { - $s = ''; - foreach ( $vars as $name => $value ) { - $s .= "$name='" . str_replace( "'", "\\'", $value ) . "' "; - } - return $s; - } - - /** - * Closes a database connection, if it is open - * Returns success, true if already closed - */ - function close() { - $this->mOpened = false; - if ( $this->mConn ) { - return pg_close( $this->mConn ); - } else { - return true; - } - } - - function doQuery( $sql ) { - if ( function_exists( 'mb_convert_encoding' ) ) { - $sql = mb_convert_encoding( $sql, 'UTF-8' ); - } - $this->mLastResult = pg_query( $this->mConn, $sql ); - $this->mAffectedRows = null; // use pg_affected_rows(mLastResult) - return $this->mLastResult; - } - - function queryIgnore( $sql, $fname = 'DatabasePostgres::queryIgnore' ) { - return $this->query( $sql, $fname, true ); - } - - function freeResult( $res ) { - if ( $res instanceof ResultWrapper ) { - $res = $res->result; - } - if ( !@pg_free_result( $res ) ) { - throw new DBUnexpectedError( $this, "Unable to free Postgres result\n" ); - } - } - - function fetchObject( $res ) { - if ( $res instanceof ResultWrapper ) { - $res = $res->result; - } - @$row = pg_fetch_object( $res ); - # FIXME: HACK HACK HACK HACK debug - - # TODO: - # hashar : not sure if the following test really trigger if the object - # fetching failed. - if( pg_last_error( $this->mConn ) ) { - throw new DBUnexpectedError( $this, 'SQL error: ' . htmlspecialchars( pg_last_error( $this->mConn ) ) ); - } - return $row; - } - - function fetchRow( $res ) { - if ( $res instanceof ResultWrapper ) { - $res = $res->result; - } - @$row = pg_fetch_array( $res ); - if( pg_last_error( $this->mConn ) ) { - throw new DBUnexpectedError( $this, 'SQL error: ' . htmlspecialchars( pg_last_error( $this->mConn ) ) ); - } - return $row; - } - - function numRows( $res ) { - if ( $res instanceof ResultWrapper ) { - $res = $res->result; - } - @$n = pg_num_rows( $res ); - if( pg_last_error( $this->mConn ) ) { - throw new DBUnexpectedError( $this, 'SQL error: ' . htmlspecialchars( pg_last_error( $this->mConn ) ) ); - } - return $n; - } - - function numFields( $res ) { - if ( $res instanceof ResultWrapper ) { - $res = $res->result; - } - return pg_num_fields( $res ); - } - - function fieldName( $res, $n ) { - if ( $res instanceof ResultWrapper ) { - $res = $res->result; - } - return pg_field_name( $res, $n ); - } - - /** - * This must be called after nextSequenceVal - */ - function insertId() { - return $this->mInsertId; - } - - function dataSeek( $res, $row ) { - if ( $res instanceof ResultWrapper ) { - $res = $res->result; - } - return pg_result_seek( $res, $row ); - } - - function lastError() { - if ( $this->mConn ) { - return pg_last_error(); - } else { - return 'No database connection'; - } - } - function lastErrno() { - return pg_last_error() ? 1 : 0; - } - - function affectedRows() { - if ( !is_null( $this->mAffectedRows ) ) { - // Forced result for simulated queries - return $this->mAffectedRows; - } - if( empty( $this->mLastResult ) ) { - return 0; - } - return pg_affected_rows( $this->mLastResult ); - } - - /** - * Estimate rows in dataset - * Returns estimated count, based on EXPLAIN output - * This is not necessarily an accurate estimate, so use sparingly - * Returns -1 if count cannot be found - * Takes same arguments as Database::select() - */ - function estimateRowCount( $table, $vars = '*', $conds='', $fname = 'DatabasePostgres::estimateRowCount', $options = array() ) { - $options['EXPLAIN'] = true; - $res = $this->select( $table, $vars, $conds, $fname, $options ); - $rows = -1; - if ( $res ) { - $row = $this->fetchRow( $res ); - $count = array(); - if( preg_match( '/rows=(\d+)/', $row[0], $count ) ) { - $rows = $count[1]; - } - } - return $rows; - } - - /** - * Returns information about an index - * If errors are explicitly ignored, returns NULL on failure - */ - function indexInfo( $table, $index, $fname = 'DatabasePostgres::indexInfo' ) { - $sql = "SELECT indexname FROM pg_indexes WHERE tablename='$table'"; - $res = $this->query( $sql, $fname ); - if ( !$res ) { - return null; - } - foreach ( $res as $row ) { - if ( $row->indexname == $this->indexName( $index ) ) { - return $row; - } - } - return false; - } - - function indexUnique( $table, $index, $fname = 'DatabasePostgres::indexUnique' ) { - $sql = "SELECT indexname FROM pg_indexes WHERE tablename='{$table}'". - " AND indexdef LIKE 'CREATE UNIQUE%(" . - $this->strencode( $this->indexName( $index ) ) . - ")'"; - $res = $this->query( $sql, $fname ); - if ( !$res ) { - return null; - } - foreach ( $res as $row ) { - return true; - } - return false; - } - - /** - * INSERT wrapper, inserts an array into a table - * - * $args may be a single associative array, or an array of these with numeric keys, - * for multi-row insert (Postgres version 8.2 and above only). - * - * @param $table String: Name of the table to insert to. - * @param $args Array: Items to insert into the table. - * @param $fname String: Name of the function, for profiling - * @param $options String or Array. Valid options: IGNORE - * - * @return bool Success of insert operation. IGNORE always returns true. - */ - function insert( $table, $args, $fname = 'DatabasePostgres::insert', $options = array() ) { - if ( !count( $args ) ) { - return true; - } - - $table = $this->tableName( $table ); - if (! isset( $this->numeric_version ) ) { - $this->getServerVersion(); - } - - if ( !is_array( $options ) ) { - $options = array( $options ); - } - - if ( isset( $args[0] ) && is_array( $args[0] ) ) { - $multi = true; - $keys = array_keys( $args[0] ); - } else { - $multi = false; - $keys = array_keys( $args ); - } - - // If IGNORE is set, we use savepoints to emulate mysql's behavior - $ignore = in_array( 'IGNORE', $options ) ? 'mw' : ''; - - // If we are not in a transaction, we need to be for savepoint trickery - $didbegin = 0; - if ( $ignore ) { - if ( !$this->mTrxLevel ) { - $this->begin(); - $didbegin = 1; - } - $olde = error_reporting( 0 ); - // For future use, we may want to track the number of actual inserts - // Right now, insert (all writes) simply return true/false - $numrowsinserted = 0; - } - - $sql = "INSERT INTO $table (" . implode( ',', $keys ) . ') VALUES '; - - if ( $multi ) { - if ( $this->numeric_version >= 8.2 && !$ignore ) { - $first = true; - foreach ( $args as $row ) { - if ( $first ) { - $first = false; - } else { - $sql .= ','; - } - $sql .= '(' . $this->makeList( $row ) . ')'; - } - $res = (bool)$this->query( $sql, $fname, $ignore ); - } else { - $res = true; - $origsql = $sql; - foreach ( $args as $row ) { - $tempsql = $origsql; - $tempsql .= '(' . $this->makeList( $row ) . ')'; - - if ( $ignore ) { - pg_query( $this->mConn, "SAVEPOINT $ignore" ); - } - - $tempres = (bool)$this->query( $tempsql, $fname, $ignore ); - - if ( $ignore ) { - $bar = pg_last_error(); - if ( $bar != false ) { - pg_query( $this->mConn, "ROLLBACK TO $ignore" ); - } else { - pg_query( $this->mConn, "RELEASE $ignore" ); - $numrowsinserted++; - } - } - - // If any of them fail, we fail overall for this function call - // Note that this will be ignored if IGNORE is set - if ( !$tempres ) { - $res = false; - } - } - } - } else { - // Not multi, just a lone insert - if ( $ignore ) { - pg_query($this->mConn, "SAVEPOINT $ignore"); - } - - $sql .= '(' . $this->makeList( $args ) . ')'; - $res = (bool)$this->query( $sql, $fname, $ignore ); - if ( $ignore ) { - $bar = pg_last_error(); - if ( $bar != false ) { - pg_query( $this->mConn, "ROLLBACK TO $ignore" ); - } else { - pg_query( $this->mConn, "RELEASE $ignore" ); - $numrowsinserted++; - } - } - } - if ( $ignore ) { - $olde = error_reporting( $olde ); - if ( $didbegin ) { - $this->commit(); - } - - // Set the affected row count for the whole operation - $this->mAffectedRows = $numrowsinserted; - - // IGNORE always returns true - return true; - } - - return $res; - } - - /** - * INSERT SELECT wrapper - * $varMap must be an associative array of the form array( 'dest1' => 'source1', ...) - * Source items may be literals rather then field names, but strings should be quoted with Database::addQuotes() - * $conds may be "*" to copy the whole table - * srcTable may be an array of tables. - * @todo FIXME: implement this a little better (seperate select/insert)? - */ - function insertSelect( $destTable, $srcTable, $varMap, $conds, $fname = 'DatabasePostgres::insertSelect', - $insertOptions = array(), $selectOptions = array() ) - { - $destTable = $this->tableName( $destTable ); - - // If IGNORE is set, we use savepoints to emulate mysql's behavior - $ignore = in_array( 'IGNORE', $insertOptions ) ? 'mw' : ''; - - if( is_array( $insertOptions ) ) { - $insertOptions = implode( ' ', $insertOptions ); - } - if( !is_array( $selectOptions ) ) { - $selectOptions = array( $selectOptions ); - } - list( $startOpts, $useIndex, $tailOpts ) = $this->makeSelectOptions( $selectOptions ); - if( is_array( $srcTable ) ) { - $srcTable = implode( ',', array_map( array( &$this, 'tableName' ), $srcTable ) ); - } else { - $srcTable = $this->tableName( $srcTable ); - } - - // If we are not in a transaction, we need to be for savepoint trickery - $didbegin = 0; - if ( $ignore ) { - if( !$this->mTrxLevel ) { - $this->begin(); - $didbegin = 1; - } - $olde = error_reporting( 0 ); - $numrowsinserted = 0; - pg_query( $this->mConn, "SAVEPOINT $ignore"); - } - - $sql = "INSERT INTO $destTable (" . implode( ',', array_keys( $varMap ) ) . ')' . - " SELECT $startOpts " . implode( ',', $varMap ) . - " FROM $srcTable $useIndex"; - - if ( $conds != '*' ) { - $sql .= ' WHERE ' . $this->makeList( $conds, LIST_AND ); - } - - $sql .= " $tailOpts"; - - $res = (bool)$this->query( $sql, $fname, $ignore ); - if( $ignore ) { - $bar = pg_last_error(); - if( $bar != false ) { - pg_query( $this->mConn, "ROLLBACK TO $ignore" ); - } else { - pg_query( $this->mConn, "RELEASE $ignore" ); - $numrowsinserted++; - } - $olde = error_reporting( $olde ); - if( $didbegin ) { - $this->commit(); - } - - // Set the affected row count for the whole operation - $this->mAffectedRows = $numrowsinserted; - - // IGNORE always returns true - return true; - } - - return $res; - } - - function tableName( $name ) { - # Replace reserved words with better ones - switch( $name ) { - case 'user': - return 'mwuser'; - case 'text': - return 'pagecontent'; - default: - return $name; - } - } - - /** - * Return the next in a sequence, save the value for retrieval via insertId() - */ - function nextSequenceValue( $seqName ) { - $safeseq = str_replace( "'", "''", $seqName ); - $res = $this->query( "SELECT nextval('$safeseq')" ); - $row = $this->fetchRow( $res ); - $this->mInsertId = $row[0]; - return $this->mInsertId; - } - - /** - * Return the current value of a sequence. Assumes it has been nextval'ed in this session. - */ - function currentSequenceValue( $seqName ) { - $safeseq = str_replace( "'", "''", $seqName ); - $res = $this->query( "SELECT currval('$safeseq')" ); - $row = $this->fetchRow( $res ); - $currval = $row[0]; - return $currval; - } - - /** - * REPLACE query wrapper - * Postgres simulates this with a DELETE followed by INSERT - * $row is the row to insert, an associative array - * $uniqueIndexes is an array of indexes. Each element may be either a - * field name or an array of field names - * - * It may be more efficient to leave off unique indexes which are unlikely to collide. - * However if you do this, you run the risk of encountering errors which wouldn't have - * occurred in MySQL - */ - function replace( $table, $uniqueIndexes, $rows, $fname = 'DatabasePostgres::replace' ) { - $table = $this->tableName( $table ); - - if ( count( $rows ) == 0 ) { - return; - } - - # Single row case - if ( !is_array( reset( $rows ) ) ) { - $rows = array( $rows ); - } - - foreach( $rows as $row ) { - # Delete rows which collide - if ( $uniqueIndexes ) { - $sql = "DELETE FROM $table WHERE "; - $first = true; - foreach ( $uniqueIndexes as $index ) { - if ( $first ) { - $first = false; - $sql .= '('; - } else { - $sql .= ') OR ('; - } - if ( is_array( $index ) ) { - $first2 = true; - foreach ( $index as $col ) { - if ( $first2 ) { - $first2 = false; - } else { - $sql .= ' AND '; - } - $sql .= $col.'=' . $this->addQuotes( $row[$col] ); - } - } else { - $sql .= $index.'=' . $this->addQuotes( $row[$index] ); - } - } - $sql .= ')'; - $this->query( $sql, $fname ); - } - - # Now insert the row - $sql = "INSERT INTO $table (" . $this->makeList( array_keys( $row ), LIST_NAMES ) .') VALUES (' . - $this->makeList( $row, LIST_COMMA ) . ')'; - $this->query( $sql, $fname ); - } - } - - # DELETE where the condition is a join - function deleteJoin( $delTable, $joinTable, $delVar, $joinVar, $conds, $fname = 'DatabasePostgres::deleteJoin' ) { - if ( !$conds ) { - throw new DBUnexpectedError( $this, 'DatabasePostgres::deleteJoin() called with empty $conds' ); - } - - $delTable = $this->tableName( $delTable ); - $joinTable = $this->tableName( $joinTable ); - $sql = "DELETE FROM $delTable WHERE $delVar IN (SELECT $joinVar FROM $joinTable "; - if ( $conds != '*' ) { - $sql .= 'WHERE ' . $this->makeList( $conds, LIST_AND ); - } - $sql .= ')'; - - $this->query( $sql, $fname ); - } - - # Returns the size of a text field, or -1 for "unlimited" - function textFieldSize( $table, $field ) { - $table = $this->tableName( $table ); - $sql = "SELECT t.typname as ftype,a.atttypmod as size - FROM pg_class c, pg_attribute a, pg_type t - WHERE relname='$table' AND a.attrelid=c.oid AND - a.atttypid=t.oid and a.attname='$field'"; - $res =$this->query( $sql ); - $row = $this->fetchObject( $res ); - if ( $row->ftype == 'varchar' ) { - $size = $row->size - 4; - } else { - $size = $row->size; - } - return $size; - } - - function limitResult( $sql, $limit, $offset = false ) { - return "$sql LIMIT $limit " . ( is_numeric( $offset ) ? " OFFSET {$offset} " : '' ); - } - - function wasDeadlock() { - return $this->lastErrno() == '40P01'; - } - - function duplicateTableStructure( $oldName, $newName, $temporary = false, $fname = 'DatabasePostgres::duplicateTableStructure' ) { - return $this->query( 'CREATE ' . ( $temporary ? 'TEMPORARY ' : '' ) . " TABLE $newName (LIKE $oldName INCLUDING DEFAULTS)", $fname ); - } - - function timestamp( $ts = 0 ) { - return wfTimestamp( TS_POSTGRES, $ts ); - } - - /** - * Return aggregated value function call - */ - function aggregateValue( $valuedata, $valuename = 'value' ) { - return $valuedata; - } - - /** - * @return string wikitext of a link to the server software's web site - */ - public static function getSoftwareLink() { - return '[http://www.postgresql.org/ PostgreSQL]'; - } - - /** - * @return string Version information from the database - */ - function getServerVersion() { - if ( !isset( $this->numeric_version ) ) { - $versionInfo = pg_version( $this->mConn ); - if ( version_compare( $versionInfo['client'], '7.4.0', 'lt' ) ) { - // Old client, abort install - $this->numeric_version = '7.3 or earlier'; - } elseif ( isset( $versionInfo['server'] ) ) { - // Normal client - $this->numeric_version = $versionInfo['server']; - } else { - // Bug 16937: broken pgsql extension from PHP<5.3 - $this->numeric_version = pg_parameter_status( $this->mConn, 'server_version' ); - } - } - return $this->numeric_version; - } - - /** - * Query whether a given relation exists (in the given schema, or the - * default mw one if not given) - */ - function relationExists( $table, $types, $schema = false ) { - global $wgDBmwschema; - if ( !is_array( $types ) ) { - $types = array( $types ); - } - if ( !$schema ) { - $schema = $wgDBmwschema; - } - $etable = $this->addQuotes( $table ); - $eschema = $this->addQuotes( $schema ); - $SQL = "SELECT 1 FROM pg_catalog.pg_class c, pg_catalog.pg_namespace n " - . "WHERE c.relnamespace = n.oid AND c.relname = $etable AND n.nspname = $eschema " - . "AND c.relkind IN ('" . implode( "','", $types ) . "')"; - $res = $this->query( $SQL ); - $count = $res ? $res->numRows() : 0; - return (bool)$count; - } - - /** - * For backward compatibility, this function checks both tables and - * views. - */ - function tableExists( $table, $schema = false ) { - return $this->relationExists( $table, array( 'r', 'v' ), $schema ); - } - - function sequenceExists( $sequence, $schema = false ) { - return $this->relationExists( $sequence, 'S', $schema ); - } - - function triggerExists( $table, $trigger ) { - global $wgDBmwschema; - - $q = <<query( - sprintf( - $q, - $this->addQuotes( $wgDBmwschema ), - $this->addQuotes( $table ), - $this->addQuotes( $trigger ) - ) - ); - if ( !$res ) { - return null; - } - $rows = $res->numRows(); - return $rows; - } - - function ruleExists( $table, $rule ) { - global $wgDBmwschema; - $exists = $this->selectField( 'pg_rules', 'rulename', - array( - 'rulename' => $rule, - 'tablename' => $table, - 'schemaname' => $wgDBmwschema - ) - ); - return $exists === $rule; - } - - function constraintExists( $table, $constraint ) { - global $wgDBmwschema; - $SQL = sprintf( "SELECT 1 FROM information_schema.table_constraints ". - "WHERE constraint_schema = %s AND table_name = %s AND constraint_name = %s", - $this->addQuotes( $wgDBmwschema ), - $this->addQuotes( $table ), - $this->addQuotes( $constraint ) - ); - $res = $this->query( $SQL ); - if ( !$res ) { - return null; - } - $rows = $res->numRows(); - return $rows; - } - - /** - * Query whether a given schema exists. Returns true if it does, false if it doesn't. - */ - function schemaExists( $schema ) { - $exists = $this->selectField( '"pg_catalog"."pg_namespace"', 1, - array( 'nspname' => $schema ), __METHOD__ ); - return (bool)$exists; - } - - /** - * Returns true if a given role (i.e. user) exists, false otherwise. - */ - function roleExists( $roleName ) { - $exists = $this->selectField( '"pg_catalog"."pg_roles"', 1, - array( 'rolname' => $roleName ), __METHOD__ ); - return (bool)$exists; - } - - function fieldInfo( $table, $field ) { - return PostgresField::fromText( $this, $table, $field ); - } - - /** - * pg_field_type() wrapper - */ - function fieldType( $res, $index ) { - if ( $res instanceof ResultWrapper ) { - $res = $res->result; - } - return pg_field_type( $res, $index ); - } - - /* Not even sure why this is used in the main codebase... */ - function limitResultForUpdate( $sql, $num ) { - return $sql; - } - - function encodeBlob( $b ) { - return new Blob( pg_escape_bytea( $this->mConn, $b ) ); - } - - function decodeBlob( $b ) { - if ( $b instanceof Blob ) { - $b = $b->fetch(); - } - return pg_unescape_bytea( $b ); - } - - function strencode( $s ) { # Should not be called by us - return pg_escape_string( $this->mConn, $s ); - } - - function addQuotes( $s ) { - if ( is_null( $s ) ) { - return 'NULL'; - } elseif ( is_bool( $s ) ) { - return intval( $s ); - } elseif ( $s instanceof Blob ) { - return "'" . $s->fetch( $s ) . "'"; - } - return "'" . pg_escape_string( $this->mConn, $s ) . "'"; - } - - /** - * Postgres specific version of replaceVars. - * Calls the parent version in Database.php - * - * @private - * - * @param $ins String: SQL string, read from a stream (usually tables.sql) - * - * @return string SQL string - */ - protected function replaceVars( $ins ) { - $ins = parent::replaceVars( $ins ); - - if ( $this->numeric_version >= 8.3 ) { - // Thanks for not providing backwards-compatibility, 8.3 - $ins = preg_replace( "/to_tsvector\s*\(\s*'default'\s*,/", 'to_tsvector(', $ins ); - } - - if ( $this->numeric_version <= 8.1 ) { // Our minimum version - $ins = str_replace( 'USING gin', 'USING gist', $ins ); - } - - return $ins; - } - - /** - * Various select options - * - * @private - * - * @param $options Array: an associative array of options to be turned into - * an SQL query, valid keys are listed in the function. - * @return array - */ - function makeSelectOptions( $options ) { - $preLimitTail = $postLimitTail = ''; - $startOpts = $useIndex = ''; - - $noKeyOptions = array(); - foreach ( $options as $key => $option ) { - if ( is_numeric( $key ) ) { - $noKeyOptions[$option] = true; - } - } - - if ( isset( $options['GROUP BY'] ) ) { - $preLimitTail .= ' GROUP BY ' . $options['GROUP BY']; - } - if ( isset( $options['HAVING'] ) ) { - $preLimitTail .= " HAVING {$options['HAVING']}"; - } - if ( isset( $options['ORDER BY'] ) ) { - $preLimitTail .= ' ORDER BY ' . $options['ORDER BY']; - } - - //if ( isset( $options['LIMIT'] ) ) { - // $tailOpts .= $this->limitResult( '', $options['LIMIT'], - // isset( $options['OFFSET'] ) ? $options['OFFSET'] - // : false ); - //} - - if ( isset( $noKeyOptions['FOR UPDATE'] ) ) { - $postLimitTail .= ' FOR UPDATE'; - } - if ( isset( $noKeyOptions['LOCK IN SHARE MODE'] ) ) { - $postLimitTail .= ' LOCK IN SHARE MODE'; - } - if ( isset( $noKeyOptions['DISTINCT'] ) || isset( $noKeyOptions['DISTINCTROW'] ) ) { - $startOpts .= 'DISTINCT'; - } - - return array( $startOpts, $useIndex, $preLimitTail, $postLimitTail ); - } - - function setFakeMaster( $enabled = true ) {} - - function getDBname() { - return $this->mDBname; - } - - function getServer() { - return $this->mServer; - } - - function buildConcat( $stringList ) { - return implode( ' || ', $stringList ); - } - - public function getSearchEngine() { - return 'SearchPostgres'; - } -} // end DatabasePostgres class