duckdb

package
v3.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 25, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package duckdb implements the DuckDB SQL dialect for cel2sql.

Index

Constants

View Source
const (
	IndexTypeART = "ART"
)

DuckDB index type constants.

Variables

This section is empty.

Functions

This section is empty.

Types

type Dialect

type Dialect struct{}

Dialect implements dialect.Dialect for DuckDB.

func New

func New() *Dialect

New creates a new DuckDB dialect.

func (*Dialect) ConvertRegex

func (d *Dialect) ConvertRegex(re2Pattern string) (string, bool, error)

ConvertRegex converts an RE2 regex pattern to DuckDB-compatible format. DuckDB uses RE2 natively, so minimal conversion is needed.

func (*Dialect) MaxIdentifierLength

func (d *Dialect) MaxIdentifierLength() int

MaxIdentifierLength returns 0 as DuckDB has no hard identifier length limit.

func (*Dialect) Name

func (d *Dialect) Name() dialect.Name

Name returns the dialect name.

func (*Dialect) RecommendIndex

func (d *Dialect) RecommendIndex(pattern dialect.IndexPattern) *dialect.IndexRecommendation

RecommendIndex generates a DuckDB-specific index recommendation for the given pattern. DuckDB uses ART (Adaptive Radix Tree) indexes by default. Returns nil for unsupported patterns.

func (*Dialect) ReservedKeywords

func (d *Dialect) ReservedKeywords() map[string]bool

ReservedKeywords returns the set of reserved SQL keywords for DuckDB.

func (*Dialect) SupportedPatterns

func (d *Dialect) SupportedPatterns() []dialect.PatternType

SupportedPatterns returns the pattern types supported by DuckDB.

func (*Dialect) SupportsIndexAnalysis

func (d *Dialect) SupportsIndexAnalysis() bool

SupportsIndexAnalysis returns true as DuckDB index analysis is supported.

func (*Dialect) SupportsJSONB

func (d *Dialect) SupportsJSONB() bool

SupportsJSONB returns false as DuckDB has a single JSON type.

func (*Dialect) SupportsNativeArrays

func (d *Dialect) SupportsNativeArrays() bool

SupportsNativeArrays returns true as DuckDB has native array (LIST) types.

func (*Dialect) SupportsRegex

func (d *Dialect) SupportsRegex() bool

SupportsRegex returns true as DuckDB supports RE2 regex natively.

func (*Dialect) ValidateFieldName

func (d *Dialect) ValidateFieldName(name string) error

ValidateFieldName validates a field name against DuckDB naming rules.

func (*Dialect) WriteArrayLength

func (d *Dialect) WriteArrayLength(w *strings.Builder, _ int, writeExpr func() error) error

WriteArrayLength writes COALESCE(array_length(expr), 0) for DuckDB.

func (*Dialect) WriteArrayLiteralClose

func (d *Dialect) WriteArrayLiteralClose(w *strings.Builder)

WriteArrayLiteralClose writes the DuckDB array literal closing (]).

func (*Dialect) WriteArrayLiteralOpen

func (d *Dialect) WriteArrayLiteralOpen(w *strings.Builder)

WriteArrayLiteralOpen writes the DuckDB array literal opening ([).

func (*Dialect) WriteArrayMembership

func (d *Dialect) WriteArrayMembership(w *strings.Builder, writeElem func() error, writeArray func() error) error

WriteArrayMembership writes a DuckDB array membership test using = ANY().

func (*Dialect) WriteArraySubqueryExprClose

func (d *Dialect) WriteArraySubqueryExprClose(_ *strings.Builder)

WriteArraySubqueryExprClose is a no-op for DuckDB (no wrapper around the expression).

func (*Dialect) WriteArraySubqueryOpen

func (d *Dialect) WriteArraySubqueryOpen(w *strings.Builder)

WriteArraySubqueryOpen writes ARRAY(SELECT for DuckDB.

func (*Dialect) WriteBytesLiteral

func (d *Dialect) WriteBytesLiteral(w *strings.Builder, value []byte) error

WriteBytesLiteral writes a DuckDB hex-encoded byte literal ('\x...').

func (*Dialect) WriteCastToNumeric

func (d *Dialect) WriteCastToNumeric(w *strings.Builder)

WriteCastToNumeric writes a DuckDB numeric cast (::DOUBLE).

func (*Dialect) WriteContains

func (d *Dialect) WriteContains(w *strings.Builder, writeHaystack, writeNeedle func() error) error

WriteContains writes CONTAINS(haystack, needle) for DuckDB.

func (*Dialect) WriteDuration

func (d *Dialect) WriteDuration(w *strings.Builder, value int64, unit string)

WriteDuration writes a DuckDB INTERVAL literal.

func (*Dialect) WriteEmptyTypedArray

func (d *Dialect) WriteEmptyTypedArray(w *strings.Builder, typeName string)

WriteEmptyTypedArray writes an empty DuckDB typed array.

func (*Dialect) WriteEpochExtract

func (d *Dialect) WriteEpochExtract(w *strings.Builder, writeExpr func() error) error

WriteEpochExtract writes EXTRACT(EPOCH FROM expr)::BIGINT for DuckDB.

func (*Dialect) WriteExtract

func (d *Dialect) WriteExtract(w *strings.Builder, part string, writeExpr func() error, writeTZ func() error) error

WriteExtract writes a DuckDB EXTRACT expression with DOW conversion.

func (*Dialect) WriteInterval

func (d *Dialect) WriteInterval(w *strings.Builder, writeValue func() error, unit string) error

WriteInterval writes a DuckDB INTERVAL expression.

func (*Dialect) WriteJSONArrayElements

func (d *Dialect) WriteJSONArrayElements(w *strings.Builder, _ bool, _ bool, writeExpr func() error) error

WriteJSONArrayElements writes DuckDB JSON array expansion using json_each.

func (*Dialect) WriteJSONArrayLength

func (d *Dialect) WriteJSONArrayLength(w *strings.Builder, writeExpr func() error) error

WriteJSONArrayLength writes COALESCE(json_array_length(expr), 0) for DuckDB.

func (*Dialect) WriteJSONArrayMembership

func (d *Dialect) WriteJSONArrayMembership(w *strings.Builder, _ string, writeExpr func() error) error

WriteJSONArrayMembership writes DuckDB JSON array membership using json_each.

func (*Dialect) WriteJSONExistence

func (d *Dialect) WriteJSONExistence(w *strings.Builder, _ bool, fieldName string, writeBase func() error) error

WriteJSONExistence writes a DuckDB JSON key existence check using json_exists.

func (*Dialect) WriteJSONExtractPath

func (d *Dialect) WriteJSONExtractPath(w *strings.Builder, pathSegments []string, writeRoot func() error) error

WriteJSONExtractPath writes DuckDB JSON path existence using json_exists.

func (*Dialect) WriteJSONFieldAccess

func (d *Dialect) WriteJSONFieldAccess(w *strings.Builder, writeBase func() error, fieldName string, isFinal bool) error

WriteJSONFieldAccess writes DuckDB JSON field access using -> or ->> operators.

func (*Dialect) WriteJoin

func (d *Dialect) WriteJoin(w *strings.Builder, writeArray, writeDelim func() error) error

WriteJoin writes DuckDB array join using ARRAY_TO_STRING.

func (*Dialect) WriteLikeEscape

func (d *Dialect) WriteLikeEscape(w *strings.Builder)

WriteLikeEscape writes the DuckDB LIKE escape clause.

func (*Dialect) WriteListIndex

func (d *Dialect) WriteListIndex(w *strings.Builder, writeArray func() error, writeIndex func() error) error

WriteListIndex writes DuckDB 1-indexed array access.

func (*Dialect) WriteListIndexConst

func (d *Dialect) WriteListIndexConst(w *strings.Builder, writeArray func() error, index int64) error

WriteListIndexConst writes DuckDB constant array index access (0-indexed to 1-indexed).

func (*Dialect) WriteNestedJSONArrayMembership

func (d *Dialect) WriteNestedJSONArrayMembership(w *strings.Builder, writeExpr func() error) error

WriteNestedJSONArrayMembership writes DuckDB nested JSON array membership.

func (*Dialect) WriteParamPlaceholder

func (d *Dialect) WriteParamPlaceholder(w *strings.Builder, paramIndex int)

WriteParamPlaceholder writes a DuckDB positional parameter ($1, $2, ...).

func (*Dialect) WriteRegexMatch

func (d *Dialect) WriteRegexMatch(w *strings.Builder, writeTarget func() error, pattern string, caseInsensitive bool) error

WriteRegexMatch writes a DuckDB regex match expression using ~ or ~*.

func (*Dialect) WriteSplit

func (d *Dialect) WriteSplit(w *strings.Builder, writeStr, writeDelim func() error) error

WriteSplit writes DuckDB string split using STRING_SPLIT.

func (*Dialect) WriteSplitWithLimit

func (d *Dialect) WriteSplitWithLimit(w *strings.Builder, writeStr, writeDelim func() error, limit int64) error

WriteSplitWithLimit writes DuckDB string split with array slice.

func (*Dialect) WriteStringConcat

func (d *Dialect) WriteStringConcat(w *strings.Builder, writeLHS, writeRHS func() error) error

WriteStringConcat writes DuckDB string concatenation using ||.

func (*Dialect) WriteStringLiteral

func (d *Dialect) WriteStringLiteral(w *strings.Builder, value string)

WriteStringLiteral writes a DuckDB string literal with ” escaping.

func (*Dialect) WriteStructClose

func (d *Dialect) WriteStructClose(w *strings.Builder)

WriteStructClose writes the DuckDB struct literal closing.

func (*Dialect) WriteStructOpen

func (d *Dialect) WriteStructOpen(w *strings.Builder)

WriteStructOpen writes the DuckDB struct literal opening.

func (*Dialect) WriteTimestampArithmetic

func (d *Dialect) WriteTimestampArithmetic(w *strings.Builder, op string, writeTS, writeDur func() error) error

WriteTimestampArithmetic writes DuckDB timestamp arithmetic.

func (*Dialect) WriteTimestampCast

func (d *Dialect) WriteTimestampCast(w *strings.Builder, writeExpr func() error) error

WriteTimestampCast writes a DuckDB CAST to TIMESTAMPTZ.

func (*Dialect) WriteTypeName

func (d *Dialect) WriteTypeName(w *strings.Builder, celTypeName string)

WriteTypeName writes a DuckDB type name for CAST expressions.

func (*Dialect) WriteUnnest

func (d *Dialect) WriteUnnest(w *strings.Builder, writeSource func() error) error

WriteUnnest writes DuckDB UNNEST for array unnesting.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL