Estoy tratando de escribir un procedimiento de almacenamiento en el que paso una consulta a un procedimiento almacenado que llamará internamente a la función row_to_json. Tenemos múltiples DBMS (Oracle, SQL Server y postgres) y queremos escribir un procedimiento genérico que actuará como contenedor para la función de manejo de json.
estoy mirando algo como esto
CREATE OR REPLACE FUNCTION proj.sql_row_to_json(sql_t text) RETURNS json LANGUAGE sql AS $function$ with t as (select sql_t ) select row_to_json(t) from t; $function$Llamaría a la función en mi aplicación como
select SQL_ROW_TO_JSON('<sql query>') -> que debería funcionar en diferentes bases de datos
Pero el procedimiento anterior me da el siguiente resultado en lugar de los datos reales.
select SQL_ROW_TO_JSON('SELECT id,name FROM emp') {"sql_t":"SELECT id,name FROM emp"}Tienes que usar plpgsql y sql dinámico .
create or replace function sql_row_to_json(sql_t text) returns json language plpgsql as $function$ declare rslt json; begin execute format($ex$ select json_agg(row_to_json(t)) from (%s) t $ex$, sql_t) into rslt; return rslt; end; $function$; select sql_row_to_json('select 1 as id, ''abcd'' as value'); sql_row_to_json ------------------------- {"id":1,"value":"abcd"} (1 row)Tenga en cuenta que la función es propensa a ataques de inyección SQL .