orm

Apr 16, 2024

Changes in this version

+ type JsonField struct

+ Data T

+ func NewJsonField[T any](data T) JsonField[T]

+ func (t *JsonField[T]) Scan(raw any) error

+ func (t *JsonField[T]) UnmarshalJSON(data []byte) error

+ func (t JsonField[T]) MarshalJSON() ([]byte, error)

+ func (t JsonField[T]) Value() (driver.Value, error)

Apr 15, 2024

Changes in this version

type Query

+ func (q *Query[T]) GetMapSliceString() (map[string][]string, QueryResult)

+ func (q *Query[T]) GetMapString() (map[string]string, QueryResult)

+ func (q *Query[T]) GetSliceInt() ([]int64, QueryResult)

+ func (q *Query[T]) GetSliceString() ([]string, QueryResult)

+ func (q *Query[T]) GetSliceUint() ([]uint64, QueryResult)

+ func (q *Query[T]) GetUint() (uint64, QueryResult)

Mar 5, 2024

Changes in this version

+ var ErrDeleteWithoutCondition = errors.New("delete without condition not allowed")

+ var ErrDestOfGetToMapElemMustNotBePtr = errors.New("dest of Get-to map elem kind must not be ptr")

+ var ErrUpdateWithoutCondition = errors.New("update without condition not allowed")

type Query

+ func (q *Query[T]) OnConflictUpdate(column any, val any, columnVars ...any) *Query[T]

+ func (q *Query[T]) OnConflictUpdates(columnVars map[any]any) *Query[T]

+ func (q *Query[T]) OrHaving(column any, vals ...any) *Query[T]

+ func (q *Query[T]) SelectExclude(exceptColumns ...any) *Query[T]

+ func (q *Query[T]) WherePrimaryIfNotZero(val any) *Query[T]

Feb 2, 2024

Changes in this version

+ var ErrInsertPtrNotAllowed = errors.New("insert ptr data not allowed")

+ func SetErrorLogger(l ErrorLogger)

+ func SetInfoLogger(l InfoLogger)

+ type ErrorLogger interface

+ Error func(args ...interface{})

+ type InfoLogger interface

+ Info func(args ...interface{})

type Query

+ func (q *Query[T]) AllColInterfaces() map[interface{}]string

+ func (q *Query[T]) GetBool() (bool, QueryResult)

+ func (q *Query[T]) GetInt() (int64, QueryResult)

+ func (q *Query[T]) GetString() (string, QueryResult)

+ func (q *Query[T]) InsertUpdate(data T, updates []UpdateColumn, acceptFieldPtrs ...interface{}) QueryResult

+ func (q *Query[T]) InsertUpdates(data []T, updates []UpdateColumn, acceptFieldPtrs ...interface{}) QueryResult

+ func (q *Query[T]) OrWhereBetween(column interface{}, valLess, valGreat interface{}) *Query[T]

+ func (q *Query[T]) SelectRowNumber(column interface{}, alias string) *Query[T]

+ func (q *Query[T]) SelectRowNumberDesc(column interface{}, alias string) *Query[T]

+ func (q *Query[T]) WhereBetween(column interface{}, valLess, valGreat interface{}) *Query[T]

Sep 19, 2023

Changes in this version

type SubQuery

+ func (m SubQuery) Connections() []*sql.DB

type Table

+ Connections func() []*sql.DB

Sep 13, 2023

Changes in this version

type Query

+ func (q *Query[T]) Clone() *Query[T]

+ func (q *Query[T]) CreateStruct(file ...string) error

+ func (q *Query[T]) CreateTable() (string, error)

+ func (q *Query[T]) Tx() *sql.Tx

Sep 13, 2023

Changes in this version

type Query

+ func (m Query[T]) DBs() []*sql.DB

type SubQuery

+ func (m SubQuery) Connection() []*sql.DB

type Table

+ Connection func() []*sql.DB

Mar 1, 2023

Changes in this version

type Query

+ func (m Query[T]) SelectWithTimeout(duration time.Duration) Query[T]

+ func (m Query[T]) WithContext(ctx context.Context) Query[T]

Feb 24, 2023

Changes in this version

+ func Open(driverName, dataSourceName string) (*sql.DB, error)

+ func OpenDB(driver sqldriver.Connector) *sql.DB

+ func OpenMysql(dataSourceName string) (*sql.DB, error)

+ func Register(name string, drvier sqldriver.Driver)

Feb 23, 2023

Changes in this version

type Query

+ func (m Query[T]) OrWherePrimary(val ...interface{}) Query[T]

+ func (m Query[T]) WherePrimary(val ...interface{}) Query[T]

Jun 13, 2022

Changes in this version

+ var ErrColumnNotExisted = errors.New("column not existed")

+ var ErrColumnNotSelected = errors.New("column not selected")

+ var ErrColumnShouldBeStringOrPtr = errors.New("column should be string or ptr")

+ var ErrDbNotSelected = errors.New("db not selecteed")

+ var ErrDestOfGetToMustBePtr = errors.New("dest of Get-to must be ptr")

+ var ErrDestOfGetToSliceElemMustBeStruct = errors.New("dest of Get-to slice elem kind must be struct")

+ var ErrDestOfGetToSliceElemMustNotBePtr = errors.New("dest of Get-to slice elem kind must not be ptr")

+ var ErrParamElemKindMustBeStruct = errors.New("param elem kind must be struct")

+ var ErrParamMustBePtr = errors.New("param must be ptr")

+ var ErrRawSqlRequired = errors.New("raw sql required")

+ var ErrTableNotExisted = errors.New("table not existed")

+ var ErrTableNotSelected = errors.New("table not selected")

type JoinType

+ const JoinTypeOuter

type Query

+ func (m Query[T]) OuterJoin(table Table, where func(join Query[T]) Query[T], alias ...string) Query[T]

Jun 9, 2022

Changes in this version

type Query

+ func NewQuerySub(subquery SubQuery) Query[SubQuery]

+ func (m Query[T]) SelectOverRaw(windowFunc string, windowName string, alias string) Query[T]

type SubQuery

+ func (m SubQuery) Sql() string

Jun 9, 2022

Changes in this version

type Query

+ func (m Query[T]) SelectOver(windowFunc string, f func(query Query[T]) Query[T], alias string) Query[T]

+ func (m Query[T]) SelectRankDesc(column interface{}, alias string) Query[T]

Jun 9, 2022

Changes in this version

type Query

+ func NewQueryRaw(db *sql.DB, tableName ...string) Query[SubQuery]

+ func (m Query[T]) Union(subquery SubQuery) Query[T]

+ func (m Query[T]) UnionAll(subquery SubQuery) Query[T]

+ func (m Query[T]) WithChildrenOnColumn(selfPidColumn interface{}) Query[T]

+ func (m Query[T]) WithCte(subquery SubQuery, cteName string, columns ...string) Query[T]

+ func (m Query[T]) WithParentsOnColumn(childPidColumn interface{}) Query[T]

+ func (m Query[T]) WithRecursiveCte(subquery SubQuery, cteName string, columns ...string) Query[T]

+ func (m Query[T]) WithWindow(subquery SubQuery, windowName string) Query[T]

type SubQuery

+ func NewSubQuery(prepareSql string, bindings ...interface{}) SubQuery

+ func (m SubQuery) ToSql() string

Jun 7, 2022

Changes in this version

+ func FillDefaults(table Table)

type Query

+ func (m Query[T]) ForUpdate(forUpdateType ...SelectForUpdateType) Query[T]

+ func (m Query[T]) PartitionBy(column interface{}) Query[T]

+ func (m Query[T]) SelectRank(f func(query Query[T]) Query[T], alias ...string) Query[T]

+ type SelectForUpdateType string

+ const SelectForUpdateTypeDefault

+ const SelectForUpdateTypeNowait

+ const SelectForUpdateTypeSkipLocked

Jun 2, 2022

Changes in this version

+ func ErrorNotNil(errors ...error) error

type Query

+ T *T

+ func NewQuery(t T, db *sql.DB) Query[T]

+ func (m Query[T]) Alias(alias string) Query[T]

+ func (m Query[T]) AllCols() string

+ func (m Query[T]) Execute() QueryResult

+ func (m Query[T]) Get() (T, QueryResult)

+ func (m Query[T]) GetCount() (int64, QueryResult)

+ func (m Query[T]) GetRow() (map[string]interface{}, QueryResult)

+ func (m Query[T]) GetRows() ([]map[string]interface{}, QueryResult)

+ func (m Query[T]) GetTo(destPtr interface{}) QueryResult

+ func (m Query[T]) Gets() ([]T, QueryResult)

+ func (m Query[T]) InsertSubquery(data *SubQuery, tableFieldPtrs []interface{}, updates ...UpdateColumn) QueryResult

+ func (m Query[T]) Inserts(data []T, tableFieldAddrs ...interface{}) QueryResult

+ func (m Query[T]) InsertsIgnore(data []T, tableFieldPtrs []interface{}, updates ...UpdateColumn) QueryResult

+ func (m Query[T]) OrWhereFunc(f func(Query[T]) Query[T]) Query[T]

+ func (m Query[T]) Raw(prepareSql string, bindings ...interface{}) Query[T]

+ func (m Query[T]) SubQuery() *SubQuery

+ func (m Query[T]) TableInterface() Table

+ func (m Query[T]) WhereFunc(f func(Query[T]) Query[T]) Query[T]

type QueryResult

+ func (q QueryResult) Error() error

+ type SubQuery struct

+ func (SubQuery) TableName() string

+ func (m SubQuery) DatabaseName() string

+ func (m SubQuery) Error() error

May 12, 2022

Changes in this version

+ func SetDefaults(table Table)

May 9, 2022

Changes in this version

+ func CreateStructFromTable(table Table) error

+ func CreateTableFromStruct(table Table) (string, error)

type Query

+ func (m *Query) ExecuteRaw(prepareSql string, bindings ...interface{}) QueryResult

+ func (m *Query) SelectMapStr2Interface(dest *map[string]interface{}, columns ...interface{}) QueryResult

+ func (m *Query) SelectRaw(dest interface{}, prepareSql string, bindings ...interface{}) QueryResult

+ func (m *Query) SelectSliceOfMapStr2Interface(dest *[]map[string]interface{}, columns ...interface{}) QueryResult

Mar 17, 2022

Changes in this version

+ var AllCols = "*"

+ func MakeAllNilSliceEmpty(inter interface{}) interface

+ func SliceContain(array interface{}, val interface{}) (index int)

+ type JoinType string

+ const JoinTypeInner

+ const JoinTypeLeft

+ const JoinTypeRight

+ type JsonInt int64

+ func (i *JsonInt) Scan(v interface{}) error

+ func (i *JsonInt) UnmarshalJSON(data []byte) error

+ func (i JsonInt) MarshalJSON() ([]byte, error)

+ func (i JsonInt) ToString() string

+ func (i JsonInt) Value() (driver.Value, error)

+ type JsonTime struct

+ func (t *JsonTime) Scan(v interface{}) error

+ func (t *JsonTime) UnmarshalJSON(data []byte) error

+ func (t JsonTime) MarshalJSON() ([]byte, error)

+ func (t JsonTime) Value() (driver.Value, error)

+ type Query struct

+ func (m *Query) AliasTable(alias string) *Query

+ func (m *Query) DB() *sql.DB

+ func (m *Query) Delete() QueryResult

+ func (m *Query) FromTable(table Table, alias ...string) *Query

+ func (m *Query) GroupBy(columns ...interface{}) *Query

+ func (m *Query) Having(where func(*Query)) *Query

+ func (m *Query) Insert(data interface{}, tableFieldAddrs ...interface{}) QueryResult

+ func (m *Query) InsertIgnore(data interface{}, tableFieldAddrs []interface{}, updates ...UpdateColumn) QueryResult

+ func (m *Query) Join(table Table, where func(join *Query), alias ...string) *Query

+ func (m *Query) LeftJoin(table Table, where func(join *Query), alias ...string) *Query

+ func (m *Query) Limit(limit int) *Query

+ func (m *Query) Migrate() (string, error)

+ func (m *Query) Offset(offset int) *Query

+ func (m *Query) OrWhere(column interface{}, vals ...interface{}) *Query

+ func (m *Query) OrWhereGroup(f func(*Query)) *Query

+ func (m *Query) OrderBy(column interface{}) *Query

+ func (m *Query) OrderByDesc(column interface{}) *Query

+ func (m *Query) RightJoin(table Table, where func(join *Query), alias ...string) *Query

+ func (m *Query) Select(dest interface{}, columns ...interface{}) QueryResult

+ func (m *Query) SelectCount(dest interface{}) QueryResult

+ func (m *Query) SelectForUpdate(dest interface{}, columns ...interface{}) QueryResult

+ func (m *Query) SelectMapOfColumn2KeyByColumn1(dest interface{}, columns ...interface{}) QueryResult

+ func (m *Query) SelectMapOfStructKeyByColumn1(dest interface{}, columns ...interface{}) QueryResult

+ func (m *Query) SelectMapOfStructSliceKeyByColumn1(dest interface{}, columns ...interface{}) QueryResult

+ func (m *Query) SelectSliceOfColumn1(dest interface{}, columns ...interface{}) QueryResult

+ func (m *Query) SelectSliceOfStruct(dest interface{}, columns ...interface{}) QueryResult

+ func (m *Query) SelectStructOfRow1(dest interface{}, columns ...interface{}) QueryResult

+ func (m *Query) SelectSub(columns ...interface{}) *tempTable

+ func (m *Query) SelectValueOfFirstCell(dest interface{}, columns ...interface{}) QueryResult

+ func (m *Query) Transaction(query func(db *Query) error) error

+ func (m *Query) Update(column interface{}, val interface{}) QueryResult

+ func (m *Query) Updates(updates ...UpdateColumn) QueryResult

+ func (m *Query) UseDB(db *sql.DB) *Query

+ func (m *Query) UseTx(tx *sql.Tx) *Query

+ func (m *Query) Where(column interface{}, vals ...interface{}) *Query

+ func (m *Query) WhereGroup(f func(*Query)) *Query

+ type QueryResult struct

+ Bindings []interface{}

+ Err error

+ LastInsertId int64

+ PrepareSql string

+ RowsAffected int64

+ func (q *QueryResult) Sql() string

+ type Raw string

+ type Table interface

+ DatabaseName func() string

+ Query func() *Query

+ TableName func() string

+ type UpdateColumn struct

+ Column interface{}

+ Val interface{}

+ type WhereOperator Raw

+ const WhereEqual

+ const WhereGreatThan

+ const WhereGreaterOrEqual

+ const WhereIn

+ const WhereIsNotNull

+ const WhereIsNull

+ const WhereLessOrEqual

+ const WhereLessThan

+ const WhereLike

+ const WhereNotEqual

+ const WhereNotIn

+ const WhereNotLike

+ const WhereNotRlike

+ const WhereRlike