View source
<?php
namespace Drupal\KernelTests\Core\Database;
class InsertTest extends DatabaseTestBase {
public function testSimpleInsert() {
$num_records_before = $this->connection
->query('SELECT COUNT(*) FROM {test}')
->fetchField();
$query = $this->connection
->insert('test');
$query
->fields([
'name' => 'Yoko',
'age' => '29',
]);
$this
->assertIdentical($query
->count(), 1, 'One record is queued for insertion.');
$query
->execute();
$num_records_after = $this->connection
->query('SELECT COUNT(*) FROM {test}')
->fetchField();
$this
->assertSame($num_records_before + 1, (int) $num_records_after, 'Record inserts correctly.');
$saved_age = $this->connection
->query('SELECT age FROM {test} WHERE name = :name', [
':name' => 'Yoko',
])
->fetchField();
$this
->assertIdentical($saved_age, '29', 'Can retrieve after inserting.');
}
public function testMultiInsert() {
$num_records_before = (int) $this->connection
->query('SELECT COUNT(*) FROM {test}')
->fetchField();
$query = $this->connection
->insert('test');
$query
->fields([
'name' => 'Larry',
'age' => '30',
]);
$query
->values([
'age' => '31',
'name' => 'Curly',
]);
$this
->assertIdentical($query
->count(), 2, 'Two records are queued for insertion.');
$query
->values([
'Moe',
'32',
]);
$this
->assertIdentical($query
->count(), 3, 'Three records are queued for insertion.');
$query
->execute();
$num_records_after = (int) $this->connection
->query('SELECT COUNT(*) FROM {test}')
->fetchField();
$this
->assertSame($num_records_before + 3, $num_records_after, 'Record inserts correctly.');
$saved_age = $this->connection
->query('SELECT age FROM {test} WHERE name = :name', [
':name' => 'Larry',
])
->fetchField();
$this
->assertIdentical($saved_age, '30', 'Can retrieve after inserting.');
$saved_age = $this->connection
->query('SELECT age FROM {test} WHERE name = :name', [
':name' => 'Curly',
])
->fetchField();
$this
->assertIdentical($saved_age, '31', 'Can retrieve after inserting.');
$saved_age = $this->connection
->query('SELECT age FROM {test} WHERE name = :name', [
':name' => 'Moe',
])
->fetchField();
$this
->assertIdentical($saved_age, '32', 'Can retrieve after inserting.');
}
public function testRepeatedInsert() {
$num_records_before = $this->connection
->query('SELECT COUNT(*) FROM {test}')
->fetchField();
$query = $this->connection
->insert('test');
$query
->fields([
'name' => 'Larry',
'age' => '30',
]);
$this
->assertIdentical($query
->count(), 1, 'One record is queued for insertion.');
$query
->execute();
$query
->values([
'age' => '31',
'name' => 'Curly',
]);
$this
->assertIdentical($query
->count(), 1, 'One record is queued for insertion.');
$query
->execute();
$query
->values([
'Moe',
'32',
]);
$this
->assertIdentical($query
->count(), 1, 'One record is queued for insertion.');
$query
->execute();
$num_records_after = $this->connection
->query('SELECT COUNT(*) FROM {test}')
->fetchField();
$this
->assertSame((int) $num_records_before + 3, (int) $num_records_after, 'Record inserts correctly.');
$saved_age = $this->connection
->query('SELECT age FROM {test} WHERE name = :name', [
':name' => 'Larry',
])
->fetchField();
$this
->assertIdentical($saved_age, '30', 'Can retrieve after inserting.');
$saved_age = $this->connection
->query('SELECT age FROM {test} WHERE name = :name', [
':name' => 'Curly',
])
->fetchField();
$this
->assertIdentical($saved_age, '31', 'Can retrieve after inserting.');
$saved_age = $this->connection
->query('SELECT age FROM {test} WHERE name = :name', [
':name' => 'Moe',
])
->fetchField();
$this
->assertIdentical($saved_age, '32', 'Can retrieve after inserting.');
}
public function testInsertFieldOnlyDefinition() {
$this->connection
->insert('test')
->fields([
'name',
'age',
])
->values([
'Larry',
'30',
])
->values([
'Curly',
'31',
])
->values([
'Moe',
'32',
])
->execute();
$saved_age = $this->connection
->query('SELECT age FROM {test} WHERE name = :name', [
':name' => 'Larry',
])
->fetchField();
$this
->assertIdentical($saved_age, '30', 'Can retrieve after inserting.');
$saved_age = $this->connection
->query('SELECT age FROM {test} WHERE name = :name', [
':name' => 'Curly',
])
->fetchField();
$this
->assertIdentical($saved_age, '31', 'Can retrieve after inserting.');
$saved_age = $this->connection
->query('SELECT age FROM {test} WHERE name = :name', [
':name' => 'Moe',
])
->fetchField();
$this
->assertIdentical($saved_age, '32', 'Can retrieve after inserting.');
}
public function testInsertLastInsertID() {
$id = $this->connection
->insert('test')
->fields([
'name' => 'Larry',
'age' => '30',
])
->execute();
$this
->assertIdentical($id, '5', 'Auto-increment ID returned successfully.');
}
public function testInsertSelectFields() {
$query = $this->connection
->select('test_people', 'tp');
$query
->addExpression('tp.age', 'age');
$query
->fields('tp', [
'name',
'job',
])
->condition('tp.name', 'Meredith');
$this->connection
->insert('test')
->from($query)
->execute();
$saved_age = $this->connection
->query('SELECT age FROM {test} WHERE name = :name', [
':name' => 'Meredith',
])
->fetchField();
$this
->assertIdentical($saved_age, '30', 'Can retrieve after inserting.');
}
public function testInsertSelectAll() {
$query = $this->connection
->select('test_people', 'tp')
->fields('tp')
->condition('tp.name', 'Meredith');
$this->connection
->insert('test_people_copy')
->from($query)
->execute();
$saved_age = $this->connection
->query('SELECT age FROM {test_people_copy} WHERE name = :name', [
':name' => 'Meredith',
])
->fetchField();
$this
->assertIdentical($saved_age, '30', 'Can retrieve after inserting.');
}
public function testSpecialColumnInsert() {
$this->connection
->insert('test_special_columns')
->fields([
'id' => 2,
'offset' => 'Offset value 2',
'function' => 'foobar',
])
->execute();
$result = $this->connection
->select('test_special_columns')
->fields('test_special_columns', [
'offset',
'function',
])
->condition('test_special_columns.function', 'foobar')
->execute();
$record = $result
->fetch();
$this
->assertSame('Offset value 2', $record->offset);
$this
->assertSame('foobar', $record->function);
}
}