database/openGauss-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Support get unique sql without sql query

Browse Source
This commit is contained in:
totaj
2025-06-11 09:27:11 +08:00
parent 0f9ccd37ca
commit eb2cf72488
2 changed files with 14 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/gausskernel/cbb/instruments/unique_sql/instr_unique_sql.cpp
View File

@ -2697,8 +2697,9 @@ void ResetCurrentUniqueSQL(bool need_reset_cn_id)
u_sess->unique_sql_cxt.force_generate_unique_sql = false;
}
void FindUniqueSQL(UniqueSQLKey key, char* unique_sql)
bool FindUniqueSQL(UniqueSQLKey key, char* unique_sql)
{
bool res = false;
errno_t rc = 0;
uint32 hashCode = uniqueSQLHashCode(&key, sizeof(key));
(void)LockUniqueSQLHashPartition(hashCode, LW_SHARED);
@ -2706,13 +2707,20 @@ void FindUniqueSQL(UniqueSQLKey key, char* unique_sql)
UniqueSQL *entry = (UniqueSQL*)hash_search(g_instance.stat_cxt.UniqueSQLHashtbl, &key, HASH_FIND, NULL);
if (entry == NULL) {
rc = strcpy_s(unique_sql, UNIQUE_SQL_MAX_LEN, "");
securec_check(rc, "\0", "\0");
if (unique_sql != NULL) {
rc = strcpy_s(unique_sql, UNIQUE_SQL_MAX_LEN, "");
securec_check(rc, "\0", "\0");
}
res = false;
} else {
rc = strcpy_s(unique_sql, UNIQUE_SQL_MAX_LEN, entry->unique_sql);
securec_check(rc, "\0", "\0");
if (unique_sql != NULL) {
rc = strcpy_s(unique_sql, UNIQUE_SQL_MAX_LEN, entry->unique_sql);
securec_check(rc, "\0", "\0");
}
res = true;
}
UnlockUniqueSQLHashPartition(hashCode);
return res;
}
char* FindCurrentUniqueSQL()

2
src/include/instruments/instr_unique_sql.h
View File

@ -217,7 +217,7 @@ bool isUniqueSQLContextInvalid();
void UpdateSingleNodeByPassUniqueSQLStat(bool isTopLevel);
void UpdateUniqueSQLHashStats(HashJoinTable hashtable, TimestampTz* start_time);
void UpdateUniqueSQLVecSortStats(Batchsortstate* state, uint64 spill_count, TimestampTz* start_time);
void FindUniqueSQL(UniqueSQLKey key, char* unique_sql);
bool FindUniqueSQL(UniqueSQLKey key, char* unique_sql);
char* FindCurrentUniqueSQL();
bool is_instr_top_portal();