continue - v4-alpha.1

.github/workflows/ci.yml

@@ -13,7 +13,7 @@ jobs:
 
     strategy:
       matrix:
-        go-version: ["1.18", "1.19", "1.20"]
+        go-version: ["1.19", "1.20"]
         os: [ubuntu-latest]
 
     runs-on: ${{ matrix.os }}

.gitignore

@@ -10,3 +10,4 @@
 # Local testing
 .envrc
 *.FAIL
+/scripts

.goreleaser.yml

@@ -48,4 +48,3 @@ changelog:
     exclude:
       - "^docs:"
       - "^test:"
-# TODO(mf): add docker support?

Makefile

@@ -10,6 +10,10 @@ dist:
 	GOOS=windows GOARCH=amd64 go build -o ./bin/goose-windows64.exe  ./cmd/goose
 	GOOS=windows GOARCH=386   go build -o ./bin/goose-windows386.exe ./cmd/goose
 
+.PHONY: build
+build:
+	go build -o $$GOBIN/goose ./cmd/goose
+
 .PHONY: clean
 clean:
 	@find . -type f -name '*.FAIL' -delete
@@ -28,25 +32,31 @@ test-packages:
 test-e2e: test-e2e-postgres test-e2e-mysql test-e2e-clickhouse test-e2e-vertica
 
 test-e2e-postgres:
-	go test $(GO_TEST_FLAGS) ./tests/e2e -dialect=postgres
+	go test $(GO_TEST_FLAGS) ./tests/e2e/postgres
 
 test-e2e-mysql:
-	go test $(GO_TEST_FLAGS) ./tests/e2e -dialect=mysql
+	go test $(GO_TEST_FLAGS) ./tests/e2e/mysql
 
 test-e2e-clickhouse:
-	go test $(GO_TEST_FLAGS) ./tests/clickhouse -test.short
+	go test $(GO_TEST_FLAGS) ./tests/e2e/clickhouse -test.short
 
 test-e2e-vertica:
-	go test $(GO_TEST_FLAGS) ./tests/vertica
+	go test $(GO_TEST_FLAGS) ./tests/e2e/vertica
 
 docker-cleanup:
 	docker stop -t=0 $$(docker ps --filter="label=goose_test" -aq)
 
 docker-start-postgres:
 	docker run --rm -d \
-		-e POSTGRES_USER=${GOOSE_POSTGRES_DB_USER} \
-		-e POSTGRES_PASSWORD=${GOOSE_POSTGRES_PASSWORD} \
-		-e POSTGRES_DB=${GOOSE_POSTGRES_DBNAME} \
-		-p ${GOOSE_POSTGRES_PORT}:5432 \
+		-e POSTGRES_USER=${POSTGRES_DB_USER} \
+		-e POSTGRES_PASSWORD=${POSTGRES_PASSWORD} \
+		-e POSTGRES_DB=${POSTGRES_DBNAME} \
+		-p ${POSTGRES_PORT}:5432 \
 		-l goose_test \
 		postgres:14-alpine -c log_statement=all
+
+todo:
+	rg --type go --ignore-case '//.*(todo|feat)\('
+
+gh-links:
+	rg --type go --ignore-case '//.*github.com/.*/(issues|pull)/[0-9]+'

apply_version.go

@@ -0,0 +1,61 @@
+package goose
+
+import (
+	"context"
+	"database/sql"
+	"errors"
+	"fmt"
+
+	"github.com/pressly/goose/v4/internal/sqlparser"
+	"go.uber.org/multierr"
+)
+
+// ApplyVersion applies exactly one migration at the specified version. If a migration cannot be
+// found for the specified version, this method returns ErrNoCurrentVersion. If the migration has
+// been applied already, this method returns ErrAlreadyApplied.
+//
+// If the direction is true, the migration will be applied. If the direction is false, the migration
+// will be rolled back.
+func (p *Provider) ApplyVersion(ctx context.Context, version int64, direction bool) (_ *MigrationResult, retErr error) {
+	if version < 1 {
+		return nil, fmt.Errorf("invalid version: %d", version)
+	}
+
+	m, err := p.getMigration(version)
+	if err != nil {
+		return nil, err
+	}
+
+	conn, cleanup, err := p.initialize(ctx)
+	if err != nil {
+		return nil, err
+	}
+	defer func() {
+		retErr = multierr.Append(retErr, cleanup())
+	}()
+	// Ensure version table exists.
+	if err := p.ensureVersionTable(ctx, conn); err != nil {
+		return nil, err
+	}
+
+	result, err := p.store.GetMigration(ctx, conn, version)
+	if err != nil && !errors.Is(err, sql.ErrNoRows) {
+		return nil, err
+	}
+	if result != nil {
+		return nil, ErrAlreadyApplied
+	}
+
+	d := sqlparser.DirectionDown
+	if direction {
+		d = sqlparser.DirectionUp
+	}
+	results, err := p.runMigrations(ctx, conn, []*migration{m}, d, true)
+	if err != nil {
+		return nil, err
+	}
+	if len(results) == 0 {
+		return nil, ErrAlreadyApplied
+	}
+	return results[0], nil
+}