function MigrateSqlIdMapEnsureTablesTest::testEnsureTablesNotExist

Tests the ensureTables method when the tables do not exist.

File

core/modules/migrate/tests/src/Unit/MigrateSqlIdMapEnsureTablesTest.php, line 26

Class

MigrateSqlIdMapEnsureTablesTest

Tests the SQL ID map plugin ensureTables() method.

Namespace

Code

public function testEnsureTablesNotExist() {
    $fields['source_ids_hash'] = [
        'type' => 'varchar',
        'length' => 64,
        'not null' => 1,
        'description' => 'Hash of source ids. Used as primary key',
    ];
    $fields['sourceid1'] = [
        'type' => 'int',
        'not null' => TRUE,
    ];
    $fields['sourceid2'] = [
        'type' => 'int',
        'not null' => TRUE,
    ];
    $fields['destid1'] = [
        'type' => 'varchar',
        'length' => 255,
        'not null' => FALSE,
    ];
    $fields['source_row_status'] = [
        'type' => 'int',
        'size' => 'tiny',
        'unsigned' => TRUE,
        'not null' => TRUE,
        'default' => MigrateIdMapInterface::STATUS_IMPORTED,
        'description' => 'Indicates current status of the source row',
    ];
    $fields['rollback_action'] = [
        'type' => 'int',
        'size' => 'tiny',
        'unsigned' => TRUE,
        'not null' => TRUE,
        'default' => MigrateIdMapInterface::ROLLBACK_DELETE,
        'description' => 'Flag indicating what to do for this item on rollback',
    ];
    $fields['last_imported'] = [
        'type' => 'int',
        'unsigned' => TRUE,
        'not null' => TRUE,
        'default' => 0,
        'description' => 'UNIX timestamp of the last time this row was imported',
    ];
    $fields['hash'] = [
        'type' => 'varchar',
        'length' => '64',
        'not null' => FALSE,
        'description' => 'Hash of source row data, for detecting changes',
    ];
    $map_table_schema = [
        'description' => 'Mappings from source identifier value(s) to destination identifier value(s).',
        'fields' => $fields,
        'primary key' => [
            'source_ids_hash',
        ],
        'indexes' => [
            'source' => [
                'sourceid1',
                'sourceid2',
            ],
        ],
    ];
    $schema = $this->getMockBuilder('Drupal\\Core\\Database\\Schema')
        ->disableOriginalConstructor()
        ->getMock();
    $schema->expects($this->at(0))
        ->method('tableExists')
        ->with('migrate_map_sql_idmap_test')
        ->will($this->returnValue(FALSE));
    $schema->expects($this->at(1))
        ->method('createTable')
        ->with('migrate_map_sql_idmap_test', $map_table_schema);
    // Now do the message table.
    $fields = [];
    $fields['msgid'] = [
        'type' => 'serial',
        'unsigned' => TRUE,
        'not null' => TRUE,
    ];
    $fields['source_ids_hash'] = [
        'type' => 'varchar',
        'length' => 64,
        'not null' => 1,
        'description' => 'Hash of source ids. Used as primary key',
    ];
    $fields['level'] = [
        'type' => 'int',
        'unsigned' => TRUE,
        'not null' => TRUE,
        'default' => 1,
    ];
    $fields['message'] = [
        'type' => 'text',
        'size' => 'medium',
        'not null' => TRUE,
    ];
    $table_schema = [
        'description' => 'Messages generated during a migration process',
        'fields' => $fields,
        'primary key' => [
            'msgid',
        ],
    ];
    $schema->expects($this->at(2))
        ->method('tableExists')
        ->with('migrate_message_sql_idmap_test')
        ->will($this->returnValue(FALSE));
    $schema->expects($this->at(3))
        ->method('createTable')
        ->with('migrate_message_sql_idmap_test', $table_schema);
    $schema->expects($this->any())
        ->method($this->anything());
    $this->runEnsureTablesTest($schema);
}