bigquery

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 bigquery implements the BigQuery SQL dialect for cel2sql.

Index

Constants

View Source 
const (
	IndexTypeClustering  = "CLUSTERING"
	IndexTypeSearchIndex = "SEARCH_INDEX"
)

BigQuery index type constants.

Variables

This section is empty.

Functions

This section is empty.

Types

type Dialect 

type Dialect struct{}

Dialect implements dialect.Dialect for BigQuery.

func New 

func New() *Dialect

New creates a new BigQuery dialect.

func (*Dialect) ConvertRegex 

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

ConvertRegex converts an RE2 regex pattern for BigQuery. BigQuery uses RE2 natively, so minimal conversion is needed.

func (*Dialect) MaxIdentifierLength 

func (d *Dialect) MaxIdentifierLength() int

MaxIdentifierLength returns 300 for BigQuery.

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 BigQuery-specific index recommendation for the given pattern. BigQuery uses clustering keys and search indexes. Returns nil for unsupported patterns.

func (*Dialect) ReservedKeywords 

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

ReservedKeywords returns the set of reserved SQL keywords for BigQuery.

func (*Dialect) SupportedPatterns 

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

SupportedPatterns returns the pattern types supported by BigQuery.

func (*Dialect) SupportsIndexAnalysis 

func (d *Dialect) SupportsIndexAnalysis() bool

SupportsIndexAnalysis returns true as BigQuery index analysis is supported.

func (*Dialect) SupportsJSONB 

func (d *Dialect) SupportsJSONB() bool

SupportsJSONB returns false as BigQuery has a single JSON type.

func (*Dialect) SupportsNativeArrays 

func (d *Dialect) SupportsNativeArrays() bool

SupportsNativeArrays returns true as BigQuery has native array types.

func (*Dialect) SupportsRegex 

func (d *Dialect) SupportsRegex() bool

SupportsRegex returns true as BigQuery supports RE2 regex natively.

func (*Dialect) ValidateFieldName 

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

ValidateFieldName validates a field name against BigQuery naming rules.

func (*Dialect) WriteArrayLength 

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

WriteArrayLength writes ARRAY_LENGTH(expr) for BigQuery.

func (*Dialect) WriteArrayLiteralClose 

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

WriteArrayLiteralClose writes the BigQuery array literal closing (]).

func (*Dialect) WriteArrayLiteralOpen 

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

WriteArrayLiteralOpen writes the BigQuery array literal opening ([).

func (*Dialect) WriteArrayMembership 

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

WriteArrayMembership writes a BigQuery array membership test using IN UNNEST().

func (*Dialect) WriteArraySubqueryExprClose 

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

WriteArraySubqueryExprClose is a no-op for BigQuery.

func (*Dialect) WriteArraySubqueryOpen 

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

WriteArraySubqueryOpen writes ARRAY(SELECT for BigQuery.

func (*Dialect) WriteBytesLiteral 

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

WriteBytesLiteral writes a BigQuery octal-encoded byte literal (b"...").

func (*Dialect) WriteCastToNumeric 

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

WriteCastToNumeric writes a BigQuery numeric cast (CAST(... AS FLOAT64)).

func (*Dialect) WriteContains 

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

WriteContains writes STRPOS(haystack, needle) > 0 for BigQuery.

func (*Dialect) WriteDuration 

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

WriteDuration writes a BigQuery INTERVAL literal.

func (*Dialect) WriteEmptyTypedArray 

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

WriteEmptyTypedArray writes an empty BigQuery typed array.

func (*Dialect) WriteEpochExtract 

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

WriteEpochExtract writes UNIX_SECONDS(expr) for BigQuery.

func (*Dialect) WriteExtract 

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

WriteExtract writes a BigQuery EXTRACT expression. BigQuery uses DAYOFWEEK (1=Sunday) instead of DOW (0=Sunday).

func (*Dialect) WriteInterval 

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

WriteInterval writes a BigQuery INTERVAL expression.

func (*Dialect) WriteJSONArrayElements 

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

WriteJSONArrayElements writes BigQuery JSON array expansion.

func (*Dialect) WriteJSONArrayLength 

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

WriteJSONArrayLength writes ARRAY_LENGTH(JSON_QUERY_ARRAY(expr)) for BigQuery.

func (*Dialect) WriteJSONArrayMembership 

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

WriteJSONArrayMembership writes BigQuery JSON array membership.

func (*Dialect) WriteJSONExistence 

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

WriteJSONExistence writes a BigQuery JSON key existence check.

func (*Dialect) WriteJSONExtractPath 

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

WriteJSONExtractPath writes BigQuery JSON path existence using JSON_VALUE.

func (*Dialect) WriteJSONFieldAccess 

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

WriteJSONFieldAccess writes BigQuery JSON field access using JSON_VALUE.

func (*Dialect) WriteJoin 

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

WriteJoin writes BigQuery array join using ARRAY_TO_STRING.

func (*Dialect) WriteLikeEscape 

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

WriteLikeEscape is a no-op for BigQuery. BigQuery uses backslash as the default escape character in LIKE patterns and does not support the ESCAPE keyword.

func (*Dialect) WriteListIndex 

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

WriteListIndex writes BigQuery 0-indexed array access using OFFSET.

func (*Dialect) WriteListIndexConst 

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

WriteListIndexConst writes BigQuery constant array index access using OFFSET.

func (*Dialect) WriteNestedJSONArrayMembership 

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

WriteNestedJSONArrayMembership writes BigQuery nested JSON array membership.

func (*Dialect) WriteParamPlaceholder 

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

WriteParamPlaceholder writes a BigQuery named parameter (@p1, @p2, ...).

func (*Dialect) WriteRegexMatch 

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

WriteRegexMatch writes a BigQuery regex match using REGEXP_CONTAINS.

func (*Dialect) WriteSplit 

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

WriteSplit writes BigQuery string split using SPLIT.

func (*Dialect) WriteSplitWithLimit 

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

WriteSplitWithLimit writes BigQuery SPLIT with array slice.

func (*Dialect) WriteStringConcat 

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

WriteStringConcat writes BigQuery string concatenation using ||.

func (*Dialect) WriteStringLiteral 

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

WriteStringLiteral writes a BigQuery string literal with ” escaping.

func (*Dialect) WriteStructClose 

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

WriteStructClose writes the BigQuery struct literal closing.

func (*Dialect) WriteStructOpen 

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

WriteStructOpen writes the BigQuery struct literal opening.

func (*Dialect) WriteTimestampArithmetic 

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

WriteTimestampArithmetic writes BigQuery timestamp arithmetic using functions. BigQuery uses TIMESTAMP_ADD/TIMESTAMP_SUB instead of + / - operators.

func (*Dialect) WriteTimestampCast 

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

WriteTimestampCast writes a BigQuery CAST to TIMESTAMP.

func (*Dialect) WriteTypeName 

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

WriteTypeName writes a BigQuery type name for CAST expressions.

func (*Dialect) WriteUnnest 

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

WriteUnnest writes BigQuery UNNEST for array unnesting.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.