data

package module

Go to main page

Versions in this module

v0

v0.13.0

Feb 4, 2024

Changes in this version

+ type DataDriver struct

+ func (receiver *DataDriver) CreateIndex(tableName string, idxName string, idxField IdxField) string

+ func (receiver *DataDriver) GetDriver(connectionString string) gorm.Dialector

type IDataDriver

+ CreateIndex func(tableName string, idxName string, idxField IdxField) string

+ type IMigratorIndex interface

+ CreateIndex func() map[string]IdxField

+ type IdxField struct

+ Fields string

+ IsUNIQUE bool

type TableSet

+ func (receiver *TableSet[Table]) CreateIndex(db *gorm.DB)

v0.12.0

Jan 8, 2024

Changes in this version

type TableSet

+ func (receiver *TableSet[Table]) AscIf(conditional bool, fieldName string) *TableSet[Table]

+ func (receiver *TableSet[Table]) AscIfElse(conditional bool, trueFieldName string, falseFieldName string) *TableSet[Table]

+ func (receiver *TableSet[Table]) DescIf(conditional bool, fieldName string) *TableSet[Table]

+ func (receiver *TableSet[Table]) DescIfElse(conditional bool, trueFieldName string, falseFieldName string) *TableSet[Table]

+ func (receiver *TableSet[Table]) OrderIf(conditional bool, value any) *TableSet[Table]

+ func (receiver *TableSet[Table]) WhereBetween(columnName any, min, max any) *TableSet[Table]

+ func (receiver *TableSet[Table]) WhereBetweenIf(conditional bool, columnName any, min, max any) *TableSet[Table]

+ func (receiver *TableSet[Table]) WhereEq(columnName any, args any) *TableSet[Table]

+ func (receiver *TableSet[Table]) WhereEqIf(conditional bool, columnName any, args any) *TableSet[Table]

+ func (receiver *TableSet[Table]) WhereGt(columnName any, args any) *TableSet[Table]

+ func (receiver *TableSet[Table]) WhereGtIf(conditional bool, columnName any, args any) *TableSet[Table]

+ func (receiver *TableSet[Table]) WhereGte(columnName any, args any) *TableSet[Table]

+ func (receiver *TableSet[Table]) WhereGteIf(conditional bool, columnName any, args any) *TableSet[Table]

+ func (receiver *TableSet[Table]) WhereIn(columnName any, args ...any) *TableSet[Table]

+ func (receiver *TableSet[Table]) WhereInIf(conditional bool, columnName any, args ...any) *TableSet[Table]

+ func (receiver *TableSet[Table]) WhereLike(columnName any, args any) *TableSet[Table]

+ func (receiver *TableSet[Table]) WhereLikeIf(conditional bool, columnName any, args any) *TableSet[Table]

+ func (receiver *TableSet[Table]) WhereLt(columnName any, args any) *TableSet[Table]

+ func (receiver *TableSet[Table]) WhereLtIf(conditional bool, columnName any, args any) *TableSet[Table]

+ func (receiver *TableSet[Table]) WhereLte(columnName any, args any) *TableSet[Table]

+ func (receiver *TableSet[Table]) WhereLteIf(conditional bool, columnName any, args any) *TableSet[Table]

v0.11.0

Dec 25, 2023

Changes in this version

+ type IDataDriver interface

+ GetDriver func(connectionString string) gorm.Dialector

type TableSet

+ func (receiver *TableSet[Table]) WhereIf(conditional bool, query any, args ...any) *TableSet[Table]

v0.10.0

Dec 17, 2023

v0.9.0

Nov 22, 2023

Changes in this version

+ func RegisterInternalContext(key string, configString string)

+ func ToMap(entity any) map[string]any

type DefaultRepository

+ func (receiver *DefaultRepository[TPoType, TDomainObject]) Delete(id any) (int64, error)

+ func (receiver *DefaultRepository[TPoType, TDomainObject]) IsExists(id any) bool

+ func (receiver *DefaultRepository[TPoType, TDomainObject]) Update(id any, do TDomainObject) (int64, error)

type IInternalContext

+ ExecuteSql func(sql string, values ...any) (int64, error)

+ ExecuteSqlToResult func(arrayOrEntity any, sql string, values ...any) (int64, error)

+ ExecuteSqlToValue func(field any, sql string, values ...any) (int64, error)

+ type IMigratorCreate interface

+ CreateTable func() string

type IRepository

+ Delete func(id any) (int64, error)

+ IsExists func(id any) bool

+ Update func(id any, do TDomainObject) (int64, error)

type TableSet

+ func (receiver *TableSet[Table]) Clickhouse() *mergeTreeSet

+ func (receiver *TableSet[Table]) Exprs(fields map[string][]any) (int64, error)

+ func (receiver *TableSet[Table]) GetDecimal(fieldName string) decimal.Decimal

+ func (receiver *TableSet[Table]) Omit(columns ...string) *TableSet[Table]

+ type TracePlugin struct

+ func (op *TracePlugin) Initialize(db *gorm.DB) (err error)

+ func (op *TracePlugin) Name() string

v0.8.0

Jul 27, 2023

Changes in this version

+ func GetContext(dbName string) *TDbContext

+ func RegisterContext(dbName string, autoCreateTable bool)

+ type DefaultRepository struct

+ func (receiver *DefaultRepository[TDomainObject, TPoType]) Add(entity TDomainObject)

+ func (receiver *DefaultRepository[TDomainObject, TPoType]) Count() int64

+ func (receiver *DefaultRepository[TDomainObject, TPoType]) ToEntity(id any) TDomainObject

+ func (receiver *DefaultRepository[TDomainObject, TPoType]) ToList() collections.List[TDomainObject]

+ func (receiver *DefaultRepository[TDomainObject, TPoType]) ToPageList(pageSize, pageIndex int) collections.PageList[TDomainObject]

+ type DomainSet struct

+ func (r *DomainSet[Table, TDomainObject]) Init(dbContext *internalContext, tableName string, autoCreateTable bool)

+ type IDbContext interface

+ type IInternalContext interface

+ Original func() *gorm.DB

+ type IRepository interface

+ Add func(entity TDomainObject)

+ Count func() int64

+ ToEntity func(id any) TDomainObject

+ ToList func() collections.List[TDomainObject]

+ ToPageList func(pageSize, pageIndex int) collections.PageList[TDomainObject]

+ func NewDefaultRepository(table TableSet[TPoType]) IRepository[TDomainObject]

type TableSet

+ func (table *TableSet[Table]) ExecuteSql(sql string, values ...any)

+ func (table *TableSet[Table]) ExecuteSqlToArray(sql string, values ...any) []Table

+ func (table *TableSet[Table]) ExecuteSqlToEntity(sql string, values ...any) Table

+ func (table *TableSet[Table]) ExecuteSqlToList(sql string, values ...any) collections.List[Table]

+ func (table *TableSet[Table]) Expr(field string, expr string, args ...any) int64

+ func (table *TableSet[Table]) GetPrimaryName() string

+ func (table *TableSet[Table]) Original() *gorm.DB

+ func (table *TableSet[Table]) WhereIgnoreLessZero(query any, val int) *TableSet[Table]

+ func (table *TableSet[Table]) WhereIgnoreNil(query any, val any) *TableSet[Table]

v0.2.0

Mar 3, 2023

Changes in this version

type TableSet

+ func (table *TableSet[Table]) CreateTable()

+ func (table *TableSet[Table]) InsertList(lst collections.List[Table], batchSize int) error

+ func (table *TableSet[Table]) UpdateOrInsert(po Table, fields ...string) error

v0.1.1

Dec 20, 2022

Changes in this version

+ func InitContext(dbContext *TDbContext, dbName string)

+ func NewContext(dbName string) *TDbContext

+ type DbContext struct

+ type Module struct

+ func (module Module) DependsModule() []modules.FarseerModule

+ func (module Module) Initialize()

+ func (module Module) PostInitialize()

+ func (module Module) PreInitialize()

+ func (module Module) Shutdown()

+ type TableSet struct

+ func (table *TableSet[Table]) Asc(fieldName string) *TableSet[Table]

+ func (table *TableSet[Table]) Count() int64

+ func (table *TableSet[Table]) Delete() int64

+ func (table *TableSet[Table]) Desc(fieldName string) *TableSet[Table]

+ func (table *TableSet[Table]) GetBool(fieldName string) bool

+ func (table *TableSet[Table]) GetFloat32(fieldName string) float32

+ func (table *TableSet[Table]) GetFloat64(fieldName string) float64

+ func (table *TableSet[Table]) GetInt(fieldName string) int

+ func (table *TableSet[Table]) GetLong(fieldName string) int64

+ func (table *TableSet[Table]) GetString(fieldName string) string

+ func (table *TableSet[Table]) GetTableName() string

+ func (table *TableSet[Table]) Init(dbContext *DbContext, tableName string)

+ func (table *TableSet[Table]) Insert(po *Table)

+ func (table *TableSet[Table]) IsExists() bool

+ func (table *TableSet[Table]) Limit(limit int) *TableSet[Table]

+ func (table *TableSet[Table]) Order(value any) *TableSet[Table]

+ func (table *TableSet[Table]) Select(query any, args ...any) *TableSet[Table]

+ func (table *TableSet[Table]) SetTableName(tableName string) *TableSet[Table]

+ func (table *TableSet[Table]) ToArray() []Table

+ func (table *TableSet[Table]) ToEntity() Table

+ func (table *TableSet[Table]) ToList() collections.List[Table]

+ func (table *TableSet[Table]) ToPageList(pageSize int, pageIndex int) collections.PageList[Table]

+ func (table *TableSet[Table]) Update(po Table) int64

+ func (table *TableSet[Table]) UpdateValue(column string, value any)

+ func (table *TableSet[Table]) Where(query any, args ...any) *TableSet[Table]

v0.1.0

Sep 7, 2022

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