io

type Builder ¶

type Builder interface {
	Build(record interface{}, options ...option.Option) string
}

Builder represents SQL builder

func NewBuilderAdapter(builder RecordlessBuilder) Builder

type BuilderAdapter ¶ added in v0.4.0

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

Builder represents SQL builder

func (b *BuilderAdapter) Build(_ interface{}, options ...option.Option) string

type Column ¶

type Column interface {
	Name() string
	Length() (length int64, ok bool)
	DecimalSize() (precision, scale int64, ok bool)
	ScanType() reflect.Type
	Nullable() (nullable, ok bool)
	DatabaseTypeName() string
	Tag() *Tag
}

Column represents a column

func NamesToColumns(columns []string) []Column

func NewColumn(name, databaseTypeName string, rType reflect.Type, opts ...interface{}) Column

func StructColumns(recordType reflect.Type, tagName string, opts ...option.Option) ([]Column, error)

func TypesToColumns(columns []*sql.ColumnType) []Column

type ColumnDecimalPrecision ¶

type ColumnDecimalPrecision int64

ColumnDecimalPrecision represents column decimal precision

type ColumnDecimalScale ¶

type ColumnDecimalScale int64

ColumnDecimalScale represents column decimal scale

type ColumnLength ¶

type ColumnLength int64

ColumnLength represents column length

type ColumnMapper ¶

type ColumnMapper func(src interface{}, tagName string, options ...option.Option) ([]Column, PlaceholderBinder, error)

ColumnMapper maps src to columns and its placeholders

type ColumnNullable ¶

type ColumnNullable bool

ColumnNullable represents column nullable option

type Columns ¶

type Columns []Column

Columns represents columns

func (c Columns) Autoincrement() int

func (c Columns) IdentityColumnPos() int

func (c Columns) Names() []string

func (c Columns) PrimaryKeys() int

type Field ¶

type Field struct {
	Tag
	Column
	*xunsafe.Field
	EvalAddr    func(pointer unsafe.Pointer) interface{}
	Info        *sink.Column
	MatchesType bool
}

Field represents column mapped field

func (f *Field) Addr(pointer unsafe.Pointer) interface{}

func (f *Field) CanExpand() bool

type FieldStringifierFn ¶

type FieldStringifierFn = func(pointer unsafe.Pointer) (string, bool)

func Stringifier(field *xunsafe.Field, nullifyZeroValue bool, nullValue string) FieldStringifierFn

type Fields ¶

type Fields []Field

Fields represents slice of Field

func (f Fields) ColumnNames() []string

func (f Fields) XFields() []xunsafe.Field

type Matcher ¶

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

Matcher implements column to struct filed mapper

func NewMatcher(tagName string, resolver Resolve) *Matcher

func (f *Matcher) Match(targetType reflect.Type, columns []Column) ([]Field, error)

type ObjectStringifier ¶

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

func TypeStringifier(rType reflect.Type, nullValue string, omitTransient bool, options ...interface{}) *ObjectStringifier

func (s *ObjectStringifier) FieldNames() []string

func (s *ObjectStringifier) Has(fieldName string) bool

func (s *ObjectStringifier) Stringifier(options ...interface{}) (ObjectStringifierFn, error)

type ObjectStringifierFn ¶

type ObjectStringifierFn func(val interface{}) ([]string, []bool)

ObjectStringifierFn returns stringified object properties values and information if value was string before

type Parallel ¶

type Parallel bool

type PlaceholderBinder ¶

type PlaceholderBinder func(src interface{}, params []interface{}, offset, limit int)

PlaceholderBinder copies source values to params starting with offset

type QueryResult ¶

type QueryResult struct {
	sql.Result
	Rows  int64
	Error error
}

QueryResult summarizes an executed SQL command. use instead of standard Result when you need omit bug: "0 affected rows"

func (r *QueryResult) RowsAffected() (int64, error)

type RecordlessBuilder ¶ added in v0.4.0

type RecordlessBuilder interface {
	Build(options ...option.Option) string
}

Builder represents SQL builder

type Resolve ¶

type Resolve func(column Column) func(pointer unsafe.Pointer) interface{}

Resolve Resolver handler unresolved columns

type Resolver ¶

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

Resolver represents unmatched column resolver

func NewResolver() *Resolver

func (r *Resolver) Data(index int) []interface{}

func (r *Resolver) Index(column string) int

func (r *Resolver) OnSkip(values []interface{}) error

func (r *Resolver) Resolve(column Column) func(ptr unsafe.Pointer) interface{}

type Session ¶

type Session interface {
	Exec(context context.Context, data interface{}, db *sql.DB, tableName string, options ...option.Option) (sql.Result, error)
}

Session represents load session e.g. MySQL "LOAD DATA LOCAL INFILE"

type SessionResolver ¶

type SessionResolver = func(dialect *info.Dialect) Session

SessionResolver returns new Session configured with given Dialect

type StringifierConfig ¶

type StringifierConfig struct {
	Fields     []string
	CaseFormat format.Case
}

type Tag ¶

type Tag struct {
	Column           string
	Autoincrement    bool
	PrimaryKey       bool
	Sequence         string
	FieldIndex       int
	Transient        bool
	Ns               string
	Generator        string
	IsUnique         bool
	Db               string
	Table            string
	RefDb            string
	RefTable         string
	RefColumn        string
	Required         bool
	NullifyEmpty     bool
	ErrorMgs         string
	PresenceProvider bool
	Bit              bool
}

Tag represent field tag

func ParseTag(tagString string) *Tag

type Transaction ¶

type Transaction struct {
	*sql.Tx
	Global bool
}

func TransactionFor(ctx context.Context, dialect *info.Dialect, db *sql.DB, options []option.Option) (*Transaction, error)

func (t *Transaction) Commit() error

func (t *Transaction) Rollback() error

func (t *Transaction) RollbackWithErr(err error) error

type ValueAccessor ¶

type ValueAccessor = func(index int) interface{}

ValueAccessor represents function that returns value at given index.

func Values(any interface{}) (ValueAccessor, int, error)