|
| 1 | +/* contrib/aqo/aqo--1.4--1.5.sql */ |
| 2 | + |
| 3 | +-- complain if script is sourced in psql, rather than via CREATE EXTENSION |
| 4 | +\echo Use "ALTER EXTENSION aqo UPDATE TO '1.5'" to load this file. \quit |
| 5 | + |
| 6 | +/* Remove old interface of the extension */ |
| 7 | +DROP FUNCTION array_mse; |
| 8 | +DROP FUNCTION array_avg; |
| 9 | +DROP FUNCTION public.aqo_clear_hist; -- Should be renamed and reworked |
| 10 | +DROP FUNCTION public.aqo_disable_query; |
| 11 | +DROP FUNCTION public.aqo_drop; |
| 12 | +DROP FUNCTION public.aqo_enable_query; |
| 13 | +DROP FUNCTION public.aqo_ne_queries; -- Not needed anymore due to changing in the logic |
| 14 | +DROP FUNCTION public.aqo_status; |
| 15 | +DROP FUNCTION public.clean_aqo_data; |
| 16 | +DROP FUNCTION public.show_cardinality_errors; |
| 17 | +DROP FUNCTION public.top_time_queries; |
| 18 | +DROP TABLE public.aqo_data CASCADE; |
| 19 | +DROP TABLE public.aqo_queries CASCADE; |
| 20 | +DROP TABLE public.aqo_query_texts CASCADE; |
| 21 | +DROP TABLE public.aqo_query_stat CASCADE; |
| 22 | + |
| 23 | + |
| 24 | +/* |
| 25 | +* VIEWs to discover AQO data. |
| 26 | +*/ |
| 27 | +CREATE FUNCTION aqo_queries ( |
| 28 | +OUT queryid bigint, |
| 29 | +OUT fs bigint, |
| 30 | +OUT learn_aqo boolean, |
| 31 | +OUT use_aqo boolean, |
| 32 | +OUT auto_tuning boolean |
| 33 | +) |
| 34 | +RETURNS SETOF record |
| 35 | +AS 'MODULE_PATHNAME', 'aqo_queries' |
| 36 | +LANGUAGE C STRICT VOLATILE PARALLEL SAFE; |
| 37 | + |
| 38 | +CREATE FUNCTION aqo_query_texts(OUT queryid bigint, OUT query_text text) |
| 39 | +RETURNS SETOF record |
| 40 | +AS 'MODULE_PATHNAME', 'aqo_query_texts' |
| 41 | +LANGUAGE C STRICT VOLATILE PARALLEL SAFE; |
| 42 | + |
| 43 | +CREATE FUNCTION aqo_query_stat ( |
| 44 | +OUT queryid bigint, |
| 45 | +OUT execution_time_with_aqo double precision[], |
| 46 | +OUT execution_time_without_aqo double precision[], |
| 47 | +OUT planning_time_with_aqo double precision[], |
| 48 | +OUT planning_time_without_aqo double precision[], |
| 49 | +OUT cardinality_error_with_aqo double precision[], |
| 50 | +OUT cardinality_error_without_aqo double precision[], |
| 51 | +OUT executions_with_aqo bigint, |
| 52 | +OUT executions_without_aqo bigint |
| 53 | +) |
| 54 | +RETURNS SETOF record |
| 55 | +AS 'MODULE_PATHNAME', 'aqo_query_stat' |
| 56 | +LANGUAGE C STRICT VOLATILE PARALLEL SAFE; |
| 57 | + |
| 58 | +CREATE FUNCTION aqo_data ( |
| 59 | +OUT fs bigint, |
| 60 | +OUT fss integer, |
| 61 | +OUT nfeatures integer, |
| 62 | +OUT features double precision[][], |
| 63 | +OUT targets double precision[], |
| 64 | +OUT reliability double precision[], |
| 65 | +OUT oids Oid[] |
| 66 | +) |
| 67 | +RETURNS SETOF record |
| 68 | +AS 'MODULE_PATHNAME', 'aqo_data' |
| 69 | +LANGUAGE C STRICT VOLATILE PARALLEL SAFE; |
| 70 | + |
| 71 | +CREATE VIEW aqo_query_stat AS SELECT * FROM aqo_query_stat(); |
| 72 | +CREATE VIEW aqo_query_texts AS SELECT * FROM aqo_query_texts(); |
| 73 | +CREATE VIEW aqo_data AS SELECT * FROM aqo_data(); |
| 74 | +CREATE VIEW aqo_queries AS SELECT * FROM aqo_queries(); |
| 75 | + |
| 76 | +/* UI functions */ |
| 77 | + |
| 78 | + |
| 79 | +CREATE FUNCTION aqo_enable_query(queryid bigint) |
| 80 | +RETURNS void |
| 81 | +AS 'MODULE_PATHNAME', 'aqo_enable_query' |
| 82 | +LANGUAGE C STRICT VOLATILE; |
| 83 | + |
| 84 | +CREATE FUNCTION aqo_disable_query(queryid bigint) |
| 85 | +RETURNS void |
| 86 | +AS 'MODULE_PATHNAME', 'aqo_enable_query' |
| 87 | +LANGUAGE C STRICT VOLATILE; |
| 88 | + |
| 89 | +CREATE FUNCTION aqo_queries_update( |
| 90 | +queryid bigint, fs bigint, learn_aqo bool, use_aqo bool, auto_tuning bool) |
| 91 | +RETURNS bool |
| 92 | +AS 'MODULE_PATHNAME', 'aqo_queries_update' |
| 93 | +LANGUAGE C VOLATILE; |
| 94 | + |
| 95 | +-- |
| 96 | +-- Get cardinality error of queries the last time they were executed. |
| 97 | +-- IN: |
| 98 | +-- controlled - show queries executed under a control of AQO (true); |
| 99 | +-- executed without an AQO control, but AQO has a stat on the query (false). |
| 100 | +-- |
| 101 | +-- OUT: |
| 102 | +-- num - sequental number. Smaller number corresponds to higher error. |
| 103 | +-- id - ID of a query. |
| 104 | +-- fshash - feature space. Usually equal to zero or ID. |
| 105 | +-- error - AQO error that calculated on plan nodes of the query. |
| 106 | +-- nexecs - number of executions of queries associated with this ID. |
| 107 | +-- |
| 108 | +CREATE OR REPLACE FUNCTION aqo_cardinality_error(controlled boolean) |
| 109 | +RETURNS TABLE(num integer, id bigint, fshash bigint, error double precision, nexecs bigint) |
| 110 | +AS 'MODULE_PATHNAME', 'aqo_cardinality_error' |
| 111 | +LANGUAGE C STRICT VOLATILE; |
| 112 | +COMMENT ON FUNCTION aqo_cardinality_error(boolean) IS |
| 113 | +'Get cardinality error of queries the last time they were executed. Order queries according to an error value.'; |
| 114 | + |
| 115 | +-- |
| 116 | +-- Show execution time of queries, for which AQO has statistics. |
| 117 | +-- controlled - show stat on executions where AQO was used for cardinality |
| 118 | +-- estimations, or not used (controlled = false). |
| 119 | +-- Last case is possible in disabled mode with aqo.force_collect_stat = 'on'. |
| 120 | +-- |
| 121 | +CREATE OR REPLACE FUNCTION aqo_execution_time(controlled boolean) |
| 122 | +RETURNS TABLE(num integer, id bigint, fshash bigint, exec_time double precision, nexecs bigint) |
| 123 | +AS 'MODULE_PATHNAME', 'aqo_execution_time' |
| 124 | +LANGUAGE C STRICT VOLATILE; |
| 125 | +COMMENT ON FUNCTION aqo_execution_time(boolean) IS |
| 126 | +'Get execution time of queries. If controlled = true (AQO could advise cardinality estimations), show time of last execution attempt. Another case (AQO not used), return an average value of execution time across all known executions.'; |
| 127 | + |
| 128 | +-- |
| 129 | +-- Remove query class settings, text, statistics and ML data from AQO storage. |
| 130 | +-- Return number of FSS records, removed from the storage. |
| 131 | +-- |
| 132 | +CREATE OR REPLACE FUNCTION aqo_drop_class(queryid bigint) |
| 133 | +RETURNS integer |
| 134 | +AS 'MODULE_PATHNAME', 'aqo_drop_class' |
| 135 | +LANGUAGE C STRICT VOLATILE; |
| 136 | +COMMENT ON FUNCTION aqo_drop_class(bigint) IS |
| 137 | +'Remove info about an query class from AQO ML knowledge base.'; |
| 138 | + |
| 139 | +-- |
| 140 | +-- Remove unneeded rows from the AQO ML storage. |
| 141 | +-- For common feature space, remove rows from aqo_data only. |
| 142 | +-- For custom feature space - remove all rows related to the space from all AQO |
| 143 | +-- tables even if only one oid for one feature subspace of the space is illegal. |
| 144 | +-- Returns number of deleted rows from aqo_queries and aqo_data tables. |
| 145 | +-- |
| 146 | +CREATE OR REPLACE FUNCTION aqo_cleanup(OUT nfs integer, OUT nfss integer) |
| 147 | +AS 'MODULE_PATHNAME', 'aqo_cleanup' |
| 148 | +LANGUAGE C STRICT VOLATILE; |
| 149 | +COMMENT ON FUNCTION aqo_cleanup() IS |
| 150 | +'Remove unneeded rows from the AQO ML storage'; |
| 151 | + |
| 152 | +-- |
| 153 | +-- Remove all records in the AQO storage. |
| 154 | +-- Return number of rows removed. |
| 155 | +-- |
| 156 | +CREATE FUNCTION aqo_reset() RETURNS bigint |
| 157 | +AS 'MODULE_PATHNAME', 'aqo_reset' |
| 158 | +LANGUAGE C PARALLEL SAFE; |
| 159 | +COMMENT ON FUNCTION aqo_reset() IS |
| 160 | +'Reset all data gathered by AQO'; |
0 commit comments