search_api.install in Search API 7
Same filename and directory in other branches
Install, update and uninstall functions for the Search API module.
File
search_api.installView source
<?php
/**
* @file
* Install, update and uninstall functions for the Search API module.
*/
/**
* Implements hook_schema().
*/
function search_api_schema() {
$schema['search_api_server'] = array(
'description' => 'Stores all search servers created through the Search API.',
'fields' => array(
'id' => array(
'description' => 'The primary identifier for a server.',
'type' => 'serial',
'unsigned' => TRUE,
'not null' => TRUE,
),
'name' => array(
'description' => 'The displayed name for a server.',
'type' => 'varchar',
'length' => 50,
'not null' => TRUE,
),
'machine_name' => array(
'description' => 'The machine name for a server.',
'type' => 'varchar',
'length' => 50,
'not null' => TRUE,
),
'description' => array(
'description' => 'The displayed description for a server.',
'type' => 'text',
'not null' => FALSE,
),
'class' => array(
'description' => 'The id of the service class to use for this server.',
'type' => 'varchar',
'length' => 50,
'not null' => TRUE,
),
'options' => array(
'description' => 'The options used to configure the service object.',
'type' => 'text',
'size' => 'medium',
'serialize' => TRUE,
'not null' => TRUE,
),
'enabled' => array(
'description' => 'A flag indicating whether the server is enabled.',
'type' => 'int',
'size' => 'tiny',
'not null' => TRUE,
'default' => 1,
),
'status' => array(
'description' => 'The exportable status of the entity.',
'type' => 'int',
'not null' => TRUE,
'default' => 0x1,
'size' => 'tiny',
),
'module' => array(
'description' => 'The name of the providing module if the entity has been defined in code.',
'type' => 'varchar',
'length' => 255,
'not null' => FALSE,
),
),
'indexes' => array(
'enabled' => array(
'enabled',
),
),
'unique keys' => array(
'machine_name' => array(
'machine_name',
),
),
'primary key' => array(
'id',
),
);
$schema['search_api_index'] = array(
'description' => 'Stores all search indexes on a {search_api_server}.',
'fields' => array(
'id' => array(
'description' => 'An integer identifying the index.',
'type' => 'serial',
'unsigned' => TRUE,
'not null' => TRUE,
),
'name' => array(
'description' => 'A name to be displayed for the index.',
'type' => 'varchar',
'length' => 50,
'not null' => TRUE,
),
'machine_name' => array(
'description' => 'The machine name of the index.',
'type' => 'varchar',
'length' => 50,
'not null' => TRUE,
),
'description' => array(
'description' => "A string describing the index' use to users.",
'type' => 'text',
'not null' => FALSE,
),
'server' => array(
'description' => 'The {search_api_server}.machine_name with which data should be indexed.',
'type' => 'varchar',
'length' => 50,
'not null' => FALSE,
),
'item_type' => array(
'description' => 'The type of items stored in this index.',
'type' => 'varchar',
'length' => 50,
'not null' => TRUE,
),
'options' => array(
'description' => 'An array of additional arguments configuring this index.',
'type' => 'text',
'size' => 'medium',
'serialize' => TRUE,
'not null' => TRUE,
),
'enabled' => array(
'description' => 'A flag indicating whether this index is enabled.',
'type' => 'int',
'size' => 'tiny',
'not null' => TRUE,
'default' => 1,
),
'read_only' => array(
'description' => 'A flag indicating whether to write to this index.',
'type' => 'int',
'size' => 'tiny',
'not null' => TRUE,
'default' => 0,
),
'status' => array(
'description' => 'The exportable status of the entity.',
'type' => 'int',
'not null' => TRUE,
'default' => 0x1,
'size' => 'tiny',
),
'module' => array(
'description' => 'The name of the providing module if the entity has been defined in code.',
'type' => 'varchar',
'length' => 255,
'not null' => FALSE,
),
),
'indexes' => array(
'item_type' => array(
'item_type',
),
'server' => array(
'server',
),
'enabled' => array(
'enabled',
),
),
'unique keys' => array(
'machine_name' => array(
'machine_name',
),
),
'primary key' => array(
'id',
),
);
$schema['search_api_item'] = array(
'description' => 'Stores the items which should be indexed for each index, and their status.',
'fields' => array(
'item_id' => array(
'description' => "The item's entity id (e.g. {node}.nid for nodes).",
'type' => 'int',
'unsigned' => TRUE,
'not null' => TRUE,
),
'index_id' => array(
'description' => 'The {search_api_index}.id this item belongs to.',
'type' => 'int',
'unsigned' => TRUE,
'not null' => TRUE,
),
'changed' => array(
'description' => 'Either a flag or a timestamp to indicate if or when the item was changed since it was last indexed.',
'type' => 'int',
'size' => 'big',
'not null' => TRUE,
'default' => 1,
),
),
'indexes' => array(
'indexing' => array(
'index_id',
'changed',
),
),
'primary key' => array(
'item_id',
'index_id',
),
);
$schema['search_api_item_string_id'] = array(
'description' => 'Stores the items which should be indexed for each index, and their status. Used only for items with string IDs.',
'fields' => array(
'item_id' => array(
'description' => "The item's ID.",
'type' => 'varchar',
'length' => 64,
'not null' => TRUE,
),
'index_id' => array(
'description' => 'The {search_api_index}.id this item belongs to.',
'type' => 'int',
'unsigned' => TRUE,
'not null' => TRUE,
),
'changed' => array(
'description' => 'Either a flag or a timestamp to indicate if or when the item was changed since it was last indexed.',
'type' => 'int',
'size' => 'big',
'not null' => TRUE,
'default' => 1,
),
),
'indexes' => array(
'indexing' => array(
'index_id',
'changed',
),
),
'primary key' => array(
'item_id',
'index_id',
),
);
$schema['search_api_task'] = array(
'description' => 'Stores pending tasks for servers.',
'fields' => array(
'id' => array(
'description' => 'An integer identifying this task.',
'type' => 'serial',
'unsigned' => TRUE,
'not null' => TRUE,
),
'server_id' => array(
'description' => 'The {search_api_server}.machine_name for which this task should be executed.',
'type' => 'varchar',
'length' => 50,
'not null' => TRUE,
),
'type' => array(
'description' => 'A keyword identifying the type of task that should be executed.',
'type' => 'varchar',
'length' => 50,
'not null' => TRUE,
),
'index_id' => array(
'description' => 'The {search_api_index}.machine_name to which this task pertains, if applicable for this type.',
'type' => 'varchar',
'length' => 50,
'not null' => FALSE,
),
'data' => array(
'description' => 'Some data needed for the task, might be optional depending on the type.',
'type' => 'text',
'size' => 'medium',
'serialize' => TRUE,
'not null' => FALSE,
),
),
'indexes' => array(
'server' => array(
'server_id',
),
),
'primary key' => array(
'id',
),
);
return $schema;
}
/**
* Implements hook_requirements().
*/
function search_api_requirements($phase) {
$requirements = array();
if ($phase == 'runtime') {
// Check whether at least one server has pending tasks.
if (search_api_server_tasks_count()) {
$items = array();
$conditions = array(
'enabled' => TRUE,
);
foreach (search_api_server_load_multiple(FALSE, $conditions) as $server) {
$count = search_api_server_tasks_count($server);
if ($count) {
$args = array(
'@name' => $server->name,
);
$text = format_plural($count, '@name has @count pending task.', '@name has @count pending tasks.', $args);
$items[] = l($text, "admin/config/search/search_api/server/{$server->machine_name}/execute-tasks");
}
}
if ($items) {
$text = t('There are pending tasks for the following servers:');
$text .= theme('item_list', array(
'type' => 'ul',
'items' => $items,
));
if (count($items) > 1) {
$label = t('Execute pending tasks on all servers');
$text .= l($label, 'admin/config/search/search_api/execute-tasks');
}
$requirements['search_api_pending_tasks'] = array(
'title' => t('Search API'),
'value' => $text,
'severity' => REQUIREMENT_WARNING,
);
}
}
}
return $requirements;
}
/**
* Implements hook_install().
*
* Creates a default node index if the module is installed manually.
*/
function search_api_install() {
// In case the module is installed via an installation profile, a batch is
// active and we skip that.
if (batch_get()) {
return;
}
$name = t('Default node index');
$values = array(
'name' => $name,
'machine_name' => preg_replace('/[^a-z0-9]+/', '_', drupal_strtolower($name)),
'description' => t('An automatically created search index for indexing node data. Might be configured to specific needs.'),
'server' => NULL,
'item_type' => 'node',
'options' => array(
'index_directly' => 1,
'cron_limit' => '50',
'data_alter_callbacks' => array(
'search_api_alter_node_access' => array(
'status' => 1,
'weight' => '0',
'settings' => array(),
),
),
'processors' => array(
'search_api_case_ignore' => array(
'status' => 1,
'weight' => '0',
'settings' => array(
'strings' => 0,
),
),
'search_api_html_filter' => array(
'status' => 1,
'weight' => '10',
'settings' => array(
'title' => 0,
'alt' => 1,
'tags' => "h1 = 5\n" . "h2 = 3\n" . "h3 = 2\n" . "strong = 2\n" . "b = 2\n" . "em = 1.5\n" . "u = 1.5",
),
),
'search_api_tokenizer' => array(
'status' => 1,
'weight' => '20',
'settings' => array(
'spaces' => '[^\\p{L}\\p{N}]',
'ignorable' => '[-]',
),
),
),
'fields' => array(
'type' => array(
'type' => 'string',
),
'title' => array(
'type' => 'text',
'boost' => '5.0',
),
'promote' => array(
'type' => 'boolean',
),
'sticky' => array(
'type' => 'boolean',
),
'created' => array(
'type' => 'date',
),
'changed' => array(
'type' => 'date',
),
'author' => array(
'type' => 'integer',
'entity_type' => 'user',
),
'comment_count' => array(
'type' => 'integer',
),
'search_api_language' => array(
'type' => 'string',
),
'body:value' => array(
'type' => 'text',
),
),
),
);
search_api_index_insert($values);
drupal_set_message(t('The Search API module was installed. A new default node index was created.'));
}
/**
* Implements hook_enable().
*
* Mark all items as "dirty", since we can't know whether they are.
*/
function search_api_enable() {
$types = array();
foreach (search_api_index_load_multiple(FALSE) as $index) {
if ($index->enabled) {
$types[$index->item_type][] = $index;
}
}
foreach ($types as $type => $indexes) {
try {
$controller = search_api_get_datasource_controller($type);
$controller
->startTracking($indexes);
} catch (SearchApiException $e) {
watchdog_exception('search_api', $e);
}
}
}
/**
* Implements hook_disable().
*/
function search_api_disable() {
$types = array();
foreach (search_api_index_load_multiple(FALSE) as $index) {
$types[$index->item_type][] = $index;
}
foreach ($types as $type => $indexes) {
try {
$controller = search_api_get_datasource_controller($type);
$controller
->stopTracking($indexes);
} catch (SearchApiException $e) {
// Modules defining entity or item types might have been disabled. Ignore.
}
}
}
/**
* Implements hook_uninstall().
*/
function search_api_uninstall() {
variable_del('search_api_index_worker_callback_runtime');
}
/**
* Update function that adds the machine names for servers and indexes.
*/
function search_api_update_7101() {
$tx = db_transaction();
try {
// Servers
$spec = array(
'description' => 'The machine name for a server.',
'type' => 'varchar',
'length' => 50,
'not null' => TRUE,
'default' => '',
);
db_add_field('search_api_server', 'machine_name', $spec);
$names = array();
$servers = db_select('search_api_server', 's')
->fields('s')
->execute();
foreach ($servers as $server) {
$base = $name = drupal_strtolower(preg_replace('/[^a-z0-9]+/i', '_', $server->name));
$i = 0;
while (isset($names[$name])) {
$name = $base . '_' . ++$i;
}
$names[$name] = TRUE;
db_update('search_api_server')
->fields(array(
'machine_name' => $name,
))
->condition('id', $server->id)
->execute();
}
db_add_unique_key('search_api_server', 'machine_name', array(
'machine_name',
));
//Indexes
$spec = array(
'description' => 'The machine name of the index.',
'type' => 'varchar',
'length' => 50,
'not null' => TRUE,
'default' => '',
);
db_add_field('search_api_index', 'machine_name', $spec);
$names = array();
$indexes = db_select('search_api_index', 'i')
->fields('i')
->execute();
foreach ($indexes as $index) {
$base = $name = drupal_strtolower(preg_replace('/[^a-z0-9]+/i', '_', $index->name));
$i = 0;
while (isset($names[$name])) {
$name = $base . '_' . ++$i;
}
$names[$name] = TRUE;
db_update('search_api_index')
->fields(array(
'machine_name' => $name,
))
->condition('id', $index->id)
->execute();
}
db_add_unique_key('search_api_index', 'machine_name', array(
'machine_name',
));
} catch (Exception $e) {
$tx
->rollback();
try {
db_drop_field('search_api_server', 'machine_name');
db_drop_field('search_api_index', 'machine_name');
} catch (Exception $e1) {
// Ignore.
}
throw new DrupalUpdateException(t('An exception occurred during the update: @msg.', array(
'@msg' => $e
->getMessage(),
)));
}
}
/**
* Update replacing IDs with machine names for foreign keys.
* {search_api_index}.server and {search_api_item}.index_id are altered.
*/
function search_api_update_7102() {
// Update of search_api_index:
$indexes = array();
$select = db_select('search_api_index', 'i')
->fields('i');
foreach ($select
->execute() as $index) {
$indexes[$index->id] = $index;
}
$servers = db_select('search_api_server', 's')
->fields('s', array(
'id',
'machine_name',
))
->execute()
->fetchAllKeyed();
db_drop_index('search_api_index', 'server');
db_drop_field('search_api_index', 'server');
$spec = array(
'description' => 'The {search_api_server}.machine_name with which data should be indexed.',
'type' => 'varchar',
'length' => 50,
'not null' => FALSE,
);
db_add_field('search_api_index', 'server', $spec);
foreach ($indexes as $index) {
db_update('search_api_index')
->fields(array(
'server' => $servers[$index->server],
))
->condition('id', $index->id)
->execute();
}
db_add_index('search_api_index', 'server', array(
'server',
));
// Update of search_api_item:
db_drop_index('search_api_item', 'indexing');
db_drop_primary_key('search_api_item');
$spec = array(
'description' => 'The {search_api_index}.machine_name this item belongs to.',
'type' => 'varchar',
'length' => 50,
'not null' => TRUE,
);
$keys_new = array(
'indexes' => array(
'indexing' => array(
'index_id',
'changed',
),
),
'primary key' => array(
'item_id',
'index_id',
),
);
db_change_field('search_api_item', 'index_id', 'index_id', $spec, $keys_new);
foreach ($indexes as $index) {
// We explicitly forbid numeric machine names, therefore we don't have to
// worry about conflicts here.
db_update('search_api_item')
->fields(array(
'index_id' => $index->machine_name,
))
->condition('index_id', $index->id)
->execute();
}
}
/**
* Add the database fields newly required for entities by the Entity API.
*/
function search_api_update_7103() {
if (!function_exists('entity_exportable_schema_fields')) {
throw new DrupalUpdateException(t('Please update the Entity API module first.'));
}
foreach (array(
'search_api_server',
'search_api_index',
) as $table) {
foreach (entity_exportable_schema_fields() as $field => $spec) {
db_add_field($table, $field, $spec);
}
}
}
/**
* Initialize the "Fields to run on" settings for processors.
*/
function search_api_update_7107() {
$rows = db_select('search_api_index', 'i')
->fields('i', array(
'id',
'options',
))
->execute()
->fetchAllKeyed();
foreach ($rows as $id => $options) {
$opt = unserialize($options);
$processors =& $opt['processors'];
// Only update our own processors, don't mess with others.
$check_processors = array(
'search_api_case_ignore' => 1,
'search_api_html_filter' => 1,
'search_api_tokenizer' => 1,
);
foreach (array_intersect_key($processors, $check_processors) as $name => $info) {
$types = array(
'text',
);
if (!empty($info['settings']['strings'])) {
$types[] = 'string';
unset($processors[$name]['settings']['strings']);
}
foreach ($opt['fields'] as $field => $info) {
if ($info['indexed'] && search_api_is_text_type($info['type'], $types)) {
$processors[$name]['settings']['fields'][$field] = $field;
}
}
}
$opt = serialize($opt);
if ($opt != $options) {
db_update('search_api_index')
->fields(array(
'options' => $opt,
))
->condition('id', $id)
->execute();
}
}
}
/**
* Change {search_api_item}.index_id back to the index' numeric ID.
*/
function search_api_update_7104() {
$select = db_select('search_api_index', 'i')
->fields('i');
foreach ($select
->execute() as $index) {
// We explicitly forbid numeric machine names, therefore we don't have to
// worry about conflicts here.
db_update('search_api_item')
->fields(array(
'index_id' => $index->id,
))
->condition('index_id', $index->machine_name)
->execute();
}
// Update primary key and index.
db_drop_index('search_api_item', 'indexing');
db_drop_primary_key('search_api_item');
$spec = array(
'description' => 'The {search_api_index}.id this item belongs to.',
'type' => 'int',
'unsigned' => TRUE,
'not null' => TRUE,
);
$keys_new = array(
'indexes' => array(
'indexing' => array(
'index_id',
'changed',
),
),
'primary key' => array(
'item_id',
'index_id',
),
);
db_change_field('search_api_item', 'index_id', 'index_id', $spec, $keys_new);
}
/**
* Remove all empty aggregated fields for the search_api_alter_add_fulltext data
* alterations.
*/
function search_api_update_7105() {
$rows = db_select('search_api_index', 'i')
->fields('i', array(
'id',
'options',
))
->execute()
->fetchAllKeyed();
foreach ($rows as $id => $options) {
$opt = unserialize($options);
if (isset($opt['data_alter_callbacks']['search_api_alter_add_fulltext']['settings']['fields'])) {
foreach ($opt['data_alter_callbacks']['search_api_alter_add_fulltext']['settings']['fields'] as $name => $field) {
if (empty($field['name']) || empty($field['fields'])) {
unset($opt['data_alter_callbacks']['search_api_alter_add_fulltext']['settings']['fields'][$name]);
}
}
}
$opt = serialize($opt);
if ($opt != $options) {
db_update('search_api_index')
->fields(array(
'options' => $opt,
))
->condition('id', $id)
->execute();
}
}
}
/**
* Update the settings for the "Aggregated fields" data alteration.
*/
function search_api_update_7106() {
$rows = db_select('search_api_index', 'i')
->fields('i')
->execute()
->fetchAll();
foreach ($rows as $row) {
$opt = unserialize($row->options);
$callbacks =& $opt['data_alter_callbacks'];
if (isset($callbacks['search_api_alter_add_fulltext'])) {
$callbacks['search_api_alter_add_aggregation'] = $callbacks['search_api_alter_add_fulltext'];
unset($callbacks['search_api_alter_add_fulltext']);
if (!empty($callbacks['search_api_alter_add_aggregation']['settings']['fields'])) {
foreach ($callbacks['search_api_alter_add_aggregation']['settings']['fields'] as &$info) {
if (!isset($info['type'])) {
$info['type'] = 'fulltext';
}
}
}
}
$opt = serialize($opt);
if ($opt != $row->options) {
// Mark the entity as overridden, in case it has been defined in code
// only.
$row->status |= 0x1;
db_update('search_api_index')
->fields(array(
'options' => $opt,
'status' => $row->status,
))
->condition('id', $row->id)
->execute();
}
}
}
/**
* Add "read only" property to Search API index entities.
*/
function search_api_update_7108() {
$db_field = array(
'description' => 'A flag indicating whether to write to this index.',
'type' => 'int',
'size' => 'tiny',
'not null' => TRUE,
'default' => 0,
);
db_add_field('search_api_index', 'read_only', $db_field);
return t('Added a "read only" property to index entities.');
}
/**
* Clear entity info cache, as entity controller classes hae changed.
*/
function search_api_update_7109() {
cache_clear_all('entity_info:', 'cache', TRUE);
}
/**
* Rename the "entity_type" field to "item_type" in the {search_api_index} table.
*/
function search_api_update_7110() {
$table = 'search_api_index';
// This index isn't used anymore.
db_drop_index($table, 'entity_type');
// Rename the "item_type" field (and change the description).
$item_type = array(
'description' => 'The type of items stored in this index.',
'type' => 'varchar',
'length' => 50,
'not null' => TRUE,
);
// Also add the new "item_type" index, while we're at it.
$keys_new['indexes']['item_type'] = array(
'item_type',
);
db_change_field($table, 'entity_type', 'item_type', $item_type, $keys_new);
// Mark all indexes in code as "OVERRIDDEN".
db_update($table)
->fields(array(
'status' => 0x3,
))
->condition('status', 0x2)
->execute();
// Clear entity info caches.
cache_clear_all('*', 'cache', TRUE);
}
/**
* Change the definition of the {search_api_item}.changed field.
*/
function search_api_update_7111() {
$spec = array(
'description' => 'Either a flag or a timestamp to indicate if or when the item was changed since it was last indexed.',
'type' => 'int',
'size' => 'big',
'not null' => TRUE,
'default' => 1,
);
db_change_field('search_api_item', 'changed', 'changed', $spec);
}
/**
* Changes the size of the {search_api_index}.options and {search_api_server}.options fields to "medium".
*/
function search_api_update_7112() {
$spec = array(
'description' => 'The options used to configure the service object.',
'type' => 'text',
'size' => 'medium',
'serialize' => TRUE,
'not null' => TRUE,
);
db_change_field('search_api_server', 'options', 'options', $spec);
$spec = array(
'description' => 'An array of additional arguments configuring this index.',
'type' => 'text',
'size' => 'medium',
'serialize' => TRUE,
'not null' => TRUE,
);
db_change_field('search_api_index', 'options', 'options', $spec);
}
/**
* Removes superfluous data from the stored index options.
*/
function search_api_update_7113() {
$indexes = db_select('search_api_index', 'i')
->fields('i')
->execute();
foreach ($indexes as $index) {
$options = unserialize($index->options);
// Weed out fields settings.
if (!empty($options['fields'])) {
foreach ($options['fields'] as $key => $field) {
if (isset($field['indexed']) && !$field['indexed']) {
unset($options['fields'][$key]);
continue;
}
unset($options['fields'][$key]['name'], $options['fields'][$key]['indexed']);
if (isset($field['boost']) && $field['boost'] == '1.0') {
unset($options['fields'][$key]['boost']);
}
}
}
// Weed out processor settings.
if (!empty($options['processors'])) {
// Only weed out settings for our own processors.
$processors = array(
'search_api_case_ignore',
'search_api_html_filter',
'search_api_tokenizer',
'search_api_stopwords',
);
foreach ($processors as $key) {
if (empty($options['processors'][$key])) {
continue;
}
$processor = $options['processors'][$key];
if (empty($processor['settings']['fields'])) {
continue;
}
$fields = array_filter($processor['settings']['fields']);
if ($fields) {
$fields = array_combine($fields, array_fill(0, count($fields), TRUE));
}
$options['processors'][$key]['settings']['fields'] = $fields;
}
}
// Weed out settings for the „Aggregated fields“ data alteration.
if (!empty($options['data_alter_callbacks']['search_api_alter_add_aggregation']['settings']['fields'])) {
unset($options['data_alter_callbacks']['search_api_alter_add_aggregation']['settings']['actions']);
$aggregated_fields =& $options['data_alter_callbacks']['search_api_alter_add_aggregation']['settings']['fields'];
foreach ($aggregated_fields as $key => $field) {
unset($aggregated_fields[$key]['actions']);
if (!empty($field['fields'])) {
$aggregated_fields[$key]['fields'] = array_values(array_filter($field['fields']));
}
}
}
$options = serialize($options);
if ($options != $index->options) {
// Mark the entity as overridden, in case it has been defined in code
// only.
$index->status |= 0x1;
db_update('search_api_index')
->fields(array(
'options' => $options,
'status' => $index->status,
))
->condition('id', $index->id)
->execute();
}
}
}
/**
* Sanitize watchdog messages.
*/
function search_api_update_7114() {
if (db_table_exists('watchdog')) {
try {
$entries = db_select('watchdog', 'w')
->fields('w', array(
'wid',
'message',
))
->condition('type', 'search_api')
->execute();
foreach ($entries as $entry) {
db_update('watchdog')
->fields(array(
'message' => check_plain($entry->message),
))
->condition('wid', $entry->wid)
->execute();
}
} catch (Exception $e) {
throw new DrupalUpdateException(t('An exception occurred during the update: @msg.', array(
'@msg' => $e
->getMessage(),
)));
}
}
}
/**
* Switch to indexing without the use of a cron queue.
*/
function search_api_update_7115() {
variable_del('search_api_batch_per_cron');
DrupalQueue::get('search_api_indexing_queue')
->deleteQueue();
db_update('search_api_item')
->fields(array(
'changed' => 1,
))
->condition('changed', 0, '<')
->execute();
}
/**
* Transfers the tasks for disabled servers to a separate database table.
*/
function search_api_update_7116() {
// Create table.
$table = array(
'description' => 'Stores pending tasks for servers.',
'fields' => array(
'id' => array(
'description' => 'An integer identifying this task.',
'type' => 'serial',
'unsigned' => TRUE,
'not null' => TRUE,
),
'server_id' => array(
'description' => 'The {search_api_server}.machine_name for which this task should be executed.',
'type' => 'varchar',
'length' => 50,
'not null' => TRUE,
),
'type' => array(
'description' => 'A keyword identifying the type of task that should be executed.',
'type' => 'varchar',
'length' => 50,
'not null' => TRUE,
),
'index_id' => array(
'description' => 'The {search_api_index}.machine_name to which this task pertains, if applicable for this type.',
'type' => 'varchar',
'length' => 50,
'not null' => FALSE,
),
'data' => array(
'description' => 'Some data needed for the task, might be optional depending on the type.',
'type' => 'text',
'size' => 'medium',
'serialize' => TRUE,
'not null' => FALSE,
),
),
'indexes' => array(
'server' => array(
'server_id',
),
),
'primary key' => array(
'id',
),
);
db_create_table('search_api_task', $table);
// Collect old tasks.
$tasks = array();
foreach (variable_get('search_api_tasks', array()) as $server => $indexes) {
foreach ($indexes as $index => $old_tasks) {
if (in_array('clear all', $old_tasks)) {
$tasks[] = array(
'server_id' => $server,
'type' => 'deleteItems',
);
}
if (in_array('remove', $old_tasks)) {
$tasks[] = array(
'server_id' => $server,
'type' => 'removeIndex',
'index_id' => $index,
);
}
}
}
variable_del('search_api_tasks');
$select = db_select('search_api_index', 'i')
->fields('i', array(
'machine_name',
'server',
));
$select
->innerJoin('search_api_server', 's', 'i.server = s.machine_name AND s.enabled = 0');
$index_ids = array();
foreach ($select
->execute() as $index) {
$index_ids[] = $index->machine_name;
$tasks[] = array(
'server_id' => $index->server,
'type' => 'removeIndex',
'index_id' => $index->machine_name,
);
}
if ($index_ids) {
db_update('search_api_index')
->fields(array(
'enabled' => 0,
'server' => NULL,
))
->condition('machine_name', $index_ids)
->execute();
}
if ($tasks) {
$insert = db_insert('search_api_task')
->fields(array(
'server_id',
'type',
'index_id',
'data',
));
foreach ($tasks as $task) {
$task += array(
'index_id' => NULL,
'data' => NULL,
);
$insert
->values($task);
}
$insert
->execute();
}
}
/**
* Checks the database for illegal {search_api_index}.server values.
*/
function search_api_update_7117() {
$servers = db_select('search_api_server', 's')
->fields('s', array(
'machine_name',
))
->condition('enabled', 1);
$indexes = db_select('search_api_index', 'i')
->fields('i', array(
'id',
))
->condition('server', $servers, 'NOT IN')
->execute()
->fetchCol();
if ($indexes) {
db_delete('search_api_item')
->condition('index_id', $indexes)
->execute();
db_update('search_api_index')
->fields(array(
'server' => NULL,
'enabled' => 0,
))
->condition('id', $indexes)
->execute();
}
}
/**
* Adds the {search_api_item_string_id} table for items with string IDs.
*/
function search_api_update_7118() {
// Some users have reported that the table already existed for them, for
// whatever reason. Therefore, just bail if the table already exists, assuming
// it already looks as expected.
if (db_table_exists('search_api_item_string_id')) {
return;
}
$table = array(
'description' => 'Stores the items which should be indexed for each index, and their status. Used only for items with string IDs.',
'fields' => array(
'item_id' => array(
'description' => "The item's ID.",
'type' => 'varchar',
'length' => 64,
'not null' => TRUE,
),
'index_id' => array(
'description' => 'The {search_api_index}.id this item belongs to.',
'type' => 'int',
'unsigned' => TRUE,
'not null' => TRUE,
),
'changed' => array(
'description' => 'Either a flag or a timestamp to indicate if or when the item was changed since it was last indexed.',
'type' => 'int',
'size' => 'big',
'not null' => TRUE,
'default' => 1,
),
),
'indexes' => array(
'indexing' => array(
'index_id',
'changed',
),
),
'primary key' => array(
'item_id',
'index_id',
),
);
db_create_table('search_api_item_string_id', $table);
}
Functions
Name | Description |
---|---|
search_api_disable | Implements hook_disable(). |
search_api_enable | Implements hook_enable(). |
search_api_install | Implements hook_install(). |
search_api_requirements | Implements hook_requirements(). |
search_api_schema | Implements hook_schema(). |
search_api_uninstall | Implements hook_uninstall(). |
search_api_update_7101 | Update function that adds the machine names for servers and indexes. |
search_api_update_7102 | Update replacing IDs with machine names for foreign keys. {search_api_index}.server and {search_api_item}.index_id are altered. |
search_api_update_7103 | Add the database fields newly required for entities by the Entity API. |
search_api_update_7104 | Change {search_api_item}.index_id back to the index' numeric ID. |
search_api_update_7105 | Remove all empty aggregated fields for the search_api_alter_add_fulltext data alterations. |
search_api_update_7106 | Update the settings for the "Aggregated fields" data alteration. |
search_api_update_7107 | Initialize the "Fields to run on" settings for processors. |
search_api_update_7108 | Add "read only" property to Search API index entities. |
search_api_update_7109 | Clear entity info cache, as entity controller classes hae changed. |
search_api_update_7110 | Rename the "entity_type" field to "item_type" in the {search_api_index} table. |
search_api_update_7111 | Change the definition of the {search_api_item}.changed field. |
search_api_update_7112 | Changes the size of the {search_api_index}.options and {search_api_server}.options fields to "medium". |
search_api_update_7113 | Removes superfluous data from the stored index options. |
search_api_update_7114 | Sanitize watchdog messages. |
search_api_update_7115 | Switch to indexing without the use of a cron queue. |
search_api_update_7116 | Transfers the tasks for disabled servers to a separate database table. |
search_api_update_7117 | Checks the database for illegal {search_api_index}.server values. |
search_api_update_7118 | Adds the {search_api_item_string_id} table for items with string IDs. |