hcq/oceanbase
hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[FTS] add rowkey exist for fts index table

Browse Source
This commit is contained in:
Tyshawn 2024-12-17 20:45:34 +00:00 committed by ob-robot
parent bb0f03a92b
commit 2c236c259a
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/storage/ls/ob_ls_tablet_service.cpp
View File

@ -4468,8 +4468,11 @@ int ObLSTabletService::insert_tablet_rows(
{
int ret = OB_SUCCESS;
ObRelativeTable &table = run_ctx.relative_table_;
#ifdef OB_BUILD_PACKAGE
const bool check_exists = !table.is_storage_index_table() || table.is_unique_index();
#else
const bool check_exists = !table.is_storage_index_table() || table.is_unique_index() || table.is_fts_index();
#endif
// 1. Defensive checking of new rows.
if (GCONF.enable_defensive_check()) {
for (int64_t i = 0; OB_SUCC(ret) && i < row_count; i++) {
@ -4503,6 +4506,12 @@ int ObLSTabletService::insert_tablet_rows(
blocksstable::ObDatumRowkey &duplicate_rowkey = rows_info.get_conflict_rowkey();
LOG_WARN("Rowkey already exist", K(ret), K(table), K(duplicate_rowkey),
K(rows_info.get_conflict_idx()));
#ifndef OB_BUILD_PACKAGE
if (table.is_fts_index()) {
ret = OB_ERR_UNEXPECTED;
LOG_ERROR("unexpected error, duplicated row", K(ret), K(table));
}
#endif
} else if (OB_TRY_LOCK_ROW_CONFLICT != ret) {
LOG_WARN("Failed to insert rows to tablet", K(ret), K(rows_info));
}