ipcdb

func (Channel) BatchEdit ¶

func (d Channel) BatchEdit(ctx context.Context, column string, value any, args ...orm.QueryOption) error

BatchEdit implements ipc.ChannelStorer.

func (Channel) Create ¶ added in v1.4.21

func (d Channel) Create(ctx context.Context, model *ipc.Channel) error

Create implements ipc.ChannelStorer.

func (Channel) Delete ¶ added in v1.4.21

func (d Channel) Delete(ctx context.Context, model *ipc.Channel, opts ...orm.QueryOption) error

Delete implements ipc.ChannelStorer.

func (Channel) EditGB28181Config ¶ added in v1.4.0

func (d Channel) EditGB28181Config(ctx context.Context, model *ipc.Channel) error

EditGB28181Config 直接更新 GB28181 上报的字段（name/is_online/ptztype/ext），跳过 SELECT FOR UPDATE，因为调用方已持有 existing 对象。

func (Channel) Get ¶

func (d Channel) Get(ctx context.Context, model *ipc.Channel, opts ...orm.QueryOption) error

Get implements ipc.ChannelStorer.

func (Channel) List ¶ added in v1.4.21

func (d Channel) List(ctx context.Context, bs *[]*ipc.Channel, page orm.Pager, opts ...orm.QueryOption) (int64, error)

List implements ipc.ChannelStorer.

func (Channel) Session ¶

func (d Channel) Session(ctx context.Context, changeFns ...func(*gorm.DB) error) error

func (Channel) Update ¶ added in v1.4.21

func (d Channel) Update(ctx context.Context, model *ipc.Channel, changeFn func(*ipc.Channel) error, opts ...orm.QueryOption) error

Update implements ipc.ChannelStorer.

func (Channel) UpdateWithSession ¶ added in v1.4.21

func (d Channel) UpdateWithSession(tx *gorm.DB, model *ipc.Channel, changeFn func(b *ipc.Channel) error, opts ...orm.QueryOption) error

func (DB) AutoMigrate ¶

func (d DB) AutoMigrate(ok bool) DB

AutoMigrate sync database

func (DB) Channel ¶

func (d DB) Channel() ipc.ChannelStorer

Channel Get business instance

func (DB) Device ¶

func (d DB) Device() ipc.DeviceStorer

Device Get business instance

func (Device) Create ¶ added in v1.4.21

func (d Device) Create(ctx context.Context, model *ipc.Device) error

Create implements ipc.DeviceStorer.

func (Device) Delete ¶ added in v1.4.21

func (d Device) Delete(ctx context.Context, model *ipc.Device, opts ...orm.QueryOption) error

Delete implements ipc.DeviceStorer.

func (Device) Get ¶

func (d Device) Get(ctx context.Context, model *ipc.Device, opts ...orm.QueryOption) error

Get implements ipc.DeviceStorer.

func (Device) List ¶ added in v1.4.21

func (d Device) List(ctx context.Context, bs *[]*ipc.Device, page orm.Pager, opts ...orm.QueryOption) (int64, error)

List implements ipc.DeviceStorer.

func (Device) Session ¶

func (d Device) Session(ctx context.Context, changeFns ...func(*gorm.DB) error) error

func (Device) Update ¶ added in v1.4.21

func (d Device) Update(ctx context.Context, model *ipc.Device, changeFn func(*ipc.Device) error, opts ...orm.QueryOption) error

Update implements ipc.DeviceStorer.

func (Device) UpdateWithSession ¶ added in v1.4.21

func (d Device) UpdateWithSession(tx *gorm.DB, model *ipc.Device, changeFn func(b *ipc.Device) error, opts ...orm.QueryOption) error