Jonathan Leffler の例と、Informix 12.10FC8DE を使用した連結値の順序付けに関する RET コメントに基づいて、次のユーザー集計を作成しました。
CREATE FUNCTION mgc_init
(
dummy VARCHAR(255)
)
RETURNING
SET(LVARCHAR(2048) NOT NULL);
RETURN SET{}::SET(LVARCHAR(2048) NOT NULL);
END FUNCTION;
CREATE FUNCTION mgc_iter
(
p_result SET(LVARCHAR(2048) NOT NULL)
, p_value VARCHAR(255)
)
RETURNING
SET(LVARCHAR(2048) NOT NULL);
IF p_value IS NOT NULL THEN
INSERT INTO TABLE(p_result) VALUES (TRIM(p_value));
END IF;
RETURN p_result;
END FUNCTION;
CREATE FUNCTION mgc_comb
(
p_partial1 SET(LVARCHAR(2048) NOT NULL)
, p_partial2 SET(LVARCHAR(2048) NOT NULL)
)
RETURNING
SET(LVARCHAR(2048) NOT NULL);
INSERT INTO TABLE(p_partial1)
SELECT vc1 FROM TABLE(p_partial2)(vc1);
RETURN p_partial1;
END FUNCTION;
CREATE FUNCTION mgc_fini
(
p_final SET(LVARCHAR(2048) NOT NULL)
)
RETURNING
LVARCHAR;
DEFINE l_str LVARCHAR(2048);
DEFINE l_value LVARCHAR(2048);
LET l_str = NULL;
FOREACH SELECT vvalue1 INTO l_value FROM TABLE(p_final) AS vt1(vvalue1) ORDER BY vvalue1
IF l_str IS NULL THEN
LET l_str = l_value;
ELSE
LET l_str = l_str || ',' || l_value;
END IF;
END FOREACH;
RETURN l_str;
END FUNCTION;
GRANT EXECUTE ON mgc_fini TO PUBLIC;
CREATE AGGREGATE m_group_concat
WITH
(
INIT = mgc_init
, ITER = mgc_iter
, COMBINE = mgc_comb
, FINAL = mgc_fini
);
連結された値には重複がなく、順序付けされます。
Informix を使用しましたcollections
。つまりSET
、値の重複を許可しないため、コードをやや単純に保つようにしました。
この方法は、 を使用SET
して中間結果を保持し (重複を排除し)、最後に final の順序付けられた値から連結された文字列を構築しますSET
。
要素の使用はLVARCHAR
、最初は使用していたが、メモリ消費が非常に高かったという事実によるものです。ドキュメンテーションは、Informix が内部的に を にキャストしている可能性があることを示唆しています。変更を行ったところ、実際にメモリ消費量が減少しました (ただし、依然として高いままです)。SET
VARCHAR
VARCHAR
CHAR
ただし、この総メモリ消費量は、ジョナサンよりも約 2 桁高く、私が実施したテストでは約 2 倍遅くなります (約 300 000 行のテーブルを使用)。
したがって、注意して使用してください。多くのメモリを消費し、広範囲にテストされていません (どこかでメモリ リークが発生している可能性があります)。
編集1:
私の以前のコードは、どこかでメモリ構造をリークしているに違いありません (または、Informix が内部的にコレクション派生テーブルを保持しており、それらの多くを生成する可能性があります)。
そのため、集約関数を でコーディングする必要を回避しようとしていますC
が、Informix の組み込み関数を使用する別の方法をBSON
使用すると、メモリ使用量が大幅に減り、少し高速になります。
CREATE FUNCTION m2gc_init
(
dummy VARCHAR(255)
)
RETURNING
BSON;
RETURN '{"terms":[]}'::JSON::BSON;
END FUNCTION;
CREATE FUNCTION m2gc_iter
(
p_result BSON
, p_value VARCHAR(255)
)
RETURNING
BSON;
DEFINE l_add_array_element LVARCHAR(2048);
IF p_value IS NOT NULL THEN
LET l_add_array_element = '{ $addToSet: { terms: "' || TRIM(p_value) || '" } }';
LET p_result = BSON_UPDATE(p_result, l_add_array_element);
END IF;
RETURN p_result;
END FUNCTION;
CREATE FUNCTION m2gc_comb
(
p_partial1 BSON
, p_partial2 BSON
)
RETURNING
BSON;
DEFINE l_array_elements LVARCHAR(2048);
DEFINE l_an_element LVARCHAR(2048);
DEFINE l_guard INTEGER;
LET l_array_elements = NULL;
LET l_guard = BSON_SIZE(p_partial2, 'terms.0');
IF l_guard > 0 THEN
WHILE l_guard > 0
LET l_an_element = BSON_VALUE_LVARCHAR(p_partial2, 'terms.0');
IF l_array_elements IS NULL THEN
LET l_array_elements = '"' || l_an_element || '"';
ELSE
LET l_array_elements = l_array_elements || ', "' || l_an_element || '"';
END IF;
LET p_partial2 = BSON_UPDATE(p_partial2, '{ $pop: { terms: -1 } }');
LET l_guard = BSON_SIZE(p_partial2, 'terms.0');
END WHILE;
LET l_array_elements = '{ $addToSet: { terms: { $each: [ ' || l_array_elements || ' ] } } }';
LET p_partial1 = BSON_UPDATE(p_partial1, l_array_elements);
END IF;
RETURN p_partial1;
END FUNCTION;
CREATE FUNCTION m2gc_fini
(
p_final BSON
)
RETURNING
LVARCHAR;
DEFINE l_str_agg LVARCHAR(2048);
DEFINE l_an_element LVARCHAR(2048);
DEFINE l_iter_int INTEGER;
DEFINE l_guard INTEGER;
LET l_str_agg = NULL;
LET l_guard = BSON_SIZE(p_final, 'terms.0');
IF l_guard > 0 THEN
LET p_final = BSON_UPDATE(p_final, '{ $push: { terms: { $each: [], $sort: 1 } } }');
LET l_iter_int = 0;
WHILE l_guard > 0
LET l_an_element = BSON_VALUE_LVARCHAR(p_final, 'terms.' || l_iter_int);
IF l_str_agg IS NULL THEN
LET l_str_agg = TRIM(l_an_element);
ELSE
LET l_str_agg = l_str_agg || ',' || TRIM(l_an_element);
END IF;
LET l_iter_int = l_iter_int + 1;
LET l_guard = BSON_SIZE(p_final, 'terms.' || l_iter_int);
END WHILE;
END IF;
RETURN l_str_agg;
END FUNCTION;
CREATE AGGREGATE m2_group_concat
WITH
(
INIT = m2gc_init
, ITER = m2gc_iter
, COMBINE = m2gc_comb
, FINAL = m2gc_fini
)
;
集計された戻り値は順序付けられ、重複はありません。
繰り返しますが、これは適切にテストされていません。これは単なる POC です。
問題の 1 つは、入力値をサニタイズしていないことです。一部のBSON
操作関数は、文字列を連結することによって構築されているパラメーターを受け取り、エスケープされていない文字はそれらのパラメーターを壊す可能性があります。たとえば、引用符で囲まれた文字列値: 'I"BrokeIt'
) は、さまざまなエラー (Assert Failures を含む) を引き起こす可能性があります。
そして、他にも問題があると確信しています。
ただし、この実装のメモリ消費量は、Jonathan の例と同程度であり、約 60% 遅くなります (ここでも、非常に初歩的なテストのみが実行されました)。