chschema

package
v0.3.1 Latest Latest
Warning

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

 Go to latest Published: Feb 16, 2023 License: BSD-2-Clause Imports: 25 Imported by: 11

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Append 

func Append(fmter Formatter, b []byte, v any) []byte

func AppendBool 

func AppendBool(dst []byte, v bool) []byte

func AppendBytes 

func AppendBytes(b []byte, bytes []byte) []byte

func AppendError 

func AppendError(b []byte, err error) []byte

func AppendFQN 

func AppendFQN(b []byte, field string) []byte

func AppendFloat 

func AppendFloat(dst []byte, v float64) []byte

func AppendIdent 

func AppendIdent(b []byte, field string) []byte

func AppendNull 

func AppendNull(b []byte) []byte

func AppendQuery 

func AppendQuery(b []byte, query string, args ...any) []byte

func AppendQueryAppender 

func AppendQueryAppender(fmter Formatter, b []byte, app QueryAppender) []byte

func AppendString 

func AppendString(b []byte, s string) []byte

func AppendTime 

func AppendTime(b []byte, tm time.Time) []byte

func AppendValue 

func AppendValue(fmter Formatter, b []byte, v reflect.Value) []byte

func FormatQuery 

func FormatQuery(query string, args ...any) string

func SetTableNameInflector 

func SetTableNameInflector(fn func(string) string)

SetTableNameInflector overrides the default func that pluralizes model name to get table name, e.g. my_article becomes my_articles.

Types

type AfterScanRowHook 

type AfterScanRowHook interface {
	AfterScanRow(context.Context) error
}

type AppenderFunc 

type AppenderFunc func(fmter Formatter, b []byte, v reflect.Value) []byte

func Appender 

func Appender(typ reflect.Type) AppenderFunc

type ArrayArrayBoolColumn added in v0.3.0 

type ArrayArrayBoolColumn struct {
	ColumnOf[[][]bool]
	// contains filtered or unexported fields
}

func (*ArrayArrayBoolColumn) Init added in v0.3.0 

func (c *ArrayArrayBoolColumn) Init(chType string) error

func (*ArrayArrayBoolColumn) ReadFrom added in v0.3.0 

func (c *ArrayArrayBoolColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayArrayBoolColumn) Type added in v0.3.0 

func (c *ArrayArrayBoolColumn) Type() reflect.Type

func (*ArrayArrayBoolColumn) WriteData added in v0.3.0 

func (c *ArrayArrayBoolColumn) WriteData(wr *chproto.Writer) error

func (*ArrayArrayBoolColumn) WriteOffset added in v0.3.0 

func (c *ArrayArrayBoolColumn) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayArrayBoolColumn) WriteTo added in v0.3.0 

func (c *ArrayArrayBoolColumn) WriteTo(wr *chproto.Writer) error

type ArrayArrayBytesColumn added in v0.3.0 

type ArrayArrayBytesColumn struct {
	ColumnOf[[][][]byte]
	// contains filtered or unexported fields
}

func (*ArrayArrayBytesColumn) Init added in v0.3.0 

func (c *ArrayArrayBytesColumn) Init(chType string) error

func (*ArrayArrayBytesColumn) ReadFrom added in v0.3.0 

func (c *ArrayArrayBytesColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayArrayBytesColumn) Type added in v0.3.0 

func (c *ArrayArrayBytesColumn) Type() reflect.Type

func (*ArrayArrayBytesColumn) WriteData added in v0.3.0 

func (c *ArrayArrayBytesColumn) WriteData(wr *chproto.Writer) error

func (*ArrayArrayBytesColumn) WriteOffset added in v0.3.0 

func (c *ArrayArrayBytesColumn) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayArrayBytesColumn) WriteTo added in v0.3.0 

func (c *ArrayArrayBytesColumn) WriteTo(wr *chproto.Writer) error

type ArrayArrayDateTimeColumn added in v0.3.0 

type ArrayArrayDateTimeColumn struct {
	ColumnOf[[][]time.Time]
	// contains filtered or unexported fields
}

func (*ArrayArrayDateTimeColumn) Init added in v0.3.0 

func (c *ArrayArrayDateTimeColumn) Init(chType string) error

func (*ArrayArrayDateTimeColumn) ReadFrom added in v0.3.0 

func (c *ArrayArrayDateTimeColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayArrayDateTimeColumn) Type added in v0.3.0 

func (c *ArrayArrayDateTimeColumn) Type() reflect.Type

func (*ArrayArrayDateTimeColumn) WriteData added in v0.3.0 

func (c *ArrayArrayDateTimeColumn) WriteData(wr *chproto.Writer) error

func (*ArrayArrayDateTimeColumn) WriteOffset added in v0.3.0 

func (c *ArrayArrayDateTimeColumn) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayArrayDateTimeColumn) WriteTo added in v0.3.0 

func (c *ArrayArrayDateTimeColumn) WriteTo(wr *chproto.Writer) error

type ArrayArrayEnumColumn added in v0.3.0 

type ArrayArrayEnumColumn struct {
	ColumnOf[[][]string]
	// contains filtered or unexported fields
}

func (*ArrayArrayEnumColumn) Init added in v0.3.0 

func (c *ArrayArrayEnumColumn) Init(chType string) error

func (*ArrayArrayEnumColumn) ReadFrom added in v0.3.0 

func (c *ArrayArrayEnumColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayArrayEnumColumn) Type added in v0.3.0 

func (c *ArrayArrayEnumColumn) Type() reflect.Type

func (*ArrayArrayEnumColumn) WriteData added in v0.3.0 

func (c *ArrayArrayEnumColumn) WriteData(wr *chproto.Writer) error

func (*ArrayArrayEnumColumn) WriteOffset added in v0.3.0 

func (c *ArrayArrayEnumColumn) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayArrayEnumColumn) WriteTo added in v0.3.0 

func (c *ArrayArrayEnumColumn) WriteTo(wr *chproto.Writer) error

type ArrayArrayFloat32Column added in v0.3.0 

type ArrayArrayFloat32Column struct {
	ColumnOf[[][]float32]
	// contains filtered or unexported fields
}

func (*ArrayArrayFloat32Column) Init added in v0.3.0 

func (c *ArrayArrayFloat32Column) Init(chType string) error

func (*ArrayArrayFloat32Column) ReadFrom added in v0.3.0 

func (c *ArrayArrayFloat32Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayArrayFloat32Column) Type added in v0.3.0 

func (c *ArrayArrayFloat32Column) Type() reflect.Type

func (*ArrayArrayFloat32Column) WriteData added in v0.3.0 

func (c *ArrayArrayFloat32Column) WriteData(wr *chproto.Writer) error

func (*ArrayArrayFloat32Column) WriteOffset added in v0.3.0 

func (c *ArrayArrayFloat32Column) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayArrayFloat32Column) WriteTo added in v0.3.0 

func (c *ArrayArrayFloat32Column) WriteTo(wr *chproto.Writer) error

type ArrayArrayFloat64Column added in v0.3.0 

type ArrayArrayFloat64Column struct {
	ColumnOf[[][]float64]
	// contains filtered or unexported fields
}

func (*ArrayArrayFloat64Column) Init added in v0.3.0 

func (c *ArrayArrayFloat64Column) Init(chType string) error

func (*ArrayArrayFloat64Column) ReadFrom added in v0.3.0 

func (c *ArrayArrayFloat64Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayArrayFloat64Column) Type added in v0.3.0 

func (c *ArrayArrayFloat64Column) Type() reflect.Type

func (*ArrayArrayFloat64Column) WriteData added in v0.3.0 

func (c *ArrayArrayFloat64Column) WriteData(wr *chproto.Writer) error

func (*ArrayArrayFloat64Column) WriteOffset added in v0.3.0 

func (c *ArrayArrayFloat64Column) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayArrayFloat64Column) WriteTo added in v0.3.0 

func (c *ArrayArrayFloat64Column) WriteTo(wr *chproto.Writer) error

type ArrayArrayInt16Column added in v0.3.0 

type ArrayArrayInt16Column struct {
	ColumnOf[[][]int16]
	// contains filtered or unexported fields
}

func (*ArrayArrayInt16Column) Init added in v0.3.0 

func (c *ArrayArrayInt16Column) Init(chType string) error

func (*ArrayArrayInt16Column) ReadFrom added in v0.3.0 

func (c *ArrayArrayInt16Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayArrayInt16Column) Type added in v0.3.0 

func (c *ArrayArrayInt16Column) Type() reflect.Type

func (*ArrayArrayInt16Column) WriteData added in v0.3.0 

func (c *ArrayArrayInt16Column) WriteData(wr *chproto.Writer) error

func (*ArrayArrayInt16Column) WriteOffset added in v0.3.0 

func (c *ArrayArrayInt16Column) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayArrayInt16Column) WriteTo added in v0.3.0 

func (c *ArrayArrayInt16Column) WriteTo(wr *chproto.Writer) error

type ArrayArrayInt32Column added in v0.3.0 

type ArrayArrayInt32Column struct {
	ColumnOf[[][]int32]
	// contains filtered or unexported fields
}

func (*ArrayArrayInt32Column) Init added in v0.3.0 

func (c *ArrayArrayInt32Column) Init(chType string) error

func (*ArrayArrayInt32Column) ReadFrom added in v0.3.0 

func (c *ArrayArrayInt32Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayArrayInt32Column) Type added in v0.3.0 

func (c *ArrayArrayInt32Column) Type() reflect.Type

func (*ArrayArrayInt32Column) WriteData added in v0.3.0 

func (c *ArrayArrayInt32Column) WriteData(wr *chproto.Writer) error

func (*ArrayArrayInt32Column) WriteOffset added in v0.3.0 

func (c *ArrayArrayInt32Column) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayArrayInt32Column) WriteTo added in v0.3.0 

func (c *ArrayArrayInt32Column) WriteTo(wr *chproto.Writer) error

type ArrayArrayInt64Column added in v0.3.0 

type ArrayArrayInt64Column struct {
	ColumnOf[[][]int64]
	// contains filtered or unexported fields
}

func (*ArrayArrayInt64Column) Init added in v0.3.0 

func (c *ArrayArrayInt64Column) Init(chType string) error

func (*ArrayArrayInt64Column) ReadFrom added in v0.3.0 

func (c *ArrayArrayInt64Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayArrayInt64Column) Type added in v0.3.0 

func (c *ArrayArrayInt64Column) Type() reflect.Type

func (*ArrayArrayInt64Column) WriteData added in v0.3.0 

func (c *ArrayArrayInt64Column) WriteData(wr *chproto.Writer) error

func (*ArrayArrayInt64Column) WriteOffset added in v0.3.0 

func (c *ArrayArrayInt64Column) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayArrayInt64Column) WriteTo added in v0.3.0 

func (c *ArrayArrayInt64Column) WriteTo(wr *chproto.Writer) error

type ArrayArrayInt8Column added in v0.3.0 

type ArrayArrayInt8Column struct {
	ColumnOf[[][]int8]
	// contains filtered or unexported fields
}

func (*ArrayArrayInt8Column) Init added in v0.3.0 

func (c *ArrayArrayInt8Column) Init(chType string) error

func (*ArrayArrayInt8Column) ReadFrom added in v0.3.0 

func (c *ArrayArrayInt8Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayArrayInt8Column) Type added in v0.3.0 

func (c *ArrayArrayInt8Column) Type() reflect.Type

func (*ArrayArrayInt8Column) WriteData added in v0.3.0 

func (c *ArrayArrayInt8Column) WriteData(wr *chproto.Writer) error

func (*ArrayArrayInt8Column) WriteOffset added in v0.3.0 

func (c *ArrayArrayInt8Column) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayArrayInt8Column) WriteTo added in v0.3.0 

func (c *ArrayArrayInt8Column) WriteTo(wr *chproto.Writer) error

type ArrayArrayStringColumn added in v0.3.0 

type ArrayArrayStringColumn struct {
	ColumnOf[[][]string]
	// contains filtered or unexported fields
}

func (*ArrayArrayStringColumn) Init added in v0.3.0 

func (c *ArrayArrayStringColumn) Init(chType string) error

func (*ArrayArrayStringColumn) ReadFrom added in v0.3.0 

func (c *ArrayArrayStringColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayArrayStringColumn) Type added in v0.3.0 

func (c *ArrayArrayStringColumn) Type() reflect.Type

func (*ArrayArrayStringColumn) WriteData added in v0.3.0 

func (c *ArrayArrayStringColumn) WriteData(wr *chproto.Writer) error

func (*ArrayArrayStringColumn) WriteOffset added in v0.3.0 

func (c *ArrayArrayStringColumn) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayArrayStringColumn) WriteTo added in v0.3.0 

func (c *ArrayArrayStringColumn) WriteTo(wr *chproto.Writer) error

type ArrayArrayUInt16Column added in v0.3.0 

type ArrayArrayUInt16Column struct {
	ColumnOf[[][]uint16]
	// contains filtered or unexported fields
}

func (*ArrayArrayUInt16Column) Init added in v0.3.0 

func (c *ArrayArrayUInt16Column) Init(chType string) error

func (*ArrayArrayUInt16Column) ReadFrom added in v0.3.0 

func (c *ArrayArrayUInt16Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayArrayUInt16Column) Type added in v0.3.0 

func (c *ArrayArrayUInt16Column) Type() reflect.Type

func (*ArrayArrayUInt16Column) WriteData added in v0.3.0 

func (c *ArrayArrayUInt16Column) WriteData(wr *chproto.Writer) error

func (*ArrayArrayUInt16Column) WriteOffset added in v0.3.0 

func (c *ArrayArrayUInt16Column) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayArrayUInt16Column) WriteTo added in v0.3.0 

func (c *ArrayArrayUInt16Column) WriteTo(wr *chproto.Writer) error

type ArrayArrayUInt32Column added in v0.3.0 

type ArrayArrayUInt32Column struct {
	ColumnOf[[][]uint32]
	// contains filtered or unexported fields
}

func (*ArrayArrayUInt32Column) Init added in v0.3.0 

func (c *ArrayArrayUInt32Column) Init(chType string) error

func (*ArrayArrayUInt32Column) ReadFrom added in v0.3.0 

func (c *ArrayArrayUInt32Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayArrayUInt32Column) Type added in v0.3.0 

func (c *ArrayArrayUInt32Column) Type() reflect.Type

func (*ArrayArrayUInt32Column) WriteData added in v0.3.0 

func (c *ArrayArrayUInt32Column) WriteData(wr *chproto.Writer) error

func (*ArrayArrayUInt32Column) WriteOffset added in v0.3.0 

func (c *ArrayArrayUInt32Column) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayArrayUInt32Column) WriteTo added in v0.3.0 

func (c *ArrayArrayUInt32Column) WriteTo(wr *chproto.Writer) error

type ArrayArrayUInt64Column added in v0.3.0 

type ArrayArrayUInt64Column struct {
	ColumnOf[[][]uint64]
	// contains filtered or unexported fields
}

func (*ArrayArrayUInt64Column) Init added in v0.3.0 

func (c *ArrayArrayUInt64Column) Init(chType string) error

func (*ArrayArrayUInt64Column) ReadFrom added in v0.3.0 

func (c *ArrayArrayUInt64Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayArrayUInt64Column) Type added in v0.3.0 

func (c *ArrayArrayUInt64Column) Type() reflect.Type

func (*ArrayArrayUInt64Column) WriteData added in v0.3.0 

func (c *ArrayArrayUInt64Column) WriteData(wr *chproto.Writer) error

func (*ArrayArrayUInt64Column) WriteOffset added in v0.3.0 

func (c *ArrayArrayUInt64Column) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayArrayUInt64Column) WriteTo added in v0.3.0 

func (c *ArrayArrayUInt64Column) WriteTo(wr *chproto.Writer) error

type ArrayArrayUInt8Column added in v0.3.0 

type ArrayArrayUInt8Column struct {
	ColumnOf[[][]uint8]
	// contains filtered or unexported fields
}

func (*ArrayArrayUInt8Column) Init added in v0.3.0 

func (c *ArrayArrayUInt8Column) Init(chType string) error

func (*ArrayArrayUInt8Column) ReadFrom added in v0.3.0 

func (c *ArrayArrayUInt8Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayArrayUInt8Column) Type added in v0.3.0 

func (c *ArrayArrayUInt8Column) Type() reflect.Type

func (*ArrayArrayUInt8Column) WriteData added in v0.3.0 

func (c *ArrayArrayUInt8Column) WriteData(wr *chproto.Writer) error

func (*ArrayArrayUInt8Column) WriteOffset added in v0.3.0 

func (c *ArrayArrayUInt8Column) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayArrayUInt8Column) WriteTo added in v0.3.0 

func (c *ArrayArrayUInt8Column) WriteTo(wr *chproto.Writer) error

type ArrayBoolColumn added in v0.3.0 

type ArrayBoolColumn struct {
	ColumnOf[[]bool]
	// contains filtered or unexported fields
}

func (*ArrayBoolColumn) Init added in v0.3.0 

func (c *ArrayBoolColumn) Init(chType string) error

func (*ArrayBoolColumn) ReadFrom added in v0.3.0 

func (c *ArrayBoolColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayBoolColumn) Type added in v0.3.0 

func (c *ArrayBoolColumn) Type() reflect.Type

func (*ArrayBoolColumn) WriteData added in v0.3.0 

func (c *ArrayBoolColumn) WriteData(wr *chproto.Writer) error

func (*ArrayBoolColumn) WriteOffset added in v0.3.0 

func (c *ArrayBoolColumn) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayBoolColumn) WriteTo added in v0.3.0 

func (c *ArrayBoolColumn) WriteTo(wr *chproto.Writer) error

type ArrayBytesColumn added in v0.3.0 

type ArrayBytesColumn struct {
	ColumnOf[[][]byte]
	// contains filtered or unexported fields
}

func (*ArrayBytesColumn) Init added in v0.3.0 

func (c *ArrayBytesColumn) Init(chType string) error

func (*ArrayBytesColumn) ReadFrom added in v0.3.0 

func (c *ArrayBytesColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayBytesColumn) Type added in v0.3.0 

func (c *ArrayBytesColumn) Type() reflect.Type

func (*ArrayBytesColumn) WriteData added in v0.3.0 

func (c *ArrayBytesColumn) WriteData(wr *chproto.Writer) error

func (*ArrayBytesColumn) WriteOffset added in v0.3.0 

func (c *ArrayBytesColumn) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayBytesColumn) WriteTo added in v0.3.0 

func (c *ArrayBytesColumn) WriteTo(wr *chproto.Writer) error

type ArrayColumnar 

type ArrayColumnar interface {
	WriteOffset(wr *chproto.Writer, offset int) int
	WriteData(wr *chproto.Writer) error
}

type ArrayDateTimeColumn added in v0.3.0 

type ArrayDateTimeColumn struct {
	ColumnOf[[]time.Time]
	// contains filtered or unexported fields
}

func (*ArrayDateTimeColumn) Init added in v0.3.0 

func (c *ArrayDateTimeColumn) Init(chType string) error

func (*ArrayDateTimeColumn) ReadFrom added in v0.3.0 

func (c *ArrayDateTimeColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayDateTimeColumn) Type added in v0.3.0 

func (c *ArrayDateTimeColumn) Type() reflect.Type

func (*ArrayDateTimeColumn) WriteData added in v0.3.0 

func (c *ArrayDateTimeColumn) WriteData(wr *chproto.Writer) error

func (*ArrayDateTimeColumn) WriteOffset added in v0.3.0 

func (c *ArrayDateTimeColumn) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayDateTimeColumn) WriteTo added in v0.3.0 

func (c *ArrayDateTimeColumn) WriteTo(wr *chproto.Writer) error

type ArrayEnumColumn added in v0.3.0 

type ArrayEnumColumn struct {
	ColumnOf[[]string]
	// contains filtered or unexported fields
}

func (*ArrayEnumColumn) Init added in v0.3.0 

func (c *ArrayEnumColumn) Init(chType string) error

func (*ArrayEnumColumn) ReadFrom added in v0.3.0 

func (c *ArrayEnumColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayEnumColumn) Type added in v0.3.0 

func (c *ArrayEnumColumn) Type() reflect.Type

func (*ArrayEnumColumn) WriteData added in v0.3.0 

func (c *ArrayEnumColumn) WriteData(wr *chproto.Writer) error

func (*ArrayEnumColumn) WriteOffset added in v0.3.0 

func (c *ArrayEnumColumn) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayEnumColumn) WriteTo added in v0.3.0 

func (c *ArrayEnumColumn) WriteTo(wr *chproto.Writer) error

type ArrayFloat32Column added in v0.3.0 

type ArrayFloat32Column struct {
	ColumnOf[[]float32]
	// contains filtered or unexported fields
}

func (*ArrayFloat32Column) Init added in v0.3.0 

func (c *ArrayFloat32Column) Init(chType string) error

func (*ArrayFloat32Column) ReadFrom added in v0.3.0 

func (c *ArrayFloat32Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayFloat32Column) Type added in v0.3.0 

func (c *ArrayFloat32Column) Type() reflect.Type

func (*ArrayFloat32Column) WriteData added in v0.3.0 

func (c *ArrayFloat32Column) WriteData(wr *chproto.Writer) error

func (*ArrayFloat32Column) WriteOffset added in v0.3.0 

func (c *ArrayFloat32Column) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayFloat32Column) WriteTo added in v0.3.0 

func (c *ArrayFloat32Column) WriteTo(wr *chproto.Writer) error

type ArrayFloat64Column added in v0.3.0 

type ArrayFloat64Column struct {
	ColumnOf[[]float64]
	// contains filtered or unexported fields
}

func (*ArrayFloat64Column) Init added in v0.3.0 

func (c *ArrayFloat64Column) Init(chType string) error

func (*ArrayFloat64Column) ReadFrom added in v0.3.0 

func (c *ArrayFloat64Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayFloat64Column) Type added in v0.3.0 

func (c *ArrayFloat64Column) Type() reflect.Type

func (*ArrayFloat64Column) WriteData added in v0.3.0 

func (c *ArrayFloat64Column) WriteData(wr *chproto.Writer) error

func (*ArrayFloat64Column) WriteOffset added in v0.3.0 

func (c *ArrayFloat64Column) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayFloat64Column) WriteTo added in v0.3.0 

func (c *ArrayFloat64Column) WriteTo(wr *chproto.Writer) error

type ArrayInt16Column added in v0.3.0 

type ArrayInt16Column struct {
	ColumnOf[[]int16]
	// contains filtered or unexported fields
}

func (*ArrayInt16Column) Init added in v0.3.0 

func (c *ArrayInt16Column) Init(chType string) error

func (*ArrayInt16Column) ReadFrom added in v0.3.0 

func (c *ArrayInt16Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayInt16Column) Type added in v0.3.0 

func (c *ArrayInt16Column) Type() reflect.Type

func (*ArrayInt16Column) WriteData added in v0.3.0 

func (c *ArrayInt16Column) WriteData(wr *chproto.Writer) error

func (*ArrayInt16Column) WriteOffset added in v0.3.0 

func (c *ArrayInt16Column) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayInt16Column) WriteTo added in v0.3.0 

func (c *ArrayInt16Column) WriteTo(wr *chproto.Writer) error

type ArrayInt32Column added in v0.3.0 

type ArrayInt32Column struct {
	ColumnOf[[]int32]
	// contains filtered or unexported fields
}

func (*ArrayInt32Column) Init added in v0.3.0 

func (c *ArrayInt32Column) Init(chType string) error

func (*ArrayInt32Column) ReadFrom added in v0.3.0 

func (c *ArrayInt32Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayInt32Column) Type added in v0.3.0 

func (c *ArrayInt32Column) Type() reflect.Type

func (*ArrayInt32Column) WriteData added in v0.3.0 

func (c *ArrayInt32Column) WriteData(wr *chproto.Writer) error

func (*ArrayInt32Column) WriteOffset added in v0.3.0 

func (c *ArrayInt32Column) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayInt32Column) WriteTo added in v0.3.0 

func (c *ArrayInt32Column) WriteTo(wr *chproto.Writer) error

type ArrayInt64Column added in v0.3.0 

type ArrayInt64Column struct {
	ColumnOf[[]int64]
	// contains filtered or unexported fields
}

func (*ArrayInt64Column) Init added in v0.3.0 

func (c *ArrayInt64Column) Init(chType string) error

func (*ArrayInt64Column) ReadFrom added in v0.3.0 

func (c *ArrayInt64Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayInt64Column) Type added in v0.3.0 

func (c *ArrayInt64Column) Type() reflect.Type

func (*ArrayInt64Column) WriteData added in v0.3.0 

func (c *ArrayInt64Column) WriteData(wr *chproto.Writer) error

func (*ArrayInt64Column) WriteOffset added in v0.3.0 

func (c *ArrayInt64Column) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayInt64Column) WriteTo added in v0.3.0 

func (c *ArrayInt64Column) WriteTo(wr *chproto.Writer) error

type ArrayInt8Column added in v0.3.0 

type ArrayInt8Column struct {
	ColumnOf[[]int8]
	// contains filtered or unexported fields
}

func (*ArrayInt8Column) Init added in v0.3.0 

func (c *ArrayInt8Column) Init(chType string) error

func (*ArrayInt8Column) ReadFrom added in v0.3.0 

func (c *ArrayInt8Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayInt8Column) Type added in v0.3.0 

func (c *ArrayInt8Column) Type() reflect.Type

func (*ArrayInt8Column) WriteData added in v0.3.0 

func (c *ArrayInt8Column) WriteData(wr *chproto.Writer) error

func (*ArrayInt8Column) WriteOffset added in v0.3.0 

func (c *ArrayInt8Column) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayInt8Column) WriteTo added in v0.3.0 

func (c *ArrayInt8Column) WriteTo(wr *chproto.Writer) error

type ArrayLCStringColumn 

type ArrayLCStringColumn struct {
	ArrayStringColumn
	// contains filtered or unexported fields
}

func (*ArrayLCStringColumn) ConvertAssign added in v0.3.0 

func (c *ArrayLCStringColumn) ConvertAssign(idx int, dest reflect.Value) error

func (*ArrayLCStringColumn) ReadFrom 

func (c *ArrayLCStringColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayLCStringColumn) WriteData added in v0.3.0 

func (c *ArrayLCStringColumn) WriteData(wr *chproto.Writer) error

func (*ArrayLCStringColumn) WriteTo 

func (c *ArrayLCStringColumn) WriteTo(wr *chproto.Writer) error

type ArrayStringColumn added in v0.3.0 

type ArrayStringColumn struct {
	ColumnOf[[]string]
	// contains filtered or unexported fields
}

func (*ArrayStringColumn) Init added in v0.3.0 

func (c *ArrayStringColumn) Init(chType string) error

func (*ArrayStringColumn) ReadFrom added in v0.3.0 

func (c *ArrayStringColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayStringColumn) Type added in v0.3.0 

func (c *ArrayStringColumn) Type() reflect.Type

func (*ArrayStringColumn) WriteData added in v0.3.0 

func (c *ArrayStringColumn) WriteData(wr *chproto.Writer) error

func (*ArrayStringColumn) WriteOffset added in v0.3.0 

func (c *ArrayStringColumn) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayStringColumn) WriteTo added in v0.3.0 

func (c *ArrayStringColumn) WriteTo(wr *chproto.Writer) error

type ArrayUInt16Column added in v0.3.0 

type ArrayUInt16Column struct {
	ColumnOf[[]uint16]
	// contains filtered or unexported fields
}

func (*ArrayUInt16Column) Init added in v0.3.0 

func (c *ArrayUInt16Column) Init(chType string) error

func (*ArrayUInt16Column) ReadFrom added in v0.3.0 

func (c *ArrayUInt16Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayUInt16Column) Type added in v0.3.0 

func (c *ArrayUInt16Column) Type() reflect.Type

func (*ArrayUInt16Column) WriteData added in v0.3.0 

func (c *ArrayUInt16Column) WriteData(wr *chproto.Writer) error

func (*ArrayUInt16Column) WriteOffset added in v0.3.0 

func (c *ArrayUInt16Column) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayUInt16Column) WriteTo added in v0.3.0 

func (c *ArrayUInt16Column) WriteTo(wr *chproto.Writer) error

type ArrayUInt32Column added in v0.3.0 

type ArrayUInt32Column struct {
	ColumnOf[[]uint32]
	// contains filtered or unexported fields
}

func (*ArrayUInt32Column) Init added in v0.3.0 

func (c *ArrayUInt32Column) Init(chType string) error

func (*ArrayUInt32Column) ReadFrom added in v0.3.0 

func (c *ArrayUInt32Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayUInt32Column) Type added in v0.3.0 

func (c *ArrayUInt32Column) Type() reflect.Type

func (*ArrayUInt32Column) WriteData added in v0.3.0 

func (c *ArrayUInt32Column) WriteData(wr *chproto.Writer) error

func (*ArrayUInt32Column) WriteOffset added in v0.3.0 

func (c *ArrayUInt32Column) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayUInt32Column) WriteTo added in v0.3.0 

func (c *ArrayUInt32Column) WriteTo(wr *chproto.Writer) error

type ArrayUInt64Column added in v0.3.0 

type ArrayUInt64Column struct {
	ColumnOf[[]uint64]
	// contains filtered or unexported fields
}

func (*ArrayUInt64Column) Init added in v0.3.0 

func (c *ArrayUInt64Column) Init(chType string) error

func (*ArrayUInt64Column) ReadFrom added in v0.3.0 

func (c *ArrayUInt64Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayUInt64Column) Type added in v0.3.0 

func (c *ArrayUInt64Column) Type() reflect.Type

func (*ArrayUInt64Column) WriteData added in v0.3.0 

func (c *ArrayUInt64Column) WriteData(wr *chproto.Writer) error

func (*ArrayUInt64Column) WriteOffset added in v0.3.0 

func (c *ArrayUInt64Column) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayUInt64Column) WriteTo added in v0.3.0 

func (c *ArrayUInt64Column) WriteTo(wr *chproto.Writer) error

type ArrayUInt8Column added in v0.3.0 

type ArrayUInt8Column struct {
	ColumnOf[[]uint8]
	// contains filtered or unexported fields
}

func (*ArrayUInt8Column) Init added in v0.3.0 

func (c *ArrayUInt8Column) Init(chType string) error

func (*ArrayUInt8Column) ReadFrom added in v0.3.0 

func (c *ArrayUInt8Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*ArrayUInt8Column) Type added in v0.3.0 

func (c *ArrayUInt8Column) Type() reflect.Type

func (*ArrayUInt8Column) WriteData added in v0.3.0 

func (c *ArrayUInt8Column) WriteData(wr *chproto.Writer) error

func (*ArrayUInt8Column) WriteOffset added in v0.3.0 

func (c *ArrayUInt8Column) WriteOffset(wr *chproto.Writer, offset int) int

func (*ArrayUInt8Column) WriteTo added in v0.3.0 

func (c *ArrayUInt8Column) WriteTo(wr *chproto.Writer) error

type BFloat16HistColumn added in v0.2.9 

type BFloat16HistColumn struct {
	ColumnOf[bfloat16.Map]
}

func (*BFloat16HistColumn) ReadFrom added in v0.2.9 

func (c *BFloat16HistColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (BFloat16HistColumn) Type added in v0.2.9 

func (c BFloat16HistColumn) Type() reflect.Type

func (BFloat16HistColumn) WriteTo added in v0.2.9 

func (c BFloat16HistColumn) WriteTo(wr *chproto.Writer) error

type Block 

type Block struct {
	Table *Table

	NumColumn int // read-only
	NumRow    int // read-only

	Columns []*Column
	// contains filtered or unexported fields
}

func NewBlock 

func NewBlock(table *Table, numCol, numRow int) *Block

func (*Block) Column 

func (b *Block) Column(colName, colType string) *Column

func (*Block) ColumnForField 

func (b *Block) ColumnForField(field *Field) *Column

func (*Block) WriteTo 

func (b *Block) WriteTo(wr *chproto.Writer) error

type BoolColumn 

type BoolColumn struct {
	ColumnOf[bool]
}

func (*BoolColumn) AppendValue 

func (c *BoolColumn) AppendValue(v reflect.Value)

func (BoolColumn) ConvertAssign 

func (c BoolColumn) ConvertAssign(idx int, v reflect.Value) error

func (*BoolColumn) ReadFrom 

func (c *BoolColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (*BoolColumn) Type 

func (c *BoolColumn) Type() reflect.Type

func (*BoolColumn) WriteTo 

func (c *BoolColumn) WriteTo(wr *chproto.Writer) error

type BytesColumn 

type BytesColumn struct {
	ColumnOf[[]byte]
}

func (*BytesColumn) AppendValue 

func (c *BytesColumn) AppendValue(v reflect.Value)

func (*BytesColumn) ReadFrom 

func (c *BytesColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (*BytesColumn) Type 

func (c *BytesColumn) Type() reflect.Type

func (*BytesColumn) WriteTo 

func (c *BytesColumn) WriteTo(wr *chproto.Writer) error

type CHModel 

type CHModel struct{}

type Column 

type Column struct {
	Name  string
	Type  string
	Field *Field

	Columnar
}

func (*Column) String 

func (c *Column) String() string

type ColumnOf 

type ColumnOf[T any] struct {
	Column []T
}

func (*ColumnOf[T]) AllocForReading added in v0.3.0 

func (c *ColumnOf[T]) AllocForReading(numRow int)

func (*ColumnOf[T]) AppendValue 

func (c *ColumnOf[T]) AppendValue(v reflect.Value)

func (*ColumnOf[T]) ConvertAssign 

func (c *ColumnOf[T]) ConvertAssign(idx int, dest reflect.Value) error

func (ColumnOf[T]) Index 

func (c ColumnOf[T]) Index(idx int) any

func (*ColumnOf[T]) Init added in v0.3.0 

func (c *ColumnOf[T]) Init(chType string) error

func (ColumnOf[T]) Len 

func (c ColumnOf[T]) Len() int

func (ColumnOf[T]) Nullable 

func (c ColumnOf[T]) Nullable(nulls UInt8Column) any

func (*ColumnOf[T]) ResetForWriting added in v0.3.0 

func (c *ColumnOf[T]) ResetForWriting(numRow int)

func (*ColumnOf[T]) Set 

func (c *ColumnOf[T]) Set(v any)

func (ColumnOf[T]) Slice 

func (c ColumnOf[T]) Slice(s, e int) any

func (ColumnOf[T]) Value 

func (c ColumnOf[T]) Value() any

type Columnar 

type Columnar interface {
	Init(chType string) error
	AllocForReading(numRow int)
	ResetForWriting(numRow int)

	Type() reflect.Type
	Set(v any)
	AppendValue(v reflect.Value)
	Value() any
	Nullable(nulls UInt8Column) any
	Len() int
	Index(idx int) any
	Slice(s, e int) any
	ConvertAssign(idx int, dest reflect.Value) error

	ReadFrom(rd *chproto.Reader, numRow int) error
	WriteTo(wr *chproto.Writer) error
}

func NewArrayArrayBoolColumn added in v0.3.0 

func NewArrayArrayBoolColumn() Columnar

func NewArrayArrayBytesColumn added in v0.3.0 

func NewArrayArrayBytesColumn() Columnar

func NewArrayArrayDateTimeColumn added in v0.3.0 

func NewArrayArrayDateTimeColumn() Columnar

func NewArrayArrayEnumColumn added in v0.3.0 

func NewArrayArrayEnumColumn() Columnar

func NewArrayArrayFloat32Column added in v0.3.0 

func NewArrayArrayFloat32Column() Columnar

func NewArrayArrayFloat64Column added in v0.3.0 

func NewArrayArrayFloat64Column() Columnar

func NewArrayArrayInt16Column added in v0.3.0 

func NewArrayArrayInt16Column() Columnar

func NewArrayArrayInt32Column added in v0.3.0 

func NewArrayArrayInt32Column() Columnar

func NewArrayArrayInt64Column added in v0.3.0 

func NewArrayArrayInt64Column() Columnar

func NewArrayArrayInt8Column added in v0.3.0 

func NewArrayArrayInt8Column() Columnar

func NewArrayArrayStringColumn added in v0.3.0 

func NewArrayArrayStringColumn() Columnar

func NewArrayArrayUInt16Column added in v0.3.0 

func NewArrayArrayUInt16Column() Columnar

func NewArrayArrayUInt32Column added in v0.3.0 

func NewArrayArrayUInt32Column() Columnar

func NewArrayArrayUInt64Column added in v0.3.0 

func NewArrayArrayUInt64Column() Columnar

func NewArrayArrayUInt8Column added in v0.3.0 

func NewArrayArrayUInt8Column() Columnar

func NewArrayBoolColumn added in v0.3.0 

func NewArrayBoolColumn() Columnar

func NewArrayBytesColumn added in v0.3.0 

func NewArrayBytesColumn() Columnar

func NewArrayDateTimeColumn added in v0.3.0 

func NewArrayDateTimeColumn() Columnar

func NewArrayEnumColumn added in v0.3.0 

func NewArrayEnumColumn() Columnar

func NewArrayFloat32Column added in v0.3.0 

func NewArrayFloat32Column() Columnar

func NewArrayFloat64Column added in v0.3.0 

func NewArrayFloat64Column() Columnar

func NewArrayInt16Column added in v0.3.0 

func NewArrayInt16Column() Columnar

func NewArrayInt32Column added in v0.3.0 

func NewArrayInt32Column() Columnar

func NewArrayInt64Column added in v0.3.0 

func NewArrayInt64Column() Columnar

func NewArrayInt8Column added in v0.3.0 

func NewArrayInt8Column() Columnar

func NewArrayLCStringColumn added in v0.3.0 

func NewArrayLCStringColumn() Columnar

func NewArrayStringColumn added in v0.3.0 

func NewArrayStringColumn() Columnar

func NewArrayUInt16Column added in v0.3.0 

func NewArrayUInt16Column() Columnar

func NewArrayUInt32Column added in v0.3.0 

func NewArrayUInt32Column() Columnar

func NewArrayUInt64Column added in v0.3.0 

func NewArrayUInt64Column() Columnar

func NewArrayUInt8Column added in v0.3.0 

func NewArrayUInt8Column() Columnar

func NewBFloat16HistColumn added in v0.2.9 

func NewBFloat16HistColumn() Columnar

func NewBoolColumn 

func NewBoolColumn() Columnar

func NewBytesColumn 

func NewBytesColumn() Columnar

func NewColumn 

func NewColumn(chType string, typ reflect.Type) Columnar

func NewDateColumn 

func NewDateColumn() Columnar

func NewDateTime64Column added in v0.2.6 

func NewDateTime64Column() Columnar

func NewDateTimeColumn 

func NewDateTimeColumn() Columnar

func NewEnumColumn 

func NewEnumColumn() Columnar

func NewFloat32Column 

func NewFloat32Column() Columnar

func NewFloat64Column 

func NewFloat64Column() Columnar

func NewIPColumn 

func NewIPColumn() Columnar

func NewInt16Column 

func NewInt16Column() Columnar

func NewInt32Column 

func NewInt32Column() Columnar

func NewInt64Column 

func NewInt64Column() Columnar

func NewInt8Column 

func NewInt8Column() Columnar

func NewJSONColumn 

func NewJSONColumn() Columnar

func NewLCStringColumn 

func NewLCStringColumn() Columnar

func NewStringColumn 

func NewStringColumn() Columnar

func NewTimeColumn 

func NewTimeColumn() Columnar

func NewUInt16Column added in v0.2.6 

func NewUInt16Column() Columnar

func NewUInt32Column added in v0.2.6 

func NewUInt32Column() Columnar

func NewUInt64Column added in v0.2.6 

func NewUInt64Column() Columnar

func NewUInt8Column added in v0.2.6 

func NewUInt8Column() Columnar

func NewUUIDColumn 

func NewUUIDColumn() Columnar

type ColumnsAppender 

type ColumnsAppender interface {
	AppendColumns(fmter Formatter, b []byte) ([]byte, error)
}

type DateColumn 

type DateColumn struct {
	DateTimeColumn
}

func (*DateColumn) ReadFrom 

func (c *DateColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (DateColumn) WriteTo 

func (c DateColumn) WriteTo(wr *chproto.Writer) error

type DateTime64Column added in v0.2.6 

type DateTime64Column struct {
	ColumnOf[time.Time]
	// contains filtered or unexported fields
}

func (*DateTime64Column) ConvertAssign added in v0.2.6 

func (c *DateTime64Column) ConvertAssign(idx int, v reflect.Value) error

func (*DateTime64Column) Init added in v0.3.0 

func (c *DateTime64Column) Init(chType string) error

func (*DateTime64Column) ReadFrom added in v0.2.6 

func (c *DateTime64Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*DateTime64Column) Type added in v0.2.6 

func (c *DateTime64Column) Type() reflect.Type

func (*DateTime64Column) WriteTo added in v0.2.6 

func (c *DateTime64Column) WriteTo(wr *chproto.Writer) error

type DateTimeColumn 

type DateTimeColumn struct {
	ColumnOf[time.Time]
}

func (*DateTimeColumn) ReadFrom 

func (c *DateTimeColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (*DateTimeColumn) Type 

func (c *DateTimeColumn) Type() reflect.Type

func (*DateTimeColumn) WriteTo 

func (c *DateTimeColumn) WriteTo(wr *chproto.Writer) error

type EnumColumn 

type EnumColumn struct {
	StringColumn
	// contains filtered or unexported fields
}

func (*EnumColumn) Init added in v0.3.0 

func (c *EnumColumn) Init(chType string) error

func (*EnumColumn) ReadFrom 

func (c *EnumColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (*EnumColumn) WriteTo 

func (c *EnumColumn) WriteTo(wr *chproto.Writer) error

type FQN 

type FQN string

FQN represents a fully qualified SQL name, for example, table or column name.

func (FQN) AppendQuery 

func (s FQN) AppendQuery(fmter Formatter, b []byte) ([]byte, error)

type Field 

type Field struct {
	Field reflect.StructField
	Type  reflect.Type
	Index []int

	GoName    string // struct field name, e.g. Id
	CHName    string // SQL name, .e.g. id
	Column    Safe   // escaped SQL name, e.g. "id"
	CHType    string
	CHDefault Safe

	NewColumn NewColumnFunc

	IsPK    bool
	NotNull bool
	// contains filtered or unexported fields
}

func (*Field) AppendValue 

func (f *Field) AppendValue(fmter Formatter, b []byte, strct reflect.Value) []byte

func (*Field) String 

func (f *Field) String() string

func (*Field) Value 

func (f *Field) Value(strct reflect.Value) reflect.Value

type Float32Column 

type Float32Column struct {
	NumericColumnOf[float32]
}

func (*Float32Column) AppendValue 

func (c *Float32Column) AppendValue(v reflect.Value)

func (*Float32Column) ReadFrom 

func (c *Float32Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*Float32Column) Type 

func (c *Float32Column) Type() reflect.Type

func (*Float32Column) WriteTo 

func (c *Float32Column) WriteTo(wr *chproto.Writer) error

type Float64Column 

type Float64Column struct {
	NumericColumnOf[float64]
}

func (*Float64Column) AppendValue 

func (c *Float64Column) AppendValue(v reflect.Value)

func (*Float64Column) ReadFrom 

func (c *Float64Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*Float64Column) Type 

func (c *Float64Column) Type() reflect.Type

func (*Float64Column) WriteTo 

func (c *Float64Column) WriteTo(wr *chproto.Writer) error

type Formatter 

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

func NewFormatter 

func NewFormatter() Formatter

func (Formatter) AppendIdent 

func (f Formatter) AppendIdent(b []byte, ident string) []byte

func (Formatter) AppendQuery 

func (f Formatter) AppendQuery(b []byte, query string, args ...any) []byte

func (Formatter) FormatQuery 

func (f Formatter) FormatQuery(query string, args ...any) string

func (Formatter) WithArg 

func (f Formatter) WithArg(arg NamedArgAppender) Formatter

func (Formatter) WithNamedArg 

func (f Formatter) WithNamedArg(name string, value any) Formatter

type IPColumn 

type IPColumn struct {
	ColumnOf[net.IP]
}

func (*IPColumn) AppendValue 

func (c *IPColumn) AppendValue(v reflect.Value)

func (IPColumn) ConvertAssign 

func (c IPColumn) ConvertAssign(idx int, v reflect.Value) error

func (*IPColumn) ReadFrom 

func (c *IPColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (IPColumn) Type 

func (c IPColumn) Type() reflect.Type

func (IPColumn) WriteTo 

func (c IPColumn) WriteTo(wr *chproto.Writer) error

type Ident 

type Ident string

Ident represents a SQL identifier, for example, table or column name.

func (Ident) AppendQuery 

func (s Ident) AppendQuery(fmter Formatter, b []byte) ([]byte, error)

type Int16Column 

type Int16Column struct {
	NumericColumnOf[int16]
}

func (*Int16Column) AppendValue 

func (c *Int16Column) AppendValue(v reflect.Value)

func (*Int16Column) ReadFrom 

func (c *Int16Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*Int16Column) Type 

func (c *Int16Column) Type() reflect.Type

func (*Int16Column) WriteTo 

func (c *Int16Column) WriteTo(wr *chproto.Writer) error

type Int32Column 

type Int32Column struct {
	NumericColumnOf[int32]
}

func (*Int32Column) AppendValue 

func (c *Int32Column) AppendValue(v reflect.Value)

func (*Int32Column) ReadFrom 

func (c *Int32Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*Int32Column) Type 

func (c *Int32Column) Type() reflect.Type

func (*Int32Column) WriteTo 

func (c *Int32Column) WriteTo(wr *chproto.Writer) error

type Int64Column 

type Int64Column struct {
	NumericColumnOf[int64]
}

func (*Int64Column) AppendValue 

func (c *Int64Column) AppendValue(v reflect.Value)

func (*Int64Column) ReadFrom 

func (c *Int64Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*Int64Column) Type 

func (c *Int64Column) Type() reflect.Type

func (*Int64Column) WriteTo 

func (c *Int64Column) WriteTo(wr *chproto.Writer) error

type Int8Column 

type Int8Column struct {
	NumericColumnOf[int8]
}

func (*Int8Column) AppendValue 

func (c *Int8Column) AppendValue(v reflect.Value)

func (*Int8Column) ReadFrom 

func (c *Int8Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*Int8Column) Type 

func (c *Int8Column) Type() reflect.Type

func (*Int8Column) WriteTo 

func (c *Int8Column) WriteTo(wr *chproto.Writer) error

type JSONColumn 

type JSONColumn struct {
	BytesColumn
	Values []reflect.Value
}

func (*JSONColumn) AppendValue 

func (c *JSONColumn) AppendValue(v reflect.Value)

func (*JSONColumn) ConvertAssign 

func (c *JSONColumn) ConvertAssign(idx int, v reflect.Value) error

func (*JSONColumn) Len 

func (c *JSONColumn) Len() int

func (*JSONColumn) ResetForWriting added in v0.3.0 

func (c *JSONColumn) ResetForWriting(numRow int)

func (*JSONColumn) WriteTo 

func (c *JSONColumn) WriteTo(wr *chproto.Writer) error

type LCStringColumn 

type LCStringColumn struct {
	StringColumn
}

func (*LCStringColumn) ReadFrom 

func (c *LCStringColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (*LCStringColumn) WriteTo 

func (c *LCStringColumn) WriteTo(wr *chproto.Writer) error

type Model 

type Model interface {
	ScanBlock(*Block) error
}

type NamedArgAppender 

type NamedArgAppender interface {
	AppendNamedArg(fmter Formatter, b []byte, name string) ([]byte, bool)
}

type NewColumnFunc 

type NewColumnFunc func() Columnar

func ColumnFactory 

func ColumnFactory(chType string, typ reflect.Type) NewColumnFunc

func NewNullableColumnFunc added in v0.3.0 

func NewNullableColumnFunc(fn NewColumnFunc) NewColumnFunc

type NullableColumn 

type NullableColumn struct {
	Nulls  UInt8Column
	Values Columnar
	// contains filtered or unexported fields
}

func (*NullableColumn) AllocForReading added in v0.3.0 

func (c *NullableColumn) AllocForReading(numRow int)

func (*NullableColumn) AppendValue 

func (c *NullableColumn) AppendValue(v reflect.Value)

func (*NullableColumn) ConvertAssign 

func (c *NullableColumn) ConvertAssign(idx int, dest reflect.Value) error

func (*NullableColumn) Index 

func (c *NullableColumn) Index(idx int) any

func (*NullableColumn) Init added in v0.3.0 

func (c *NullableColumn) Init(chType string) error

func (*NullableColumn) Len 

func (c *NullableColumn) Len() int

func (*NullableColumn) Nullable 

func (c *NullableColumn) Nullable(nulls UInt8Column) any

func (*NullableColumn) ReadFrom 

func (c *NullableColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (*NullableColumn) ResetForWriting added in v0.3.0 

func (c *NullableColumn) ResetForWriting(numRow int)

func (*NullableColumn) Set 

func (c *NullableColumn) Set(v any)

func (*NullableColumn) Slice 

func (c *NullableColumn) Slice(s, e int) any

func (*NullableColumn) Type 

func (c *NullableColumn) Type() reflect.Type

func (*NullableColumn) Value 

func (c *NullableColumn) Value() any

func (*NullableColumn) WriteTo 

func (c *NullableColumn) WriteTo(wr *chproto.Writer) error

type NumericColumnOf 

type NumericColumnOf[T constraints.Integer | constraints.Float] struct {
	ColumnOf[T]
}

func (NumericColumnOf[T]) ConvertAssign 

func (c NumericColumnOf[T]) ConvertAssign(idx int, v reflect.Value) error

type Query 

type Query interface {
	QueryAppender
	Operation() string
	GetModel() Model
	GetTableName() string
}

type QueryAppender 

type QueryAppender interface {
	AppendQuery(fmter Formatter, b []byte) ([]byte, error)
}

type QueryWithArgs 

type QueryWithArgs struct {
	Query string
	Args  []any
}

func SafeQuery 

func SafeQuery(query string, args []any) QueryWithArgs

func UnsafeIdent 

func UnsafeIdent(ident string) QueryWithArgs

func (QueryWithArgs) AppendQuery 

func (q QueryWithArgs) AppendQuery(fmter Formatter, b []byte) ([]byte, error)

func (QueryWithArgs) IsEmpty added in v0.3.0 

func (q QueryWithArgs) IsEmpty() bool

func (QueryWithArgs) IsZero 

func (q QueryWithArgs) IsZero() bool

func (QueryWithArgs) Value 

func (q QueryWithArgs) Value() Safe

type QueryWithSep 

type QueryWithSep struct {
	QueryWithArgs
	Sep string
}

func SafeQueryWithSep 

func SafeQueryWithSep(query string, args []any, sep string) QueryWithSep

type Safe 

type Safe string

Safe represents a safe SQL query.

func (Safe) AppendQuery 

func (s Safe) AppendQuery(fmter Formatter, b []byte) ([]byte, error)

type StringColumn 

type StringColumn struct {
	ColumnOf[string]
}

func (*StringColumn) AppendValue 

func (c *StringColumn) AppendValue(v reflect.Value)

func (StringColumn) ConvertAssign 

func (c StringColumn) ConvertAssign(idx int, v reflect.Value) error

func (*StringColumn) ReadFrom 

func (c *StringColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (*StringColumn) Type 

func (c *StringColumn) Type() reflect.Type

func (*StringColumn) WriteTo 

func (c *StringColumn) WriteTo(wr *chproto.Writer) error

type Table 

type Table struct {
	Type reflect.Type

	ModelName string

	Name         string
	CHName       Safe
	CHInsertName Safe
	CHAlias      Safe
	CHEngine     string
	CHPartition  string

	Fields     []*Field // PKs + DataFields
	PKs        []*Field
	DataFields []*Field
	FieldMap   map[string]*Field
	// contains filtered or unexported fields
}

func TableForType 

func TableForType(typ reflect.Type) *Table

func (*Table) AppendNamedArg 

func (t *Table) AppendNamedArg(
	fmter Formatter, b []byte, name string, strct reflect.Value,
) ([]byte, bool)

func (*Table) Field 

func (t *Table) Field(name string) (*Field, error)

func (*Table) HasAfterScanRowHook 

func (t *Table) HasAfterScanRowHook() bool

func (*Table) IsColumnar 

func (t *Table) IsColumnar() bool

func (*Table) NewColumn 

func (t *Table) NewColumn(colName, colType string) *Column

func (*Table) String 

func (t *Table) String() string

type TimeColumn 

type TimeColumn struct {
	DateTimeColumn
}

func (*TimeColumn) ReadFrom 

func (c *TimeColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (TimeColumn) WriteTo 

func (c TimeColumn) WriteTo(wr *chproto.Writer) error

type UInt16Column added in v0.2.6 

type UInt16Column struct {
	NumericColumnOf[uint16]
}

func (*UInt16Column) AppendValue added in v0.2.6 

func (c *UInt16Column) AppendValue(v reflect.Value)

func (*UInt16Column) ReadFrom added in v0.2.6 

func (c *UInt16Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*UInt16Column) Type added in v0.2.6 

func (c *UInt16Column) Type() reflect.Type

func (*UInt16Column) WriteTo added in v0.2.6 

func (c *UInt16Column) WriteTo(wr *chproto.Writer) error

type UInt32Column added in v0.2.6 

type UInt32Column struct {
	NumericColumnOf[uint32]
}

func (*UInt32Column) AppendValue added in v0.2.6 

func (c *UInt32Column) AppendValue(v reflect.Value)

func (*UInt32Column) ReadFrom added in v0.2.6 

func (c *UInt32Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*UInt32Column) Type added in v0.2.6 

func (c *UInt32Column) Type() reflect.Type

func (*UInt32Column) WriteTo added in v0.2.6 

func (c *UInt32Column) WriteTo(wr *chproto.Writer) error

type UInt64Column added in v0.2.6 

type UInt64Column struct {
	NumericColumnOf[uint64]
}

func (*UInt64Column) AppendValue added in v0.2.6 

func (c *UInt64Column) AppendValue(v reflect.Value)

func (*UInt64Column) ReadFrom added in v0.2.6 

func (c *UInt64Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*UInt64Column) Type added in v0.2.6 

func (c *UInt64Column) Type() reflect.Type

func (*UInt64Column) WriteTo added in v0.2.6 

func (c *UInt64Column) WriteTo(wr *chproto.Writer) error

type UInt8Column added in v0.2.6 

type UInt8Column struct {
	NumericColumnOf[uint8]
}

func (*UInt8Column) AppendValue added in v0.2.6 

func (c *UInt8Column) AppendValue(v reflect.Value)

func (*UInt8Column) ReadFrom added in v0.2.6 

func (c *UInt8Column) ReadFrom(rd *chproto.Reader, numRow int) error

func (*UInt8Column) Type added in v0.2.6 

func (c *UInt8Column) Type() reflect.Type

func (*UInt8Column) WriteTo added in v0.2.6 

func (c *UInt8Column) WriteTo(wr *chproto.Writer) error

type UUID 

type UUID [16]byte

type UUIDColumn 

type UUIDColumn struct {
	ColumnOf[UUID]
}

TODO: rework to use []byte

func (*UUIDColumn) AppendValue 

func (c *UUIDColumn) AppendValue(v reflect.Value)

func (UUIDColumn) ConvertAssign 

func (c UUIDColumn) ConvertAssign(idx int, v reflect.Value) error

func (*UUIDColumn) ReadFrom 

func (c *UUIDColumn) ReadFrom(rd *chproto.Reader, numRow int) error

func (UUIDColumn) Type 

func (c UUIDColumn) Type() reflect.Type

func (UUIDColumn) WriteTo 

func (c UUIDColumn) WriteTo(wr *chproto.Writer) error

type UnknownColumnError 

type UnknownColumnError struct {
	Table  *Table
	Column string
}

func (*UnknownColumnError) Error 

func (err *UnknownColumnError) Error() string

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.