function DatabaseTablePrefixTestCase::testSchemaDotTablePrefixes

File

modules/simpletest/tests/database_test.test, line 4644

Class

DatabaseTablePrefixTestCase

Test table prefix handling.

Code

public function testSchemaDotTablePrefixes() {
    // Get a copy of the default connection options.
    $db = Database::getConnection('default', 'default');
    $connection_options = $db->getConnectionOptions();
    if ($connection_options['driver'] === 'sqlite') {
        // In SQLite simpletest's prefixed db tables exist in their own schema
        // (e.g. simpletest124904.system), so we cannot test the schema.table
        // prefix syntax here.
        $this->assert(TRUE, 'Skipping schema.table prefixed tables test for SQLite.');
        return;
    }
    $db_name = $connection_options['database'];
    if ($connection_options['driver'] === 'pgsql') {
        // database.scheme.table for PostgreSQL
        // @see https://www.postgresql.org/docs/14/ddl-schemas.html
        $db_name .= '.public';
    }
    // This prefix is usually something like simpletest12345
    $test_prefix = $connection_options['prefix']['default'];
    // Set up a new connection with table prefixes in the form "schema.table"
    $prefixed = $connection_options;
    $prefixed['prefix'] = array(
        'default' => $test_prefix,
        'users' => $db_name . '.' . $test_prefix,
        'role' => $db_name . '.' . $test_prefix,
    );
    Database::addConnectionInfo('default', 'prefixed', $prefixed);
    // Test that the prefixed database connection can query the prefixed tables.
    $num_users_prefixed = Database::getConnection('prefixed', 'default')->query('SELECT COUNT(1) FROM {users}')
        ->fetchField();
    $this->assertTrue((int) $num_users_prefixed > 0, 'Successfully queried the users table using a schema.table prefix');
    $num_users_default = Database::getConnection('default', 'default')->query('SELECT COUNT(1) FROM {users}')
        ->fetchField();
    $this->assertEqual($num_users_default, $num_users_prefixed, 'Verified results of query using a connection with schema.table prefixed tables');
}