Method Lock

postgres.go:22–27

Lock implements the Locker interface to obtain a global lock before the migrations are run.

(ctx context.Context, tx Queryer, tableName string)

// Lock implements the Locker interface to obtain a global lock before the
// migrations are run.
func (p postgresDialect) Lock(ctx context.Context, tx Queryer, tableName string) error {
	lockID := p.advisoryLockID(tableName)
	query := fmt.Sprintf("SELECT pg_advisory_lock(%s)", lockID)
	_, err := tx.ExecContext(ctx, query)
	return err
}

// Unlock implements the Locker interface to release the global lock after the
// migrations are run.