class DatabaseStorageTest
Same name in this branch
- 9 core/tests/Drupal/KernelTests/Core/Config/Storage/DatabaseStorageTest.php \Drupal\KernelTests\Core\Config\Storage\DatabaseStorageTest
Same name and namespace in other branches
- 11.x core/tests/Drupal/KernelTests/Core/Config/Storage/DatabaseStorageTest.php \Drupal\KernelTests\Core\Config\Storage\DatabaseStorageTest
- 11.x core/tests/Drupal/KernelTests/Core/KeyValueStore/DatabaseStorageTest.php \Drupal\KernelTests\Core\KeyValueStore\DatabaseStorageTest
Tests the key-value database storage.
@group KeyValueStore
Hierarchy
- class \Drupal\KernelTests\KernelTestBase extends \Drupal\Core\DependencyInjection\ServiceProviderInterface uses \Drupal\KernelTests\AssertLegacyTrait, \Drupal\KernelTests\AssertContentTrait, \Drupal\Tests\RandomGeneratorTrait, \Drupal\Tests\ConfigTestTrait, \Drupal\Tests\ExtensionListTestTrait, \Drupal\Tests\TestRequirementsTrait, \Drupal\Tests\Traits\PhpUnitWarnings, \Drupal\Tests\PhpUnitCompatibilityTrait, \Symfony\Bridge\PhpUnit\ExpectDeprecationTrait implements \PHPUnit\Framework\TestCase
- class \Drupal\KernelTests\Core\KeyValueStore\StorageTestBase implements \Drupal\KernelTests\KernelTestBase
- class \Drupal\KernelTests\Core\KeyValueStore\DatabaseStorageTest implements \Drupal\KernelTests\Core\KeyValueStore\StorageTestBase
- class \Drupal\KernelTests\Core\KeyValueStore\StorageTestBase implements \Drupal\KernelTests\KernelTestBase
Expanded class hierarchy of DatabaseStorageTest
File
-
core/
tests/ Drupal/ KernelTests/ Core/ KeyValueStore/ DatabaseStorageTest.php, line 15
Namespace
Drupal\KernelTests\Core\KeyValueStoreView source
class DatabaseStorageTest extends StorageTestBase {
/**
* {@inheritdoc}
*/
protected function setUp() : void {
parent::setUp();
$this->factory = 'keyvalue.database';
}
/**
* {@inheritdoc}
*/
public function register(ContainerBuilder $container) {
parent::register($container);
$parameter[KeyValueFactory::DEFAULT_SETTING] = 'keyvalue.database';
$container->setParameter('factory.keyvalue', $parameter);
}
/**
* Tests asynchronous table creation.
*/
public function testConcurrent() {
if (!function_exists('pcntl_fork')) {
$this->markTestSkipped('Requires the pcntl_fork() function');
}
$functions = [];
for ($i = 1; $i <= 10; $i++) {
$functions[] = 'set';
$functions[] = 'getAll';
}
$default_connection = Database::getConnectionInfo();
Database::removeConnection('default');
$time_to_start = microtime(TRUE) + 0.1;
// This loop creates a new fork to set or get key values keys.
foreach ($functions as $i => $function) {
$pid = pcntl_fork();
if ($pid == -1) {
$this->fail("Error forking");
}
elseif ($pid == 0) {
Database::addConnectionInfo('default' . $i, 'default', $default_connection['default']);
Database::setActiveConnection('default' . $i);
// Create a new factory using the new connection to avoid problems with
// forks closing the database connections.
$factory = new KeyValueDatabaseFactory($this->container
->get('serialization.phpserialize'), Database::getConnection());
$store = $factory->get('test');
// Sleep so that all the forks start at the same time.
usleep((int) (($time_to_start - microtime(TRUE)) * 1000000));
if ($function === 'getAll') {
$this->assertIsArray($store->getAll());
}
else {
$this->assertNull($store->set('foo' . $i, 'bar'));
}
exit;
}
}
// This while loop holds the parent process until all the child threads
// are complete - at which point the script continues to execute.
while (pcntl_waitpid(0, $status) != -1) {
}
Database::addConnectionInfo('default', 'default', $default_connection['default']);
$factory = new KeyValueDatabaseFactory($this->container
->get('serialization.phpserialize'), Database::getConnection());
$store = $factory->get('test');
$this->assertCount(10, $store->getAll());
}
}
Buggy or inaccurate documentation? Please file an issue. Need support? Need help programming? Connect with the Drupal community.