aboutsummaryrefslogtreecommitdiff
path: root/cmd/app/migrator/migrator.go
diff options
context:
space:
mode:
authorAlexander Neonxp Kiryukhin <i@neonxp.ru>2024-10-12 02:52:22 +0300
committerAlexander Neonxp Kiryukhin <i@neonxp.ru>2024-10-12 02:53:52 +0300
commitd05ea66f4bbcf0cc5c8908f3435c68de1b070fa1 (patch)
tree7c7a769206646f2b81a0eda0680f0be5033a4197 /cmd/app/migrator/migrator.go
Начальная версияv0.0.1
Diffstat (limited to 'cmd/app/migrator/migrator.go')
-rw-r--r--cmd/app/migrator/migrator.go83
1 files changed, 83 insertions, 0 deletions
diff --git a/cmd/app/migrator/migrator.go b/cmd/app/migrator/migrator.go
new file mode 100644
index 0000000..fa5b03b
--- /dev/null
+++ b/cmd/app/migrator/migrator.go
@@ -0,0 +1,83 @@
+package migrator
+
+import (
+ "fmt"
+ "strings"
+
+ "github.com/urfave/cli/v2"
+ "go.neonxp.ru/framework/cmd/app/migrator/migrate"
+ "go.neonxp.ru/framework/cmd/app/migrator/migrator"
+ "go.neonxp.ru/framework/migrations"
+)
+
+func Migrator() *cli.Command {
+ return &cli.Command{
+ Name: "db",
+ Usage: "manage database migrations",
+ Subcommands: []*cli.Command{
+ {
+ Name: "init",
+ Usage: "create migration tables",
+ Flags: []cli.Flag{
+ &cli.StringFlag{
+ Name: "config",
+ Value: "./config/config.yaml",
+ Usage: "config",
+ },
+ },
+ Action: migrate.Init,
+ },
+ {
+ Name: "migrate",
+ Usage: "migrate database",
+ Flags: []cli.Flag{
+ &cli.StringFlag{
+ Name: "config",
+ Value: "./config/config.yaml",
+ Usage: "config",
+ },
+ },
+ Action: migrate.Migrate,
+ },
+ {
+ Name: "rollback",
+ Usage: "rollback the last migration group",
+ Flags: []cli.Flag{
+ &cli.StringFlag{
+ Name: "config",
+ Value: "./config/config.yaml",
+ Usage: "config",
+ },
+ },
+ Action: migrate.Rollback,
+ },
+
+ {
+ Name: "create",
+ Usage: "create migration",
+ Flags: []cli.Flag{
+ &cli.StringFlag{
+ Name: "config",
+ Value: "./config/config.yaml",
+ Usage: "config",
+ },
+ },
+ Action: func(c *cli.Context) error {
+ migrator, err := migrator.New(c, migrations.Migrations)
+ if err != nil {
+ return err
+ }
+
+ name := strings.Join(c.Args().Slice(), "_")
+ mf, err := migrator.CreateGoMigration(c.Context, name)
+ if err != nil {
+ return err
+ }
+ fmt.Printf("created migration %s (%s)\n", mf.Name, mf.Path)
+
+ return nil
+ },
+ },
+ },
+ }
+}