zpc_gitlink
/
openGauss-server
forked from huawei/openGauss-server
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix bugs on the index advisor: repair log extraction function

This commit is contained in:
liuly 2021-08-03 12:31:45 +00:00 committed by Gitee
parent cb7199ad10
commit afc8573e0c
1 changed files with 3 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/gausskernel/dbmind/tools/index_advisor/extract_log.py
View File

@ -36,13 +36,10 @@ def get_workload_template(templates, sqls):
def output_valid_sql(sql):
is_quotation_valid = sql.count("'") % 2
if 'from pg_' in sql.lower() or ' join ' in sql.lower() or is_quotation_valid:
if 'from pg_' in sql.lower() or is_quotation_valid:
return ''
if any(tp in sql.lower() for tp in SQL_TYPE[1:]) or \
(SQL_TYPE[0] in sql.lower() and 'from ' in sql.lower()):
if ' where ' in sql.lower() and \
len(re.search(r'\s+where\s+(.*)', sql, flags=re.I).group(1)) > 256:
return ''
sql = re.sub(r'for\s+update[\s;]*$', '', sql, flags=re.I)
return sql.strip() if sql.endswith('; ') else sql + ';'
return ''
@ -105,12 +102,8 @@ def get_parsed_sql(file, user, database, sql_amount, statement):
param_list.sort(key=lambda x: int(x[0].strip(' $')),
reverse=True)
for item in param_list:
if len(item[1].strip()) >= 256:
sql = sql.replace(item[0].strip() if re.match(r'\$', item[0]) else
('$' + item[0].strip()), "''")
else:
sql = sql.replace(item[0].strip() if re.match(r'\$', item[0]) else
('$' + item[0].strip()), item[1].strip())
sql = sql.replace(item[0].strip() if re.match(r'\$', item[0]) else
('$' + item[0].strip()), item[1].strip())
if output_valid_sql(sql):
SQL_AMOUNT += 1
yield output_valid_sql(sql)