sqlx_locks

package module
v0.0.0-...-2b11dad Latest Latest
Warning

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

Go to latest
Published: Aug 6, 2023 License: MIT Imports: 6 Imported by: 0

README

SqlX Locks

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

Documentation

Index

Constants

View Source
const SqlxConnectionManagerName = "sqlx-connection-manager"

Variables

This section is empty.

Functions

func CreateStorageForSqlxDb

func CreateStorageForSqlxDb(db *sqlx.DB, connectionManager storage.ConnectionManager[*sql.DB]) (storage.Storage, error)

CreateStorageForSqlxDb 尝试从sqlx创建Storage

func InitGlobalSqlxLockFactory

func InitGlobalSqlxLockFactory(db *sqlx.DB) error

InitGlobalSqlxLockFactory 初始化全局的SqlxLockFactory

Types

type SqlxConnectionManager

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

SqlxConnectionManager 从sqlx(https://github.com/jmoiron/sqlx)中复用数据库连接,如果当前项目是引入的sqlx的话则可以与其复用数据库连接资源 TODO 2023-8-4 01:32:17 单元测试

func NewSqlxConnectionManager

func NewSqlxConnectionManager(db *sqlx.DB) *SqlxConnectionManager

func (*SqlxConnectionManager) Name

func (x *SqlxConnectionManager) Name() string

func (*SqlxConnectionManager) Return

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

func (*SqlxConnectionManager) Shutdown

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

func (*SqlxConnectionManager) Take

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

type SqlxLockFactory

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

func NewSqlxLockFactory

func NewSqlxLockFactory(db *sqlx.DB) (*SqlxLockFactory, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL