2017-08-24 10 views
1

私はC言語を使用してPostgreSQLの拡張機能を作成しています。PostgreSQLで最終機能が実行されない

タイムスタンプの配列を返すために、集計関数を実装しました。

time_to_array関数は、テーブル列のすべてのタイムスタンプ要素を配列に追加します。

time_to_array_final関数はタイムスタンプ配列を受け取り、並べ替えます。

CREATE OR REPLACE FUNCTION time_to_array(timestamp[], timestamp) 
    RETURNS timestamp[] 
    AS 'MODULE_PATHNAME','time_to_array' 
    LANGUAGE C IMMUTABLE; 

CREATE OR REPLACE FUNCTION time_to_array_final(timestamp[]) 
    RETURNS timestamp[] 
    AS 'MODULE_PATHNAME', 'time_to_array_final' 
    LANGUAGE C IMMUTABLE; 

CREATE AGGREGATE array_time_agg(timestamp) 
(
    SFUNC = time_to_array, 
    STYPE = timestamp[], 
    FINALFUNC = time_to_array_final 
); 

SELECT array_time_agg(column) FROM table; 

ELOG(): NOTA:time_to_array CALL(5回)

結果:

次は、SQLで定義されている array_time_agg | {「2016-06-01 00:00:00」、「2016-06-02 00:00:00」、「2016-06-05 00:00:00」、「2016-06-03 00:00: 00 "、" 2016-07-03 00:00:00 "}

私は現在、elogを使用してコード内で何が起こっているのか分析しています。

selectを実行すると、time_to_array関数が毎回正しく呼び出されることがわかります。

しかし、time_to_array_final関数はそうではありません。 ELOGは()と同じが呼び出されていないことを示す、関数の先頭である:

PG_FUNCTION_INFO_V1(time_to_array_final); 

Datum 
time_to_array_final(PG_FUNCTION_ARGS) 
{ 
    elog(NOTICE, "time_to_array_final"); 

    ArrayType *array_time; 
    ArrayType *array_time_result; 

    /* variables for "deconstructed" array*/ 
    Datum *datums_time; 
    bool *nulls_time; 
    int count_time; 
    int16 typlen; 
    bool typbyval; 
    char typalign; 

    array_time = PG_GETARG_ARRAYTYPE_P(0); 

    /*values found in table pg_type*/ 
    get_typlenbyvalalign(TIMESTAMPOID, &typlen, &typbyval, &typalign); 

    deconstruct_array(array_time, TIMESTAMPOID, typlen, typbyval, typalign , &datums_time, &nulls_time, &count_time); 

    quick_sort(datums_time, 0, count_time - 1); 

    array_time_result = construct_array(datums_time, 1, TIMESTAMPOID, typlen, typbyval, typalign); 

    PG_RETURN_ARRAYTYPE_P(array_time_result); 
} 

私はいくつかの間違ったパラメータを渡すだろうか?

集計関数を作成するために他のものは必要ですか?私はinitcondが必要ではないことを読んで、関数はそれがnullであると仮定します。事前

答えて

1

あなたのDDL文が正しいで

おかげで、あなたのC関数で何かがなければなりません。見よ:

create or replace function time_to_array(timestamp[], timestamp) 
returns timestamp[] language sql as $$ 
    select $1 || $2 
$$; 

create or replace function time_to_array_final(timestamp[]) 
returns timestamp[] language sql as $$ 
    select array_agg(elem order by elem) 
    from unnest($1) as elem; 
$$; 

create aggregate array_time_agg(timestamp) 
(
    sfunc = time_to_array, 
    stype = timestamp[], 
    finalfunc = time_to_array_final 
); 

with my_table(tstamp) as (
values 
    ('2017-08-20'::timestamp), 
    ('2017-08-19'), 
    ('2017-08-22'), 
    ('2017-08-21') 
) 
select array_time_agg(tstamp) 
from my_table; 

             array_time_agg          
------------------------------------------------------------------------------------------- 
{"2017-08-19 00:00:00","2017-08-20 00:00:00","2017-08-21 00:00:00","2017-08-22 00:00:00"} 
(1 row) 

私は(クイックソートなし())あなたの関数をコンパイルしたのだが、マイナーなバグがあるようです:それはのように私の集計にうまく機能し、とにかく

array_time_result = construct_array(datums_time, count_time, TIMESTAMPOID, typlen, typbyval, typalign); 
//            | was 1 

を最終的な機能(ソートせずに)。

+0

ありがとうございました! 私のC関数(time_to_array)は配列を返すので、おそらくtime_to_array_final関数のエラーか、必ずしもそうではありませんか? –

+0

私はそう思います、C関数 'time_to_array_final'には問題があります。 – klin

+0

私はポストを編集しました。私はC –

関連する問題