cartodb4/dataservices-api
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Check server return

Browse Source
This commit is contained in:
Carla Iriberri 2016-09-01 16:37:54 +02:00
parent a98093540d
commit e959873b32
1 changed files with 16 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
client/sql/20_table_augmentation.sql
View File

@ -111,9 +111,12 @@ CREATE OR REPLACE FUNCTION cdb_dataservices_client.__DST_PrepareTableOBS_GetMeas
params=plpy.quote_literal(params) params=plpy.quote_literal(params)
) )
) )
if ds_return_metadata[0]["colnames"]:
colnames_arr = ds_return_metadata[0]["colnames"]
coltypes_arr = ds_return_metadata[0]["coltypes"]
else:
raise Exception('Error retrieving OBS_GetMeasure metadata')
colnames_arr = ds_return_metadata[0]["colnames"]
coltypes_arr = ds_return_metadata[0]["coltypes"]
# Prepare column and type strings required in the SQL queries # Prepare column and type strings required in the SQL queries
columns_with_types_arr = [colnames_arr[i] + ' ' + coltypes_arr[i] for i in range(0,len(colnames_arr))] columns_with_types_arr = [colnames_arr[i] + ' ' + coltypes_arr[i] for i in range(0,len(colnames_arr))]
@ -153,8 +156,11 @@ CREATE OR REPLACE FUNCTION cdb_dataservices_client.__DST_PopulateTableOBS_GetMea
function_name=plpy.quote_literal(function_name), function_name=plpy.quote_literal(function_name),
params=plpy.quote_literal(params))) params=plpy.quote_literal(params)))
colnames_arr = ds_return_metadata[0]["colnames"] if ds_return_metadata[0]["colnames"]:
coltypes_arr = ds_return_metadata[0]["coltypes"] colnames_arr = ds_return_metadata[0]["colnames"]
coltypes_arr = ds_return_metadata[0]["coltypes"]
else:
raise Exception('Error retrieving OBS_GetMeasure metadata')
# Prepare column and type strings required in the SQL queries # Prepare column and type strings required in the SQL queries
columns_with_types_arr = [ columns_with_types_arr = [
@ -182,9 +188,12 @@ CREATE OR REPLACE FUNCTION cdb_dataservices_client.__DST_PopulateTableOBS_GetMea
dbname=plpy.quote_literal(dbname), dbname=plpy.quote_literal(dbname),
table_name=plpy.quote_literal(table_name))) table_name=plpy.quote_literal(table_name)))
server_schema = ds_fdw_metadata[0]["schemaname"] if ds_fdw_metadata[0]["schemaname"]:
server_table_name = ds_fdw_metadata[0]["tabname"] server_schema = ds_fdw_metadata[0]["schemaname"]
server_name = ds_fdw_metadata[0]["servername"] server_table_name = ds_fdw_metadata[0]["tabname"]
server_name = ds_fdw_metadata[0]["servername"]
else:
raise Exception('Error connecting dataset via FDW')
# Create a new table with the required columns # Create a new table with the required columns
plpy.execute( plpy.execute(