function SchemaTest::testPgsqlSequences

Tests if the new sequences get the right ownership.

File

core/modules/pgsql/tests/src/Kernel/pgsql/SchemaTest.php, line 252

Class

SchemaTest

Tests schema API for the PostgreSQL driver.

Namespace

Code

public function testPgsqlSequences() : void {
  $table_specification = [
    'description' => 'A test table with an ANSI reserved keywords for naming.',
    'fields' => [
      'uid' => [
        'description' => 'Simple unique ID.',
        'type' => 'serial',
        'not null' => TRUE,
      ],
      'update' => [
        'description' => 'A column with reserved name.',
        'type' => 'varchar',
        'length' => 255,
      ],
    ],
    'primary key' => [
      'uid',
    ],
    'unique keys' => [
      'having' => [
        'update',
      ],
    ],
    'indexes' => [
      'in' => [
        'uid',
        'update',
      ],
    ],
  ];
  // Creating a table.
  $table_name = 'sequence_test';
  $this->schema
    ->createTable($table_name, $table_specification);
  $this->assertTrue($this->schema
    ->tableExists($table_name));
  // Retrieves a sequence name that is owned by the table and column.
  $sequence_name = $this->connection
    ->query("SELECT pg_get_serial_sequence(:table, :column)", [
    ':table' => $this->connection
      ->getPrefix() . 'sequence_test',
    ':column' => 'uid',
  ])
    ->fetchField();
  $schema = $this->connection
    ->getConnectionOptions()['schema'] ?? 'public';
  $this->assertEquals($schema . '.' . $this->connection
    ->getPrefix() . 'sequence_test_uid_seq', $sequence_name);
  // Checks if the sequence exists.
  $this->assertTrue((bool) \Drupal::database()->query("SELECT c.relname FROM pg_class as c WHERE c.relkind = 'S' AND c.relname = :name", [
    ':name' => $this->connection
      ->getPrefix() . 'sequence_test_uid_seq',
  ])
    ->fetchField());
  // Retrieves the sequence owner object.
  $sequence_owner = \Drupal::database()->query("SELECT d.refobjid::regclass as table_name, a.attname as field_name\n      FROM pg_depend d\n      JOIN pg_attribute a ON a.attrelid = d.refobjid AND a.attnum = d.refobjsubid\n      WHERE d.objid = :seq_name::regclass\n      AND d.refobjsubid > 0\n      AND d.classid = 'pg_class'::regclass", [
    ':seq_name' => $sequence_name,
  ])
    ->fetchObject();
  $this->assertEquals($this->connection
    ->getPrefix() . 'sequence_test', $sequence_owner->table_name);
  $this->assertEquals('uid', $sequence_owner->field_name, 'New sequence is owned by its table.');
}