duckgo

Documentation

Index

• func NewConnector(path string) (lynktable.Connector, error)
• func NewFilter() lynktable.Filter
• func NewQueryer() lynktable.Queryer
• type Dialect
  • func (dc *Dialect) DBName() string
  • func (dc *Dialect) Modeler() modeler.Modeler
  • func (dc *Dialect) NewFilter() lynktable.Filter
  • func (dc *Dialect) NewQueryer() lynktable.Queryer
  • func (dc *Dialect) QuoteStr(str string) string
  • func (dc *Dialect) Upsert(tableName string, item map[string]any, keys map[string]any) lynktable.Result
• type DialectModeler
  • func (dc *DialectModeler) ColumnDel(tableName string, col *modeler.Column) error
  • func (dc *DialectModeler) ColumnList(tableName string) ([]*modeler.Column, error)
  • func (dc *DialectModeler) ColumnSet(tableName string, col *modeler.Column) error
  • func (dc *DialectModeler) ColumnSync(tableName string, col *modeler.Column) error
  • func (dc *DialectModeler) IndexDel(tableName string, index *modeler.Index) error
  • func (dc *DialectModeler) IndexList(tableName string) ([]*modeler.Index, error)
  • func (dc *DialectModeler) IndexSet(tableName string, index *modeler.Index) error
  • func (dc *DialectModeler) IndexSync(tableName string, index *modeler.Index) error
  • func (dc *DialectModeler) QuoteStr(str string) string
  • func (dc *DialectModeler) Schema() (*modeler.Schema, error)
  • func (dc *DialectModeler) SchemaSync(newds *modeler.Schema) error
  • func (dc *DialectModeler) TableExist(tableName string) bool
  • func (dc *DialectModeler) TableList() ([]*modeler.Table, error)
  • func (dc *DialectModeler) TableSync(table *modeler.Table) error
• type Filter
  • func (fr *Filter) And(expr string, args ...any) lynktable.Filter
  • func (fr *Filter) Or(expr string, args ...any) lynktable.Filter
  • func (fr *Filter) Parse() (where string, params []any)
  • func (fr *Filter) Reset() lynktable.Filter
• type Queryer
  • func (q *Queryer) From(s string) lynktable.Queryer
  • func (q *Queryer) Group(s string) lynktable.Queryer
  • func (q *Queryer) Limit(num int64) lynktable.Queryer
  • func (q *Queryer) Offset(num int64) lynktable.Queryer
  • func (q *Queryer) Order(s string) lynktable.Queryer
  • func (q *Queryer) Parse() (sql string, params []any)
  • func (q *Queryer) Select(s string) lynktable.Queryer
  • func (q *Queryer) SetFilter(fr lynktable.Filter)
  • func (q *Queryer) Where() lynktable.Filter

Functions

func NewConnector

func NewConnector(path string) (lynktable.Connector, error)

func NewFilter

func NewFilter() lynktable.Filter

func NewQueryer

func NewQueryer() lynktable.Queryer

Types

type Dialect

type Dialect struct {
	*lynktable.Base
}

func (*Dialect) DBName

func (dc *Dialect) DBName() string

func (*Dialect) Modeler

func (dc *Dialect) Modeler() modeler.Modeler

func (*Dialect) NewFilter

func (dc *Dialect) NewFilter() lynktable.Filter

func (*Dialect) NewQueryer

func (dc *Dialect) NewQueryer() lynktable.Queryer

func (*Dialect) QuoteStr

func (dc *Dialect) QuoteStr(str string) string

func (*Dialect) Upsert

func (dc *Dialect) Upsert(tableName string, item map[string]any, keys map[string]any) lynktable.Result

type DialectModeler

type DialectModeler struct {
	// contains filtered or unexported fields
}

func (*DialectModeler) ColumnDel

func (dc *DialectModeler) ColumnDel(tableName string, col *modeler.Column) error

func (*DialectModeler) ColumnList

func (dc *DialectModeler) ColumnList(tableName string) ([]*modeler.Column, error)

func (*DialectModeler) ColumnSet

func (dc *DialectModeler) ColumnSet(tableName string, col *modeler.Column) error

ColumnSet alters an existing column to match col. DuckDB does not accept NOT NULL / DEFAULT inside ALTER COLUMN ... TYPE, so each constraint is a separate statement.

func (*DialectModeler) ColumnSync

func (dc *DialectModeler) ColumnSync(tableName string, col *modeler.Column) error

func (*DialectModeler) IndexDel

func (dc *DialectModeler) IndexDel(tableName string, index *modeler.Index) error

func (*DialectModeler) IndexList

func (dc *DialectModeler) IndexList(tableName string) ([]*modeler.Index, error)

func (*DialectModeler) IndexSet

func (dc *DialectModeler) IndexSet(tableName string, index *modeler.Index) error

func (*DialectModeler) IndexSync

func (dc *DialectModeler) IndexSync(tableName string, index *modeler.Index) error

func (*DialectModeler) QuoteStr

func (dc *DialectModeler) QuoteStr(str string) string

func (*DialectModeler) Schema

func (dc *DialectModeler) Schema() (*modeler.Schema, error)

func (*DialectModeler) SchemaSync

func (dc *DialectModeler) SchemaSync(newds *modeler.Schema) error

func (*DialectModeler) TableExist

func (dc *DialectModeler) TableExist(tableName string) bool

func (*DialectModeler) TableList

func (dc *DialectModeler) TableList() ([]*modeler.Table, error)

func (*DialectModeler) TableSync

func (dc *DialectModeler) TableSync(table *modeler.Table) error

type Filter

type Filter struct {
	// contains filtered or unexported fields
}

func (*Filter) And

func (fr *Filter) And(expr string, args ...any) lynktable.Filter

And appends a condition joined with AND, the default connective. An expr containing '(' or '?' is taken as a raw SQL fragment; anything else is parsed as the dotted DSL "field.op", with the operator defaulting to eq.

func (*Filter) Or

func (fr *Filter) Or(expr string, args ...any) lynktable.Filter

Or appends a condition joined with OR; expr is interpreted as in And.

func (*Filter) Parse

func (fr *Filter) Parse() (where string, params []any)

func (*Filter) Reset

func (fr *Filter) Reset() lynktable.Filter

type Queryer

type Queryer struct {
	// contains filtered or unexported fields
}

func (*Queryer) From

func (q *Queryer) From(s string) lynktable.Queryer

func (*Queryer) Group

func (q *Queryer) Group(s string) lynktable.Queryer

func (*Queryer) Limit

func (q *Queryer) Limit(num int64) lynktable.Queryer

func (*Queryer) Offset

func (q *Queryer) Offset(num int64) lynktable.Queryer

func (*Queryer) Order

func (q *Queryer) Order(s string) lynktable.Queryer

func (*Queryer) Parse

func (q *Queryer) Parse() (sql string, params []any)

func (*Queryer) Select

func (q *Queryer) Select(s string) lynktable.Queryer

func (*Queryer) SetFilter

func (q *Queryer) SetFilter(fr lynktable.Filter)

func (*Queryer) Where

func (q *Queryer) Where() lynktable.Filter