feat: implement Phase 2 Snowflake UDF support (14 functions)

[sivchari]

概要

Phase 2 の実装として、Snowflake 互換の UDF（User Defined Functions）を 14 個実装しました。

実装した関数

条件式関数 (3)

• ✅ IFF(condition, true_value, false_value) - インライン IF 式
• ✅ NVL(expr1, expr2) - expr1 が NULL の場合 expr2 を返す
• ✅ NVL2(expr1, expr2, expr3) - expr1 が NOT NULL なら expr2、NULL なら expr3

JSON 関数 (2)

• ✅ PARSE_JSON(string) - 文字列を JSON としてパース
• ✅ TO_JSON(variant) - 値を JSON 文字列に変換

日付/時刻関数 (2)

• ✅ DATEADD(part, value, date) - 日付に間隔を加算
• ✅ DATEDIFF(part, date1, date2) - 日付間の差を計算

TRY_* 関数群 (4)

• ✅ TRY_PARSE_JSON(string) - JSON パース（エラー時 NULL）
• ✅ TRY_TO_NUMBER(string) - 数値変換（エラー時 NULL）
• ✅ TRY_TO_DATE(string) - 日付変換（エラー時 NULL）
• ✅ TRY_TO_BOOLEAN(string) - 真偽値変換（エラー時 NULL）

配列/オブジェクト関数 (4)

• ✅ FLATTEN_ARRAY(array, index) - 配列から要素を取得
• ✅ ARRAY_SIZE(array) - 配列のサイズを取得
• ✅ GET_PATH(json, path) - JSON パスで値を取得
• ✅ OBJECT_KEYS(object) - オブジェクトのキー一覧

技術詳細

アーキテクチャ

• DataFusion の ScalarUDF インターフェースを使用
• Executor 初期化時に全 UDF を登録
• Arrow の列指向データ処理を活用

ファイル構成

engine/src/functions/
├── mod.rs               # モジュール組織とエクスポート
├── conditional.rs       # IFF, NVL, NVL2
├── json.rs              # PARSE_JSON, TO_JSON
├── datetime.rs          # DATEADD, DATEDIFF
├── try_functions.rs     # TRY_* 関数群
└── flatten.rs           # 配列/オブジェクト関数

テスト

Rust ユニットテスト

cargo test --package engine

結果: 41 テストすべてパス ✅

Go 統合テスト

cd go && go test

追加: 17 件の統合テスト（全 14 UDF をカバー）

変更ファイル

• engine/Cargo.toml: chrono 依存関係を追加
• engine/src/lib.rs: functions モジュールを公開
• engine/src/executor.rs: 14 個の UDF を登録
• engine/src/functions/*.rs: 各カテゴリの UDF 実装（計 5 ファイル）
• go/integration_test.go: 統合テスト追加（330 行追加）

統計: 10 ファイル変更、3205 行追加

実行例

-- 条件式
SELECT IFF(amount > 100, 'high', 'low') FROM sales;

-- JSON 処理
SELECT PARSE_JSON('{"user": {"name": "Alice"}}');
SELECT GET_PATH(data, 'user.name') FROM json_table;

-- 日付計算
SELECT DATEADD('day', 7, '2024-01-01');
SELECT DATEDIFF('month', start_date, end_date) FROM events;

-- エラーセーフ変換
SELECT TRY_TO_NUMBER(price_str) FROM products;

チェックリスト

• 全 UDF の実装完了
• Rust ユニットテスト追加（41 件）
• Go 統合テスト追加（17 件）
• コード品質確認（warnings のみ、errors なし）
• ドキュメント追加（mod.rs にドキュメントコメント）
• CI/CD パス確認
• レビュー準備完了

関連

Phase 2 実装計画に基づく実装です。
次のステップ: Phase 3 (半構造化データ、LATERAL FLATTEN)