);

CREATEUNIQUE INDEXaqo_fss_access_idxONpublic.aqo_data (fspace_hash, fsspace_hash);

CREATE OR REPLACEFUNCTIONpublic.clean_aqo_data() RETURNS voidAS $$

DECLARE

aqo_data_row aqo_data%ROWTYPE;

aqo_queries_row aqo_queries%ROWTYPE;

aqo_query_texts_row aqo_query_texts%ROWTYPE;

aqo_query_stat_row aqo_query_stat%ROWTYPE;

oid_varoid;

fspace_hash_varbigint;

delete_rowboolean DEFAULT false;

FOR aqo_data_rowIN (SELECT*FROM aqo_data)

LOOP

delete_row= false;

SELECTaqo_data_row.fspace_hash INTO fspace_hash_varFROM aqo_data;

IF (aqo_data_row.oidsIS NOT NULL) THEN

FOREACH oid_varIN ARRAYaqo_data_row.oids

LOOP

IF NOT EXISTS (SELECT relnameFROM pg_classWHEREoid= oid_var) THEN

delete_row= true;

END IF;

END LOOP;

END IF;

FOR aqo_queries_rowIN (SELECT*FROMpublic.aqo_queries)

LOOP

IF (delete_row= trueAND fspace_hash_var<>0AND

fspace_hash_var=aqo_queries_row.fspace_hashAND

aqo_queries_row.fspace_hash=aqo_queries_row.query_hash) THEN

DELETEFROM aqo_dataWHERE aqo_data= aqo_data_row;

DELETEFROM aqo_queriesWHERE aqo_queries= aqo_queries_row;

FOR aqo_query_texts_rowIN (SELECT*FROM aqo_query_texts)

LOOP

DELETEFROM aqo_query_texts

WHEREaqo_query_texts_row.query_hash= fspace_hash_varAND

aqo_query_texts= aqo_query_texts_row;

END LOOP;

FOR aqo_query_stat_rowIN (SELECT*FROM aqo_query_stat)

LOOP

DELETEFROM aqo_query_stat

WHEREaqo_query_stat_row.query_hash= fspace_hash_varAND

aqo_query_stat= aqo_query_stat_row;

END LOOP;

END IF;

END LOOP;

END LOOP;

END;

$$ LANGUAGE plpgsql;

DROPFUNCTIONpublic.top_time_queries;

DROPFUNCTIONpublic.aqo_drop;

DROPFUNCTIONpublic.clean_aqo_data;