mirror of
https://github.com/MariaDB/server.git
synced 2025-01-18 04:53:01 +01:00
8a79fa0e4d
Problem: ======= During dropping of fts index, InnoDB waits for fts_optimize_remove_table() and it holds dict_sys->mutex and dict_operaiton_lock even though the table id is not present in the queue. But fts_optimize_thread does wait for dict_sys->mutex to process the unrelated table id from the slot. Solution: ======== Whenever table is added to fts_optimize_wq, update the fts_status of in-memory fts subsystem to TABLE_IN_QUEUE. Whenever drop index wants to remove table from the queue, it can check the fts_status to decide whether it should send the MSG_DELETE_TABLE to the queue. Removed the following functions because these are all deadcode. dict_table_wait_for_bg_threads_to_exit(), fts_wait_for_background_thread_to_start(),fts_start_shutdown(), fts_shudown().
309 lines
8 KiB
C++
309 lines
8 KiB
C++
/*****************************************************************************
|
|
|
|
Copyright (c) 2007, 2013, Oracle and/or its affiliates. All Rights Reserved.
|
|
Copyright (c) 2019, MariaDB Corporation.
|
|
|
|
This program is free software; you can redistribute it and/or modify it under
|
|
the terms of the GNU General Public License as published by the Free Software
|
|
Foundation; version 2 of the License.
|
|
|
|
This program is distributed in the hope that it will be useful, but WITHOUT
|
|
ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
|
|
FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License along with
|
|
this program; if not, write to the Free Software Foundation, Inc.,
|
|
51 Franklin Street, Fifth Floor, Boston, MA 02110-1335 USA
|
|
|
|
*****************************************************************************/
|
|
|
|
/**************************************************//**
|
|
@file fts/fts0sql.cc
|
|
Full Text Search functionality.
|
|
|
|
Created 2007-03-27 Sunny Bains
|
|
*******************************************************/
|
|
|
|
#include "que0que.h"
|
|
#include "trx0roll.h"
|
|
#include "pars0pars.h"
|
|
#include "dict0dict.h"
|
|
#include "fts0types.h"
|
|
#include "fts0priv.h"
|
|
|
|
#ifndef UNIV_NONINL
|
|
#include "fts0types.ic"
|
|
#include "fts0vlc.ic"
|
|
#endif
|
|
|
|
/** SQL statements for creating the ancillary FTS tables. */
|
|
|
|
/** Preamble to all SQL statements. */
|
|
static const char* fts_sql_begin=
|
|
"PROCEDURE P() IS\n";
|
|
|
|
/** Postamble to non-committing SQL statements. */
|
|
static const char* fts_sql_end=
|
|
"\n"
|
|
"END;\n";
|
|
|
|
/******************************************************************//**
|
|
Get the table id.
|
|
@return number of bytes written */
|
|
UNIV_INTERN
|
|
int
|
|
fts_get_table_id(
|
|
/*=============*/
|
|
const fts_table_t*
|
|
fts_table, /*!< in: FTS Auxiliary table */
|
|
char* table_id) /*!< out: table id, must be at least
|
|
FTS_AUX_MIN_TABLE_ID_LENGTH bytes
|
|
long */
|
|
{
|
|
int len;
|
|
bool hex_name = DICT_TF2_FLAG_IS_SET(fts_table->table,
|
|
DICT_TF2_FTS_AUX_HEX_NAME);
|
|
|
|
ut_a(fts_table->table != NULL);
|
|
|
|
switch (fts_table->type) {
|
|
case FTS_COMMON_TABLE:
|
|
len = fts_write_object_id(fts_table->table_id, table_id,
|
|
hex_name);
|
|
break;
|
|
|
|
case FTS_INDEX_TABLE:
|
|
|
|
len = fts_write_object_id(fts_table->table_id, table_id,
|
|
hex_name);
|
|
|
|
table_id[len] = '_';
|
|
++len;
|
|
table_id += len;
|
|
|
|
len += fts_write_object_id(fts_table->index_id, table_id,
|
|
hex_name);
|
|
break;
|
|
|
|
default:
|
|
ut_error;
|
|
}
|
|
|
|
ut_a(len >= 16);
|
|
ut_a(len < FTS_AUX_MIN_TABLE_ID_LENGTH);
|
|
|
|
return(len);
|
|
}
|
|
|
|
/** Construct the name of an internal FTS table for the given table.
|
|
@param[in] fts_table metadata on fulltext-indexed table
|
|
@param[in] dict_locked whether dict_sys->mutex is being held
|
|
@return the prefix, must be freed with ut_free() */
|
|
UNIV_INTERN char* fts_get_table_name_prefix(const fts_table_t* fts_table)
|
|
{
|
|
char table_id[FTS_AUX_MIN_TABLE_ID_LENGTH];
|
|
const size_t table_id_len = size_t(fts_get_table_id(fts_table,
|
|
table_id)) + 1;
|
|
mutex_enter(&dict_sys->mutex);
|
|
const char* slash = strchr(fts_table->table->name, '/');
|
|
ut_ad(slash);
|
|
/* Include the separator as well. */
|
|
const size_t dbname_len = (slash - fts_table->table->name) + 1;
|
|
ut_ad(dbname_len > 1);
|
|
const size_t prefix_name_len = dbname_len + 4 + table_id_len;
|
|
char* prefix_name = static_cast<char*>(ut_malloc(prefix_name_len));
|
|
memcpy(prefix_name, fts_table->table->name, dbname_len);
|
|
mutex_exit(&dict_sys->mutex);
|
|
memcpy(prefix_name + dbname_len, "FTS_", 4);
|
|
memcpy(prefix_name + dbname_len + 4, table_id, table_id_len);
|
|
return prefix_name;
|
|
}
|
|
|
|
/** Construct the name of an internal FTS table for the given table.
|
|
@param[in] fts_table metadata on fulltext-indexed table
|
|
@param[out] table_name a name up to MAX_FULL_NAME_LEN
|
|
@param[in] dict_locked whether dict_sys->mutex is being held */
|
|
UNIV_INTERN
|
|
void fts_get_table_name(const fts_table_t* fts_table, char* table_name,
|
|
bool dict_locked)
|
|
{
|
|
if (!dict_locked) {
|
|
mutex_enter(&dict_sys->mutex);
|
|
}
|
|
ut_ad(mutex_own(&dict_sys->mutex));
|
|
const char* slash = strchr(fts_table->table->name, '/');
|
|
ut_ad(slash);
|
|
/* Include the separator as well. */
|
|
const size_t dbname_len = (slash - fts_table->table->name) + 1;
|
|
ut_ad(dbname_len > 1);
|
|
memcpy(table_name, fts_table->table->name, dbname_len);
|
|
if (!dict_locked) {
|
|
mutex_exit(&dict_sys->mutex);
|
|
}
|
|
memcpy(table_name += dbname_len, "FTS_", 4);
|
|
table_name += 4;
|
|
table_name += fts_get_table_id(fts_table, table_name);
|
|
*table_name++ = '_';
|
|
strcpy(table_name, fts_table->suffix);
|
|
}
|
|
|
|
/******************************************************************//**
|
|
Parse an SQL string. %s is replaced with the table's id.
|
|
@return query graph */
|
|
UNIV_INTERN
|
|
que_t*
|
|
fts_parse_sql(
|
|
/*==========*/
|
|
fts_table_t* fts_table, /*!< in: FTS auxiliarry table info */
|
|
pars_info_t* info, /*!< in: info struct, or NULL */
|
|
const char* sql) /*!< in: SQL string to evaluate */
|
|
{
|
|
char* str;
|
|
que_t* graph;
|
|
ibool dict_locked;
|
|
|
|
str = ut_str3cat(fts_sql_begin, sql, fts_sql_end);
|
|
|
|
dict_locked = (fts_table && fts_table->table->fts
|
|
&& fts_table->table->fts->dict_locked);
|
|
|
|
if (!dict_locked) {
|
|
ut_ad(!mutex_own(&(dict_sys->mutex)));
|
|
|
|
/* The InnoDB SQL parser is not re-entrant. */
|
|
mutex_enter(&dict_sys->mutex);
|
|
}
|
|
|
|
graph = pars_sql(info, str);
|
|
ut_a(graph);
|
|
|
|
if (!dict_locked) {
|
|
mutex_exit(&dict_sys->mutex);
|
|
}
|
|
|
|
mem_free(str);
|
|
|
|
return(graph);
|
|
}
|
|
|
|
/******************************************************************//**
|
|
Parse an SQL string.
|
|
@return query graph */
|
|
UNIV_INTERN
|
|
que_t*
|
|
fts_parse_sql_no_dict_lock(
|
|
/*=======================*/
|
|
fts_table_t* fts_table, /*!< in: FTS aux table info */
|
|
pars_info_t* info, /*!< in: info struct, or NULL */
|
|
const char* sql) /*!< in: SQL string to evaluate */
|
|
{
|
|
char* str;
|
|
que_t* graph;
|
|
|
|
ut_ad(mutex_own(&dict_sys->mutex));
|
|
|
|
str = ut_str3cat(fts_sql_begin, sql, fts_sql_end);
|
|
|
|
graph = pars_sql(info, str);
|
|
ut_a(graph);
|
|
|
|
mem_free(str);
|
|
|
|
return(graph);
|
|
}
|
|
|
|
/******************************************************************//**
|
|
Evaluate an SQL query graph.
|
|
@return DB_SUCCESS or error code */
|
|
UNIV_INTERN
|
|
dberr_t
|
|
fts_eval_sql(
|
|
/*=========*/
|
|
trx_t* trx, /*!< in: transaction */
|
|
que_t* graph) /*!< in: Query graph to evaluate */
|
|
{
|
|
que_thr_t* thr;
|
|
|
|
graph->trx = trx;
|
|
graph->fork_type = QUE_FORK_MYSQL_INTERFACE;
|
|
|
|
ut_a(thr = que_fork_start_command(graph));
|
|
|
|
que_run_threads(thr);
|
|
|
|
return(trx->error_state);
|
|
}
|
|
|
|
/******************************************************************//**
|
|
Construct the column specification part of the SQL string for selecting the
|
|
indexed FTS columns for the given table. Adds the necessary bound
|
|
ids to the given 'info' and returns the SQL string. Examples:
|
|
|
|
One indexed column named "text":
|
|
|
|
"$sel0",
|
|
info/ids: sel0 -> "text"
|
|
|
|
Two indexed columns named "subject" and "content":
|
|
|
|
"$sel0, $sel1",
|
|
info/ids: sel0 -> "subject", sel1 -> "content",
|
|
@return heap-allocated WHERE string */
|
|
UNIV_INTERN
|
|
const char*
|
|
fts_get_select_columns_str(
|
|
/*=======================*/
|
|
dict_index_t* index, /*!< in: index */
|
|
pars_info_t* info, /*!< in/out: parser info */
|
|
mem_heap_t* heap) /*!< in: memory heap */
|
|
{
|
|
ulint i;
|
|
const char* str = "";
|
|
|
|
for (i = 0; i < index->n_user_defined_cols; i++) {
|
|
char* sel_str;
|
|
|
|
dict_field_t* field = dict_index_get_nth_field(index, i);
|
|
|
|
sel_str = mem_heap_printf(heap, "sel%lu", (ulong) i);
|
|
|
|
/* Set copy_name to TRUE since it's dynamic. */
|
|
pars_info_bind_id(info, TRUE, sel_str, field->name);
|
|
|
|
str = mem_heap_printf(
|
|
heap, "%s%s$%s", str, (*str) ? ", " : "", sel_str);
|
|
}
|
|
|
|
return(str);
|
|
}
|
|
|
|
/******************************************************************//**
|
|
Commit a transaction.
|
|
@return DB_SUCCESS or error code */
|
|
UNIV_INTERN
|
|
dberr_t
|
|
fts_sql_commit(
|
|
/*===========*/
|
|
trx_t* trx) /*!< in: transaction */
|
|
{
|
|
dberr_t error;
|
|
|
|
error = trx_commit_for_mysql(trx);
|
|
|
|
/* Commit should always succeed */
|
|
ut_a(error == DB_SUCCESS);
|
|
|
|
return(DB_SUCCESS);
|
|
}
|
|
|
|
/******************************************************************//**
|
|
Rollback a transaction.
|
|
@return DB_SUCCESS or error code */
|
|
UNIV_INTERN
|
|
dberr_t
|
|
fts_sql_rollback(
|
|
/*=============*/
|
|
trx_t* trx) /*!< in: transaction */
|
|
{
|
|
return(trx_rollback_to_savepoint(trx, NULL));
|
|
}
|