View source
<?php
class WebformLastDownload extends Migration {
public function __construct(array $arguments) {
parent::__construct($arguments);
$simple_fields = array(
'requested',
);
$complex_fields = array(
'nid',
'uid',
'sid',
);
$fields = array_merge($simple_fields, $complex_fields);
$query = $this
->query($fields);
$table_name = 'webform_last_download';
$this->source = new MigrateSourceSQL($query, $fields, NULL, array(
'map_joinable' => FALSE,
'skip_count' => FALSE,
));
$this->destination = new MigrateDestinationTable($table_name);
$this->map = new MigrateSQLMap($this->machineName, array(
'nid' => array(
'type' => 'int',
'unsigned' => TRUE,
'not null' => TRUE,
'description' => 'Source node ID',
'alias' => 'n',
),
'uid' => array(
'type' => 'int',
'unsigned' => TRUE,
'not null' => TRUE,
'description' => 'Source component ID',
'alias' => 'u',
),
), MigrateDestinationTable::getKeySchema($table_name));
$this
->addSimpleMappings($simple_fields);
$this
->addFieldMapping('nid', 'nid')
->sourceMigration($arguments['node_migrations']);
if (variable_get('migrate_webform_user_map_ok', FALSE)) {
$this
->removeFieldMapping('uid');
$this
->addFieldMapping('uid', 'uid')
->sourceMigration(variable_get('migrate_webform_user_migration_class', ""))
->defaultValue(1);
}
else {
$this
->removeFieldMapping('uid');
$this
->addFieldMapping('uid', 'uid')
->defaultValue(1);
}
$this
->addFieldMapping('sid', 'sid')
->sourceMigration('WebformSubmissions');
}
protected function query($fields) {
$connection = migrate_webform_get_source_connection();
$query = $connection
->select('webform_last_download', 'wld')
->fields('wld', $fields)
->orderBy('nid', 'ASC');
return $query;
}
public function prepareRow($row) {
if (parent::prepareRow($row) === FALSE) {
return FALSE;
}
}
public function prepare($entity, $row) {
}
}