Class ilDBPdoPostgreSQL. More...

Inheritance diagram for ilDBPdoPostgreSQL:

Collaboration diagram for ilDBPdoPostgreSQL:

Public Member Functions

generateDSN ()

connect ($return_false_for_error=false)

initHelpers ()

getPrimaryKeyIdentifier ()

Primary key identifier. More...

supportsFulltext ()

supportsTransactions ()

constraintName ($a_table, $a_constraint)

getIndexName ($index_name_base)

replace ($a_table, $a_pk_columns, $a_other_columns)

lockTables ($a_tables)

unlockTables ()

getStorageEngine ()

setStorageEngine ($storage_engine)

nextId ($table_name)

dropTable ($table_name, $error_if_not_existing=false)

quoteIdentifier ($identifier, $check_option=false)

tableExists ($table_name)

tableColumnExists ($table_name, $column_name)

renameTable ($a_name, $a_new_name)

createSequence ($table_name, $start=1)

createTable ($table_name, $fields, $drop_table=false, $ignore_erros=false)

addPrimaryKey ($table_name, $primary_keys)

addIndex ($table_name, $fields, $index_name='', $fulltext=false)

addUniqueConstraint ($table, $fields, $name="con")

dropPrimaryKey ($table_name)

Public Member Functions inherited from ilDBPdo

connect ($return_false_for_error=false)

initHelpers ()

getFieldDefinition ()

setFieldDefinition ($field_definition)

createDatabase ($a_name, $a_charset="utf8", $a_collation="")

getLastErrorCode ()

initFromIniFile ($tmpClientIniFile=null)

generateDSN ()

quoteIdentifier ($identifier, $check_option=false)

nextId ($table_name)

createTable ($table_name, $fields, $drop_table=false, $ignore_erros=false)

checkColumnName ($a_name)

addPrimaryKey ($table_name, $primary_keys)

dropIndexByFields ($table_name, $fields)

getPrimaryKeyIdentifier ()

createSequence ($table_name, $start=1)

tableExists ($table_name)

tableColumnExists ($table_name, $column_name)

addTableColumn ($table_name, $column_name, $attributes)

dropTable ($table_name, $error_if_not_existing=true)

query ($query)

dropSequence ($table_name)

dropTableColumn ($table_name, $column_name)

renameTableColumn ($table_name, $column_old_name, $column_new_name)

insert ($table_name, $values)

fetchObject ($query_result)

update ($table_name, $columns, $where)

manipulate ($query)

fetchAssoc ($query_result)

numRows ($query_result)

quote ($value, $type=null)

indexExistsByFields ($table_name, $fields)

addIndex ($table_name, $fields, $index_name='', $fulltext=false)

addFulltextIndex ($a_table, $a_fields, $a_name="in")

dropFulltextIndex ($a_table, $a_name)

Drop fulltext index. More...

isFulltextIndex ($a_table, $a_name)

Is index a fulltext index? More...

getIndexName ($index_name_base)

getSequenceName ($table_name)

constraintName ($a_table, $a_constraint)

Determine contraint name by table name and constraint name. More...

getDSN ()

getDBType ()

setDBType ($type)

lockTables ($tables)

unlockTables ()

in ($field, $values, $negate=false, $type="")

queryF ($query, $types, $values)

manipulateF ($query, $types, $values)

useSlave ($bool)

setLimit ($limit, $offset=0)

Set the Limit for the next Query. More...

like ($column, $type, $value="?", $case_insensitive=true)

now ()

replace ($table, $primaryKeys, $otherColumns)

Replace into method. More...

equals ($columns, $value, $type, $emptyOrNull=false)

getHost ()

setHost ($host)

getDbname ()

setDbname ($dbname)

getCharset ()

setCharset ($charset)

getUsername ()

setUsername ($username)

getPassword ()

setPassword ($password)

getPort ()

setPort ($port)

setDBUser ($user)

setDBPort ($port)

setDBPassword ($password)

setDBHost ($host)

upper ($a_exp)

lower ($a_exp)

substr ($a_exp, $a_pos=1, $a_len=-1)

prepareManip ($query, $types=null)

prepare ($query, $types=null, $result_types=null)

enableResultBuffering ($a_status)

supportsSlave ()

supportsFulltext ()

supportsTransactions ()

supports ($feature)

listTables ()

loadModule ($module)

getAllowedAttributes ()

Returns: array

More...

sequenceExists ($sequence)

listSequences ()

concat (array $values, $allow_null=true)

locate ($a_needle, $a_string, $a_start_pos=1)

modifyTableColumn ($table, $a_column, $a_attributes)

renameTable ($a_name, $a_new_name)

checkTableName ($a_name)

beginTransaction ()

commit ()

rollback ()

dropIndex ($a_table, $a_name="i1")

setStorageEngine ($storage_engine)

getStorageEngine ()

queryCol ($query, $type=PDO::FETCH_ASSOC, $colnum=0)

queryRow ($query, $types=null, $fetchmode=ilDBConstants::FETCHMODE_DEFAULT)

getServerVersion ($native=false)

escape ($value, $escape_wildcards=false)

escapePattern ($text)

migrateAllTablesToEngine ($engine=ilDBConstants::MYSQL_ENGINE_INNODB)

migrateAllTablesToCollation ($collation=ilDBConstants::MYSQL_COLLATION_UTF8MB4)

@inheritDoc More...

supportsCollationMigration ()

@inheritDoc More...

supportsEngineMigration ()

checkIndexName ($name)

addUniqueConstraint ($table, $fields, $name="con")

dropUniqueConstraint ($a_table, $a_name="con")

dropUniqueConstraintByFields ($a_table, $a_fields)

getLastInsertId ()

buildAtomQuery ()

uniqueConstraintExists ($table, array $fields)

dropPrimaryKey ($table_name)

executeMultiple ($stmt, $a_data)

fromUnixtime ($a_expr, $a_to_text=true)

unixTimestamp ()

autoExecute ($tablename, $fields, $mode=ilDBConstants::AUTOQUERY_INSERT, $where=false)

Generate an insert, update or delete query and call prepare() and execute() on it. More...

getDBVersion ()

sanitizeMB4StringIfNotSupported ($query)

Parameters

$query string to sanitize, all MB4-Characters like emojis will re replaced with ???

Returns: string sanitized query

More...

doesCollationSupportMB4Strings ()

@inheritDoc More...

groupConcat ($a_field_name, $a_seperator=",", $a_order=null)

Parameters

string	$a_field_name
string	$a_seperator
string	$a_order

Returns: string

More...

cast ($a_field_name, $a_dest_type)

Parameters

string	$a_field_name
string	$a_dest_type

Returns: string;

More...

Public Member Functions inherited from ilDBInterface

doesCollationSupportMB4Strings ()

sanitizeMB4StringIfNotSupported ($query)

initFromIniFile ($tmpClientIniFile=null)

connect ($return_false_on_error=false)

nextId ($table_name)

createTable ($table_name, $fields, $drop_table=false, $ignore_erros=false)

addPrimaryKey ($table_name, $primary_keys)

createSequence ($table_name, $start=1)

getSequenceName ($table_name)

tableExists ($table_name)

tableColumnExists ($table_name, $column_name)

addTableColumn ($table_name, $column_name, $attributes)

dropTable ($table_name, $error_if_not_existing=true)

renameTable ($old_name, $new_name)

query ($query)

Run a (read-only) Query on the database. More...

fetchAll ($query_result, $fetch_mode=ilDBConstants::FETCHMODE_ASSOC)

dropSequence ($table_name)

dropTableColumn ($table_name, $column_name)

renameTableColumn ($table_name, $column_old_name, $column_new_name)

insert ($table_name, $values)

fetchObject ($query_result)

update ($table_name, $values, $where)

manipulate ($query)

Run a (write) Query on the database. More...

fetchAssoc ($query_result)

numRows ($query_result)

quote ($value, $type)

addIndex ($table_name, $fields, $index_name='', $fulltext=false)

indexExistsByFields ($table_name, $fields)

getDSN ()

Get DSN. More...

getDBType ()

Get DSN. More...

lockTables ($tables)

Abstraction of lock table. More...

unlockTables ()

Unlock tables locked by previous lock table calls. More...

in ($field, $values, $negate=false, $type="")

queryF ($query, $types, $values)

manipulateF ($query, $types, $values)

useSlave ($bool)

Return false iff slave is not supported. More...

setLimit ($limit, $offset)

like ($column, $type, $value="?", $case_insensitive=true)

Generate a like subquery. More...

now ()

replace ($table, $primaryKeys, $otherColumns)

Replace into method. More...

equals ($columns, $value, $type, $emptyOrNull=false)

setDBUser ($user)

setDBPort ($port)

setDBPassword ($password)

setDBHost ($host)

upper ($a_exp)

lower ($a_exp)

substr ($a_exp)

prepare ($a_query, $a_types=null, $a_result_types=null)

Prepare a query (SELECT) statement to be used with execute. More...

prepareManip ($a_query, $a_types=null)

enableResultBuffering ($a_status)

execute ($stmt, $data=array())

sequenceExists ($sequence)

listSequences ()

supports ($feature)

supportsFulltext ()

supportsSlave ()

supportsTransactions ()

listTables ()

loadModule ($module)

getAllowedAttributes ()

concat (array $values, $allow_null=true)

locate ($a_needle, $a_string, $a_start_pos=1)

quoteIdentifier ($identifier, $check_option=false)

modifyTableColumn ($table, $column, $attributes)

free ($a_st)

checkTableName ($a_name)

beginTransaction ()

commit ()

rollback ()

constraintName ($a_table, $a_constraint)

dropIndex ($a_table, $a_name="i1")

createDatabase ($a_name, $a_charset="utf8", $a_collation="")

dropIndexByFields ($table_name, $afields)

getPrimaryKeyIdentifier ()

addFulltextIndex ($table_name, $afields, $a_name='in')

dropFulltextIndex ($a_table, $a_name)

isFulltextIndex ($a_table, $a_name)

setStorageEngine ($storage_engine)

getStorageEngine ()

buildAtomQuery ()

groupConcat ($a_field_name, $a_seperator=",", $a_order=null)

cast ($a_field_name, $a_dest_type)

getServerVersion ($native=false)

queryCol ($query, $type=ilDBConstants::FETCHMODE_DEFAULT, $colnum=0)

queryRow ($query, $types=null, $fetchmode=ilDBConstants::FETCHMODE_DEFAULT)

escape ($value, $escape_wildcards=false)

escapePattern ($text)

migrateAllTablesToEngine ($engine=ilDBConstants::MYSQL_ENGINE_INNODB)

supportsEngineMigration ()

migrateAllTablesToCollation ($collation=ilDBConstants::MYSQL_COLLATION_UTF8MB4)

supportsCollationMigration ()

addUniqueConstraint ($table, $fields, $name="con")

dropUniqueConstraint ($table, $name="con")

dropUniqueConstraintByFields ($table, $fields)

checkIndexName ($name)

getLastInsertId ()

prepare ($query, $types=null, $result_types=null)

uniqueConstraintExists ($table, array $fields)

dropPrimaryKey ($table_name)

executeMultiple ($stmt, $data)

fromUnixtime ($expr, $to_text=true)

unixTimestamp ()

autoExecute ($tablename, $fields, $mode=ilDBConstants::AUTOQUERY_INSERT, $where=false)

Generate an insert, update or delete query and call prepare() and execute() on it. More...

getDBVersion ()

returns the Version of the Database (e.g. More...

Data Fields
const	POSTGRE_STD_PORT = 5432

Data Fields inherited from ilDBPdo
const	FEATURE_TRANSACTIONS = 'transactions'

const	FEATURE_FULLTEXT = 'fulltext'

const	FEATURE_SLAVE = 'slave'

Protected Member Functions
	getAdditionalAttributes ()

	appendLimit ($query)

Protected Member Functions inherited from ilDBPdo
	initSQLMode ()

	getAttributes ()

	getAdditionalAttributes ()

	checkTableColumns ($a_cols)

	checkColumn ($a_col, $a_def)

	checkColumnDefinition ($a_def, $a_modify_mode=false)

	appendLimit ($query)

	autoPrepare ($table, $table_fields, $mode=ilDBConstants::AUTOQUERY_INSERT, $where=false, $types=null, $result_types=ilDBConstants::PREPARE_MANIP)

	buildManipSQL ($table, $table_fields, $mode, $where=false)

Protected Attributes
	$port = self::POSTGRE_STD_PORT

	$storage_engine = null

	$manager

Protected Attributes inherited from ilDBPdo
	$host = ''

	$dbname = ''

	$charset = 'utf8'

	$username = ''

	$password = ''

	$port = 3306

	$pdo

	$manager

	$reverse

	$limit = null

	$offset = null

	$storage_engine = 'MyISAM'

	$dsn = ''

	$attributes

	$db_type = ''

	$error_code = 0

	$field_definition

Additional Inherited Members
Static Public Member Functions inherited from ilDBPdo
static	isReservedWord ($a_word)

Static Public Member Functions inherited from ilDBInterface
static	getReservedWords ()
	Get reserved words. More...

static	isReservedWord ($a_word)

Detailed Description

Class ilDBPdoPostgreSQL.

Author: Fabian Schmid fs@st.nosp@m.uder.nosp@m.-raim.nosp@m.ann..nosp@m.ch

Definition at line 13 of file class.ilDBPdoPostgreSQL.php.

Member Function Documentation

◆ addIndex()

ilDBPdoPostgreSQL::addIndex	(	$table_name,
		$fields,
		$index_name = `''`,
		$fulltext = `false`
	)

Parameters

	$table_name
array	$fields
	$index_name

Returns: null

Reimplemented from ilDBPdo.

Definition at line 434 of file class.ilDBPdoPostgreSQL.php.

    {
        $indices = $this->manager->listTableIndexes($table_name);
        if (in_array($this->constraintName($table_name, $index_name), $indices)) {
            return true;
        }
        try {
            return parent::addIndex($table_name, $fields, $index_name, $fulltext); // TODO: Change the autogenerated stub
        } catch (Exception $e) {
            return true;
        }
    }

References constraintName().

Here is the call graph for this function:

◆ addPrimaryKey()

ilDBPdoPostgreSQL::addPrimaryKey	(	$table_name,
		$primary_keys
	)

Parameters

string	$table_name
array	$primary_keys

Returns: bool

Reimplemented from ilDBPdo.

Definition at line 419 of file class.ilDBPdoPostgreSQL.php.

    {
        require_once('./Services/Database/classes/class.ilDBAnalyzer.php');
        $ilDBAnalyzer = new ilDBAnalyzer($this);
        if ($ilDBAnalyzer->getPrimaryKeyInformation($table_name)) {
            return true;
        }
        try {
            return parent::addPrimaryKey($table_name, $primary_keys); // TODO: Change the autogenerated stub
        } catch (Exception $e) {
            return true;
        }
    }

◆ addUniqueConstraint()

ilDBPdoPostgreSQL::addUniqueConstraint	(	$table,
		$fields,
		$name = `"con"`
	)

Parameters

	$table
	$fields
string	$name

Returns: bool

Exceptions

ilDatabaseException

Reimplemented from ilDBPdo.

Definition at line 448 of file class.ilDBPdoPostgreSQL.php.

    {
        try {
            return parent::addUniqueConstraint($table, $fields, $name); // TODO: Change the autogenerated stub
        } catch (Exception $e) {
            return true;
        }
    }

References $name, and $table.

◆ appendLimit()

ilDBPdoPostgreSQL::appendLimit ( $query )

protected

Parameters

$query

Returns: string

Reimplemented from ilDBPdo.

Definition at line 321 of file class.ilDBPdoPostgreSQL.php.

    {
        if ($this->limit !== null && $this->offset !== null) {
            $query .= ' LIMIT ' . (int) $this->limit . ' OFFSET ' . (int) $this->offset;
            $this->limit = null;
            $this->offset = null;
 
            return $query;
        }
 
        return $query;
    }

References ilDBPdo\$offset, and $query.

◆ connect()

ilDBPdoPostgreSQL::connect ( $return_false_for_error = false )

Parameters

bool $return_false_for_error

Returns: bool

Exceptions

Exception

Reimplemented from ilDBPdo.

Definition at line 45 of file class.ilDBPdoPostgreSQL.php.

    {
        $this->generateDSN();
        try {
            $this->pdo = new PDO($this->getDSN(), $this->getUsername(), $this->getPassword(), $this->getAttributes());
            $this->initHelpers();
        } catch (Exception $e) {
            $this->error_code = $e->getCode();
            if ($return_false_for_error) {
                return false;
            }
            throw $e;
        }
 
        return ($this->pdo->errorCode() == PDO::ERR_NONE);
    }

References generateDSN(), ilDBPdo\getAttributes(), ilDBPdo\getDSN(), ilDBPdo\getPassword(), ilDBPdo\getUsername(), and initHelpers().

Here is the call graph for this function:

◆ constraintName()

ilDBPdoPostgreSQL::constraintName	(	$a_table,
		$a_constraint
	)

Parameters

$a_table
$a_constraint

Returns: string

Reimplemented from ilDBPdo.

Definition at line 112 of file class.ilDBPdoPostgreSQL.php.

    {
        $a_constraint = str_replace($a_table . '_', '', $a_constraint);
 
        return $a_table . '_' . $a_constraint;
    }

Referenced by addIndex().

Here is the caller graph for this function:

◆ createSequence()

ilDBPdoPostgreSQL::createSequence	(	$table_name,
		$start = `1`
	)

Parameters

	$table_name
int	$start

Returns: bool

Reimplemented from ilDBPdo.

Definition at line 380 of file class.ilDBPdoPostgreSQL.php.

    {
        if (in_array($table_name, $this->manager->listSequences())) {
            return true;
        }
        try {
            parent::createSequence($table_name, $start); // TODO: Change the autogenerated stub
        } catch (Exception $e) {
            return true;
        }
    }

References $start.

◆ createTable()

ilDBPdoPostgreSQL::createTable	(	$table_name,
		$fields,
		$drop_table = `false`,
		$ignore_erros = `false`
	)

Parameters

	$table_name
	$fields
bool	$drop_table
bool	$ignore_erros

Returns: bool|mixed

Exceptions

ilDatabaseException

Reimplemented from ilDBPdo.

Definition at line 401 of file class.ilDBPdoPostgreSQL.php.

    {
        if ($this->tableExists($table_name)) {
            return true;
        }
        try {
            return parent::createTable($table_name, $fields, $drop_table, $ignore_erros); // TODO: Change the autogenerated stub
        } catch (Exception $e) {
            return true;
        }
    }

References tableExists().

Here is the call graph for this function:

◆ dropPrimaryKey()

ilDBPdoPostgreSQL::dropPrimaryKey ( $table_name )

Parameters

$table_name

Returns: bool

Reimplemented from ilDBPdo.

Definition at line 461 of file class.ilDBPdoPostgreSQL.php.

    {
        return $this->manager->dropConstraint($table_name, "pk", true);
    }

◆ dropTable()

ilDBPdoPostgreSQL::dropTable	(	$table_name,
		$error_if_not_existing = `false`
	)

Parameters

	$table_name
bool	$error_if_not_existing

Returns: int

Reimplemented from ilDBPdo.

Definition at line 272 of file class.ilDBPdoPostgreSQL.php.

    {
        try {
            $this->pdo->exec("DROP TABLE $table_name");
        } catch (PDOException $PDOException) {
            if ($error_if_not_existing) {
                throw $PDOException;
            }
 
            return false;
        }
 
        return true;
    }

◆ generateDSN()

ilDBPdoPostgreSQL::generateDSN ( )

Reimplemented from ilDBPdo.

Definition at line 30 of file class.ilDBPdoPostgreSQL.php.

    {
        if (!$this->getPort()) {
            $this->setPort(self::POSTGRE_STD_PORT);
        }
        $this->dsn = 'pgsql:host=' . $this->getHost() . ';port=' . $this->getPort() . ';dbname=' . $this->getDbname() . ';user='
                     . $this->getUsername() . ';password=' . $this->getPassword() . '';
    }

References ilDBPdo\getDbname(), ilDBPdo\getHost(), ilDBPdo\getPassword(), ilDBPdo\getPort(), ilDBPdo\getUsername(), and ilDBPdo\setPort().

Referenced by connect().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getAdditionalAttributes()

ilDBPdoPostgreSQL::getAdditionalAttributes ( )

protected

Returns: array

Reimplemented from ilDBPdo.

Definition at line 63 of file class.ilDBPdoPostgreSQL.php.

    {
        return array(
            PDO::ATTR_EMULATE_PREPARES => true,
            PDO::ATTR_STRINGIFY_FETCHES => true,
        );
    }

◆ getIndexName()

ilDBPdoPostgreSQL::getIndexName ( $index_name_base )

Parameters

$index_name_base

Returns: string

Reimplemented from ilDBPdo.

Definition at line 124 of file class.ilDBPdoPostgreSQL.php.

    {
        return parent::getIndexName($index_name_base); // TODO: Change the autogenerated stub
    }

◆ getPrimaryKeyIdentifier()

ilDBPdoPostgreSQL::getPrimaryKeyIdentifier ( )

Primary key identifier.

Reimplemented from ilDBPdo.

Definition at line 83 of file class.ilDBPdoPostgreSQL.php.

    {
        return "pk";
    }

◆ getStorageEngine()

ilDBPdoPostgreSQL::getStorageEngine ( )

Returns: string

Reimplemented from ilDBPdo.

Definition at line 236 of file class.ilDBPdoPostgreSQL.php.

    {
        return null;
    }

◆ initHelpers()

ilDBPdoPostgreSQL::initHelpers ( )

Reimplemented from ilDBPdo.

Definition at line 72 of file class.ilDBPdoPostgreSQL.php.

    {
        $this->manager = new ilDBPdoManagerPostgres($this->pdo, $this);
        $this->reverse = new ilDBPdoReversePostgres($this->pdo, $this);
        $this->field_definition = new ilDBPdoPostgresFieldDefinition($this);
    }

Referenced by connect().

Here is the caller graph for this function:

◆ lockTables()

ilDBPdoPostgreSQL::lockTables ( $a_tables )

Parameters

array $a_tables

Deprecated:: Use ilAtomQuery instead

Returns: bool

Reimplemented from ilDBPdo.

Definition at line 193 of file class.ilDBPdoPostgreSQL.php.

    {
        $locks = array();
 
        $counter = 0;
        foreach ($a_tables as $table) {
            if (!isset($table['sequence']) && $table['sequence']) {
                $lock = 'LOCK TABLE ' . $table['name'];
 
                switch ($table['type']) {
                    case ilDBConstants::LOCK_READ:
                        $lock .= ' IN SHARE MODE ';
                        break;
 
                    case ilDBConstants::LOCK_WRITE:
                        $lock .= ' IN EXCLUSIVE MODE ';
                        break;
                }
 
                $locks[] = $lock;
            }
        }
 
        // @TODO use and store a unique identifier to allow nested lock/unlocks
        $this->beginTransaction();
        foreach ($locks as $lock) {
            $this->query($lock);
        }
 
        return true;
    }

References $table, ilDBPdo\beginTransaction(), ilDBConstants\LOCK_READ, ilDBConstants\LOCK_WRITE, and ilDBPdo\query().

Here is the call graph for this function:

◆ nextId()

ilDBPdoPostgreSQL::nextId ( $table_name )

Parameters

string $table_name

Returns: mixed

Exceptions

ilDatabaseException

Reimplemented from ilDBPdo.

Definition at line 256 of file class.ilDBPdoPostgreSQL.php.

    {
        $sequence_name = $table_name . '_seq';
        $query = "SELECT NEXTVAL('$sequence_name')";
        $result = $this->query($query, 'integer');
        $data = $result->fetchObject();
 
        return $data->nextval;
    }

References $data, $query, $result, and ilDBPdo\query().

Here is the call graph for this function:

◆ quoteIdentifier()

ilDBPdoPostgreSQL::quoteIdentifier	(	$identifier,
		$check_option = `false`
	)

Parameters

	$identifier
bool	$check_option

Returns: mixed

Reimplemented from ilDBPdo.

Definition at line 293 of file class.ilDBPdoPostgreSQL.php.

    {
        return '"' . $identifier . '"';
    }

◆ renameTable()

ilDBPdoPostgreSQL::renameTable	(	$a_name,
		$a_new_name
	)

Parameters

$a_name
$a_new_name

Returns: bool

Exceptions

ilDatabaseException

Reimplemented from ilDBPdo.

Definition at line 353 of file class.ilDBPdoPostgreSQL.php.

    {
        // check table name
        try {
            $this->checkTableName($a_new_name);
        } catch (ilDatabaseException $e) {
            return true;
        }
 
        if ($this->tableExists($a_new_name)) {
            return true;
        }
        try {
            $this->manager->alterTable($a_name, array( "name" => $a_new_name ), false);
        } catch (Exception $e) {
            return true;
        }
 
        return true;
    }

References ilDBPdo\checkTableName(), and tableExists().

Here is the call graph for this function:

◆ replace()

ilDBPdoPostgreSQL::replace	(	$a_table,
		$a_pk_columns,
		$a_other_columns
	)

Parameters

$a_table
$a_pk_columns
$a_other_columns

Returns: bool

Exceptions

ilDatabaseException

Reimplemented from ilDBPdo.

Definition at line 137 of file class.ilDBPdoPostgreSQL.php.

    {
        $a_columns = array_merge($a_pk_columns, $a_other_columns);
        $fields = array();
        $field_values = array();
        $placeholders = array();
        $types = array();
        $values = array();
        $lobs = false;
        $lob = array();
        $val_field = array();
        $a = array();
        $b = array();
        foreach ($a_columns as $k => $col) {
            if ($col[0] == 'clob' or $col[0] == 'blob') {
                $val_field[] = $this->quote($col[1], 'text') . " " . $k;
            } else {
                $val_field[] = $this->quote($col[1], $col[0]) . " " . $k;
            }
            $fields[] = $k;
            $placeholders[] = "%s";
            $placeholders2[] = ":$k";
            $types[] = $col[0];
            $values[] = $col[1];
            $field_values[$k] = $col[1];
            if ($col[0] == "blob" || $col[0] == "clob") {
                $lobs = true;
                $lob[$k] = $k;
            }
            $a[] = "a." . $k;
            $b[] = "b." . $k;
        }
        $abpk = array();
        $aboc = array();
        $delwhere = array();
        foreach ($a_pk_columns as $k => $col) {
            $abpk[] = "a." . $k . " = b." . $k;
            $delwhere[] = $k . " = " . $this->quote($col[1], $col[0]);
        }
        foreach ($a_other_columns as $k => $col) {
            $aboc[] = "a." . $k . " = b." . $k;
        }
        //              if ($lobs)      // lobs -> use prepare execute (autoexecute broken in PEAR 2.4.1)
        //              {
        $this->manipulate("DELETE FROM " . $a_table . " WHERE " . implode(" AND ", $delwhere));
        $this->insert($a_table, $a_columns);
 
        return true;
    }

References $values, ilDBPdo\insert(), ilDBPdo\manipulate(), and ilDBPdo\quote().

Here is the call graph for this function:

◆ setStorageEngine()

ilDBPdoPostgreSQL::setStorageEngine ( $storage_engine )

Parameters

$storage_engine

Reimplemented from ilDBPdo.

Definition at line 242 of file class.ilDBPdoPostgreSQL.php.

    {
        return false;
    }

◆ supportsFulltext()

ilDBPdoPostgreSQL::supportsFulltext ( )

Returns: bool

Reimplemented from ilDBPdo.

Definition at line 92 of file class.ilDBPdoPostgreSQL.php.

    {
        return false;
    }

◆ supportsTransactions()

ilDBPdoPostgreSQL::supportsTransactions ( )

Returns: bool

Reimplemented from ilDBPdo.

Definition at line 101 of file class.ilDBPdoPostgreSQL.php.

    {
        return true;
    }

◆ tableColumnExists()

ilDBPdoPostgreSQL::tableColumnExists	(	$table_name,
		$column_name
	)

Parameters

$table_name	string
$column_name	string

Returns: bool

Reimplemented from ilDBPdo.

Definition at line 341 of file class.ilDBPdoPostgreSQL.php.

    {
        return in_array($column_name, $this->manager->listTableFields($table_name));
    }

◆ tableExists()

ilDBPdoPostgreSQL::tableExists ( $table_name )

Parameters

string $table_name

Returns: bool

Reimplemented from ilDBPdo.

Definition at line 303 of file class.ilDBPdoPostgreSQL.php.

    {
        $tables = $this->listTables();
 
        if (is_array($tables)) {
            if (in_array($table_name, $tables)) {
                return true;
            }
        }
 
        return false;
    }