From 01edf81600f4d50a61ed2a441acf182fb835229a Mon Sep 17 00:00:00 2001 From: Rafa de la Torre Date: Thu, 23 Jun 2016 16:45:59 +0200 Subject: [PATCH] Fix plproxy func that returns dynamic records --- client/sql/20_table_augmentation.sql | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/client/sql/20_table_augmentation.sql b/client/sql/20_table_augmentation.sql index 3e77f57..4cad548 100644 --- a/client/sql/20_table_augmentation.sql +++ b/client/sql/20_table_augmentation.sql @@ -32,6 +32,7 @@ BEGIN SELECT current_database() INTO dbname; SELECT cdb_dataservices_client._OBS_ProcessTable(username, useruuid, input_schema, dbname, table_name, output_table_name, params) INTO result; + RETURN result; END; @@ -101,7 +102,7 @@ $$ LANGUAGE plproxy; CREATE OR REPLACE FUNCTION cdb_dataservices_client._OBS_GetProcessedData(table_schema text, table_name text, params json) RETURNS SETOF record AS $$ CONNECT _server_conn_str(); - SELECT cdb_dataservices_server.OBS_GetProcessedData(table_schema text, table_name text, params json); + TARGET cdb_dataservices_server._OBS_GetProcessedData; $$ LANGUAGE plproxy; CREATE OR REPLACE FUNCTION cdb_dataservices_client._OBS_DisconnectUserTable(table_schema text, table_name text, server_name text)