golang 版本的migrate数据迁移工具

github地址:https://github.com/golang-migrate/migrate

一、CLI方式使用

需要下载工具:go install -tags ‘mysql‘ github.com/golang-migrate/migrate/v4/cmd/migrate@latest
之后在GOPATH目录下会多一个migrate.exe程序

golang 版本的migrate数据迁移工具

 

 

创建migrate项目,创建migration文件夹(用于存放迁移文件)

golang 版本的migrate数据迁移工具

 

 

在migrate目录下用命令生成要迁移的up和down文件文件

migrate create -ext sql -dir migration create_test_table

golang 版本的migrate数据迁移工具

 

 golang 版本的migrate数据迁移工具

 

 文件为空,需要自行补充sql命令

编辑up文件

例如:

CREATE TABLE IF NOT EXISTS test(
    id int(10) unsigned NOT NULL AUTO_INCREMENT,
   name VARCHAR(100) NOT NULL,
   password VARCHAR(40) NOT NULL,
   PRIMARY KEY ( id )
);

编辑down文件

例如:

DROP table IF EXISTS test;

  

运行1个迁移文件:migrate -verbose -source file://migration -database mysql://user:password@tcp(ip:port)/database_name up 1

可以看到:

golang 版本的migrate数据迁移工具

 

 

 golang 版本的migrate数据迁移工具

 

 

 

version 如果-1表示版本脏了,需要加上force 20*****(生成的表前缀) 来强制版本索引,例如:migrate -verbose -source file://migration -database mysql://user:password@tcp(ip:port)/database_name force 20210730160233

 

 

二、在项目中使用

go get -u github.com/golang-migrate/migrate

func main() {
   db, err := sql.Open("mysql", "user:password@tcp(ip:port)/migrate?multiStatements=true")

   if err != nil {
      log.Fatal(err)
   }

   defer db.Close()

   driver, err := mysql.WithInstance(db, &mysql.Config{})

   if err != nil {
      log.Fatal(err)
   }

   m, err := migrate.NewWithDatabaseInstance(
      "file://migration",
"migrate",
driver,
)
   if err != nil {
      log.Fatal(err)
   }
   err = m.Up()  //or m.Down()
   if err != nil {
      log.Fatal(err)
   }
   _ = m.Steps(1)  //执行的文件数
}

  

golang 版本的migrate数据迁移工具

上一篇:Increasing Subsequence


下一篇:05 docker-compose