Minor changes: use plain SQL func
This commit is contained in:
@@ -83,9 +83,6 @@ $$ LANGUAGE 'plpgsql' VOLATILE STRICT;
|
|||||||
CREATE OR REPLACE FUNCTION CDB_QueryTablesUpdatedAt(query text)
|
CREATE OR REPLACE FUNCTION CDB_QueryTablesUpdatedAt(query text)
|
||||||
RETURNS TABLE(db_name text, schema_name text, table_name text, updated_at timestamptz)
|
RETURNS TABLE(db_name text, schema_name text, table_name text, updated_at timestamptz)
|
||||||
AS $$
|
AS $$
|
||||||
BEGIN
|
|
||||||
|
|
||||||
RETURN QUERY
|
|
||||||
WITH query_tables AS (
|
WITH query_tables AS (
|
||||||
SELECT unnest(CDB_QueryTablesText(query)) schema_table_name
|
SELECT unnest(CDB_QueryTablesText(query)) schema_table_name
|
||||||
), query_tables_oid AS (
|
), query_tables_oid AS (
|
||||||
@@ -107,11 +104,10 @@ BEGIN
|
|||||||
)
|
)
|
||||||
SELECT fqtn.dbname, fqtn.schema_name, fqtn.table_name,
|
SELECT fqtn.dbname, fqtn.schema_name, fqtn.table_name,
|
||||||
(CASE WHEN relkind = 'f' THEN CDB_Get_Foreign_Updated_At(reloid)
|
(CASE WHEN relkind = 'f' THEN CDB_Get_Foreign_Updated_At(reloid)
|
||||||
ELSE (SELECT md.updated_at FROM CDB_TableMetadata md WHERE tabname = reloid)
|
ELSE (SELECT md.updated_at FROM CDB_TableMetadata md WHERE md.tabname = reloid)
|
||||||
END) AS updated_at
|
END) AS updated_at
|
||||||
FROM fqtn;
|
FROM fqtn;
|
||||||
END
|
$$ LANGUAGE SQL;
|
||||||
$$ LANGUAGE 'plpgsql' VOLATILE STRICT;
|
|
||||||
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION _cdb_dbname_of_foreign_table(reloid oid)
|
CREATE OR REPLACE FUNCTION _cdb_dbname_of_foreign_table(reloid oid)
|
||||||
|
|||||||
Reference in New Issue
Block a user