有人可以在这个自定义功能的初步尝试中给我一个提示吗?
我需要使用 2 个参数、一个 varchar 和一个 unix 时间戳(一个整数)来构造查询,我用下面的几行花了 3 个小时和这个结果
查询测试可以是 select * from pdc_posot_cf_anno('MRDDCU83C12C433F',2012); 我只是想构造一个正确的 SQL 查询来传递给 SPI_exec。
非常感谢。
CREATE FUNCTION pdc_posot_cf_anno(varchar,integer)
RETURNS integer
AS 'pdc','posot_cf_anno'
LANGUAGE C STABLE STRICT;
Datum
posot_cf_anno(PG_FUNCTION_ARGS) {
char timestring[1024] = "";
char qanno[1024];
Timestamp t;
time_t time = 0;
int tempo;
Datum td;
sprintf(timestring,"%d-01-01",PG_GETARG_INT32(1));
elog(INFO, "tutto bene %s !",timestring);
t = DatumGetTimestamp(DirectFunctionCall2(to_timestamp,
CStringGetTextDatum(timestring),
CStringGetTextDatum("YYYY-MM-DD")));
sprintf(qanno,"SELECT DISTINCT o.idot FROM sit.otpos o "
"WHERE btrim(o.codfis) = %s AND to_timestamp(validita) <= %s ORDER BY o.idot;",
PG_GETARG_CSTRING(0), t);
elog(INFO, "QUERY %s !",qanno);
// SPI_connect();
// res = SPI_exec(qanno,0);
return 0;
}