Go数据库迁移的实现步骤浅谈

分手后的思念是犯贱 2024-03-24 18:31 51阅读 0赞

![127f9d79a62a677b14f5ed7cf95b1b95.jpeg][]

![159.jpg][]

本文将介绍两个`Go`生态中常见的数据库迁移工具——`golang-migrate`和`gormigrate`。

### 1. golang-migrate ###

`golang-migrate`的官方`Github`是链接。它提供了客户端的方式使用，也可以使用`Go SDK`调用的方式使用。其各种安装方式详见链接。

对于每次迁移而言，都需要有一个迁移文件，迁移文件需要命名为`{number}_xxx.up.sql`以及`{number}_xxx.down.sql`，其中`{number}`是数字，可以使用`migrate create`命令产生，如下，`-seq`表示按顺序产生文件：

<table> 
 <tbody> 
 <tr> 
 <td> 1 </td> 
 <td> <code>migrate create -ext sql -dir ./migration_files -seq init_schema</code> </td> 
 </tr> 
 </tbody> 
</table>

`{number}`将会是从1开始的递增的数字。如下，默认按照时间格式产生，`-tz`可以设置时区：

<table> 
 <tbody> 
 <tr> 
 <td> 1 </td> 
 <td> <code>migrate create -ext sql -dir ./migration_files -tz Asia/Shanghai init_schema</code> </td> 
 </tr> 
 </tbody> 
</table>

`{number}`将会是上海时区的时间格式。反正不管是什么格式，`golang-migration`按照从小到大的顺序依次执行。

在实际运行时，迁移时顺序运行`{number}_xxx.up.sql`文件，回滚时倒序运行`{number}_xxx.down.sql`。

#### 1.1 通过migrate命令操作 ####

##### 1.1.1 创建sql文件 #####

初始化数据库

我们可以通过安装`migrate`工具，然后通过指令进行操作如下，生成`20230616164949_init.up.sql`和`20230616164949_init.down.sql`文件：

在`20230616164949_init.up.sql`中填写：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 </td> 
 <td> <code>-- ----------------------------</code> <code>-- Table structure for person</code> <code>-- ----------------------------</code> <code>DROP</code> <code>TABLE</code> <code>IF EXISTS `person`;</code> <code>CREATE</code> <code>TABLE</code> <code>`person` (</code> <code>&nbsp;&nbsp;</code><code>`id` </code><code>bigint</code><code>(20) unsigned </code><code>NOT</code> <code>NULL</code> <code>AUTO_INCREMENT,</code> <code>&nbsp;&nbsp;</code><code>`</code><code>name</code><code>` </code><code>varchar</code><code>(256) </code><code>COLLATE</code> <code>utf8mb4_unicode_ci </code><code>DEFAULT</code> <code>NULL</code><code>,</code> <code>&nbsp;&nbsp;</code><code>`age` </code><code>bigint</code><code>(20) </code><code>DEFAULT</code> <code>NULL</code><code>,</code> <code>&nbsp;&nbsp;</code><code>PRIMARY</code> <code>KEY</code> <code>(`id`)</code> <code>) ENGINE=InnoDB </code><code>DEFAULT</code> <code>CHARSET=utf8mb4 </code><code>COLLATE</code><code>=utf8mb4_unicode_ci;</code> </td> 
 </tr> 
 </tbody> 
</table>

在`20230616164949_init.down.sql`中填写：

<table> 
 <tbody> 
 <tr> 
 <td> 1 </td> 
 <td> <code>DROP</code> <code>TABLE</code> <code>IF EXISTS `person`;</code> </td> 
 </tr> 
 </tbody> 
</table>

**新增一列**

然后我们给`person`表新增一个性别`gender`列，先使用命令创建`sql`文件：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 </td> 
 <td> <code>$ migrate create -ext sql -</code><code>dir</code> <code>.</code><code>/migration_files</code> <code>-tz Asia</code><code>/Shanghai</code> <code>add_gender</code> <code>xxx</code><code>/migration_files/20230616165624_add_gender</code><code>.up.sql</code> <code>xxx</code><code>/migration_files/20230616165624_add_gender</code><code>.down.sql</code> </td> 
 </tr> 
 </tbody> 
</table>

`20230616165624_add_gender.up.sql`：

<table> 
 <tbody> 
 <tr> 
 <td> 1 </td> 
 <td> <code>ALTER</code> <code>TABLE</code> <code>`person` </code><code>ADD</code> <code>COLUMN</code> <code>`gender` </code><code>BIGINT</code><code>(20) </code><code>DEFAULT</code> <code>NULL</code> <code>AFTER</code> <code>`age`;</code> </td> 
 </tr> 
 </tbody> 
</table>

`20230616165624_add_gender.down.sql`：

<table> 
 <tbody> 
 <tr> 
 <td> 1 </td> 
 <td> <code>ALTER</code> <code>TABLE</code> <code>`person` </code><code>DROP</code> <code>COLUMN</code> <code>`gender`;</code> </td> 
 </tr> 
 </tbody> 
</table>

**新增name为index**

接下来，我们为`name`列创建一个索引，同样需要用命令创建`sql`文件：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 </td> 
 <td> <code>$ migrate create -ext sql -</code><code>dir</code> <code>.</code><code>/migration_files</code> <code>-tz Asia</code><code>/Shanghai</code> <code>add_index_name&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code> <code>xxx</code><code>/migration_files/20230619104829_add_index_name</code><code>.up.sql</code> <code>xxx</code><code>/migration_files/20230619104829_add_index_name</code><code>.down.sql</code> </td> 
 </tr> 
 </tbody> 
</table>

`20230619104829_add_index_name.up.sql`：

<table> 
 <tbody> 
 <tr> 
 <td> 1 </td> 
 <td> <code>ALTER</code> <code>TABLE</code> <code>`person` </code><code>ADD</code> <code>INDEX</code> <code>`idx_name`(`</code><code>name</code><code>`);</code> </td> 
 </tr> 
 </tbody> 
</table>

`20230619104829_add_index_name.down.sql`：

<table> 
 <tbody> 
 <tr> 
 <td> 1 </td> 
 <td> <code>ALTER</code> <code>TABLE</code> <code>`person` </code><code>DROP</code> <code>INDEX</code> <code>`idx_name`;</code> </td> 
 </tr> 
 </tbody> 
</table>

此时在迁移文件中有以下文件：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 </td> 
 <td> <code>$ ll migration_files</code> <code>total 48</code> <code>-rw-r--r--&nbsp; 1 chenyiguo&nbsp; staff&nbsp;&nbsp;&nbsp; 30B Jun 16 16:55 20230616164949_init.down.sql</code> <code>-rw-r--r--&nbsp; 1 chenyiguo&nbsp; staff&nbsp;&nbsp; 396B Jun 16 16:55 20230616164949_init.up.sql</code> <code>-rw-r--r--&nbsp; 1 chenyiguo&nbsp; staff&nbsp;&nbsp;&nbsp; 42B Jun 16 17:02 20230616165624_add_gender.down.sql</code> <code>-rw-r--r--&nbsp; 1 chenyiguo&nbsp; staff&nbsp;&nbsp;&nbsp; 77B Jun 16 17:01 20230616165624_add_gender.up.sql</code> <code>-rw-r--r--&nbsp; 1 chenyiguo&nbsp; staff&nbsp;&nbsp;&nbsp; 43B Jun 19 10:57 20230619104829_add_index_name.down.sql</code> <code>-rw-r--r--&nbsp; 1 chenyiguo&nbsp; staff&nbsp;&nbsp;&nbsp; 50B Jun 19 10:57 20230619104829_add_index_name.up.sql</code> </td> 
 </tr> 
 </tbody> 
</table>

##### 1.1.2 进行迁移 #####

**一步迁移**

我们可以使用如下指令每次执行一步迁移：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 </td> 
 <td> <code>$ migrate --path .</code><code>/migration_files</code> <code>--database=</code><code>"mysql://root:IBHojwND.yo@tcp(10.117.49.6:13306)/migration_test?charset=utf8mb4&amp;parseTime=true"</code> <code>-verbose up 1</code> <code>2023</code><code>/06/19</code> <code>11:01:28 Start buffering 20230616164949</code><code>/u</code> <code>init</code> <code>2023</code><code>/06/19</code> <code>11:01:28 Read and execute 20230616164949</code><code>/u</code> <code>init</code> <code>2023</code><code>/06/19</code> <code>11:01:28 Finished 20230616164949</code><code>/u</code> <code>init (</code><code>read</code> <code>133.166833ms, ran 286.737042ms)</code> <code>2023</code><code>/06/19</code> <code>11:01:28 Finished after 566.083083ms</code> <code>2023</code><code>/06/19</code> <code>11:01:28 Closing </code><code>source</code> <code>and database</code> </td> 
 </tr> 
 </tbody> 
</table>

然后查看表`person`:

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 </td> 
 <td> <code>MariaDB [migration_test]&gt; </code><code>DESC</code> <code>`person`;</code> <code>+</code><code>-------+---------------------+------+-----+---------+----------------+</code> <code>| Field | Type&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; | </code><code>Null</code> <code>| </code><code>Key</code> <code>| </code><code>Default</code> <code>| Extra&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>+</code><code>-------+---------------------+------+-----+---------+----------------+</code> <code>| id&nbsp;&nbsp;&nbsp; | </code><code>bigint</code><code>(20) unsigned | </code><code>NO</code>&nbsp;&nbsp; <code>| PRI | </code><code>NULL</code>&nbsp;&nbsp;&nbsp; <code>| auto_increment |</code> <code>| </code><code>name</code>&nbsp; <code>| </code><code>varchar</code><code>(256)&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; | YES&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp; | </code><code>NULL</code>&nbsp;&nbsp;&nbsp; <code>|&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>| age&nbsp;&nbsp; | </code><code>bigint</code><code>(20)&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; | YES&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp; | </code><code>NULL</code>&nbsp;&nbsp;&nbsp; <code>|&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>+</code><code>-------+---------------------+------+-----+---------+----------------+</code> <code>3 </code><code>rows</code> <code>in</code> <code>set</code> <code>(0.001 sec)</code> </td> 
 </tr> 
 </tbody> 
</table>

这时候，会发现数据库会生成一个名为`schema_migrations`的表，可以看到其只有两列，其中第一列`version`表示现阶段的版本，比如以上我们只是执行了迁移的第一步，所以版本是`20230616164949`；第二列是`dirty`，0表示正常，1表示被出错了，一般而言需要手动处理。

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 </td> 
 <td> <code>MariaDB [migration_test]&gt; </code><code>SELECT</code> <code>* </code><code>FROM</code> <code>`schema_migrations`;</code> <code>+</code><code>----------------+-------+</code> <code>| version&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; | dirty |</code> <code>+</code><code>----------------+-------+</code> <code>| 20230616164949 |&nbsp;&nbsp;&nbsp;&nbsp; 0 |</code> <code>+</code><code>----------------+-------+</code> <code>1 row </code><code>in</code> <code>set</code> <code>(0.001 sec)</code> </td> 
 </tr> 
 </tbody> 
</table>

同样的，我们可以使用以下指令回滚这一次操作：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 </td> 
 <td> <code>$ migrate </code><code>--path ./migration_files --database="mysql://root:IBHojwND.yo@tcp(10.117.49.6:13306)/migration_test?charset=utf8mb4&amp;parseTime=true" -verbose down 1</code> <code>2023/06/19 11:12:57 Start buffering 20230616164949/d init</code> <code>2023/06/19 11:12:57 </code><code>Read</code> <code>and</code> <code>execute</code> <code>20230616164949/d init</code> <code>2023/06/19 11:12:58 Finished 20230616164949/d init (</code><code>read</code> <code>238.931375ms, ran 167.683125ms)</code> <code>2023/06/19 11:12:58 Finished </code><code>after</code> <code>552.185792ms</code> <code>2023/06/19 11:12:58 Closing source </code><code>and</code> <code>database</code> </td> 
 </tr> 
 </tbody> 
</table>

可以发现操作被回滚，整个数据库只保留了`schema_migrations`表，执行了`20230616164949_init.down.sql`中的指令，`person`表被删除了。

**整体升级**

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 </td> 
 <td> <code>$ migrate --path .</code><code>/migration_files</code> <code>--database=</code><code>"mysql://root:IBHojwND.yo@tcp(10.117.49.6:13306)/migration_test?charset=utf8mb4&amp;parseTime=true"</code> <code>-verbose up&nbsp;&nbsp;&nbsp; </code> <code>2023</code><code>/06/19</code> <code>11:14:52 Start buffering 20230616164949</code><code>/u</code> <code>init</code> <code>2023</code><code>/06/19</code> <code>11:14:52 Start buffering 20230616165624</code><code>/u</code> <code>add_gender</code> <code>2023</code><code>/06/19</code> <code>11:14:52 Start buffering 20230619104829</code><code>/u</code> <code>add_index_name</code> <code>2023</code><code>/06/19</code> <code>11:14:53 Read and execute 20230616164949</code><code>/u</code> <code>init</code> <code>2023</code><code>/06/19</code> <code>11:14:53 Finished 20230616164949</code><code>/u</code> <code>init (</code><code>read</code> <code>143.943417ms, ran 167.257042ms)</code> <code>2023</code><code>/06/19</code> <code>11:14:53 Read and execute 20230616165624</code><code>/u</code> <code>add_gender</code> <code>2023</code><code>/06/19</code> <code>11:14:53 Finished 20230616165624</code><code>/u</code> <code>add_gender (</code><code>read</code> <code>463.350333ms, ran 304.728208ms)</code> <code>2023</code><code>/06/19</code> <code>11:14:53 Read and execute 20230619104829</code><code>/u</code> <code>add_index_name</code> <code>2023</code><code>/06/19</code> <code>11:14:54 Finished 20230619104829</code><code>/u</code> <code>add_index_name (</code><code>read</code> <code>987.893333ms, ran 227.057417ms)</code> <code>2023</code><code>/06/19</code> <code>11:14:54 Finished after 1.391094s</code> <code>2023</code><code>/06/19</code> <code>11:14:54 Closing </code><code>source</code> <code>and database</code> </td> 
 </tr> 
 </tbody> 
</table>

这时候可以发现，`person`表的所有改动都被付诸实现：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 </td> 
 <td> <code>MariaDB [migration_test]&gt; </code><code>DESC</code> <code>`person`;</code> <code>+</code><code>--------+---------------------+------+-----+---------+----------------+</code> <code>| Field&nbsp; | Type&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; | </code><code>Null</code> <code>| </code><code>Key</code> <code>| </code><code>Default</code> <code>| Extra&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>+</code><code>--------+---------------------+------+-----+---------+----------------+</code> <code>| id&nbsp;&nbsp;&nbsp;&nbsp; | </code><code>bigint</code><code>(20) unsigned | </code><code>NO</code>&nbsp;&nbsp; <code>| PRI | </code><code>NULL</code>&nbsp;&nbsp;&nbsp; <code>| auto_increment |</code> <code>| </code><code>name</code>&nbsp;&nbsp; <code>| </code><code>varchar</code><code>(256)&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; | YES&nbsp; | MUL | </code><code>NULL</code>&nbsp;&nbsp;&nbsp; <code>|&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>| age&nbsp;&nbsp;&nbsp; | </code><code>bigint</code><code>(20)&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; | YES&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp; | </code><code>NULL</code>&nbsp;&nbsp;&nbsp; <code>|&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>| gender | </code><code>bigint</code><code>(20)&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; | YES&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp; | </code><code>NULL</code>&nbsp;&nbsp;&nbsp; <code>|&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>+</code><code>--------+---------------------+------+-----+---------+----------------+</code> <code>4 </code><code>rows</code> <code>in</code> <code>set</code> <code>(0.001 sec)</code> </td> 
 </tr> 
 </tbody> 
</table>

而`schema_migrations`表里的数据版本变成了最新的`20230619104829`，可以发现，此表中并没有存储历史版本。

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 </td> 
 <td> <code>MariaDB [migration_test]&gt; </code><code>SELECT</code> <code>* </code><code>FROM</code> <code>`schema_migrations`;</code> <code>+</code><code>----------------+-------+</code> <code>| version&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; | dirty |</code> <code>+</code><code>----------------+-------+</code> <code>| 20230619104829 |&nbsp;&nbsp;&nbsp;&nbsp; 0 |</code> <code>+</code><code>----------------+-------+</code> <code>1 row </code><code>in</code> <code>set</code> <code>(0.000 sec)</code> </td> 
 </tr> 
 </tbody> 
</table>

同样，也可以使用`down`来回滚整个表。

当然，`golang-migrate`还有一些其他的操作，大家可以使用`migrate -help`命令学习。

#### 1.2 通过Go SDK实现 ####

除了以上通过命令的方式使用`golang-migrate`，也可以使用其`Go SDK`的方式运用于`Go project`中。

`sql`文件的创建这里就不赘述了，当然可以为了方便，使用以下的`shell`文件简化创建`sql`的流程：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 </td> 
 <td> <code>#!/bin/bash</code> <code>read</code> <code>-p </code><code>"Please input sql change tag: "</code> <code>tag</code> <code>if</code> <code>[ x</code><code>"${tag}"</code> <code>= x ]; </code><code>then</code> <code>&nbsp;&nbsp;</code><code>echo</code> <code>"Please input sql change tag!!!"</code> <code>&nbsp;&nbsp;</code><code>exit</code> <code>1</code> <code>fi</code> <code># TIMEZONE是时区的环境变量，默认 Asia/Shanghai</code> <code>if</code> <code>[ x</code><code>"${TIMEZONE}"</code> <code>= x ]; </code><code>then</code> <code>&nbsp;&nbsp;</code><code>echo</code> <code>"Not set TIMEZONE, set default Asia/Shanghai"</code> <code>&nbsp;&nbsp;</code><code>TIMEZONE=</code><code>"Asia/Shanghai"</code> <code>fi</code> <code>migrate create -ext sql -</code><code>dir</code> <code>.</code><code>/migration_files</code> <code>-tz </code><code>"${TIMEZONE}"</code> <code>${tag}</code> </td> 
 </tr> 
 </tbody> 
</table>

##### 1.2.1 代码实现 #####

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 </td> 
 <td> <code>package</code> <code>main</code> <code>import</code> <code>(</code> <code>&nbsp;&nbsp;&nbsp;</code><code>"context"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>"database/sql"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>"errors"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>"fmt"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>"github.com/golang-migrate/migrate/v4"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>"github.com/sirupsen/logrus"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>"os"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>"time"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>_ </code><code>"github.com/go-sql-driver/mysql"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>_ </code><code>"github.com/golang-migrate/migrate/v4/database/mysql"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>_ </code><code>"github.com/golang-migrate/migrate/v4/source/file"</code> <code>)</code> <code>const</code> <code>(</code> <code>&nbsp;&nbsp;&nbsp;</code><code>dbUser&nbsp;&nbsp;&nbsp;&nbsp; = </code><code>"DB_USER"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>dbPassWord = </code><code>"DEVOPS_INFRA_PASSWORD"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>dbUrl&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; = </code><code>"DB_URL"</code> <code>)</code> <code>var</code> <code>(</code> <code>&nbsp;&nbsp;&nbsp;</code><code>username = </code><code>"root"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>password = </code><code>"IBHojwND.yo"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>hostname = </code><code>"10.117.49.6:13306"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>dbname&nbsp;&nbsp; = </code><code>"migration_test"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>errUpFailed = errors.</code><code>New</code><code>(</code><code>"migration up failed"</code><code>)</code> <code>)</code> <code>func</code> <code>dsn(dbName </code><code>string</code><code>) </code><code>string</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>fmt.Sprintf(</code><code>"%s:%s@tcp(%s)/%s?charset=utf8mb4&amp;parseTime=true"</code><code>, username, password, hostname, dbName)</code> <code>}</code> <code>func</code> <code>createDBIfNotExist() </code><code>error</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;</code><code>db, err := sql.Open(</code><code>"mysql"</code><code>, dsn(</code><code>""</code><code>))</code> <code>&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>err != </code><code>nil</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>logrus.Errorf(</code><code>"opening DB err : %+v\n"</code><code>, err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>err</code> <code>&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;</code><code>defer</code> <code>db.</code><code>Close</code><code>()</code> <code>&nbsp;&nbsp;&nbsp;</code><code>ctx, cancel := context.WithTimeout(context.Background(), </code><code>5</code><code>*time.Second)</code> <code>&nbsp;&nbsp;&nbsp;</code><code>defer</code> <code>cancel()</code> <code>&nbsp;&nbsp;&nbsp;</code><code>res, err := db.ExecContext(ctx, </code><code>"CREATE DATABASE IF NOT EXISTS "</code><code>+dbname)</code> <code>&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>err != </code><code>nil</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>logrus.Errorf(</code><code>"creating DB err: %+v\n"</code><code>, err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>err</code> <code>&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;</code><code>no, err := res.RowsAffected()</code> <code>&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>err != </code><code>nil</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>logrus.Errorf(</code><code>"affected rows err: %+v"</code><code>, err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>err</code> <code>&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;</code><code>logrus.Infof(</code><code>"rows affected %d\n"</code><code>, no)</code> <code>&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>nil</code> <code>}</code> <code>func</code> <code>migration() (e </code><code>error</code><code>) { </code> <code>&nbsp;&nbsp;&nbsp;</code><code>// 新建migrate对象</code> <code>&nbsp;&nbsp;&nbsp;</code><code>m, err := migrate.</code><code>New</code><code>(</code><code>"file://migration_files"</code><code>, </code><code>"mysql://"</code><code>+dsn(dbname))</code> <code>&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>err != </code><code>nil</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>logrus.Errorf(</code><code>"new migrate err: %+v"</code><code>, err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>err</code> <code>&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;</code><code>// 进行up操作</code> <code>&nbsp;&nbsp;&nbsp;</code><code>err = m.Up()</code> <code>&nbsp;&nbsp;&nbsp;</code><code>version, dirty, _ := m.Version()</code> <code>&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>err == </code><code>nil</code> <code>|| err == migrate.ErrNoChange { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>logrus.Infof(</code><code>"migrate up success, version: %+v, dirty: %+v"</code><code>, version, dirty)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;</code><code>logrus.Errorf(</code><code>"migrate up failed, version: %+v, dirty: %+v, err: %+v"</code><code>, version, dirty, err)</code> <code>&nbsp;&nbsp;&nbsp;</code><code>// 只要up没有成功，后续都是失败</code> <code>&nbsp;&nbsp;&nbsp;</code><code>e = errUpFailed</code> <code>&nbsp;&nbsp;&nbsp;</code><code>// 如果up失败，尝试回滚一步</code> <code>&nbsp;&nbsp;&nbsp;</code><code>version, dirty, _ = m.Version()</code> <code>&nbsp;&nbsp;&nbsp;</code><code>err = m.Steps(-</code><code>1</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>err == </code><code>nil</code> <code>|| err == os.ErrNotExist { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>logrus.Infof(</code><code>"migrate down -1 success, version: %+v, dirty: %+v"</code><code>, version, dirty)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;</code><code>logrus.Errorf(</code><code>"migrate down -1 failed, version: %+v, dirty: %+v, err: %+v"</code><code>, version, dirty, err)</code> <code>&nbsp;&nbsp;&nbsp;</code><code>// 如果回滚失败，判断是不是因为dirty</code> <code>&nbsp;&nbsp;&nbsp;</code><code>er, ok := err.(migrate.ErrDirty)</code> <code>&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>!ok { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// 不是dirty错误</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;</code><code>// 是dirty错误，那我们强制设置version，再利用这个版本进行回滚</code> <code>&nbsp;&nbsp;&nbsp;</code><code>err = m.Force(er.Version)</code> <code>&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>err != </code><code>nil</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>logrus.Printf(</code><code>"migrate force %+v err: %+v"</code><code>, er.Version, err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;</code><code>err = m.Steps(-</code><code>1</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>err == </code><code>nil</code> <code>|| err == os.ErrNotExist { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>logrus.Printf(</code><code>"migrate down -1 after force success, version: %+v, dirty: %+v"</code><code>, version, dirty)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;</code><code>logrus.Printf(</code><code>"migrate down -1 after force failed, version: %+v, dirty: %+v, err: %+v"</code><code>, version, dirty, err)</code> <code>&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>}</code> <code>func</code> <code>main() { </code> <code>&nbsp;&nbsp;&nbsp;</code><code>// 如果数据库不存在则创建数据库</code> <code>&nbsp;&nbsp;&nbsp;</code><code>err := createDBIfNotExist()</code> <code>&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>err != </code><code>nil</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>os.Exit(</code><code>1</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;</code><code>// migration操作</code> <code>&nbsp;&nbsp;&nbsp;</code><code>err = migration()</code> <code>&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>err != </code><code>nil</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>os.Exit(</code><code>1</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

这样，程序执行后，就能达到和命令执行一样的效果，实现数据库的迁移。

### 2. gormigrate ###

当然，如果我们使用的是`gorm`，那么推荐使用`gromigrate`，`gorm`本身提供了`AutoMigrate`以及相应的`Migrator`的DDL接口，但是其更着重于`ORM`层面的功能，在`ORM Schema Version Control（数据库版本控制）`方面有所欠缺。而`gromigrate`就是一个轻量化的`Schema Migration Helper（迁移助手）`，基于`GORM AutoMigrate`和`Migrator`进行封装，用于弥补这一块的缺失。

和`golang-migrate`不同的是，`AutoMigrate`会根据程序中数据结构的变化来改变表结构，无需自己写`sql`文件，我们仿照上述例子，来实现一遍。

#### 2.1 InitSchema ####

应用于初始化没有表的场景，可以通过`InitSchema`函数实现注册函数，注意，这里的注册函数只有初始化函数，没有`Rollback`操作。

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 </td> 
 <td> <code>package</code> <code>main</code> <code>import</code> <code>(</code> <code>&nbsp;&nbsp;&nbsp;</code><code>"context"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>"database/sql"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>"fmt"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>"log"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>"time"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>"github.com/go-gormigrate/gormigrate/v2"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>"gorm.io/driver/mysql"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>"gorm.io/gorm"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>"gorm.io/gorm/schema"</code> <code>)</code> <code>type</code> <code>Person </code><code>struct</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;</code><code>ID&nbsp;&nbsp; </code><code>int64</code>&nbsp; <code>`gorm:</code><code>"autoIncrement:true;primaryKey;column:id;type:bigint(20);not null"</code><code>`</code> <code>&nbsp;&nbsp;&nbsp;</code><code>Name </code><code>string</code> <code>`gorm:</code><code>"column:name;type:varchar(64);not null;comment:'姓名'"</code><code>`</code> <code>&nbsp;&nbsp;&nbsp;</code><code>Age&nbsp; </code><code>int</code>&nbsp;&nbsp;&nbsp; <code>`gorm:</code><code>"column:age;type:int(11);not null;comment:'年龄'"</code><code>`</code> <code>}</code> <code>const</code> <code>(</code> <code>&nbsp;&nbsp;&nbsp;</code><code>username = </code><code>"root"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>password = </code><code>"IBHojwND.yo"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>hostname = </code><code>"10.117.49.6:13306"</code> <code>&nbsp;&nbsp;&nbsp;</code><code>dbname&nbsp;&nbsp; = </code><code>"migration_test"</code> <code>)</code> <code>func</code> <code>dsn(dbName </code><code>string</code><code>) </code><code>string</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>fmt.Sprintf(</code><code>"%s:%s@tcp(%s)/%s?charset=utf8mb4&amp;parseTime=true"</code><code>, username, password, hostname, dbName)</code> <code>}</code> <code>func</code> <code>createDBIfNotExist() </code><code>error</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;</code><code>db, err := sql.Open(</code><code>"mysql"</code><code>, dsn(</code><code>""</code><code>))</code> <code>&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>err != </code><code>nil</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>log.Printf(</code><code>"Error %s when opening DB\n"</code><code>, err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>err</code> <code>&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;</code><code>defer</code> <code>db.</code><code>Close</code><code>()</code> <code>&nbsp;&nbsp;&nbsp;</code><code>ctx, cancelfunc := context.WithTimeout(context.Background(), </code><code>5</code><code>*time.Second)</code> <code>&nbsp;&nbsp;&nbsp;</code><code>defer</code> <code>cancelfunc()</code> <code>&nbsp;&nbsp;&nbsp;</code><code>res, err := db.ExecContext(ctx, </code><code>"CREATE DATABASE IF NOT EXISTS "</code><code>+dbname)</code> <code>&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>err != </code><code>nil</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>log.Printf(</code><code>"Error %s when creating DB\n"</code><code>, err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>err</code> <code>&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;</code><code>no, err := res.RowsAffected()</code> <code>&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>err != </code><code>nil</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>log.Printf(</code><code>"Error %s when fetching rows"</code><code>, err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>err</code> <code>&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;</code><code>log.Printf(</code><code>"rows affected %d\n"</code><code>, no)</code> <code>&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>nil</code> <code>}</code> <code>func</code> <code>initScheme(db *gorm.DB) { </code> <code>&nbsp;&nbsp;&nbsp;</code><code>m := gormigrate.</code><code>New</code><code>(db, gormigrate.DefaultOptions, []*gormigrate.Migration{})</code> <code>&nbsp;&nbsp;&nbsp;</code><code>m.InitSchema(</code><code>func</code><code>(db *gorm.DB) </code><code>error</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>err := db.AutoMigrate(</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&amp;Person{},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>err != </code><code>nil</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>panic</code><code>(err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>nil</code> <code>&nbsp;&nbsp;&nbsp;</code><code>})</code> <code>&nbsp;&nbsp;&nbsp;</code><code>err := m.Migrate()</code> <code>&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>err != </code><code>nil</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>panic</code><code>(err)</code> <code>&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>}</code> <code>func</code> <code>main() { </code> <code>&nbsp;&nbsp;&nbsp;</code><code>err := createDBIfNotExist()</code> <code>&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>err != </code><code>nil</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>panic</code><code>(err)</code> <code>&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;</code><code>db, err := gorm.Open(mysql.</code><code>New</code><code>(mysql.Config{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>DSN:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; dsn(dbname), </code><code>// DSN data source name</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>DefaultStringSize:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code>256</code><code>,&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code>// string 类型字段的默认长度</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>DisableDatetimePrecision:&nbsp; </code><code>true</code><code>,&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code>// 禁用 datetime 精度，MySQL 5.6 之前的数据库不支持</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>DontSupportRenameIndex:&nbsp;&nbsp;&nbsp; </code><code>true</code><code>,&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code>// 重命名索引时采用删除并新建的方式，MySQL 5.7 之前的数据库和 MariaDB 不支持重命名索引</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>DontSupportRenameColumn:&nbsp;&nbsp; </code><code>true</code><code>,&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code>// 用 `change` 重命名列，MySQL 8 之前的数据库和 MariaDB 不支持重命名列</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>SkipInitializeWithVersion: </code><code>false</code><code>,&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code>// 根据当前 MySQL 版本自动配置</code> <code>&nbsp;&nbsp;&nbsp;</code><code>}), &amp;gorm.Config{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>NamingStrategy: &amp;schema.NamingStrategy{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>TablePrefix:&nbsp;&nbsp; </code><code>""</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>SingularTable: </code><code>true</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//SkipDefaultTransaction: true, // 开启提高性能，https://gorm.io/docs/transactions.html</code> <code>&nbsp;&nbsp;&nbsp;</code><code>})</code> <code>&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>err != </code><code>nil</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>panic</code><code>(err)</code> <code>&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;</code><code>initScheme(db)</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

可以看到，此时的`Person`结构体：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 </td> 
 <td> <code>type</code> <code>Person </code><code>struct</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;</code><code>ID&nbsp;&nbsp; </code><code>int64</code>&nbsp; <code>`gorm:</code><code>"autoIncrement:true;primaryKey;column:id;type:bigint(20);not null"</code><code>`</code> <code>&nbsp;&nbsp;&nbsp;</code><code>Name </code><code>string</code> <code>`gorm:</code><code>"column:name;type:varchar(64);not null;comment:'姓名'"</code><code>`</code> <code>&nbsp;&nbsp;&nbsp;</code><code>Age&nbsp; </code><code>int</code>&nbsp;&nbsp;&nbsp; <code>`gorm:</code><code>"column:age;type:int(11);not null;comment:'年龄'"</code><code>`</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

然后在可以看到生成了两个表：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 </td> 
 <td> <code>MariaDB [migration_test6]&gt; SHOW TABLES;</code> <code>+</code><code>---------------------------+</code> <code>| Tables_in_migration_test6 |</code> <code>+</code><code>---------------------------+</code> <code>| migrations&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>| person&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>+</code><code>---------------------------+</code> <code>2 </code><code>rows</code> <code>in</code> <code>set</code> <code>(0.000 sec)</code> </td> 
 </tr> 
 </tbody> 
</table>

其中，`person`是我们生成的表，其结构和`Person`结构体一致

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 </td> 
 <td> <code>MariaDB [migration_test6]&gt; </code><code>DESC</code> <code>`person`;</code> <code>+</code><code>-------+-------------+------+-----+---------+----------------+</code> <code>| Field | Type&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; | </code><code>Null</code> <code>| </code><code>Key</code> <code>| </code><code>Default</code> <code>| Extra&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>+</code><code>-------+-------------+------+-----+---------+----------------+</code> <code>| id&nbsp;&nbsp;&nbsp; | </code><code>bigint</code><code>(20)&nbsp; | </code><code>NO</code>&nbsp;&nbsp; <code>| PRI | </code><code>NULL</code>&nbsp;&nbsp;&nbsp; <code>| auto_increment |</code> <code>| </code><code>name</code>&nbsp; <code>| </code><code>varchar</code><code>(64) | </code><code>NO</code>&nbsp;&nbsp; <code>|&nbsp;&nbsp;&nbsp;&nbsp; | </code><code>NULL</code>&nbsp;&nbsp;&nbsp; <code>|&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>| age&nbsp;&nbsp; | </code><code>int</code><code>(11)&nbsp;&nbsp;&nbsp;&nbsp; | </code><code>NO</code>&nbsp;&nbsp; <code>|&nbsp;&nbsp;&nbsp;&nbsp; | </code><code>NULL</code>&nbsp;&nbsp;&nbsp; <code>|&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>+</code><code>-------+-------------+------+-----+---------+----------------+</code> <code>3 </code><code>rows</code> <code>in</code> <code>set</code> <code>(0.001 sec)</code> </td> 
 </tr> 
 </tbody> 
</table>

而`migrations`表是迁移版本记录表，可以发现其只有一列，记录的就是版本号，`InitSchema`成功后版本号是`SCHEMA_INIT`。

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 </td> 
 <td> <code>MariaDB [migration_test6]&gt; </code><code>SELECT</code> <code>* </code><code>FROM</code> <code>`migrations`;</code> <code>+</code><code>-------------+</code> <code>| id&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>+</code><code>-------------+</code> <code>| SCHEMA_INIT |</code> <code>+</code><code>-------------+</code> <code>1 row </code><code>in</code> <code>set</code> <code>(0.000 sec)</code> </td> 
 </tr> 
 </tbody> 
</table>

#### 2.2 增量迁移 ####

需要注意的是，当使用`InitSchema`\+`增量迁移`的时候，不能使用同一个实例对象。

##### 2.2.1 新增一列 #####

比如接下来，我们将`Person`结构体新增一个属性`Gender`表示性别：

其实这时候调用`gorm.AutoMigrate`就已经能够自动创建列了，但是为了版本的管理，我们建立以下的版本管理：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 </td> 
 <td> <code>func</code> <code>migration(db *gorm.DB) { </code> <code>&nbsp;&nbsp;&nbsp;</code><code>m := gormigrate.</code><code>New</code><code>(db, gormigrate.DefaultOptions, []*gormigrate.Migration{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>ID: </code><code>"20230616165624"</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Migrate: </code><code>func</code><code>(tx *gorm.DB) </code><code>error</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>tx.AutoMigrate(&amp;Person{})</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Rollback: </code><code>func</code><code>(tx *gorm.DB) </code><code>error</code> <code>{ </code><code>return</code> <code>tx.Migrator().DropColumn(</code><code>"person"</code><code>, </code><code>"gender"</code><code>) },</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;</code><code>})</code> <code>&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>err := m.Migrate(); err != </code><code>nil</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>log.Fatalf(</code><code>"Could not migrate: %v"</code><code>, err)</code> <code>&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;</code><code>log.Printf(</code><code>"Migration did run successfully"</code><code>)</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

然后在`main`函数最后加上`migration(db)`：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 </td> 
 <td> <code>func</code> <code>main() { </code> <code>&nbsp;&nbsp;&nbsp;</code><code>...</code> <code>&nbsp;&nbsp;&nbsp;</code><code>// 初始化</code> <code>&nbsp;&nbsp;&nbsp;</code><code>initScheme(db)</code> <code>&nbsp;&nbsp;&nbsp;</code><code>// 增量迁移</code> <code>&nbsp;&nbsp;&nbsp;</code><code>migration(db)</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

执行完之后，`person`表的结构变为

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 </td> 
 <td> <code>MariaDB [migration_test6]&gt; </code><code>DESC</code> <code>`person`;</code> <code>+</code><code>--------+-------------+------+-----+---------+----------------+</code> <code>| Field&nbsp; | Type&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; | </code><code>Null</code> <code>| </code><code>Key</code> <code>| </code><code>Default</code> <code>| Extra&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>+</code><code>--------+-------------+------+-----+---------+----------------+</code> <code>| id&nbsp;&nbsp;&nbsp;&nbsp; | </code><code>bigint</code><code>(20)&nbsp; | </code><code>NO</code>&nbsp;&nbsp; <code>| PRI | </code><code>NULL</code>&nbsp;&nbsp;&nbsp; <code>| auto_increment |</code> <code>| </code><code>name</code>&nbsp;&nbsp; <code>| </code><code>varchar</code><code>(64) | </code><code>NO</code>&nbsp;&nbsp; <code>|&nbsp;&nbsp;&nbsp;&nbsp; | </code><code>NULL</code>&nbsp;&nbsp;&nbsp; <code>|&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>| age&nbsp;&nbsp;&nbsp; | </code><code>int</code><code>(11)&nbsp;&nbsp;&nbsp;&nbsp; | </code><code>NO</code>&nbsp;&nbsp; <code>|&nbsp;&nbsp;&nbsp;&nbsp; | </code><code>NULL</code>&nbsp;&nbsp;&nbsp; <code>|&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>| gender | </code><code>int</code><code>(11)&nbsp;&nbsp;&nbsp;&nbsp; | </code><code>NO</code>&nbsp;&nbsp; <code>|&nbsp;&nbsp;&nbsp;&nbsp; | </code><code>NULL</code>&nbsp;&nbsp;&nbsp; <code>|&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>+</code><code>--------+-------------+------+-----+---------+----------------+</code> <code>4 </code><code>rows</code> <code>in</code> <code>set</code> <code>(0.001 sec)</code> </td> 
 </tr> 
 </tbody> 
</table>

然后会发现`migrations`表里变为两条：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 </td> 
 <td> <code>MariaDB [migration_test6]&gt; </code><code>SELECT</code> <code>* </code><code>FROM</code> <code>`migrations`;</code> <code>+</code><code>----------------+</code> <code>| id&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>+</code><code>----------------+</code> <code>| 20230616165624 |</code> <code>| SCHEMA_INIT&nbsp;&nbsp;&nbsp; |</code> <code>+</code><code>----------------+</code> <code>2 </code><code>rows</code> <code>in</code> <code>set</code> <code>(0.000 sec)</code> </td> 
 </tr> 
 </tbody> 
</table>

##### 2.2.2 新增name为index #####

同样的，首先修改`Person`结构体，给`Name`列加上了名为`idx_name`的索引：

然后新增版本：

执行完会发现，`person`表结构如下：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 </td> 
 <td> <code>MariaDB [migration_test6]&gt; DESC `person`;</code> <code>+--------+-------------+------+-----+---------+----------------+</code> <code>| Field&nbsp; | </code><code>Type</code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <code>| Null | Key | </code><code>Default</code> <code>| Extra&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>+--------+-------------+------+-----+---------+----------------+</code> <code>| id&nbsp;&nbsp;&nbsp;&nbsp; | bigint(</code><code>20</code><code>)&nbsp; | NO&nbsp;&nbsp; | PRI | NULL&nbsp;&nbsp;&nbsp; | auto_increment |</code> <code>| name&nbsp;&nbsp; | varchar(</code><code>64</code><code>) | NO&nbsp;&nbsp; | MUL | NULL&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>| age&nbsp;&nbsp;&nbsp; | </code><code>int</code><code>(</code><code>11</code><code>)&nbsp;&nbsp;&nbsp;&nbsp; | NO&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp; | NULL&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>| gender | </code><code>int</code><code>(</code><code>11</code><code>)&nbsp;&nbsp;&nbsp;&nbsp; | NO&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp; | NULL&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>+--------+-------------+------+-----+---------+----------------+</code> <code>4</code> <code>rows in set (</code><code>0.001</code> <code>sec)</code> </td> 
 </tr> 
 </tbody> 
</table>

而`migrations`表里会新增一个版本：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 </td> 
 <td> <code>MariaDB [migration_test6]&gt; </code><code>SELECT</code> <code>* </code><code>FROM</code> <code>`migrations`;</code> <code>+</code><code>----------------+</code> <code>| id&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>+</code><code>----------------+</code> <code>| 20230616165624 |</code> <code>| 20230619104829 |</code> <code>| SCHEMA_INIT&nbsp;&nbsp;&nbsp; |</code> <code>+</code><code>----------------+</code> <code>3 </code><code>rows</code> <code>in</code> <code>set</code> <code>(0.000 sec)</code> </td> 
 </tr> 
 </tbody> 
</table>

##### 2.2.3 加联合索引 #####

假如我们希望加一个名为`idx_gender_name`的联合索引，使用`gender`和`name`列作为索引，那么需要修改`Person`结构体如下，一定要在每个相关字段上标注联合索引`idx_gender_name`，并且需要按照先后顺序利用`priority`确定优先级，数字越低，优先级越高。

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 </td> 
 <td> <code>type</code> <code>Person </code><code>struct</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;</code><code>ID&nbsp;&nbsp;&nbsp;&nbsp; </code><code>int64</code>&nbsp; <code>`gorm:</code><code>"autoIncrement:true;primaryKey;column:id;type:bigint(20);not null"</code><code>`</code> <code>&nbsp;&nbsp;&nbsp;</code><code>Name&nbsp;&nbsp; </code><code>string</code> <code>`gorm:</code><code>"index:idx_name;index:idx_gender_name,priority:2;column:name;type:varchar(64);not null;comment:''姓名''"</code><code>` </code><code>// '姓名'</code> <code>&nbsp;&nbsp;&nbsp;</code><code>Age&nbsp;&nbsp;&nbsp; </code><code>int</code>&nbsp;&nbsp;&nbsp; <code>`gorm:</code><code>"column:age;type:int(11);not null;comment:''年龄''"</code><code>`&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code>// '年龄'</code> <code>&nbsp;&nbsp;&nbsp;</code><code>Gender </code><code>int</code>&nbsp;&nbsp;&nbsp; <code>`gorm:</code><code>"index:idx_gender_name,priority:1;column:gender;type:int(11);not null;comment:''性别：0-未知，1-男性，2-女性''"</code><code>`&nbsp;&nbsp; </code><code>// '性别：0-未知，1-男性，2-女性'</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

然后同样加上版本规划：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 </td> 
 <td> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;</code><code>ID: </code><code>"20230619112345"</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;</code><code>Migrate: func(tx *gorm.DB) error { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return tx.AutoMigrate(&amp;Person{})</code> <code>&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;</code><code>Rollback: func(tx *gorm.DB) error { return tx.Migrator().DropIndex(</code><code>"person"</code><code>, </code><code>"idx_gender_name"</code><code>) },</code> <code>},</code> </td> 
 </tr> 
 </tbody> 
</table>

可以发现`person`的索引如下：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 </td> 
 <td> <code>MariaDB [migration_test6]&gt; SHOW </code><code>INDEX</code> <code>FROM</code> <code>`person`;</code> <code>+</code><code>--------+------------+-----------------+--------------+-------------+-----------+-------------+----------+--------+------+------------+---------+---------------+</code> <code>| </code><code>Table</code>&nbsp; <code>| Non_unique | Key_name&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; | Seq_in_index | Column_name | Collation | Cardinality | Sub_part | Packed | </code><code>Null</code> <code>| Index_type | Comment | Index_comment |</code> <code>+</code><code>--------+------------+-----------------+--------------+-------------+-----------+-------------+----------+--------+------+------------+---------+---------------+</code> <code>| person |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 0 | </code><code>PRIMARY</code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <code>|&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 1 | id&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; | A&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 0 |&nbsp;&nbsp;&nbsp;&nbsp; </code><code>NULL</code> <code>| </code><code>NULL</code>&nbsp;&nbsp; <code>|&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; | BTREE&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>| person |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 1 | idx_name&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 1 | </code><code>name</code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <code>| A&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 0 |&nbsp;&nbsp;&nbsp;&nbsp; </code><code>NULL</code> <code>| </code><code>NULL</code>&nbsp;&nbsp; <code>|&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; | BTREE&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>| person |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 1 | idx_gender_name |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 1 | gender&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; | A&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 0 |&nbsp;&nbsp;&nbsp;&nbsp; </code><code>NULL</code> <code>| </code><code>NULL</code>&nbsp;&nbsp; <code>|&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; | BTREE&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>| person |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 1 | idx_gender_name |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 2 | </code><code>name</code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <code>| A&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 0 |&nbsp;&nbsp;&nbsp;&nbsp; </code><code>NULL</code> <code>| </code><code>NULL</code>&nbsp;&nbsp; <code>|&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; | BTREE&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |</code> <code>+</code><code>--------+------------+-----------------+--------------+-------------+-----------+-------------+----------+--------+------+------------+---------+---------------+</code> <code>4 </code><code>rows</code> <code>in</code> <code>set</code> <code>(0.000 sec)</code> </td> 
 </tr> 
 </tbody> 
</table>

可以发现，`gormigrate`可以实现数据库的版本迁移，并且是对`Go`语言友好的。在微服务中，如果数据库版本管理不是很复杂，且使用的是`gorm`组件，那么可以使用`gormigrate`。

转自：[微点阅读][Link 1] [https://www.weidianyuedu.com][Link 1]

[127f9d79a62a677b14f5ed7cf95b1b95.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/22115d77ea3e460baf3378c84584ebef.png
[159.jpg]: https://images.weidianyuedu.com/thumb/159.jpg
[Link 1]: https://www.weidianyuedu.com