xorm_locks

package module

v0.0.0-...-c14dae7 Latest Latest Go to latest Published: Aug 6, 2023 License: MIT Imports: 6 Imported by: 0

Details

go get -u github.com/storage-lock/go-xorm-locks

This section is empty.

This section is empty.

func CreateStorageForXorm(engine *xorm.Engine, connectionManager storage.ConnectionManager[*sql.DB]) (storage.Storage, error)

CreateStorageForXorm 尝试从xorm创建Storage

func InitGlobalXormLockFactory(engine *xorm.Engine) error

type XormConnectionManager struct {
	// contains filtered or unexported fields
}

XormConnectionManager 用来复用xorm（https://github.com/go-xorm/xorm）的数据库连接 TODO 2023-8-4 01:28:15 单元测试

func NewXormConnectionManager(engine *xorm.Engine) *XormConnectionManager

func (x *XormConnectionManager) Name() string

func (x *XormConnectionManager) Return(ctx context.Context, db *sql.DB) error

func (x *XormConnectionManager) Shutdown(ctx context.Context) error

func (x *XormConnectionManager) Take(ctx context.Context) (*sql.DB, error)

type XormLockFactory struct {
	*storage_lock_factory.StorageLockFactory[*sql.DB]
	// contains filtered or unexported fields
}

var GlobalXormLockFactory *XormLockFactory

func NewXormLockFactory(engine *xorm.Engine) (*XormLockFactory, error)