dbconn

Documentation

Index

• Variables
• func GetContextExecutor(ctx context.Context) boil.ContextExecutor

Variables

var (
	DB *sql.DB
)

var RunTx = func(ctx context.Context, fn func(context.Context) error) (err error) {
	tx, err := DB.BeginTx(ctx, nil)
	if err != nil {
		return err
	}

	defer func() {
		if r := recover(); r != nil || err != nil {
			fmt.Println("Rollback transaction due to panic or error")
			if rbErr := tx.Rollback(); rbErr != nil {
				fmt.Printf("Rollback error: %v\n", rbErr)
			}
			if r != nil {
				err = fmt.Errorf("panic occurred: %v", r)
			}
		}
	}()

	ctx = context.WithValue(ctx, ctxTxKey, tx)

	if err = fn(ctx); err != nil {
		return err
	}

	if err = tx.Commit(); err != nil {
		return err
	}

	return nil
}

Functions

func GetContextExecutor

func GetContextExecutor(ctx context.Context) boil.ContextExecutor