datahub

Jan 21, 2025

Changes in this version

+ func GetByParmEl[T orm.DataModel](h *Hub, model T, where *dbflex.Filter, order string, fields ...string) (T, error)

type Hub

+ func (h *Hub) GetAnyByParmEl(tablename string, dest interface{}, where *dbflex.Filter, order string, ...) error

+ func (h *Hub) GetByParmEl(data orm.DataModel, dest interface{}, where *dbflex.Filter, order string, ...) error

+ func (h *Hub) SetTimeout(d time.Duration) *Hub

Jul 8, 2023

Changes in this version

+ func FindAnyByCommand(h *Hub, model T, cmd dbflex.ICommand) ([]T, error)

+ func FindAnyByFilter(h *Hub, model T, tablename string, filter *dbflex.Filter, n int) ([]T, error)

+ func FindAnyByParm(h *Hub, model T, tablename string, qp *dbflex.QueryParam) ([]T, error)

+ func FindAnyBySQL(h *Hub, model T, sql string) ([]T, error)

Jul 7, 2023

Changes in this version

+ func Count(h *Hub, data T, qp *dbflex.QueryParam) (int, error)

+ func Find(h *Hub, model T, param *dbflex.QueryParam) ([]T, error)

+ func FindByCommand(h *Hub, data T, cmd dbflex.ICommand) ([]T, error)

+ func FindByFilter(h *Hub, model T, filter *dbflex.Filter) ([]T, error)

+ func Get(h *Hub, model T) (T, error)

+ func GetByFilter(h *Hub, model T, filter *dbflex.Filter) (T, error)

+ func GetByID(h *Hub, model T, ids ...interface{}) (T, error)

+ func GetByParm(h *Hub, model T, qp *dbflex.QueryParam) (T, error)

+ func GetByQuery(h *Hub, model T, queryName string, payload codekit.M) (T, error)

Sep 21, 2022

Changes in this version

type Hub

+ func (h *Hub) CountAnyByFilter(name string, f *dbflex.Filter) (int, error)

+ func (h *Hub) CountByFilter(data orm.DataModel, f *dbflex.Filter) (int, error)

+ func (h *Hub) DeleteByFilter(model orm.DataModel, where *dbflex.Filter) error

Sep 5, 2022

Changes in this version

+ func GeneralDbConnBuilderWithTx(txt string, useTx bool) func() (dbflex.IConnection, error)

type Hub

+ func (h *Hub) GetsByFilter(data orm.DataModel, filter *dbflex.Filter, dest interface{}) error

Jul 13, 2022

Changes in this version

type Hub

+ func (h *Hub) GetByQuery(obj orm.DataModel, queryName string, param codekit.M) error

+ func (h *Hub) GetsByQuery(obj orm.DataModel, queryName string, param codekit.M, target interface{}) error

Jul 10, 2022

Changes in this version

type Hub

+ func (h *Hub) DeleteAny(name string, filter *dbflex.Filter) error

+ func (h *Hub) EnsureDb(obj orm.DataModel) error

+ func (h *Hub) EnsureIndex(tableName, indexName string, unique bool, fields ...string) error

+ func (h *Hub) InsertAny(name string, object interface{}) error

Jul 6, 2021

Changes in this version

type Hub

+ func (h *Hub) SetOptions(opts *HubOptions) *Hub

Jul 5, 2021

Changes in this version

type Hub

+ func NewHubWithOpts(fn func() (dbflex.IConnection, error), opts *HubOptions) *Hub

+ func (h *Hub) CountAny(name string, qp *dbflex.QueryParam) (int, error)

+ type HubOptions struct

+ AutoClose time.Duration

+ AutoRelease time.Duration

+ PoolSize int

+ Timeout time.Duration

+ UsePool bool

Jan 3, 2021

Changes in this version

type Hub

+ func (h *Hub) GetAnyByFilter(tableName string, filter *dbflex.Filter, dest interface{}) error

+ func (h *Hub) GetAnyByParm(tableName string, parm *dbflex.QueryParam, dest interface{}) error

Dec 31, 2020

Changes in this version

type Hub

+ func (h *Hub) GetByFilter(data orm.DataModel, filter *dbflex.Filter) error

+ func (h *Hub) PopulateByFilter(tableName string, filter *dbflex.Filter, n int, dest interface{}) error

Dec 16, 2020

Changes in this version

+ func GeneralDbConnBuilder(txt string) func() (dbflex.IConnection, error)

Nov 24, 2020

Changes in this version

type Hub

+ func (h *Hub) GetByAttr(data orm.DataModel, attr string, value interface{}) error

Nov 10, 2020

Changes in this version

+ func GeneraDbConnBuilder(txt string) func() (dbflex.IConnection, error)

Jul 31, 2020

Changes in this version

type Hub

+ func (h *Hub) IsTx() bool

Jun 21, 2020

Changes in this version

type Hub

+ func (h *Hub) Validate() error

Jun 20, 2020

Changes in this version

type Hub

+ func (h *Hub) EnsureTable(name string, keys []string, object interface{}) error

Jun 12, 2020

Changes in this version

type Hub

+ func (h *Hub) BeginTx() (*Hub, error)

+ func (h *Hub) Commit() error

+ func (h *Hub) Rollback() error

Jun 12, 2020

Changes in this version

type Hub

+ func (h *Hub) PopulateSQL(sql string, dest interface{}) error

Jun 11, 2020

Changes in this version

type Hub

+ func (h *Hub) UpdateAny(name string, object interface{}, fields ...string) error

Jun 11, 2020

Changes in this version

+ type Hub struct

+ func NewHub(fn func() (dbflex.IConnection, error), usePool bool, poolsize int) *Hub

+ func (h *Hub) Close()

+ func (h *Hub) CloseConnection(idx int, conn dbflex.IConnection)

+ func (h *Hub) Count(data orm.DataModel, qp *dbflex.QueryParam) (int, error)

+ func (h *Hub) Delete(data orm.DataModel) error

+ func (h *Hub) DeleteQuery(model orm.DataModel, where *dbflex.Filter) error

+ func (h *Hub) Execute(cmd dbflex.ICommand, object interface{}, parm toolkit.M) (interface{}, error)

+ func (h *Hub) Get(data orm.DataModel) error

+ func (h *Hub) GetByID(data orm.DataModel, ids ...interface{}) error

+ func (h *Hub) GetByParm(data orm.DataModel, parm *dbflex.QueryParam) error

+ func (h *Hub) GetClassicConnection() (dbflex.IConnection, error)

+ func (h *Hub) GetConnection() (int, dbflex.IConnection, error)

+ func (h *Hub) Gets(data orm.DataModel, parm *dbflex.QueryParam, dest interface{}) error

+ func (h *Hub) Insert(data orm.DataModel) error

+ func (h *Hub) Log() *toolkit.LogEngine

+ func (h *Hub) PoolSize() int

+ func (h *Hub) Populate(cmd dbflex.ICommand, parm toolkit.M, result interface{}) (int, error)

+ func (h *Hub) PopulateByParm(tableName string, parm *dbflex.QueryParam, dest interface{}) error

+ func (h *Hub) Save(data orm.DataModel) error

+ func (h *Hub) SaveAny(name string, object interface{}) error

+ func (h *Hub) SetAutoCloseDuration(d time.Duration) *Hub

+ func (h *Hub) SetAutoReleaseDuration(d time.Duration) *Hub

+ func (h *Hub) SetLog(l *toolkit.LogEngine) *Hub

+ func (h *Hub) Update(data orm.DataModel) error

+ func (h *Hub) UpdateField(data orm.DataModel, where *dbflex.Filter, update toolkit.M) error

+ func (h *Hub) UsePool() bool