function NonPublicSchemaTest::testUpsert

@covers \Drupal\Core\Database\Connection::upsert

File

core/modules/pgsql/tests/src/Kernel/pgsql/NonPublicSchemaTest.php, line 200

Class

NonPublicSchemaTest

Tests schema API for non-public schema for the PostgreSQL driver.

Namespace

Code

public function testUpsert() : void {
  $num_records_before = $this->testingFakeConnection
    ->query('SELECT COUNT(*) FROM {faking_table}')
    ->fetchField();
  $upsert = $this->testingFakeConnection
    ->upsert('faking_table')
    ->key('id')
    ->fields([
    'id',
    'test_field',
  ]);
  // Upserting a new row.
  $upsert->values([
    'id' => '456',
    'test_field' => '444',
  ]);
  // Upserting an existing row.
  $upsert->values([
    'id' => '1',
    'test_field' => '898',
  ]);
  $result = $upsert->execute();
  $this->assertSame(2, $result, 'The result of the upsert operation should report that at exactly two rows were affected.');
  $num_records_after = $this->testingFakeConnection
    ->query('SELECT COUNT(*) FROM {faking_table}')
    ->fetchField();
  $this->assertEquals($num_records_before + 1, $num_records_after, 'Merge inserted properly.');
  // Check if new row has been added with upsert.
  $result = $this->testingFakeConnection
    ->query('SELECT * FROM {faking_table} WHERE [id] = :id', [
    ':id' => '456',
  ])
    ->fetch();
  $this->assertEquals('456', $result->id, 'ID set correctly.');
  $this->assertEquals('444', $result->test_field, 'test_field set correctly.');
  // Check if new row has been edited with upsert.
  $result = $this->testingFakeConnection
    ->query('SELECT * FROM {faking_table} WHERE [id] = :id', [
    ':id' => '1',
  ])
    ->fetch();
  $this->assertEquals('1', $result->id, 'ID set correctly.');
  $this->assertEquals('898', $result->test_field, 'test_field set correctly.');
}