operations

package

Go to main page

Versions in this module

v0

v0.1.7

Apr 22, 2024

Changes in this version

type TableRow

+ func (tableRow *TableRow) AddColumnValueBoolPtr(columnName string, value *bool) *TableRow

+ func (tableRow *TableRow) AddColumnValueBytesPtr(columnName string, value *[]byte) *TableRow

+ func (tableRow *TableRow) AddColumnValueFloat32Ptr(columnName string, value *float32) *TableRow

+ func (tableRow *TableRow) AddColumnValueFloat64Ptr(columnName string, value *float64) *TableRow

+ func (tableRow *TableRow) AddColumnValueInt16Ptr(columnName string, value *int16) *TableRow

+ func (tableRow *TableRow) AddColumnValueInt32Ptr(columnName string, value *int32) *TableRow

+ func (tableRow *TableRow) AddColumnValueInt64Ptr(columnName string, value *int64) *TableRow

+ func (tableRow *TableRow) AddColumnValueInt8Ptr(columnName string, value *int8) *TableRow

+ func (tableRow *TableRow) AddColumnValueIntPtr(columnName string, value *int) *TableRow

+ func (tableRow *TableRow) AddColumnValueStringPtr(columnName string, value *string) *TableRow

+ func (tableRow *TableRow) AddColumnValueTimePtr(columnName string, value *time.Time) *TableRow

+ func (tableRow *TableRow) AddColumnValueUint16Ptr(columnName string, value *uint16) *TableRow

+ func (tableRow *TableRow) AddColumnValueUint32Ptr(columnName string, value *uint32) *TableRow

+ func (tableRow *TableRow) AddColumnValueUint64Ptr(columnName string, value *uint64) *TableRow

+ func (tableRow *TableRow) AddColumnValueUint8Ptr(columnName string, value *uint8) *TableRow

+ func (tableRow *TableRow) AddColumnValueUintPtr(columnName string, value *uint) *TableRow

+ func (tableRow *TableRow) ColumnValueBoolPtr(columnName string) *bool

+ func (tableRow *TableRow) ColumnValueBytesPtr(columnName string) *[]byte

+ func (tableRow *TableRow) ColumnValueFloat32Ptr(columnName string) *float32

+ func (tableRow *TableRow) ColumnValueFloat64Ptr(columnName string) *float64

+ func (tableRow *TableRow) ColumnValueInt16Ptr(columnName string) *int16

+ func (tableRow *TableRow) ColumnValueInt32Ptr(columnName string) *int32

+ func (tableRow *TableRow) ColumnValueInt64Ptr(columnName string) *int64

+ func (tableRow *TableRow) ColumnValueInt8Ptr(columnName string) *int8

+ func (tableRow *TableRow) ColumnValueIntPtr(columnName string) *int

+ func (tableRow *TableRow) ColumnValueStringPtr(columnName string) *string

+ func (tableRow *TableRow) ColumnValueTimePtr(columnName string) *time.Time

+ func (tableRow *TableRow) ColumnValueUint16Ptr(columnName string) *uint16

+ func (tableRow *TableRow) ColumnValueUint32Ptr(columnName string) *uint32

+ func (tableRow *TableRow) ColumnValueUint64Ptr(columnName string) *uint64

+ func (tableRow *TableRow) ColumnValueUint8Ptr(columnName string) *uint8

+ func (tableRow *TableRow) ColumnValueUintPtr(columnName string) *uint

v0.1.6

Apr 22, 2024

v0.1.5

Apr 22, 2024

v0.1.4

Apr 19, 2024

v0.1.3

Apr 19, 2024

v0.1.2

Apr 19, 2024

Changes in this version

type BaseDBOperations

+ AutoMigrate func(tables ...Table) error

type Operations

+ func (op *Operations) AutoMigrate(tables ...Table) error

+ type Table struct

+ Columns []TableColumn

+ TableName string

+ func (spec *Table) ToDBModel() (any, error)

+ type TableColumn struct

+ Comment string

+ Default any

+ Index bool

+ Name string

+ NotNull bool

+ PrimaryKey bool

+ Size int

+ Type string

+ Unique bool

+ UniqueIndex string

+ func (column *TableColumn) ToDBModelField() (*reflect.StructField, error)

v0.1.0

Apr 19, 2024

Changes in this version

+ var ErrDBRecordHasExist = errors.New("记录已存在")

+ var ErrDBRecordNotExist = errors.New("记录不存在")

+ func DestroyOperation(op *Operations) error

+ type BaseDBOperations interface

+ CheckExist func() (bool, error)

+ CheckHasOnlyOne func() (bool, error)

+ Count func(count *int64) error

+ Create func(tableRow *TableRow) error

+ CreateBatch func(tableRows []TableRow) error

+ Delete func() error

+ GroupBy func(groupBy string) DBOperations

+ Having func(conditions *Conditions) DBOperations

+ Joins func(query string, args ...any) DBOperations

+ NewSession func() DBOperations

+ Or func(conditions *Conditions) DBOperations

+ OrderBy func(orderBy string) DBOperations

+ Paging func(pageNo int, pageSize int) DBOperations

+ Raw func(sql string, values ...any) DBOperations

+ Row func() (*TableRow, error)

+ Rows func(pageNo int, pageSize int) ([]TableRow, error)

+ Select func(query string, args ...any) DBOperations

+ Table func(name string, args ...any) DBOperations

+ Updates func(newTableRow *TableRow) error

+ UpdatesWithRowsAffected func(newTableRow *TableRow) (int64, error)

+ Where func(conditions *Conditions) DBOperations

+ type Conditions struct

+ func NewConditions() *Conditions

+ func (clause *Conditions) Equal(columnName string, value any) *Conditions

+ func (clause *Conditions) GreaterThan(columnName string, value any) *Conditions

+ func (clause *Conditions) GreaterThanAndEqual(columnName string, value any) *Conditions

+ func (clause *Conditions) In(columnName string, value any) *Conditions

+ func (clause *Conditions) LessThan(columnName string, value any) *Conditions

+ func (clause *Conditions) LessThanAndEqual(columnName string, value any) *Conditions

+ func (clause *Conditions) Like(columnName string, value any) *Conditions

+ func (clause *Conditions) Not(columnName string, value any) *Conditions

+ func (clause *Conditions) NotIn(columnName string, value any) *Conditions

+ type DBConfig struct

+ Address string

+ Database string

+ MaxConnections int

+ MaxIdleConnections int

+ Password string

+ Port string

+ Type string

+ UserName string

+ type DBOperations interface

+ BeginTransaction func() TransactionDBOperations

+ type EventDBOperations interface

+ CommitEvent func()

+ EventRows func(table string, keys []string, pageSize int, pageNo string)

+ Replay func(table string, keys []string)

+ RollbackEvent func()

+ type Operations struct

+ func NewOperations(dbConfig *DBConfig) (*Operations, error)

+ func (op *Operations) BeginTransaction() TransactionDBOperations

+ func (op *Operations) CheckExist() (bool, error)

+ func (op *Operations) CheckHasOnlyOne() (bool, error)

+ func (op *Operations) Count(count *int64) error

+ func (op *Operations) Create(tableRow *TableRow) error

+ func (op *Operations) CreateBatch(tableRows []TableRow) error

+ func (op *Operations) Delete() error

+ func (op *Operations) GroupBy(groupBy string) DBOperations

+ func (op *Operations) Having(conditions *Conditions) DBOperations

+ func (op *Operations) Joins(query string, args ...any) DBOperations

+ func (op *Operations) NewSession() DBOperations

+ func (op *Operations) Or(conditions *Conditions) DBOperations

+ func (op *Operations) OrderBy(orderBy string) DBOperations

+ func (op *Operations) Paging(pageNo int, pageSize int) DBOperations

+ func (op *Operations) Raw(sql string, values ...any) DBOperations

+ func (op *Operations) Row() (*TableRow, error)

+ func (op *Operations) Rows(pageNo int, pageSize int) ([]TableRow, error)

+ func (op *Operations) Select(query string, args ...any) DBOperations

+ func (op *Operations) Table(name string, args ...any) DBOperations

+ func (op *Operations) Updates(newTableRow *TableRow) error

+ func (op *Operations) UpdatesWithRowsAffected(newTableRow *TableRow) (int64, error)

+ func (op *Operations) Where(conditions *Conditions) DBOperations

+ type TableRow struct

+ func NewTableRow() *TableRow

+ func NewTableRowFromMap(m map[string]any) *TableRow

+ func (tableRow *TableRow) AddColumnValueBool(columnName string, value bool) *TableRow

+ func (tableRow *TableRow) AddColumnValueBytes(columnName string, value []byte) *TableRow

+ func (tableRow *TableRow) AddColumnValueFloat32(columnName string, value float32) *TableRow

+ func (tableRow *TableRow) AddColumnValueFloat64(columnName string, value float64) *TableRow

+ func (tableRow *TableRow) AddColumnValueInt(columnName string, value int) *TableRow

+ func (tableRow *TableRow) AddColumnValueInt16(columnName string, value int16) *TableRow

+ func (tableRow *TableRow) AddColumnValueInt32(columnName string, value int32) *TableRow

+ func (tableRow *TableRow) AddColumnValueInt64(columnName string, value int64) *TableRow

+ func (tableRow *TableRow) AddColumnValueInt8(columnName string, value int8) *TableRow

+ func (tableRow *TableRow) AddColumnValueString(columnName string, value string) *TableRow

+ func (tableRow *TableRow) AddColumnValueTime(columnName string, value time.Time) *TableRow

+ func (tableRow *TableRow) AddColumnValueUint(columnName string, value uint) *TableRow

+ func (tableRow *TableRow) AddColumnValueUint16(columnName string, value uint16) *TableRow

+ func (tableRow *TableRow) AddColumnValueUint32(columnName string, value uint32) *TableRow

+ func (tableRow *TableRow) AddColumnValueUint64(columnName string, value uint64) *TableRow

+ func (tableRow *TableRow) AddColumnValueUint8(columnName string, value uint8) *TableRow

+ func (tableRow *TableRow) ColumnValueBool(columnName string) bool

+ func (tableRow *TableRow) ColumnValueBytes(columnName string) []byte

+ func (tableRow *TableRow) ColumnValueFloat32(columnName string) float32

+ func (tableRow *TableRow) ColumnValueFloat64(columnName string) float64

+ func (tableRow *TableRow) ColumnValueInt(columnName string) int

+ func (tableRow *TableRow) ColumnValueInt16(columnName string) int16

+ func (tableRow *TableRow) ColumnValueInt32(columnName string) int32

+ func (tableRow *TableRow) ColumnValueInt64(columnName string) int64

+ func (tableRow *TableRow) ColumnValueInt8(columnName string) int8

+ func (tableRow *TableRow) ColumnValueString(columnName string) string

+ func (tableRow *TableRow) ColumnValueTime(columnName string) time.Time

+ func (tableRow *TableRow) ColumnValueUint(columnName string) uint

+ func (tableRow *TableRow) ColumnValueUint16(columnName string) uint16

+ func (tableRow *TableRow) ColumnValueUint32(columnName string) uint32

+ func (tableRow *TableRow) ColumnValueUint64(columnName string) uint64

+ func (tableRow *TableRow) ColumnValueUint8(columnName string) uint8

+ func (tableRow *TableRow) Empty() bool

+ func (tableRow *TableRow) Len() int

+ func (tableRow *TableRow) ToMap() map[string]any

+ type TransactionDBOperations interface

+ CommitTransaction func()

+ RollbackTransaction func()

+ type TransactionOperations struct

+ func (op *TransactionOperations) CommitTransaction()

+ func (op *TransactionOperations) RollbackTransaction()

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