Documentation ¶
Index ¶
- Variables
- type NgingDbAccount
- func (a *NgingDbAccount) AsKV(keyField string, valueField string, inputRows ...[]*NgingDbAccount) param.Store
- func (a *NgingDbAccount) AsMap(onlyFields ...string) param.Store
- func (a *NgingDbAccount) AsRow(onlyFields ...string) param.Store
- func (a *NgingDbAccount) Base_() factory.Baser
- func (a *NgingDbAccount) BatchValidate(kvset map[string]interface{}) error
- func (a *NgingDbAccount) CPAFrom(source factory.Model) factory.Model
- func (a *NgingDbAccount) ConnID() int
- func (a *NgingDbAccount) Context() echo.Context
- func (a *NgingDbAccount) Count(mw func(db.Result) db.Result, args ...interface{}) (int64, error)
- func (a *NgingDbAccount) Delete(mw func(db.Result) db.Result, args ...interface{}) (err error)
- func (a *NgingDbAccount) Deletex(mw func(db.Result) db.Result, args ...interface{}) (affected int64, err error)
- func (a *NgingDbAccount) EventOFF(off ...bool) factory.Model
- func (a *NgingDbAccount) EventON(on ...bool) factory.Model
- func (a *NgingDbAccount) Exists(mw func(db.Result) db.Result, args ...interface{}) (bool, error)
- func (a *NgingDbAccount) FromRow(row map[string]interface{})
- func (a *NgingDbAccount) Get(mw func(db.Result) db.Result, args ...interface{}) (err error)
- func (a *NgingDbAccount) GetAllFieldNames() []string
- func (a *NgingDbAccount) GetField(field string) interface{}
- func (a *NgingDbAccount) GroupBy(keyField string, inputRows ...[]*NgingDbAccount) map[string][]*NgingDbAccount
- func (a *NgingDbAccount) HasField(field string) bool
- func (a *NgingDbAccount) InitObjects() *[]*NgingDbAccount
- func (a *NgingDbAccount) Insert() (pk interface{}, err error)
- func (a *NgingDbAccount) KeyBy(keyField string, inputRows ...[]*NgingDbAccount) map[string]*NgingDbAccount
- func (a *NgingDbAccount) List(recv interface{}, mw func(db.Result) db.Result, page, size int, ...) (func() int64, error)
- func (a *NgingDbAccount) ListByOffset(recv interface{}, mw func(db.Result) db.Result, offset, size int, ...) (func() int64, error)
- func (a *NgingDbAccount) ListPage(cond *db.Compounds, sorts ...interface{}) error
- func (a *NgingDbAccount) ListPageAs(recv interface{}, cond *db.Compounds, sorts ...interface{}) error
- func (a *NgingDbAccount) ListPageByOffset(cond *db.Compounds, sorts ...interface{}) error
- func (a *NgingDbAccount) ListPageByOffsetAs(recv interface{}, cond *db.Compounds, sorts ...interface{}) error
- func (a *NgingDbAccount) Name_() string
- func (a *NgingDbAccount) Namer() func(factory.Model) string
- func (a *NgingDbAccount) New(structName string, connID ...int) factory.Model
- func (a *NgingDbAccount) NewObjects() factory.Ranger
- func (a *NgingDbAccount) NewParam() *factory.Param
- func (a *NgingDbAccount) Objects() []*NgingDbAccount
- func (a *NgingDbAccount) Param(mw func(db.Result) db.Result, args ...interface{}) *factory.Param
- func (a *NgingDbAccount) Reset() *NgingDbAccount
- func (a *NgingDbAccount) Set(key interface{}, value ...interface{})
- func (a *NgingDbAccount) SetConnID(connID int) factory.Model
- func (a *NgingDbAccount) SetContext(ctx echo.Context) factory.Model
- func (a *NgingDbAccount) SetNamer(namer func(factory.Model) string) factory.Model
- func (a *NgingDbAccount) SetParam(param *factory.Param) factory.Model
- func (a *NgingDbAccount) Short_() string
- func (a *NgingDbAccount) Struct_() string
- func (a *NgingDbAccount) Trans() factory.Transactioner
- func (a *NgingDbAccount) Update(mw func(db.Result) db.Result, args ...interface{}) (err error)
- func (a *NgingDbAccount) UpdateByFields(mw func(db.Result) db.Result, fields []string, args ...interface{}) (err error)
- func (a *NgingDbAccount) UpdateField(mw func(db.Result) db.Result, field string, value interface{}, ...) (err error)
- func (a *NgingDbAccount) UpdateFields(mw func(db.Result) db.Result, kvset map[string]interface{}, ...) (err error)
- func (a *NgingDbAccount) UpdateValues(mw func(db.Result) db.Result, keysValues *db.KeysValues, args ...interface{}) (err error)
- func (a *NgingDbAccount) Updatex(mw func(db.Result) db.Result, args ...interface{}) (affected int64, err error)
- func (a *NgingDbAccount) UpdatexByFields(mw func(db.Result) db.Result, fields []string, args ...interface{}) (affected int64, err error)
- func (a *NgingDbAccount) UpdatexField(mw func(db.Result) db.Result, field string, value interface{}, ...) (affected int64, err error)
- func (a *NgingDbAccount) UpdatexFields(mw func(db.Result) db.Result, kvset map[string]interface{}, ...) (affected int64, err error)
- func (a *NgingDbAccount) Upsert(mw func(db.Result) db.Result, args ...interface{}) (pk interface{}, err error)
- func (a *NgingDbAccount) Use(trans factory.Transactioner) factory.Model
- func (a *NgingDbAccount) Validate(field string, value interface{}) error
- func (a *NgingDbAccount) XObjects() Slice_NgingDbAccount
- type NgingDbSync
- func (a *NgingDbSync) AsKV(keyField string, valueField string, inputRows ...[]*NgingDbSync) param.Store
- func (a *NgingDbSync) AsMap(onlyFields ...string) param.Store
- func (a *NgingDbSync) AsRow(onlyFields ...string) param.Store
- func (a *NgingDbSync) Base_() factory.Baser
- func (a *NgingDbSync) BatchValidate(kvset map[string]interface{}) error
- func (a *NgingDbSync) CPAFrom(source factory.Model) factory.Model
- func (a *NgingDbSync) ConnID() int
- func (a *NgingDbSync) Context() echo.Context
- func (a *NgingDbSync) Count(mw func(db.Result) db.Result, args ...interface{}) (int64, error)
- func (a *NgingDbSync) Delete(mw func(db.Result) db.Result, args ...interface{}) (err error)
- func (a *NgingDbSync) Deletex(mw func(db.Result) db.Result, args ...interface{}) (affected int64, err error)
- func (a *NgingDbSync) EventOFF(off ...bool) factory.Model
- func (a *NgingDbSync) EventON(on ...bool) factory.Model
- func (a *NgingDbSync) Exists(mw func(db.Result) db.Result, args ...interface{}) (bool, error)
- func (a *NgingDbSync) FromRow(row map[string]interface{})
- func (a *NgingDbSync) Get(mw func(db.Result) db.Result, args ...interface{}) (err error)
- func (a *NgingDbSync) GetAllFieldNames() []string
- func (a *NgingDbSync) GetField(field string) interface{}
- func (a *NgingDbSync) GroupBy(keyField string, inputRows ...[]*NgingDbSync) map[string][]*NgingDbSync
- func (a *NgingDbSync) HasField(field string) bool
- func (a *NgingDbSync) InitObjects() *[]*NgingDbSync
- func (a *NgingDbSync) Insert() (pk interface{}, err error)
- func (a *NgingDbSync) KeyBy(keyField string, inputRows ...[]*NgingDbSync) map[string]*NgingDbSync
- func (a *NgingDbSync) List(recv interface{}, mw func(db.Result) db.Result, page, size int, ...) (func() int64, error)
- func (a *NgingDbSync) ListByOffset(recv interface{}, mw func(db.Result) db.Result, offset, size int, ...) (func() int64, error)
- func (a *NgingDbSync) ListPage(cond *db.Compounds, sorts ...interface{}) error
- func (a *NgingDbSync) ListPageAs(recv interface{}, cond *db.Compounds, sorts ...interface{}) error
- func (a *NgingDbSync) ListPageByOffset(cond *db.Compounds, sorts ...interface{}) error
- func (a *NgingDbSync) ListPageByOffsetAs(recv interface{}, cond *db.Compounds, sorts ...interface{}) error
- func (a *NgingDbSync) Name_() string
- func (a *NgingDbSync) Namer() func(factory.Model) string
- func (a *NgingDbSync) New(structName string, connID ...int) factory.Model
- func (a *NgingDbSync) NewObjects() factory.Ranger
- func (a *NgingDbSync) NewParam() *factory.Param
- func (a *NgingDbSync) Objects() []*NgingDbSync
- func (a *NgingDbSync) Param(mw func(db.Result) db.Result, args ...interface{}) *factory.Param
- func (a *NgingDbSync) Reset() *NgingDbSync
- func (a *NgingDbSync) Set(key interface{}, value ...interface{})
- func (a *NgingDbSync) SetConnID(connID int) factory.Model
- func (a *NgingDbSync) SetContext(ctx echo.Context) factory.Model
- func (a *NgingDbSync) SetNamer(namer func(factory.Model) string) factory.Model
- func (a *NgingDbSync) SetParam(param *factory.Param) factory.Model
- func (a *NgingDbSync) Short_() string
- func (a *NgingDbSync) Struct_() string
- func (a *NgingDbSync) Trans() factory.Transactioner
- func (a *NgingDbSync) Update(mw func(db.Result) db.Result, args ...interface{}) (err error)
- func (a *NgingDbSync) UpdateByFields(mw func(db.Result) db.Result, fields []string, args ...interface{}) (err error)
- func (a *NgingDbSync) UpdateField(mw func(db.Result) db.Result, field string, value interface{}, ...) (err error)
- func (a *NgingDbSync) UpdateFields(mw func(db.Result) db.Result, kvset map[string]interface{}, ...) (err error)
- func (a *NgingDbSync) UpdateValues(mw func(db.Result) db.Result, keysValues *db.KeysValues, args ...interface{}) (err error)
- func (a *NgingDbSync) Updatex(mw func(db.Result) db.Result, args ...interface{}) (affected int64, err error)
- func (a *NgingDbSync) UpdatexByFields(mw func(db.Result) db.Result, fields []string, args ...interface{}) (affected int64, err error)
- func (a *NgingDbSync) UpdatexField(mw func(db.Result) db.Result, field string, value interface{}, ...) (affected int64, err error)
- func (a *NgingDbSync) UpdatexFields(mw func(db.Result) db.Result, kvset map[string]interface{}, ...) (affected int64, err error)
- func (a *NgingDbSync) Upsert(mw func(db.Result) db.Result, args ...interface{}) (pk interface{}, err error)
- func (a *NgingDbSync) Use(trans factory.Transactioner) factory.Model
- func (a *NgingDbSync) Validate(field string, value interface{}) error
- func (a *NgingDbSync) XObjects() Slice_NgingDbSync
- type NgingDbSyncLog
- func (a *NgingDbSyncLog) AsKV(keyField string, valueField string, inputRows ...[]*NgingDbSyncLog) param.Store
- func (a *NgingDbSyncLog) AsMap(onlyFields ...string) param.Store
- func (a *NgingDbSyncLog) AsRow(onlyFields ...string) param.Store
- func (a *NgingDbSyncLog) Base_() factory.Baser
- func (a *NgingDbSyncLog) BatchValidate(kvset map[string]interface{}) error
- func (a *NgingDbSyncLog) CPAFrom(source factory.Model) factory.Model
- func (a *NgingDbSyncLog) ConnID() int
- func (a *NgingDbSyncLog) Context() echo.Context
- func (a *NgingDbSyncLog) Count(mw func(db.Result) db.Result, args ...interface{}) (int64, error)
- func (a *NgingDbSyncLog) Delete(mw func(db.Result) db.Result, args ...interface{}) (err error)
- func (a *NgingDbSyncLog) Deletex(mw func(db.Result) db.Result, args ...interface{}) (affected int64, err error)
- func (a *NgingDbSyncLog) EventOFF(off ...bool) factory.Model
- func (a *NgingDbSyncLog) EventON(on ...bool) factory.Model
- func (a *NgingDbSyncLog) Exists(mw func(db.Result) db.Result, args ...interface{}) (bool, error)
- func (a *NgingDbSyncLog) FromRow(row map[string]interface{})
- func (a *NgingDbSyncLog) Get(mw func(db.Result) db.Result, args ...interface{}) (err error)
- func (a *NgingDbSyncLog) GetAllFieldNames() []string
- func (a *NgingDbSyncLog) GetField(field string) interface{}
- func (a *NgingDbSyncLog) GroupBy(keyField string, inputRows ...[]*NgingDbSyncLog) map[string][]*NgingDbSyncLog
- func (a *NgingDbSyncLog) HasField(field string) bool
- func (a *NgingDbSyncLog) InitObjects() *[]*NgingDbSyncLog
- func (a *NgingDbSyncLog) Insert() (pk interface{}, err error)
- func (a *NgingDbSyncLog) KeyBy(keyField string, inputRows ...[]*NgingDbSyncLog) map[string]*NgingDbSyncLog
- func (a *NgingDbSyncLog) List(recv interface{}, mw func(db.Result) db.Result, page, size int, ...) (func() int64, error)
- func (a *NgingDbSyncLog) ListByOffset(recv interface{}, mw func(db.Result) db.Result, offset, size int, ...) (func() int64, error)
- func (a *NgingDbSyncLog) ListPage(cond *db.Compounds, sorts ...interface{}) error
- func (a *NgingDbSyncLog) ListPageAs(recv interface{}, cond *db.Compounds, sorts ...interface{}) error
- func (a *NgingDbSyncLog) ListPageByOffset(cond *db.Compounds, sorts ...interface{}) error
- func (a *NgingDbSyncLog) ListPageByOffsetAs(recv interface{}, cond *db.Compounds, sorts ...interface{}) error
- func (a *NgingDbSyncLog) Name_() string
- func (a *NgingDbSyncLog) Namer() func(factory.Model) string
- func (a *NgingDbSyncLog) New(structName string, connID ...int) factory.Model
- func (a *NgingDbSyncLog) NewObjects() factory.Ranger
- func (a *NgingDbSyncLog) NewParam() *factory.Param
- func (a *NgingDbSyncLog) Objects() []*NgingDbSyncLog
- func (a *NgingDbSyncLog) Param(mw func(db.Result) db.Result, args ...interface{}) *factory.Param
- func (a *NgingDbSyncLog) Reset() *NgingDbSyncLog
- func (a *NgingDbSyncLog) Set(key interface{}, value ...interface{})
- func (a *NgingDbSyncLog) SetConnID(connID int) factory.Model
- func (a *NgingDbSyncLog) SetContext(ctx echo.Context) factory.Model
- func (a *NgingDbSyncLog) SetNamer(namer func(factory.Model) string) factory.Model
- func (a *NgingDbSyncLog) SetParam(param *factory.Param) factory.Model
- func (a *NgingDbSyncLog) Short_() string
- func (a *NgingDbSyncLog) Struct_() string
- func (a *NgingDbSyncLog) Trans() factory.Transactioner
- func (a *NgingDbSyncLog) Update(mw func(db.Result) db.Result, args ...interface{}) (err error)
- func (a *NgingDbSyncLog) UpdateByFields(mw func(db.Result) db.Result, fields []string, args ...interface{}) (err error)
- func (a *NgingDbSyncLog) UpdateField(mw func(db.Result) db.Result, field string, value interface{}, ...) (err error)
- func (a *NgingDbSyncLog) UpdateFields(mw func(db.Result) db.Result, kvset map[string]interface{}, ...) (err error)
- func (a *NgingDbSyncLog) UpdateValues(mw func(db.Result) db.Result, keysValues *db.KeysValues, args ...interface{}) (err error)
- func (a *NgingDbSyncLog) Updatex(mw func(db.Result) db.Result, args ...interface{}) (affected int64, err error)
- func (a *NgingDbSyncLog) UpdatexByFields(mw func(db.Result) db.Result, fields []string, args ...interface{}) (affected int64, err error)
- func (a *NgingDbSyncLog) UpdatexField(mw func(db.Result) db.Result, field string, value interface{}, ...) (affected int64, err error)
- func (a *NgingDbSyncLog) UpdatexFields(mw func(db.Result) db.Result, kvset map[string]interface{}, ...) (affected int64, err error)
- func (a *NgingDbSyncLog) Upsert(mw func(db.Result) db.Result, args ...interface{}) (pk interface{}, err error)
- func (a *NgingDbSyncLog) Use(trans factory.Transactioner) factory.Model
- func (a *NgingDbSyncLog) Validate(field string, value interface{}) error
- func (a *NgingDbSyncLog) XObjects() Slice_NgingDbSyncLog
- type Slice_NgingDbAccount
- func (s Slice_NgingDbAccount) AsKV(keyField string, valueField string) param.Store
- func (s Slice_NgingDbAccount) FromList(data interface{}) Slice_NgingDbAccount
- func (s Slice_NgingDbAccount) GroupBy(keyField string) map[string][]*NgingDbAccount
- func (s Slice_NgingDbAccount) KeyBy(keyField string) map[string]*NgingDbAccount
- func (s Slice_NgingDbAccount) Range(fn func(m factory.Model) error) error
- func (s Slice_NgingDbAccount) RangeRaw(fn func(m *NgingDbAccount) error) error
- func (s Slice_NgingDbAccount) Transform(transfers map[string]param.Transfer) []param.Store
- type Slice_NgingDbSync
- func (s Slice_NgingDbSync) AsKV(keyField string, valueField string) param.Store
- func (s Slice_NgingDbSync) FromList(data interface{}) Slice_NgingDbSync
- func (s Slice_NgingDbSync) GroupBy(keyField string) map[string][]*NgingDbSync
- func (s Slice_NgingDbSync) KeyBy(keyField string) map[string]*NgingDbSync
- func (s Slice_NgingDbSync) Range(fn func(m factory.Model) error) error
- func (s Slice_NgingDbSync) RangeRaw(fn func(m *NgingDbSync) error) error
- func (s Slice_NgingDbSync) Transform(transfers map[string]param.Transfer) []param.Store
- type Slice_NgingDbSyncLog
- func (s Slice_NgingDbSyncLog) AsKV(keyField string, valueField string) param.Store
- func (s Slice_NgingDbSyncLog) FromList(data interface{}) Slice_NgingDbSyncLog
- func (s Slice_NgingDbSyncLog) GroupBy(keyField string) map[string][]*NgingDbSyncLog
- func (s Slice_NgingDbSyncLog) KeyBy(keyField string) map[string]*NgingDbSyncLog
- func (s Slice_NgingDbSyncLog) Range(fn func(m factory.Model) error) error
- func (s Slice_NgingDbSyncLog) RangeRaw(fn func(m *NgingDbSyncLog) error) error
- func (s Slice_NgingDbSyncLog) Transform(transfers map[string]param.Transfer) []param.Store
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) 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) FromRow ¶
func (a *NgingDbAccount) FromRow(row map[string]interface{})
func (*NgingDbAccount) GetAllFieldNames ¶ added in v1.7.0
func (a *NgingDbAccount) GetAllFieldNames() []string
func (*NgingDbAccount) GetField ¶ added in v1.7.0
func (a *NgingDbAccount) GetField(field string) interface{}
func (*NgingDbAccount) GroupBy ¶
func (a *NgingDbAccount) GroupBy(keyField string, inputRows ...[]*NgingDbAccount) map[string][]*NgingDbAccount
func (*NgingDbAccount) HasField ¶ added in v1.7.0
func (a *NgingDbAccount) HasField(field string) bool
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) ListByOffset ¶
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) ListPageByOffset ¶ added in v1.7.0
func (a *NgingDbAccount) ListPageByOffset(cond *db.Compounds, sorts ...interface{}) error
func (*NgingDbAccount) ListPageByOffsetAs ¶ added in v1.7.0
func (a *NgingDbAccount) ListPageByOffsetAs(recv interface{}, cond *db.Compounds, sorts ...interface{}) error
func (*NgingDbAccount) Name_ ¶
func (a *NgingDbAccount) Name_() 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) Reset ¶
func (a *NgingDbAccount) Reset() *NgingDbAccount
func (*NgingDbAccount) Set ¶
func (a *NgingDbAccount) Set(key interface{}, value ...interface{})
func (*NgingDbAccount) SetContext ¶
func (a *NgingDbAccount) SetContext(ctx echo.Context) 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) UpdateByFields ¶
func (*NgingDbAccount) UpdateField ¶
func (*NgingDbAccount) UpdateFields ¶
func (*NgingDbAccount) UpdateValues ¶
func (a *NgingDbAccount) UpdateValues(mw func(db.Result) db.Result, keysValues *db.KeysValues, args ...interface{}) (err error)
func (*NgingDbAccount) UpdatexByFields ¶
func (*NgingDbAccount) UpdatexField ¶ added in v1.2.0
func (*NgingDbAccount) UpdatexFields ¶ added in v1.2.0
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) 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) ConnID ¶ added in v1.1.0
func (a *NgingDbSync) ConnID() int
func (*NgingDbSync) Context ¶
func (a *NgingDbSync) Context() echo.Context
func (*NgingDbSync) FromRow ¶
func (a *NgingDbSync) FromRow(row map[string]interface{})
func (*NgingDbSync) GetAllFieldNames ¶ added in v1.7.0
func (a *NgingDbSync) GetAllFieldNames() []string
func (*NgingDbSync) GetField ¶ added in v1.7.0
func (a *NgingDbSync) GetField(field string) interface{}
func (*NgingDbSync) GroupBy ¶
func (a *NgingDbSync) GroupBy(keyField string, inputRows ...[]*NgingDbSync) map[string][]*NgingDbSync
func (*NgingDbSync) HasField ¶ added in v1.7.0
func (a *NgingDbSync) HasField(field string) bool
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) ListByOffset ¶
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) ListPageByOffset ¶ added in v1.7.0
func (a *NgingDbSync) ListPageByOffset(cond *db.Compounds, sorts ...interface{}) error
func (*NgingDbSync) ListPageByOffsetAs ¶ added in v1.7.0
func (a *NgingDbSync) ListPageByOffsetAs(recv interface{}, cond *db.Compounds, sorts ...interface{}) error
func (*NgingDbSync) Name_ ¶
func (a *NgingDbSync) Name_() string
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) Reset ¶
func (a *NgingDbSync) Reset() *NgingDbSync
func (*NgingDbSync) Set ¶
func (a *NgingDbSync) Set(key interface{}, value ...interface{})
func (*NgingDbSync) SetContext ¶
func (a *NgingDbSync) SetContext(ctx echo.Context) 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) UpdateByFields ¶
func (*NgingDbSync) UpdateField ¶
func (*NgingDbSync) UpdateFields ¶
func (*NgingDbSync) UpdateValues ¶
func (a *NgingDbSync) UpdateValues(mw func(db.Result) db.Result, keysValues *db.KeysValues, args ...interface{}) (err error)
func (*NgingDbSync) UpdatexByFields ¶
func (*NgingDbSync) UpdatexField ¶ added in v1.2.0
func (*NgingDbSync) UpdatexFields ¶ added in v1.2.0
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) 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) FromRow ¶
func (a *NgingDbSyncLog) FromRow(row map[string]interface{})
func (*NgingDbSyncLog) GetAllFieldNames ¶ added in v1.7.0
func (a *NgingDbSyncLog) GetAllFieldNames() []string
func (*NgingDbSyncLog) GetField ¶ added in v1.7.0
func (a *NgingDbSyncLog) GetField(field string) interface{}
func (*NgingDbSyncLog) GroupBy ¶
func (a *NgingDbSyncLog) GroupBy(keyField string, inputRows ...[]*NgingDbSyncLog) map[string][]*NgingDbSyncLog
func (*NgingDbSyncLog) HasField ¶ added in v1.7.0
func (a *NgingDbSyncLog) HasField(field string) bool
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) ListByOffset ¶
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) ListPageByOffset ¶ added in v1.7.0
func (a *NgingDbSyncLog) ListPageByOffset(cond *db.Compounds, sorts ...interface{}) error
func (*NgingDbSyncLog) ListPageByOffsetAs ¶ added in v1.7.0
func (a *NgingDbSyncLog) ListPageByOffsetAs(recv interface{}, cond *db.Compounds, sorts ...interface{}) error
func (*NgingDbSyncLog) Name_ ¶
func (a *NgingDbSyncLog) Name_() 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) Reset ¶
func (a *NgingDbSyncLog) Reset() *NgingDbSyncLog
func (*NgingDbSyncLog) Set ¶
func (a *NgingDbSyncLog) Set(key interface{}, value ...interface{})
func (*NgingDbSyncLog) SetContext ¶
func (a *NgingDbSyncLog) SetContext(ctx echo.Context) 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) UpdateByFields ¶
func (*NgingDbSyncLog) UpdateField ¶
func (*NgingDbSyncLog) UpdateFields ¶
func (*NgingDbSyncLog) UpdateValues ¶
func (a *NgingDbSyncLog) UpdateValues(mw func(db.Result) db.Result, keysValues *db.KeysValues, args ...interface{}) (err error)
func (*NgingDbSyncLog) UpdatexByFields ¶
func (*NgingDbSyncLog) UpdatexField ¶ added in v1.2.0
func (*NgingDbSyncLog) UpdatexFields ¶ added in v1.2.0
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
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
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
Click to show internal directories.
Click to hide internal directories.