applyCustomEntities example

class SchemaUpdaterTest extends TestCase
{
    public function testDefaultFields(): void
    {
        $entity = [
            'name' => 'custom_entity_empty_entity',
            'fields' => '[]',
        ];
        $schema = new Schema();

        $updater = new SchemaUpdater();
        $updater->applyCustomEntities($schema, [$entity]);

        $this->assertColumns($schema, 'custom_entity_empty_entity', ['id', 'created_at', 'updated_at']);
    }

    public function testShortPrefix(): void
    {
        $entity = [
            'name' => 'ce_empty_entity',
            'fields' => '[]',
        ];
        $schema = new Schema();

        

        $this->connection->getDatabasePlatform()->registerDoctrineTypeMapping('enum', 'string');

        $this->lock(function D): void {
            /** @var list<array{name: string, fields: string}> $tables */
            $tables = $this->connection->fetchAllAssociative('SELECT name, fields FROM custom_entity');

            $schema = $this->connection->createSchemaManager()->introspectSchema();

            $this->cleanup($schema);

            $this->schemaUpdater->applyCustomEntities($schema, $tables);

            $this->applyNewSchema($schema);
        });
    }

    private function lock(\Closure $closure): void
    {
        $lock = $this->lockFactory->createLock('custom-entity::schema-update', 30);

        if ($lock->acquire(true)) {
            $closure();