sql

package

Go to main page

Versions in this module

v1

v1.25.0

Oct 8, 2026

v1.24.0

Oct 2, 2026

v1.23.0

Sep 22, 2026

v1.22.0

Aug 24, 2026

Changes in this version

+ const AllTables

+ const DialectFieldRowID

+ func ScalarFieldValue(fd protoreflect.FieldDescriptor, value protoreflect.Value) any

type BaseDialect

+ IndexSql []*Constraint

+ func (d *BaseDialect) AddForeignKeyReferencing(table string, referencedTable string, sql string)

+ func (d *BaseDialect) AddIndexSql(table string, sql string)

+ func (d *BaseDialect) TableApplyOrder() ([]string, error)

+ func (d *BaseDialect) TableApplyRanks() (map[string]int, error)

+ func (d *BaseDialect) TableNames() []string

+ func (d *BaseDialect) UseRowIDField(table string) bool

+ type BufferedInserter struct

+ func NewBufferedInserter(expectedRows int) *BufferedInserter

+ func (b *BufferedInserter) Insert(table string, values []any) error

+ func (b *BufferedInserter) Replay(target Inserter) error

+ func (b *BufferedInserter) Reset()

+ func (b *BufferedInserter) Rows() int

type Constraint

+ ReferencedTable string

+ type ConstraintPolicy struct

+ DisableBlockNumberIndex bool

+ DisableForeignKeys bool

+ DisablePrimaryKeys []string

+ DisableUniques []string

+ Parallelism int

+ Timing ConstraintTiming

+ WorkMem string

+ func DisableAllConstraints() ConstraintPolicy

+ func (p ConstraintPolicy) ApplyAtHead() bool

+ func (p ConstraintPolicy) ApplyUpfront() bool

+ func (p ConstraintPolicy) ConstraintsParallelism() int

+ func (p ConstraintPolicy) Describe() string

+ func (p ConstraintPolicy) SkipForeignKey(string) bool

+ func (p ConstraintPolicy) SkipPrimaryKey(table string) bool

+ func (p ConstraintPolicy) SkipUnique(table string) bool

+ func (p ConstraintPolicy) SkipsEverything() bool

+ func (p ConstraintPolicy) WithBlockNumberIndex(from ConstraintPolicy) ConstraintPolicy

+ type ConstraintTiming string

+ const ConstraintsAlways

+ const ConstraintsAuto

+ const ConstraintsManual

+ func ParseConstraintTiming(in string) (ConstraintTiming, error)

type Database

+ ApplyConstraints func() error

+ BufferStats func() (stats WriteStats, enabled bool)

+ Close func(ctx context.Context) error

+ DropConstraints func() error

+ EnsureBlockNumberIndexes func(ctx context.Context) error

+ MissingConstraints func() ([]string, error)

+ SwitchToDirectInserts func(ctx context.Context, reason string, atChainHead bool) error

+ WalkMessageDescriptorAndInsertInto func(dm protoreflect.Message, blockNum uint64, blockTimestamp time.Time, ...) (time.Duration, error)

type Dialect

+ UseRowIDField func(table string) bool

+ type EnumValue struct

+ Name string

+ Number int32

+ func (v EnumValue) String() string

+ type WriteMode string

+ const WriteModeAuto

+ const WriteModeBatchInsert

+ const WriteModeCopy

+ const WriteModeRowInsert

+ func ParseWriteMode(in string) (WriteMode, error)

+ type WriteStats struct

+ DatabaseBytesWritten int64

v1.21.0

Aug 4, 2026

v1.20.3

Jul 31, 2026

v1.20.2

Jul 24, 2026

Changes in this version

+ const DialectFieldBlockNumber

+ const DialectFieldBlockTimestamp

+ const DialectFieldDeleted

+ const DialectFieldVersion

+ const DialectTableBlock

+ const DialectTableCursor

+ func Quoted(value string) string

+ type BaseDatabase struct

+ RootMessageDescriptor protoreflect.MessageDescriptor

+ func NewBaseDatabase(moduleOutputType string, rootMessageDescriptor protoreflect.MessageDescriptor, ...) (database *BaseDatabase, err error)

+ func (d *BaseDatabase) BaseClone() *BaseDatabase

+ func (d *BaseDatabase) WalkMessageDescriptorAndInsertWithDialect(dm *dynamicpb.Message, blockNum uint64, blockTimestamp time.Time, ...) (time.Duration, error)

+ type BaseDialect struct

+ CreateTableSql map[string]string

+ ForeignKeySql []*Constraint

+ Logger *zap.Logger

+ PrimaryKeySql []*Constraint

+ TableRegistry map[string]*schema.Table

+ UniqueConstraintSql []*Constraint

+ func NewBaseDialect(registry map[string]*schema.Table, logger *zap.Logger) *BaseDialect

+ func (d *BaseDialect) AddCreateTableSql(table string, sql string)

+ func (d *BaseDialect) AddForeignKeySql(table string, sql string)

+ func (d *BaseDialect) AddPrimaryKeySql(table string, sql string)

+ func (d *BaseDialect) AddUniqueConstraintSql(table string, sql string)

+ func (d *BaseDialect) GetCreateTableSql(table string) string

+ func (d *BaseDialect) GetTable(table string) *schema.Table

+ func (d *BaseDialect) GetTables() []*schema.Table

+ type Constraint struct

+ Sql string

+ Table string

+ type Context struct

+ func NewContext() *Context

+ func (c *Context) BlockNumber() int

+ func (c *Context) SetNumber(id int)

+ type Database interface

+ BeginTransaction func() error

+ Clone func() Database

+ CommitTransaction func() error

+ CreateDatabase func(useConstraints bool) error

+ DatabaseHash func(schemaName string) (uint64, error)

+ FetchCursor func() (*sink.Cursor, error)

+ FetchSinkInfo func(schemaName string) (*SinkInfo, error)

+ Flush func() (time.Duration, error)

+ GetDialect func() Dialect

+ HandleBlocksUndo func(lastValidBlockNumber uint64) error

+ InsertBlock func(blockNum uint64, hash string, timestamp time.Time) error

+ Open func() error

+ RollbackTransaction func()

+ StoreCursor func(cursor *sink.Cursor) error

+ StoreSinkInfo func(schemaName string, schemaHash string) error

+ UpdateSinkInfoHash func(schemaName string, newHash string) error

+ WalkMessageDescriptorAndInsert func(dm *dynamicpb.Message, blockNum uint64, blockTimestamp time.Time, ...) (time.Duration, error)

+ type Dialect interface

+ AppendInlineFieldValues func(fieldValues []any, fd protoreflect.FieldDescriptor, fv protoreflect.Value, ...) ([]any, error)

+ FullTableName func(table *schema.Table) string

+ GetTable func(table string) *schema.Table

+ GetTables func() []*schema.Table

+ SchemaHash func() string

+ UseDeletedField func() bool

+ UseVersionField func() bool

+ type ForeignKey struct

+ Field string

+ ForeignField string

+ ForeignTable string

+ Name string

+ Table string

+ func (f *ForeignKey) String() string

+ type Inserter interface

+ Insert func(table string, values []any) error

+ type Parent struct

+ type SinkInfo struct

+ SchemaHash string

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