拡張の例

vsql_complex 拡張は、VEF SDK を使用したカスタム型の VillageSQL の参照実装であり、実運用可能な拡張パターンを示しています。 ソース: VillageSQL リポジトリの villagesql/examples/vsql-complex/

vsql_complex が提供するもの

複素数 (a + bi) 用の COMPLEX 型。算術演算、ユーティリティ、集計機能を備えています。 使用例:

INSTALL EXTENSION vsql_complex;

CREATE TABLE signals (
    id INT PRIMARY KEY,
    impedance COMPLEX
);

INSERT INTO signals VALUES (1, '(50.0,10.0)');

SELECT
    complex_real(impedance) as resistance,
    complex_imag(impedance) as reactance,
    complex_abs(impedance) as magnitude
FROM signals;

ディレクトリ構造

vsql_complex/
├── CMakeLists.txt       # Build config with VEF_CREATE_VEB
├── manifest.json        # Extension metadata
├── src/
│   └── complex.cc       # Complete implementation: types, functions, and VEF registration
└── test/
    ├── t/*.test         # Test cases
    └── r/*.result       # Expected results

VEF 登録パターン

ファイル: src/complex.cc vsql_complex は、VEF_GENERATE_ENTRY_POINTS() を使用して VEF SDK を使用します。

#include <villagesql/vsql.h>

// Type name constants as char arrays — required as non-type template parameters
// (NTTPs) so that make_type can auto-generate VDF names like "COMPLEX::from_string".
static constexpr const char kComplexTypeName[] = "COMPLEX";
static constexpr const char kComplex2TypeName[] = "COMPLEX2";

// Type objects: encode/decode/compare VDFs are embedded via template parameters.
// No separate .func() registration is needed for type operations.
constexpr auto COMPLEX =
    vsql::make_type<kComplexTypeName>()
        .persisted_length(kComplexSize)
        .max_decode_buffer_length(64)
        .from_string<&complex_from_string>()
        .to_string<&complex_to_string>()
        .compare<&complex_compare>()
        .intrinsic_default_str("(0,0)")
        .build();

constexpr auto COMPLEX2 =
    vsql::make_type<kComplex2TypeName>()
        .persisted_length(kComplexSize)
        .max_decode_buffer_length(64)
        .from_string<&complex2_from_string>()
        .to_string<&complex_to_string>()
        .compare<&complex_compare>()
        .hash<&complex2_hash>()
        .intrinsic_default_str("(0,0)")
        .build();

using namespace vsql;

VEF_GENERATE_ENTRY_POINTS(
    make_extension()
        .type(COMPLEX)
        .type(COMPLEX2)
        // Arithmetic operations
        .func(make_func<&complex_add_impl>("complex_add")
                  .returns(COMPLEX)
                  .param(COMPLEX)
                  .param(COMPLEX)
                  .deterministic()
                  .build())
        .func(make_func<&complex_subtract_impl>("complex_subtract")
                  .returns(COMPLEX)
                  .param(COMPLEX)
                  .param(COMPLEX)
                  .deterministic()
                  .build())
        .func(make_func<&complex_multiply_impl>("complex_multiply")
                  .returns(COMPLEX)
                  .param(COMPLEX)
                  .param(COMPLEX)
                  .deterministic()
                  .build())
        .func(make_func<&complex_divide_impl>("complex_divide")
                  .returns(COMPLEX)
                  .param(COMPLEX)
                  .param(COMPLEX)
                  .deterministic()
                  .build())
        // Utility functions
        .func(make_func<&complex_real_impl>("complex_real")
                  .returns(REAL)
                  .param(COMPLEX)
                  .build())
        .func(make_func<&complex_imag_impl>("complex_imag")
                  .returns(REAL)
                  .param(COMPLEX)
                  .build())
        .func(make_func<&complex_abs_impl>("complex_abs")
                  .returns(REAL)
                  .param(COMPLEX)
                  .build())
        .func(make_func<&complex_conjugate_impl>("complex_conjugate")
                  .returns(COMPLEX)
                  .param(COMPLEX)
                  .build())
        // Aggregate functions
        .func(make_aggregate_func<ComplexSumState, &complex_sum_result>(
                  "complex_sum")
                  .returns(COMPLEX)
                  .param(COMPLEX)
                  .clear<&complex_sum_clear>()
                  .accumulate<&complex_sum_accumulate>()
                  .build()))

主なパターン:

単一のマクロ呼び出しですべてを登録 — 手動による SQL は不要
型オブジェクトは、kName を非型テンプレートパラメータとして使用した vsql::make_type<kName>() で構築された constexpr 変数です。ここで、kName は static constexpr const char[] です。
型操作 (.from_string<>()、.to_string<>()、.compare<>()、.hash<>()) は、型オブジェクトに埋め込まれており、それらのために個別の .func() 呼び出しは必要ありません。
.compare() は ORDER BY とインデックスを有効にします。.hash() はオプションです。
.intrinsic_default_str("(0,0)") は、INSERT IGNORE または UPDATE IGNORE がこの型の NOT NULL 列に NULL を割り当てた場合に書き込まれるデフォルト値を設定します。
関数登録には、.build() を使用して make_func<&impl>("name") を使用します。
集計登録には、.clear<&fn>() および .accumulate<&fn>() を使用して make_aggregate_func<State, &result_fn>("name") を使用します。結果関数は、void(const State&, ResultWrapper) というシグネチャを持ちます。

バイナリストレージ形式

COMPLEX は 16 バイト (リトルエンディアン) を格納されます。

バイト 0-7: 実数部 (double)
バイト 8-15: 虚数部 (double)

エンコード/デコード (complex.cc):

bool encode_complex(unsigned char *buffer, size_t buffer_size,
                    const char *from, size_t from_len, size_t *length);
bool decode_complex(const unsigned char *buffer, size_t buffer_size,
                    char *to, size_t to_buffer_size, size_t *to_length);

プラットフォームに依存しないバイトオーダー関数を使用して、クロスプラットフォームの互換性を実現します。

ラッパー関数

VEF SDK は、型付きの引数と結果ラッパーを提供するため、実装は生のプロトコル構造ではなく、C++ 型で動作します。 算術演算の例 (complex.cc から):

void complex_add_impl(CustomArg in_l, CustomArg in_r, CustomResult out) {
  // Handle NULL inputs and validate arguments
  // ...
  store_complex(out.buffer().data(), Complex{lhs.re + rhs.re, lhs.im + rhs.im});
  out.set_length(kComplexSize);
}

ユーティリティ関数ラッパー (complex.cc から):

void complex_real_impl(CustomArg in, RealResult out) {
  // Handle NULL and validate
  // ...
  out.set(cx.re);
}

void complex_abs_impl(CustomArg in, RealResult out) {
  // Handle NULL and validate
  // ...
  out.set(sqrt(cx.re * cx.re + cx.im * cx.im));
}

テスト戦略

テストファイル (test/t/complex_create.test):

INSTALL EXTENSION vsql_complex;

CREATE TABLE t1 (id INT, val COMPLEX);
INSERT INTO t1 VALUES (1, '(1.0,2.0)');
SELECT * FROM t1;

DROP TABLE t1;
UNINSTALL EXTENSION vsql_complex;

結果の生成:

cd /path/to/villagesql/build/mysql-test
./mysql-test-run.pl --suite=vsql_complex --record

テストの実行:

./mysql-test-run.pl --suite=vsql_complex

主要な実装パターン

パターン	使用例
固定長のストレージ	型ビルダーで `.persisted_length()` を設定します。
プラットフォームに依存しない	double 用のカスタムバイトオーダー関数を使用します。
NULL の処理	型付きの引数ラッパーで `in.is_null()` を呼び出します。
エラー処理	結果ラッパーで `out.error("message")` を呼び出します。
結果の出力	結果ラッパーで `out.set(value)` / `out.set_length(n)` を呼び出します。

マニフェスト

ファイル: manifest.json

{
  "name": "vsql_complex",
  "version": "0.0.1",
  "description": "Complex number data type for VillageSQL",
  "author": "VillageSQL Contributors",
  "license": "GPL-2.0"
}

カスタム型を使用したデータのエクスポートとインポート

VillageSQL は、カスタム型に対して SELECT INTO OUTFILE および LOAD DATA INFILE をサポートしており、カスタム型の値を保持したままデータをエクスポートおよびインポートできます。

SELECT INTO OUTFILE

カスタム型は、エクスポート時に文字列表現にシリアライズされます。

INSTALL EXTENSION vsql_complex;

-- Create table with custom type
CREATE TABLE signals (
    id INT PRIMARY KEY,
    reading COMPLEX
);

INSERT INTO signals VALUES
    (1, '(3.0,4.0)'),
    (2, '(5.0,12.0)'),
    (3, '(-1.0,2.0)');

-- Export to file
SELECT * FROM signals INTO OUTFILE '/tmp/signals_export.txt';

ファイルの内容 (/tmp/signals_export.txt):

(3.00,4.00)
(5.00,12.00)
(-1.00,2.00)

LOAD DATA INFILE

エクスポートされたデータをテーブルにロードします。

-- Create new table with same schema
CREATE TABLE signals_imported (
    id INT PRIMARY KEY,
    reading COMPLEX
);

-- Import data
LOAD DATA INFILE '/tmp/signals_export.txt' INTO TABLE signals_imported;

-- Verify
SELECT * FROM signals_imported;

カスタム区切り文字を使用したエクスポート

カスタムフィールド区切り文字と行末文字を使用できます。

SELECT * FROM signals
INTO OUTFILE '/tmp/signals_csv.txt'
FIELDS TERMINATED BY ','
ENCLOSED BY '"'
LINES TERMINATED BY '\n';

出力:

"1","(3.00,4.00)"
"2","(5.00,12.00)"
"3","(-1.00,2.00)"

VDF 関数を使用したエクスポート

拡張関数を使用して、計算された値をエクスポートします。

SELECT
    id,
    reading,
    complex_abs(reading) AS magnitude,
    complex_real(reading) AS real_part,
    complex_imag(reading) AS imag_part
INTO OUTFILE '/tmp/signals_computed.txt'
FROM signals;

カスタム型は、文字列表現形式でエクスポートされます。カスタム型に対するバイナリエクスポート (SELECT INTO DUMPFILE) は、現在サポートされていません。

次のステップ

拡張機能の作成

独自の拡張機能を作成します。

拡張機能のアーキテクチャ

内部構造を理解します。

vsql_complexソースコード

完全なソースコードを表示します。

利用可能な拡張機能

拡張機能カタログを参照します。

Getting Started

Extensions

Using Extensions

Creating Extensions

vsql_complex が提供するもの

ディレクトリ構造

VEF 登録パターン

バイナリストレージ形式

ラッパー関数

テスト戦略

主要な実装パターン

マニフェスト

カスタム型を使用したデータのエクスポートとインポート

SELECT INTO OUTFILE

LOAD DATA INFILE

カスタム区切り文字を使用したエクスポート

VDF 関数を使用したエクスポート

次のステップ

拡張機能の作成

拡張機能のアーキテクチャ

vsql_complexソースコード

利用可能な拡張機能

​vsql_complex が提供するもの

​ディレクトリ構造

​VEF 登録パターン

​バイナリストレージ形式

​ラッパー関数

​テスト戦略

​主要な実装パターン

​マニフェスト

​カスタム型を使用したデータのエクスポートとインポート

​SELECT INTO OUTFILE

​LOAD DATA INFILE

​カスタム区切り文字を使用したエクスポート

​VDF 関数を使用したエクスポート

​次のステップ

拡張機能の作成

拡張機能のアーキテクチャ

vsql_complexソースコード

利用可能な拡張機能

vsql_complex が提供するもの

ディレクトリ構造

VEF 登録パターン

バイナリストレージ形式

ラッパー関数

テスト戦略

主要な実装パターン

マニフェスト

カスタム型を使用したデータのエクスポートとインポート

SELECT INTO OUTFILE

LOAD DATA INFILE

カスタム区切り文字を使用したエクスポート

VDF 関数を使用したエクスポート

次のステップ