From 596ea635c2c8e69b56a462349a95a0aea52705e6 Mon Sep 17 00:00:00 2001 From: Rogee Date: Tue, 23 Dec 2025 10:52:34 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E5=88=A0=E9=99=A4=E9=98=9F=E5=88=97?= =?UTF-8?q?=E8=BF=81=E7=A7=BB=E6=96=87=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../migrate/20140202000000_river_queue.go | 35 ------------------- 1 file changed, 35 deletions(-) delete mode 100644 templates/project/app/commands/migrate/20140202000000_river_queue.go diff --git a/templates/project/app/commands/migrate/20140202000000_river_queue.go b/templates/project/app/commands/migrate/20140202000000_river_queue.go deleted file mode 100644 index 40e2255..0000000 --- a/templates/project/app/commands/migrate/20140202000000_river_queue.go +++ /dev/null @@ -1,35 +0,0 @@ -package migrate - -import ( - "context" - "database/sql" - - "github.com/pkg/errors" - "github.com/pressly/goose/v3" - "github.com/riverqueue/river/riverdriver/riverdatabasesql" - "github.com/riverqueue/river/rivermigrate" -) - -func init() { - goose.AddMigrationNoTxContext(RiverQueueUp, RiverQueueDown) -} - -func RiverQueueUp(ctx context.Context, db *sql.DB) error { - migrator, err := rivermigrate.New(riverdatabasesql.New(db), nil) - if err != nil { - return errors.Wrap(err, "river migrate up failed") - } - - _, err = migrator.Migrate(ctx, rivermigrate.DirectionUp, &rivermigrate.MigrateOpts{TargetVersion: -1}) - return err -} - -func RiverQueueDown(ctx context.Context, db *sql.DB) error { - migrator, err := rivermigrate.New(riverdatabasesql.New(db), nil) - if err != nil { - return errors.Wrap(err, "river migrate down failed") - } - - _, err = migrator.Migrate(ctx, rivermigrate.DirectionDown, &rivermigrate.MigrateOpts{TargetVersion: -1}) - return err -}