dbschema

package
v1.5.13 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 21, 2024 License: AGPL-3.0 Imports: 8 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DBI = factory.DefaultDBI
View Source 
var WithPrefix = func(tableName string) string {
	return "" + tableName
}

Functions

This section is empty.

Types

type NgingDbAccount 

type NgingDbAccount struct {
	Id       uint   `db:"id,omitempty,pk" bson:"id,omitempty" comment:"ID" json:"id" xml:"id"`
	Title    string `db:"title" bson:"title" comment:"标题" json:"title" xml:"title"`
	Uid      uint   `db:"uid" bson:"uid" comment:"UID" json:"uid" xml:"uid"`
	Engine   string `db:"engine" bson:"engine" comment:"数据库引擎" json:"engine" xml:"engine"`
	Host     string `db:"host" bson:"host" comment:"服务器地址" json:"host" xml:"host"`
	User     string `db:"user" bson:"user" comment:"用户名" json:"user" xml:"user"`
	Password string `db:"password" bson:"password" comment:"密码" json:"password" xml:"password"`
	Name     string `db:"name" bson:"name" comment:"数据库名称" json:"name" xml:"name"`
	Options  string `db:"options" bson:"options" comment:"其它选项(JSON)" json:"options" xml:"options"`
	Created  uint   `db:"created" bson:"created" comment:"创建时间" json:"created" xml:"created"`
	Updated  uint   `db:"updated" bson:"updated" comment:"修改时间" json:"updated" xml:"updated"`
	// contains filtered or unexported fields
}

NgingDbAccount 数据库账号

func NewNgingDbAccount 

func NewNgingDbAccount(ctx echo.Context) *NgingDbAccount

func (*NgingDbAccount) AsKV 

func (a *NgingDbAccount) AsKV(keyField string, valueField string, inputRows ...[]*NgingDbAccount) param.Store

func (*NgingDbAccount) AsMap 

func (a *NgingDbAccount) AsMap(onlyFields ...string) param.Store

func (*NgingDbAccount) AsRow 

func (a *NgingDbAccount) AsRow(onlyFields ...string) param.Store

func (*NgingDbAccount) Base_ added in v1.4.0 

func (a *NgingDbAccount) Base_() factory.Baser

func (*NgingDbAccount) BatchValidate 

func (a *NgingDbAccount) BatchValidate(kvset map[string]interface{}) error

func (*NgingDbAccount) CPAFrom 

func (a *NgingDbAccount) CPAFrom(source factory.Model) factory.Model

func (*NgingDbAccount) ConnID added in v1.1.0 

func (a *NgingDbAccount) ConnID() int

func (*NgingDbAccount) Context 

func (a *NgingDbAccount) Context() echo.Context

func (*NgingDbAccount) Count 

func (a *NgingDbAccount) Count(mw func(db.Result) db.Result, args ...interface{}) (int64, error)

func (*NgingDbAccount) Delete 

func (a *NgingDbAccount) Delete(mw func(db.Result) db.Result, args ...interface{}) (err error)

func (*NgingDbAccount) Deletex 

func (a *NgingDbAccount) Deletex(mw func(db.Result) db.Result, args ...interface{}) (affected int64, err error)

func (*NgingDbAccount) EventOFF 

func (a *NgingDbAccount) EventOFF(off ...bool) factory.Model

func (*NgingDbAccount) EventON 

func (a *NgingDbAccount) EventON(on ...bool) factory.Model

func (*NgingDbAccount) Exists 

func (a *NgingDbAccount) Exists(mw func(db.Result) db.Result, args ...interface{}) (bool, error)

func (*NgingDbAccount) FromRow 

func (a *NgingDbAccount) FromRow(row map[string]interface{})

func (*NgingDbAccount) Get 

func (a *NgingDbAccount) Get(mw func(db.Result) db.Result, args ...interface{}) (err error)

func (*NgingDbAccount) GroupBy 

func (a *NgingDbAccount) GroupBy(keyField string, inputRows ...[]*NgingDbAccount) map[string][]*NgingDbAccount

func (*NgingDbAccount) InitObjects 

func (a *NgingDbAccount) InitObjects() *[]*NgingDbAccount

func (*NgingDbAccount) Insert 

func (a *NgingDbAccount) Insert() (pk interface{}, err error)

func (*NgingDbAccount) KeyBy 

func (a *NgingDbAccount) KeyBy(keyField string, inputRows ...[]*NgingDbAccount) map[string]*NgingDbAccount

func (*NgingDbAccount) List 

func (a *NgingDbAccount) List(recv interface{}, mw func(db.Result) db.Result, page, size int, args ...interface{}) (func() int64, error)

func (*NgingDbAccount) ListByOffset 

func (a *NgingDbAccount) ListByOffset(recv interface{}, mw func(db.Result) db.Result, offset, size int, args ...interface{}) (func() int64, error)

func (*NgingDbAccount) ListPage 

func (a *NgingDbAccount) ListPage(cond *db.Compounds, sorts ...interface{}) error

func (*NgingDbAccount) ListPageAs 

func (a *NgingDbAccount) ListPageAs(recv interface{}, cond *db.Compounds, sorts ...interface{}) error

func (*NgingDbAccount) Name_ 

func (a *NgingDbAccount) Name_() string

func (*NgingDbAccount) Namer 

func (a *NgingDbAccount) Namer() func(factory.Model) string

func (*NgingDbAccount) New 

func (a *NgingDbAccount) New(structName string, connID ...int) factory.Model

func (*NgingDbAccount) NewObjects 

func (a *NgingDbAccount) NewObjects() factory.Ranger

func (*NgingDbAccount) NewParam 

func (a *NgingDbAccount) NewParam() *factory.Param

func (*NgingDbAccount) Objects 

func (a *NgingDbAccount) Objects() []*NgingDbAccount

func (*NgingDbAccount) Param 

func (a *NgingDbAccount) Param(mw func(db.Result) db.Result, args ...interface{}) *factory.Param

func (*NgingDbAccount) Reset 

func (a *NgingDbAccount) Reset() *NgingDbAccount

func (*NgingDbAccount) Set 

func (a *NgingDbAccount) Set(key interface{}, value ...interface{})

func (*NgingDbAccount) SetConnID 

func (a *NgingDbAccount) SetConnID(connID int) factory.Model

func (*NgingDbAccount) SetContext 

func (a *NgingDbAccount) SetContext(ctx echo.Context) factory.Model

func (*NgingDbAccount) SetNamer 

func (a *NgingDbAccount) SetNamer(namer func(factory.Model) string) factory.Model

func (*NgingDbAccount) SetParam 

func (a *NgingDbAccount) SetParam(param *factory.Param) factory.Model

func (*NgingDbAccount) Short_ 

func (a *NgingDbAccount) Short_() string

func (*NgingDbAccount) Struct_ 

func (a *NgingDbAccount) Struct_() string

func (*NgingDbAccount) Trans 

func (a *NgingDbAccount) Trans() factory.Transactioner

func (*NgingDbAccount) Update 

func (a *NgingDbAccount) Update(mw func(db.Result) db.Result, args ...interface{}) (err error)

func (*NgingDbAccount) UpdateByFields 

func (a *NgingDbAccount) UpdateByFields(mw func(db.Result) db.Result, fields []string, args ...interface{}) (err error)

func (*NgingDbAccount) UpdateField 

func (a *NgingDbAccount) UpdateField(mw func(db.Result) db.Result, field string, value interface{}, args ...interface{}) (err error)

func (*NgingDbAccount) UpdateFields 

func (a *NgingDbAccount) UpdateFields(mw func(db.Result) db.Result, kvset map[string]interface{}, args ...interface{}) (err error)

func (*NgingDbAccount) UpdateValues 

func (a *NgingDbAccount) UpdateValues(mw func(db.Result) db.Result, keysValues *db.KeysValues, args ...interface{}) (err error)

func (*NgingDbAccount) Updatex 

func (a *NgingDbAccount) Updatex(mw func(db.Result) db.Result, args ...interface{}) (affected int64, err error)

func (*NgingDbAccount) UpdatexByFields 

func (a *NgingDbAccount) UpdatexByFields(mw func(db.Result) db.Result, fields []string, args ...interface{}) (affected int64, err error)

func (*NgingDbAccount) UpdatexField added in v1.2.0 

func (a *NgingDbAccount) UpdatexField(mw func(db.Result) db.Result, field string, value interface{}, args ...interface{}) (affected int64, err error)

func (*NgingDbAccount) UpdatexFields added in v1.2.0 

func (a *NgingDbAccount) UpdatexFields(mw func(db.Result) db.Result, kvset map[string]interface{}, args ...interface{}) (affected int64, err error)

func (*NgingDbAccount) Upsert 

func (a *NgingDbAccount) Upsert(mw func(db.Result) db.Result, args ...interface{}) (pk interface{}, err error)

func (*NgingDbAccount) Use 

func (a *NgingDbAccount) Use(trans factory.Transactioner) factory.Model

func (*NgingDbAccount) Validate 

func (a *NgingDbAccount) Validate(field string, value interface{}) error

func (*NgingDbAccount) XObjects 

func (a *NgingDbAccount) XObjects() Slice_NgingDbAccount

type NgingDbSync 

type NgingDbSync struct {
	Id                   uint   `db:"id,omitempty,pk" bson:"id,omitempty" comment:"ID" json:"id" xml:"id"`
	Name                 string `db:"name" bson:"name" comment:"方案名" json:"name" xml:"name"`
	SourceAccountId      uint   `` /* 127-byte string literal not displayed */
	DsnSource            string `db:"dsn_source" bson:"dsn_source" comment:"同步源" json:"dsn_source" xml:"dsn_source"`
	DestinationAccountId uint   `` /* 150-byte string literal not displayed */
	DsnDestination       string `db:"dsn_destination" bson:"dsn_destination" comment:"目标数据库" json:"dsn_destination" xml:"dsn_destination"`
	Tables               string `db:"tables" bson:"tables" comment:"要同步的表" json:"tables" xml:"tables"`
	SkipTables           string `db:"skip_tables" bson:"skip_tables" comment:"要跳过的表" json:"skip_tables" xml:"skip_tables"`
	AlterIgnore          string `db:"alter_ignore" bson:"alter_ignore" comment:"要忽略的列、索引、外键" json:"alter_ignore" xml:"alter_ignore"`
	Drop                 uint   `db:"drop" bson:"drop" comment:"删除待同步数据库中多余的字段、索引、外键 " json:"drop" xml:"drop"`
	MailTo               string `db:"mail_to" bson:"mail_to" comment:"发送邮件" json:"mail_to" xml:"mail_to"`
	Created              uint   `db:"created" bson:"created" comment:"创建时间" json:"created" xml:"created"`
	Updated              int    `db:"updated" bson:"updated" comment:"更新时间" json:"updated" xml:"updated"`
	// contains filtered or unexported fields
}

NgingDbSync 数据表同步方案

func NewNgingDbSync 

func NewNgingDbSync(ctx echo.Context) *NgingDbSync

func (*NgingDbSync) AsKV 

func (a *NgingDbSync) AsKV(keyField string, valueField string, inputRows ...[]*NgingDbSync) param.Store

func (*NgingDbSync) AsMap 

func (a *NgingDbSync) AsMap(onlyFields ...string) param.Store

func (*NgingDbSync) AsRow 

func (a *NgingDbSync) AsRow(onlyFields ...string) param.Store

func (*NgingDbSync) Base_ added in v1.4.0 

func (a *NgingDbSync) Base_() factory.Baser

func (*NgingDbSync) BatchValidate 

func (a *NgingDbSync) BatchValidate(kvset map[string]interface{}) error

func (*NgingDbSync) CPAFrom 

func (a *NgingDbSync) CPAFrom(source factory.Model) factory.Model

func (*NgingDbSync) ConnID added in v1.1.0 

func (a *NgingDbSync) ConnID() int

func (*NgingDbSync) Context 

func (a *NgingDbSync) Context() echo.Context

func (*NgingDbSync) Count 

func (a *NgingDbSync) Count(mw func(db.Result) db.Result, args ...interface{}) (int64, error)

func (*NgingDbSync) Delete 

func (a *NgingDbSync) Delete(mw func(db.Result) db.Result, args ...interface{}) (err error)

func (*NgingDbSync) Deletex 

func (a *NgingDbSync) Deletex(mw func(db.Result) db.Result, args ...interface{}) (affected int64, err error)

func (*NgingDbSync) EventOFF 

func (a *NgingDbSync) EventOFF(off ...bool) factory.Model

func (*NgingDbSync) EventON 

func (a *NgingDbSync) EventON(on ...bool) factory.Model

func (*NgingDbSync) Exists 

func (a *NgingDbSync) Exists(mw func(db.Result) db.Result, args ...interface{}) (bool, error)

func (*NgingDbSync) FromRow 

func (a *NgingDbSync) FromRow(row map[string]interface{})

func (*NgingDbSync) Get 

func (a *NgingDbSync) Get(mw func(db.Result) db.Result, args ...interface{}) (err error)

func (*NgingDbSync) GroupBy 

func (a *NgingDbSync) GroupBy(keyField string, inputRows ...[]*NgingDbSync) map[string][]*NgingDbSync

func (*NgingDbSync) InitObjects 

func (a *NgingDbSync) InitObjects() *[]*NgingDbSync

func (*NgingDbSync) Insert 

func (a *NgingDbSync) Insert() (pk interface{}, err error)

func (*NgingDbSync) KeyBy 

func (a *NgingDbSync) KeyBy(keyField string, inputRows ...[]*NgingDbSync) map[string]*NgingDbSync

func (*NgingDbSync) List 

func (a *NgingDbSync) List(recv interface{}, mw func(db.Result) db.Result, page, size int, args ...interface{}) (func() int64, error)

func (*NgingDbSync) ListByOffset 

func (a *NgingDbSync) ListByOffset(recv interface{}, mw func(db.Result) db.Result, offset, size int, args ...interface{}) (func() int64, error)

func (*NgingDbSync) ListPage 

func (a *NgingDbSync) ListPage(cond *db.Compounds, sorts ...interface{}) error

func (*NgingDbSync) ListPageAs 

func (a *NgingDbSync) ListPageAs(recv interface{}, cond *db.Compounds, sorts ...interface{}) error

func (*NgingDbSync) Name_ 

func (a *NgingDbSync) Name_() string

func (*NgingDbSync) Namer 

func (a *NgingDbSync) Namer() func(factory.Model) string

func (*NgingDbSync) New 

func (a *NgingDbSync) New(structName string, connID ...int) factory.Model

func (*NgingDbSync) NewObjects 

func (a *NgingDbSync) NewObjects() factory.Ranger

func (*NgingDbSync) NewParam 

func (a *NgingDbSync) NewParam() *factory.Param

func (*NgingDbSync) Objects 

func (a *NgingDbSync) Objects() []*NgingDbSync

func (*NgingDbSync) Param 

func (a *NgingDbSync) Param(mw func(db.Result) db.Result, args ...interface{}) *factory.Param

func (*NgingDbSync) Reset 

func (a *NgingDbSync) Reset() *NgingDbSync

func (*NgingDbSync) Set 

func (a *NgingDbSync) Set(key interface{}, value ...interface{})

func (*NgingDbSync) SetConnID 

func (a *NgingDbSync) SetConnID(connID int) factory.Model

func (*NgingDbSync) SetContext 

func (a *NgingDbSync) SetContext(ctx echo.Context) factory.Model

func (*NgingDbSync) SetNamer 

func (a *NgingDbSync) SetNamer(namer func(factory.Model) string) factory.Model

func (*NgingDbSync) SetParam 

func (a *NgingDbSync) SetParam(param *factory.Param) factory.Model

func (*NgingDbSync) Short_ 

func (a *NgingDbSync) Short_() string

func (*NgingDbSync) Struct_ 

func (a *NgingDbSync) Struct_() string

func (*NgingDbSync) Trans 

func (a *NgingDbSync) Trans() factory.Transactioner

func (*NgingDbSync) Update 

func (a *NgingDbSync) Update(mw func(db.Result) db.Result, args ...interface{}) (err error)

func (*NgingDbSync) UpdateByFields 

func (a *NgingDbSync) UpdateByFields(mw func(db.Result) db.Result, fields []string, args ...interface{}) (err error)

func (*NgingDbSync) UpdateField 

func (a *NgingDbSync) UpdateField(mw func(db.Result) db.Result, field string, value interface{}, args ...interface{}) (err error)

func (*NgingDbSync) UpdateFields 

func (a *NgingDbSync) UpdateFields(mw func(db.Result) db.Result, kvset map[string]interface{}, args ...interface{}) (err error)

func (*NgingDbSync) UpdateValues 

func (a *NgingDbSync) UpdateValues(mw func(db.Result) db.Result, keysValues *db.KeysValues, args ...interface{}) (err error)

func (*NgingDbSync) Updatex 

func (a *NgingDbSync) Updatex(mw func(db.Result) db.Result, args ...interface{}) (affected int64, err error)

func (*NgingDbSync) UpdatexByFields 

func (a *NgingDbSync) UpdatexByFields(mw func(db.Result) db.Result, fields []string, args ...interface{}) (affected int64, err error)

func (*NgingDbSync) UpdatexField added in v1.2.0 

func (a *NgingDbSync) UpdatexField(mw func(db.Result) db.Result, field string, value interface{}, args ...interface{}) (affected int64, err error)

func (*NgingDbSync) UpdatexFields added in v1.2.0 

func (a *NgingDbSync) UpdatexFields(mw func(db.Result) db.Result, kvset map[string]interface{}, args ...interface{}) (affected int64, err error)

func (*NgingDbSync) Upsert 

func (a *NgingDbSync) Upsert(mw func(db.Result) db.Result, args ...interface{}) (pk interface{}, err error)

func (*NgingDbSync) Use 

func (a *NgingDbSync) Use(trans factory.Transactioner) factory.Model

func (*NgingDbSync) Validate 

func (a *NgingDbSync) Validate(field string, value interface{}) error

func (*NgingDbSync) XObjects 

func (a *NgingDbSync) XObjects() Slice_NgingDbSync

type NgingDbSyncLog 

type NgingDbSyncLog struct {
	Id             uint64 `db:"id,omitempty,pk" bson:"id,omitempty" comment:"" json:"id" xml:"id"`
	SyncId         uint   `db:"sync_id" bson:"sync_id" comment:"同步方案ID" json:"sync_id" xml:"sync_id"`
	Created        uint   `db:"created" bson:"created" comment:"创建时间" json:"created" xml:"created"`
	Result         string `db:"result" bson:"result" comment:"结果报表" json:"result" xml:"result"`
	ChangeTables   string `db:"change_tables" bson:"change_tables" comment:"被更改的表" json:"change_tables" xml:"change_tables"`
	ChangeTableNum uint   `` /* 127-byte string literal not displayed */
	Elapsed        uint64 `db:"elapsed" bson:"elapsed" comment:"总共耗时" json:"elapsed" xml:"elapsed"`
	Failed         uint   `db:"failed" bson:"failed" comment:"失败次数" json:"failed" xml:"failed"`
	// contains filtered or unexported fields
}

NgingDbSyncLog 数据表同步日志

func NewNgingDbSyncLog 

func NewNgingDbSyncLog(ctx echo.Context) *NgingDbSyncLog

func (*NgingDbSyncLog) AsKV 

func (a *NgingDbSyncLog) AsKV(keyField string, valueField string, inputRows ...[]*NgingDbSyncLog) param.Store

func (*NgingDbSyncLog) AsMap 

func (a *NgingDbSyncLog) AsMap(onlyFields ...string) param.Store

func (*NgingDbSyncLog) AsRow 

func (a *NgingDbSyncLog) AsRow(onlyFields ...string) param.Store

func (*NgingDbSyncLog) Base_ added in v1.4.0 

func (a *NgingDbSyncLog) Base_() factory.Baser

func (*NgingDbSyncLog) BatchValidate 

func (a *NgingDbSyncLog) BatchValidate(kvset map[string]interface{}) error

func (*NgingDbSyncLog) CPAFrom 

func (a *NgingDbSyncLog) CPAFrom(source factory.Model) factory.Model

func (*NgingDbSyncLog) ConnID added in v1.1.0 

func (a *NgingDbSyncLog) ConnID() int

func (*NgingDbSyncLog) Context 

func (a *NgingDbSyncLog) Context() echo.Context

func (*NgingDbSyncLog) Count 

func (a *NgingDbSyncLog) Count(mw func(db.Result) db.Result, args ...interface{}) (int64, error)

func (*NgingDbSyncLog) Delete 

func (a *NgingDbSyncLog) Delete(mw func(db.Result) db.Result, args ...interface{}) (err error)

func (*NgingDbSyncLog) Deletex 

func (a *NgingDbSyncLog) Deletex(mw func(db.Result) db.Result, args ...interface{}) (affected int64, err error)

func (*NgingDbSyncLog) EventOFF 

func (a *NgingDbSyncLog) EventOFF(off ...bool) factory.Model

func (*NgingDbSyncLog) EventON 

func (a *NgingDbSyncLog) EventON(on ...bool) factory.Model

func (*NgingDbSyncLog) Exists 

func (a *NgingDbSyncLog) Exists(mw func(db.Result) db.Result, args ...interface{}) (bool, error)

func (*NgingDbSyncLog) FromRow 

func (a *NgingDbSyncLog) FromRow(row map[string]interface{})

func (*NgingDbSyncLog) Get 

func (a *NgingDbSyncLog) Get(mw func(db.Result) db.Result, args ...interface{}) (err error)

func (*NgingDbSyncLog) GroupBy 

func (a *NgingDbSyncLog) GroupBy(keyField string, inputRows ...[]*NgingDbSyncLog) map[string][]*NgingDbSyncLog

func (*NgingDbSyncLog) InitObjects 

func (a *NgingDbSyncLog) InitObjects() *[]*NgingDbSyncLog

func (*NgingDbSyncLog) Insert 

func (a *NgingDbSyncLog) Insert() (pk interface{}, err error)

func (*NgingDbSyncLog) KeyBy 

func (a *NgingDbSyncLog) KeyBy(keyField string, inputRows ...[]*NgingDbSyncLog) map[string]*NgingDbSyncLog

func (*NgingDbSyncLog) List 

func (a *NgingDbSyncLog) List(recv interface{}, mw func(db.Result) db.Result, page, size int, args ...interface{}) (func() int64, error)

func (*NgingDbSyncLog) ListByOffset 

func (a *NgingDbSyncLog) ListByOffset(recv interface{}, mw func(db.Result) db.Result, offset, size int, args ...interface{}) (func() int64, error)

func (*NgingDbSyncLog) ListPage 

func (a *NgingDbSyncLog) ListPage(cond *db.Compounds, sorts ...interface{}) error

func (*NgingDbSyncLog) ListPageAs 

func (a *NgingDbSyncLog) ListPageAs(recv interface{}, cond *db.Compounds, sorts ...interface{}) error

func (*NgingDbSyncLog) Name_ 

func (a *NgingDbSyncLog) Name_() string

func (*NgingDbSyncLog) Namer 

func (a *NgingDbSyncLog) Namer() func(factory.Model) string

func (*NgingDbSyncLog) New 

func (a *NgingDbSyncLog) New(structName string, connID ...int) factory.Model

func (*NgingDbSyncLog) NewObjects 

func (a *NgingDbSyncLog) NewObjects() factory.Ranger

func (*NgingDbSyncLog) NewParam 

func (a *NgingDbSyncLog) NewParam() *factory.Param

func (*NgingDbSyncLog) Objects 

func (a *NgingDbSyncLog) Objects() []*NgingDbSyncLog

func (*NgingDbSyncLog) Param 

func (a *NgingDbSyncLog) Param(mw func(db.Result) db.Result, args ...interface{}) *factory.Param

func (*NgingDbSyncLog) Reset 

func (a *NgingDbSyncLog) Reset() *NgingDbSyncLog

func (*NgingDbSyncLog) Set 

func (a *NgingDbSyncLog) Set(key interface{}, value ...interface{})

func (*NgingDbSyncLog) SetConnID 

func (a *NgingDbSyncLog) SetConnID(connID int) factory.Model

func (*NgingDbSyncLog) SetContext 

func (a *NgingDbSyncLog) SetContext(ctx echo.Context) factory.Model

func (*NgingDbSyncLog) SetNamer 

func (a *NgingDbSyncLog) SetNamer(namer func(factory.Model) string) factory.Model

func (*NgingDbSyncLog) SetParam 

func (a *NgingDbSyncLog) SetParam(param *factory.Param) factory.Model

func (*NgingDbSyncLog) Short_ 

func (a *NgingDbSyncLog) Short_() string

func (*NgingDbSyncLog) Struct_ 

func (a *NgingDbSyncLog) Struct_() string

func (*NgingDbSyncLog) Trans 

func (a *NgingDbSyncLog) Trans() factory.Transactioner

func (*NgingDbSyncLog) Update 

func (a *NgingDbSyncLog) Update(mw func(db.Result) db.Result, args ...interface{}) (err error)

func (*NgingDbSyncLog) UpdateByFields 

func (a *NgingDbSyncLog) UpdateByFields(mw func(db.Result) db.Result, fields []string, args ...interface{}) (err error)

func (*NgingDbSyncLog) UpdateField 

func (a *NgingDbSyncLog) UpdateField(mw func(db.Result) db.Result, field string, value interface{}, args ...interface{}) (err error)

func (*NgingDbSyncLog) UpdateFields 

func (a *NgingDbSyncLog) UpdateFields(mw func(db.Result) db.Result, kvset map[string]interface{}, args ...interface{}) (err error)

func (*NgingDbSyncLog) UpdateValues 

func (a *NgingDbSyncLog) UpdateValues(mw func(db.Result) db.Result, keysValues *db.KeysValues, args ...interface{}) (err error)

func (*NgingDbSyncLog) Updatex 

func (a *NgingDbSyncLog) Updatex(mw func(db.Result) db.Result, args ...interface{}) (affected int64, err error)

func (*NgingDbSyncLog) UpdatexByFields 

func (a *NgingDbSyncLog) UpdatexByFields(mw func(db.Result) db.Result, fields []string, args ...interface{}) (affected int64, err error)

func (*NgingDbSyncLog) UpdatexField added in v1.2.0 

func (a *NgingDbSyncLog) UpdatexField(mw func(db.Result) db.Result, field string, value interface{}, args ...interface{}) (affected int64, err error)

func (*NgingDbSyncLog) UpdatexFields added in v1.2.0 

func (a *NgingDbSyncLog) UpdatexFields(mw func(db.Result) db.Result, kvset map[string]interface{}, args ...interface{}) (affected int64, err error)

func (*NgingDbSyncLog) Upsert 

func (a *NgingDbSyncLog) Upsert(mw func(db.Result) db.Result, args ...interface{}) (pk interface{}, err error)

func (*NgingDbSyncLog) Use 

func (a *NgingDbSyncLog) Use(trans factory.Transactioner) factory.Model

func (*NgingDbSyncLog) Validate 

func (a *NgingDbSyncLog) Validate(field string, value interface{}) error

func (*NgingDbSyncLog) XObjects 

func (a *NgingDbSyncLog) XObjects() Slice_NgingDbSyncLog

type Slice_NgingDbAccount 

type Slice_NgingDbAccount []*NgingDbAccount

func (Slice_NgingDbAccount) AsKV 

func (s Slice_NgingDbAccount) AsKV(keyField string, valueField string) param.Store

func (Slice_NgingDbAccount) FromList 

func (s Slice_NgingDbAccount) FromList(data interface{}) Slice_NgingDbAccount

func (Slice_NgingDbAccount) GroupBy 

func (s Slice_NgingDbAccount) GroupBy(keyField string) map[string][]*NgingDbAccount

func (Slice_NgingDbAccount) KeyBy 

func (s Slice_NgingDbAccount) KeyBy(keyField string) map[string]*NgingDbAccount

func (Slice_NgingDbAccount) Range 

func (s Slice_NgingDbAccount) Range(fn func(m factory.Model) error) error

func (Slice_NgingDbAccount) RangeRaw 

func (s Slice_NgingDbAccount) RangeRaw(fn func(m *NgingDbAccount) error) error

func (Slice_NgingDbAccount) Transform 

func (s Slice_NgingDbAccount) Transform(transfers map[string]param.Transfer) []param.Store

type Slice_NgingDbSync 

type Slice_NgingDbSync []*NgingDbSync

func (Slice_NgingDbSync) AsKV 

func (s Slice_NgingDbSync) AsKV(keyField string, valueField string) param.Store

func (Slice_NgingDbSync) FromList 

func (s Slice_NgingDbSync) FromList(data interface{}) Slice_NgingDbSync

func (Slice_NgingDbSync) GroupBy 

func (s Slice_NgingDbSync) GroupBy(keyField string) map[string][]*NgingDbSync

func (Slice_NgingDbSync) KeyBy 

func (s Slice_NgingDbSync) KeyBy(keyField string) map[string]*NgingDbSync

func (Slice_NgingDbSync) Range 

func (s Slice_NgingDbSync) Range(fn func(m factory.Model) error) error

func (Slice_NgingDbSync) RangeRaw 

func (s Slice_NgingDbSync) RangeRaw(fn func(m *NgingDbSync) error) error

func (Slice_NgingDbSync) Transform 

func (s Slice_NgingDbSync) Transform(transfers map[string]param.Transfer) []param.Store

type Slice_NgingDbSyncLog 

type Slice_NgingDbSyncLog []*NgingDbSyncLog

func (Slice_NgingDbSyncLog) AsKV 

func (s Slice_NgingDbSyncLog) AsKV(keyField string, valueField string) param.Store

func (Slice_NgingDbSyncLog) FromList 

func (s Slice_NgingDbSyncLog) FromList(data interface{}) Slice_NgingDbSyncLog

func (Slice_NgingDbSyncLog) GroupBy 

func (s Slice_NgingDbSyncLog) GroupBy(keyField string) map[string][]*NgingDbSyncLog

func (Slice_NgingDbSyncLog) KeyBy 

func (s Slice_NgingDbSyncLog) KeyBy(keyField string) map[string]*NgingDbSyncLog

func (Slice_NgingDbSyncLog) Range 

func (s Slice_NgingDbSyncLog) Range(fn func(m factory.Model) error) error

func (Slice_NgingDbSyncLog) RangeRaw 

func (s Slice_NgingDbSyncLog) RangeRaw(fn func(m *NgingDbSyncLog) error) error

func (Slice_NgingDbSyncLog) Transform 

func (s Slice_NgingDbSyncLog) Transform(transfers map[string]param.Transfer) []param.Store

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.