sql

package

v1.0.2 Latest Latest Go to latest Published: Jul 9, 2025 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

func ConnectDB(cfg *config.Env, log *log.Logger) (*gorm.DB, error)

func ConnectMysql(cfg *config.Env, log *log.Logger) (*gorm.DB, error)

ConnectMysql establishes a MySQL database connection

func ConnectPostgresql(cfg *config.Env, log *log.Logger) (*gorm.DB, error)

ConnectPostgresql establishes a PostgreSQL database connection

type Sql struct {
	GormDb *gorm.DB
	// contains filtered or unexported fields
}

func NewSql(cfg *config.Env, log *log.Logger, gormDB *gorm.DB) *Sql

func (pkg *Sql) Begin() (*gorm.DB, error)

Begin starts a new transaction

func (pkg *Sql) Close() error

Close closes the database connection

func (pkg *Sql) Commit(tx *gorm.DB) error

Commit commits a transaction

func (pkg *Sql) HealthCheck() error

HealthCheck verifies the database connection

func (pkg *Sql) Migrate(models ...interface{}) error

Migrate performs database migrations

func (pkg *Sql) Rollback(tx *gorm.DB)

Rollback rolls back a transaction

func (pkg *Sql) Transaction(fn func(tx *gorm.DB) error) error

Transaction executes a function within a transaction

func (pkg *Sql) WithContext(ctx context.Context) *gorm.DB

WithContext returns a database instance with context