Implementation of _cdb_dbname_of_foreign_table (WIP)

This commit is contained in:
Rafa de la Torre 2016-02-08 16:19:20 +01:00
parent c210008184
commit 1e3c7ace99

View File

@ -78,6 +78,7 @@ END
$$ LANGUAGE 'plpgsql' VOLATILE STRICT; $$ LANGUAGE 'plpgsql' VOLATILE STRICT;
-------------------------------------------------------------------------------- --------------------------------------------------------------------------------
-- Return a set of {db_name, schema_name, table_name. updated_at} -- Return a set of {db_name, schema_name, table_name. updated_at}
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 timestamp) RETURNS TABLE(db_name text, schema_name text, table_name text, updated_at timestamp)
@ -139,8 +140,12 @@ $$ LANGUAGE plpgsql;
CREATE OR REPLACE FUNCTION _cdb_dbname_of_foreign_table(reloid oid) CREATE OR REPLACE FUNCTION _cdb_dbname_of_foreign_table(reloid oid)
RETURNS TEXT AS $$ RETURNS TEXT AS $$
BEGIN SELECT option_value FROM pg_options_to_table((
--TODO: implement
RETURN 'cartodb_dev_user_36c4a45a-eb92-4af4-a8ff-1065ecfd041f_db'; SELECT fs.srvoptions
END; FROM pg_foreign_table ft
$$ LANGUAGE plpgsql; LEFT JOIN pg_foreign_server fs ON ft.ftserver = fs.oid
WHERE ft.ftrelid = reloid
)) WHERE option_name='dbname';
$$ LANGUAGE SQL;