feat: Handle the Gorm migration for PostgreSQL

ZPascal · ZPascal · commit c2626b7afc9f · 2026-03-06T09:08:36.000+01:00
diff --git a/.gitignore b/.gitignore
@@ -1,4 +1,5 @@
 go.mod
+go.sum
 tags
 cmd/routing-api/routing-api
 /routing-api
diff --git a/cmd/routing-api/routing_api_suite_test.go b/cmd/routing-api/routing_api_suite_test.go
@@ -70,10 +70,7 @@ var _ = SynchronizedBeforeSuite(
 		Expect(err).NotTo(HaveOccurred())
 
 		locketPath, err := gexec.Build("code.cloudfoundry.org/locket/cmd/locket", "-race")
-		if err != nil {
-			// If building locket fails due to missing dependencies, skip the test
-			Skip(fmt.Sprintf("Skipping test suite: locket dependency issue - %v", err))
-		}
+		Expect(err).NotTo(HaveOccurred())
 
 		return []byte(strings.Join([]string{routingAPIBin, locketPath}, ","))
 	},
@@ -82,9 +79,6 @@ var _ = SynchronizedBeforeSuite(
 
 		path := string(binPaths)
 		parts := strings.Split(path, ",")
-		if len(parts) < 2 || parts[1] == "" {
-			Skip("Skipping test suite: locket binary not available")
-		}
 		routingAPIBinPath = parts[0]
 		locketBinPath = parts[1]
 
diff --git a/cmd/routing-api/testrunner/constants.go b/cmd/routing-api/testrunner/constants.go
@@ -1,8 +1,9 @@
 package testrunner
 
 import (
-	"code.cloudfoundry.org/routing-api/config"
 	"os"
+
+	"code.cloudfoundry.org/routing-api/config"
 )
 
 const (
diff --git a/cmd/routing-api/testrunner/db.go b/cmd/routing-api/testrunner/db.go
@@ -63,7 +63,7 @@ func (a *postgresAllocator) Create() (*config.SqlDB, error) {
 	if err != nil {
 		return nil, err
 	}
-	a.sqlDB, err = sql.Open("postgres", connStr)
+	a.sqlDB, err = sql.Open("pgx", connStr)
 	if err != nil {
 		return nil, err
 	}
diff --git a/db/db_sql.go b/db/db_sql.go
@@ -128,7 +128,6 @@ func NewSqlDB(cfg *config.SqlDB) (*SqlDB, error) {
 		return nil, err
 	}
 
-	// Use the connection pool and setup it
 	sqlDB, err := db.DB()
 	if err != nil {
 		return nil, err
diff --git a/db/db_sql_test.go b/db/db_sql_test.go
@@ -2085,13 +2085,10 @@ var _ = Describe("SqlDB", func() {
 				It("eventually resolves the issue", func() {
 					timeout := 10.0
 
-					// Verify successful pruning starts working
 					Eventually(logger, timeout).Should(gbytes.Say(`"prune.successfully-finished-pruning-tcp-routes","log_level":1,"data":{"rowsAffected":1}`))
 
-					// Verify errors occur
 					Eventually(logger, timeout).Should(gbytes.Say(`failed-to-prune-tcp-routes","log_level":2,"data":{"error":"temp-error"}`))
 
-					// Verify recovery with more rows
 					Eventually(logger, timeout).Should(gbytes.Say(`"prune.successfully-finished-pruning-tcp-routes","log_level":1,"data":{"rowsAffected":111}`))
 				})
 			})
diff --git a/db/db_suite_test.go b/db/db_suite_test.go
@@ -5,7 +5,6 @@ import (
 
 	"code.cloudfoundry.org/routing-api/cmd/routing-api/testrunner"
 	"code.cloudfoundry.org/routing-api/config"
-	_ "github.com/jackc/pgx/v5/stdlib"
 	. "github.com/onsi/ginkgo/v2"
 	. "github.com/onsi/gomega"
 )
diff --git a/db/fakes/fake_client.go b/db/fakes/fake_client.go
diff --git a/migration/V2_update_rg_migration.go b/migration/V2_update_rg_migration.go
@@ -27,7 +27,6 @@ func (v *V2UpdateRgMigration) Run(sqlDB *db.SqlDB) error {
 		return err
 	}
 
-	// Check for duplicates
 	nameMap := make(map[string]int)
 	for _, rg := range rgs {
 		nameMap[rg.Name]++
@@ -39,14 +38,14 @@ func (v *V2UpdateRgMigration) Run(sqlDB *db.SqlDB) error {
 		}
 	}
 
-	// Remove old index if it exists - using correct MySQL syntax with table name
-	_ = sqlDB.Client.ExecWithError("DROP INDEX idx_rg_name ON router_groups")
+	dropIndex(sqlDB, "idx_rg_name", "router_groups")
 
-	// Create unique index using raw SQL with column length specification
-	err = sqlDB.Client.ExecWithError("CREATE UNIQUE INDEX idx_rg_name ON router_groups (name(191))")
-	if err != nil {
-		return err
+	// Create unique index - MySQL requires length prefix for text columns
+	var indexSQL string
+	if sqlDB.Client.Dialect().Name() == "mysql" {
+		indexSQL = "CREATE UNIQUE INDEX idx_rg_name ON router_groups (name(191))"
+	} else {
+		indexSQL = "CREATE UNIQUE INDEX idx_rg_name ON router_groups (name)"
 	}
-
-	return nil
+	return sqlDB.Client.ExecWithError(indexSQL)
 }
diff --git a/migration/V2_update_rg_migration_test.go b/migration/V2_update_rg_migration_test.go
@@ -55,7 +55,6 @@ var _ = Describe("V2UpdateRgMigration", func() {
 			})
 
 			It("does not allow duplicate router group names", func() {
-				// Verify that the unique index was created
 				migrator := sqlDB.Client.Migrator()
 				hasIndex := migrator.HasIndex("router_groups", "idx_rg_name")
 				Expect(hasIndex).To(BeTrue(), "Index idx_rg_name should exist on router_groups table")
diff --git a/migration/V4_add_rg_uniq_idx_tcp_route_migration.go b/migration/V4_add_rg_uniq_idx_tcp_route_migration.go
@@ -17,11 +17,16 @@ func (v *V4AddRgUniqIdxTCPRoute) Version() int {
 }
 
 func (v *V4AddRgUniqIdxTCPRoute) Run(sqlDB *db.SqlDB) error {
-	// Drop existing index if it exists - using correct MySQL syntax with table name
-	sqlDB.Client.Exec("DROP INDEX IF EXISTS idx_tcp_route ON tcp_routes")
-
-	// Create unique index using raw SQL
-	sqlDB.Client.Exec("CREATE UNIQUE INDEX idx_tcp_route ON tcp_routes (router_group_guid, host_port, host_ip, external_port)")
+	dropIndex(sqlDB, "idx_tcp_route", "tcp_routes")
+
+	// Create unique index - MySQL requires length prefixes for text columns
+	var indexSQL string
+	if sqlDB.Client.Dialect().Name() == "mysql" {
+		indexSQL = "CREATE UNIQUE INDEX idx_tcp_route ON tcp_routes (router_group_guid(191), host_port, host_ip(191), external_port)"
+	} else {
+		indexSQL = "CREATE UNIQUE INDEX idx_tcp_route ON tcp_routes (router_group_guid, host_port, host_ip, external_port)"
+	}
+	sqlDB.Client.Exec(indexSQL)
 
 	return nil
 }
diff --git a/migration/V5_sni_hostname_migration.go b/migration/V5_sni_hostname_migration.go
@@ -24,14 +24,14 @@ func (v *V5SniHostnameMigration) Run(sqlDB *db.SqlDB) error {
 	}
 
 	// Drop old index if it exists (ignore errors since it might not exist)
-	_ = sqlDB.Client.ExecWithError("DROP INDEX idx_tcp_route ON tcp_routes")
-
-	// Create unique index for SNI hostname constraint with column length specifications
-	// This allows routes with same fingerprint but different SNI hostnames
-	err = sqlDB.Client.ExecWithError("CREATE UNIQUE INDEX idx_tcp_route ON tcp_routes (router_group_guid(191), host_port, host_ip(191), external_port, sni_hostname(191))")
-	if err != nil {
-		return err
+	dropIndex(sqlDB, "idx_tcp_route", "tcp_routes")
+
+	// Create unique index - MySQL requires length prefixes for text columns
+	var indexSQL string
+	if sqlDB.Client.Dialect().Name() == "mysql" {
+		indexSQL = "CREATE UNIQUE INDEX idx_tcp_route ON tcp_routes (router_group_guid(191), host_port, host_ip(191), external_port, sni_hostname(191))"
+	} else {
+		indexSQL = "CREATE UNIQUE INDEX idx_tcp_route ON tcp_routes (router_group_guid, host_port, host_ip, external_port, sni_hostname)"
 	}
-
-	return nil
+	return sqlDB.Client.ExecWithError(indexSQL)
 }
diff --git a/migration/V5_sni_hostname_migration_test.go b/migration/V5_sni_hostname_migration_test.go
@@ -78,7 +78,6 @@ var _ = Describe("V5SniHostnameMigration", func() {
 			})
 
 			It("denies adding the same TCP routes with same SNI hostnames", func() {
-				// Verify that the unique index was created
 				migrator := sqlDB.Client.Migrator()
 				hasIndex := migrator.HasIndex("tcp_routes", "idx_tcp_route")
 				Expect(hasIndex).To(BeTrue(), "Index idx_tcp_route should exist on tcp_routes table")
diff --git a/migration/V6_tls_tcp_route.go b/migration/V6_tls_tcp_route.go
@@ -23,14 +23,14 @@ func (v *V6TCPTLSRoutes) Run(sqlDB *db.SqlDB) error {
 		return err
 	}
 
-	// Drop existing index if it exists - using correct MySQL syntax with table name
-	_ = sqlDB.Client.ExecWithError("DROP INDEX idx_tcp_route ON tcp_routes")
-
-	// Create unique index using raw SQL with column length specifications
-	err = sqlDB.Client.ExecWithError("CREATE UNIQUE INDEX idx_tcp_route ON tcp_routes (router_group_guid(191), host_port, host_ip(191), external_port, sni_hostname(191), host_tls_port)")
-	if err != nil {
-		return err
+	dropIndex(sqlDB, "idx_tcp_route", "tcp_routes")
+
+	// Create unique index - MySQL requires length prefixes for text columns
+	var indexSQL string
+	if sqlDB.Client.Dialect().Name() == "mysql" {
+		indexSQL = "CREATE UNIQUE INDEX idx_tcp_route ON tcp_routes (router_group_guid(191), host_port, host_ip(191), external_port, sni_hostname(191), host_tls_port)"
+	} else {
+		indexSQL = "CREATE UNIQUE INDEX idx_tcp_route ON tcp_routes (router_group_guid, host_port, host_ip, external_port, sni_hostname, host_tls_port)"
 	}
-
-	return nil
+	return sqlDB.Client.ExecWithError(indexSQL)
 }
diff --git a/migration/V6_tls_tcp_route_test.go b/migration/V6_tls_tcp_route_test.go
@@ -96,7 +96,6 @@ var _ = Describe("V6TCPTLSRoutes", func() {
 			})
 
 			It("denies adding the same TCP routes with same host TLS ports", func() {
-				// Verify that the unique index was created
 				migrator := sqlDB.Client.Migrator()
 				hasIndex := migrator.HasIndex("tcp_routes", "idx_tcp_route")
 				Expect(hasIndex).To(BeTrue(), "Index idx_tcp_route should exist on tcp_routes table")
@@ -124,7 +123,6 @@ var _ = Describe("V6TCPTLSRoutes", func() {
 			})
 
 			It("denies adding the same TCP routes with different instance_ids", func() {
-				// Verify that the unique index was created
 				migrator := sqlDB.Client.Migrator()
 				hasIndex := migrator.HasIndex("tcp_routes", "idx_tcp_route")
 				Expect(hasIndex).To(BeTrue(), "Index idx_tcp_route should exist on tcp_routes table")
diff --git a/migration/V7_instance_id_defaults.go b/migration/V7_instance_id_defaults.go
@@ -15,20 +15,27 @@ func (v *V7TCPTLSRoutes) Version() int {
 }
 
 func (v *V7TCPTLSRoutes) Run(sqlDB *db.SqlDB) error {
-	// Update the instance_id column to allow NULL values
-	err := sqlDB.Client.ExecWithError("ALTER TABLE tcp_routes MODIFY COLUMN instance_id varchar(255) DEFAULT NULL")
-	if err != nil {
-		return err
+	// Update the instance_id column to allow NULL values - syntax differs by database
+	if sqlDB.Client.Dialect().Name() == "mysql" {
+		err := sqlDB.Client.ExecWithError("ALTER TABLE tcp_routes MODIFY COLUMN instance_id varchar(255) DEFAULT NULL")
+		if err != nil {
+			return err
+		}
+	} else {
+		err := sqlDB.Client.ExecWithError("ALTER TABLE tcp_routes ALTER COLUMN instance_id SET DEFAULT NULL")
+		if err != nil {
+			return err
+		}
 	}
 
-	// Drop existing index if it exists - using correct MySQL syntax with table name
-	_ = sqlDB.Client.ExecWithError("DROP INDEX idx_tcp_route ON tcp_routes")
+	dropIndex(sqlDB, "idx_tcp_route", "tcp_routes")
 
-	// Create unique index using raw SQL with column length specifications
-	err = sqlDB.Client.ExecWithError("CREATE UNIQUE INDEX idx_tcp_route ON tcp_routes (router_group_guid(191), host_port, host_ip(191), external_port, sni_hostname(191), host_tls_port)")
-	if err != nil {
-		return err
+	// Create unique index - MySQL requires length prefixes for text columns
+	var indexSQL string
+	if sqlDB.Client.Dialect().Name() == "mysql" {
+		indexSQL = "CREATE UNIQUE INDEX idx_tcp_route ON tcp_routes (router_group_guid(191), host_port, host_ip(191), external_port, sni_hostname(191), host_tls_port)"
+	} else {
+		indexSQL = "CREATE UNIQUE INDEX idx_tcp_route ON tcp_routes (router_group_guid, host_port, host_ip, external_port, sni_hostname, host_tls_port)"
 	}
-
-	return nil
+	return sqlDB.Client.ExecWithError(indexSQL)
 }
diff --git a/migration/V8_host_tls_port_tcp_default_zero.go b/migration/V8_host_tls_port_tcp_default_zero.go
@@ -21,14 +21,14 @@ func (v *V8HostTLSPortTCPDefaultZero) Run(sqlDB *db.SqlDB) error {
 		return err
 	}
 
-	// Try to remove the old index if it exists - using correct MySQL syntax with table name
-	_ = sqlDB.Client.ExecWithError("DROP INDEX IF EXISTS idx_tcp_route ON tcp_routes")
-
-	// Set the DEFAULT 0 on the host_tls_port column
-	err = sqlDB.Client.ExecWithError("ALTER TABLE tcp_routes MODIFY COLUMN host_tls_port int DEFAULT 0")
-	if err != nil {
-		return err
+	// Try to remove the old index if it exists
+	dropIndex(sqlDB, "idx_tcp_route", "tcp_routes")
+
+	// Set the DEFAULT 0 on the host_tls_port column - syntax differs by database
+	if sqlDB.Client.Dialect().Name() == "mysql" {
+		err = sqlDB.Client.ExecWithError("ALTER TABLE tcp_routes MODIFY COLUMN host_tls_port int DEFAULT 0")
+	} else {
+		err = sqlDB.Client.ExecWithError("ALTER TABLE tcp_routes ALTER COLUMN host_tls_port SET DEFAULT 0")
 	}
-
-	return nil
+	return err
 }
diff --git a/migration/migration.go b/migration/migration.go
@@ -1,13 +1,24 @@
 package migration
 
 import (
+	"fmt"
 	"os"
 
 	"code.cloudfoundry.org/lager/v3"
 	"code.cloudfoundry.org/routing-api/db"
 	"gorm.io/gorm"
 )
 
+// dropIndex drops an index by name. MySQL requires "DROP INDEX name ON table",
+// PostgreSQL uses "DROP INDEX IF EXISTS name".
+func dropIndex(sqlDB *db.SqlDB, indexName, tableName string) {
+	if sqlDB.Client.Dialect().Name() == "mysql" {
+		_ = sqlDB.Client.ExecWithError(fmt.Sprintf("DROP INDEX %s ON %s", indexName, tableName))
+	} else {
+		_ = sqlDB.Client.ExecWithError(fmt.Sprintf("DROP INDEX IF EXISTS %s", indexName))
+	}
+}
+
 const MigrationKey = "routing-api-migration"
 
 type MigrationData struct {
diff --git a/migration/migration_suite_test.go b/migration/migration_suite_test.go
@@ -1,13 +1,33 @@
 package migration_test
 
 import (
+	"testing"
+
+	"code.cloudfoundry.org/routing-api/cmd/routing-api/testrunner"
 	. "github.com/onsi/ginkgo/v2"
 	. "github.com/onsi/gomega"
+)
 
-	"testing"
+var (
+	databaseAllocator testrunner.DbAllocator
 )
 
 func TestMigration(t *testing.T) {
 	RegisterFailHandler(Fail)
 	RunSpecs(t, "Migration Suite")
 }
+
+var _ = BeforeSuite(func() {
+	var err error
+	databaseAllocator = testrunner.NewDbAllocator()
+	_, err = databaseAllocator.Create()
+	Expect(err).ToNot(HaveOccurred(), "error occurred starting database client, is the database running?")
+})
+var _ = AfterSuite(func() {
+	err := databaseAllocator.Delete()
+	Expect(err).ToNot(HaveOccurred())
+})
+var _ = BeforeEach(func() {
+	err := databaseAllocator.Reset()
+	Expect(err).ToNot(HaveOccurred())
+})
diff --git a/migration/v0/models.go b/migration/v0/models.go
@@ -25,9 +25,9 @@ func (TcpRouteMapping) TableName() string {
 
 type TcpMappingEntity struct {
 	RouterGroupGuid string `json:"router_group_guid"`
-	HostPort        uint16 `gorm:"not null; unique_index:idx_tcp_route; type:int" json:"backend_port"`
+	HostPort        uint16 `gorm:"not null; unique_index:idx_tcp_route; type:int; size:32" json:"backend_port"`
 	HostIP          string `gorm:"not null; unique_index:idx_tcp_route" json:"backend_ip"`
-	ExternalPort    uint16 `gorm:"not null; unique_index:idx_tcp_route; type: int" json:"port"`
+	ExternalPort    uint16 `gorm:"not null; unique_index:idx_tcp_route; type:int; size:32" json:"port"`
 	ModificationTag `json:"modification_tag"`
 	TTL             *int `json:"ttl,omitempty"`
 }
@@ -40,7 +40,7 @@ type Route struct {
 
 type RouteEntity struct {
 	Route           string `gorm:"not null; unique_index:idx_route" json:"route"`
-	Port            uint16 `gorm:"not null; unique_index:idx_route" json:"port"`
+	Port            uint16 `gorm:"not null; unique_index:idx_route; size:32" json:"port"`
 	IP              string `gorm:"not null; unique_index:idx_route" json:"ip"`
 	TTL             *int   `json:"ttl"`
 	LogGuid         string `json:"log_guid"`
diff --git a/migration/v5/models.go b/migration/v5/models.go
@@ -27,10 +27,10 @@ func (TcpRouteMapping) TableName() string {
 
 type TcpMappingEntity struct {
 	RouterGroupGuid  string  `gorm:"not null; unique_index:idx_tcp_route" json:"router_group_guid"`
-	HostPort         uint16  `gorm:"not null; unique_index:idx_tcp_route; type:int" json:"backend_port"`
+	HostPort         uint16  `gorm:"not null; unique_index:idx_tcp_route; type:int; size:32" json:"backend_port"`
 	HostIP           string  `gorm:"not null; unique_index:idx_tcp_route" json:"backend_ip"`
 	SniHostname      *string `gorm:"default:null; unique_index:idx_tcp_route" json:"backend_sni_hostname,omitempty"`
-	ExternalPort     uint16  `gorm:"not null; unique_index:idx_tcp_route; type: int" json:"port"`
+	ExternalPort     uint16  `gorm:"not null; unique_index:idx_tcp_route; type:int; size:32" json:"port"`
 	ModificationTag  `json:"modification_tag"`
 	TTL              *int   `json:"ttl,omitempty"`
 	IsolationSegment string `json:"isolation_segment"`
diff --git a/models/route.go b/models/route.go
@@ -14,7 +14,7 @@ type Route struct {
 
 type RouteEntity struct {
 	Route           string `gorm:"not null; unique_index:idx_route" json:"route"`
-	Port            uint16 `gorm:"not null; unique_index:idx_route" json:"port"`
+	Port            uint16 `gorm:"not null; unique_index:idx_route; size:32" json:"port"`
 	IP              string `gorm:"not null; unique_index:idx_route" json:"ip"`
 	TTL             *int   `json:"ttl"`
 	LogGuid         string `json:"log_guid"`
diff --git a/models/tcp_route.go b/models/tcp_route.go

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,5 @@`
`1`	`1`	`go.mod`
	`2`	`+go.sum`
`2`	`3`	`tags`
`3`	`4`	`cmd/routing-api/routing-api`
`4`	`5`	`/routing-api`
Original file line number	Diff line number	Diff line change
`@@ -1,8 +1,9 @@`
`1`	`1`	`package testrunner`
`2`	`2`
`3`	`3`	`import (`
`4`		`- "code.cloudfoundry.org/routing-api/config"`
`5`	`4`	`"os"`
	`5`	`+`
	`6`	`+ "code.cloudfoundry.org/routing-api/config"`
`6`	`7`	`)`
`7`	`8`
`8`	`9`	`const (`
Original file line number	Diff line number	Diff line change
`@@ -63,7 +63,7 @@ func (a postgresAllocator) Create() (config.SqlDB, error) {`
`63`	`63`	`if err != nil {`
`64`	`64`	`return nil, err`
`65`	`65`	`}`
`66`		`- a.sqlDB, err = sql.Open("postgres", connStr)`
	`66`	`+ a.sqlDB, err = sql.Open("pgx", connStr)`
`67`	`67`	`if err != nil {`
`68`	`68`	`return nil, err`
`69`	`69`	`}`
Original file line number	Diff line number	Diff line change
`@@ -128,7 +128,6 @@ func NewSqlDB(cfg config.SqlDB) (SqlDB, error) {`
`128`	`128`	`return nil, err`
`129`	`129`	`}`
`130`	`130`
`131`		`- // Use the connection pool and setup it`
`132`	`131`	`sqlDB, err := db.DB()`
`133`	`132`	`if err != nil {`
`134`	`133`	`return nil, err`
Original file line number	Diff line number	Diff line change
`@@ -5,7 +5,6 @@ import (`
`5`	`5`
`6`	`6`	`"code.cloudfoundry.org/routing-api/cmd/routing-api/testrunner"`
`7`	`7`	`"code.cloudfoundry.org/routing-api/config"`
`8`		`- _ "github.com/jackc/pgx/v5/stdlib"`
`9`	`8`	`. "github.com/onsi/ginkgo/v2"`
`10`	`9`	`. "github.com/onsi/gomega"`
`11`	`10`	`)`
Original file line number	Diff line number	Diff line change
`@@ -27,7 +27,6 @@ func (v V2UpdateRgMigration) Run(sqlDB db.SqlDB) error {`
`27`	`27`	`return err`
`28`	`28`	`}`
`29`	`29`
`30`		`- // Check for duplicates`
`31`	`30`	`nameMap := make(map[string]int)`
`32`	`31`	`for _, rg := range rgs {`
`33`	`32`	`nameMap[rg.Name]++`
`@@ -39,14 +38,14 @@ func (v V2UpdateRgMigration) Run(sqlDB db.SqlDB) error {`
`39`	`38`	`}`
`40`	`39`	`}`
`41`	`40`
`42`		`- // Remove old index if it exists - using correct MySQL syntax with table name`
`43`		`- _ = sqlDB.Client.ExecWithError("DROP INDEX idx_rg_name ON router_groups")`
	`41`	`+ dropIndex(sqlDB, "idx_rg_name", "router_groups")`
`44`	`42`
`45`		`- // Create unique index using raw SQL with column length specification`
`46`		`- err = sqlDB.Client.ExecWithError("CREATE UNIQUE INDEX idx_rg_name ON router_groups (name(191))")`
`47`		`- if err != nil {`
`48`		`- return err`
	`43`	`+ // Create unique index - MySQL requires length prefix for text columns`
	`44`	`+ var indexSQL string`
	`45`	`+ if sqlDB.Client.Dialect().Name() == "mysql" {`
	`46`	`+ indexSQL = "CREATE UNIQUE INDEX idx_rg_name ON router_groups (name(191))"`
	`47`	`+ } else {`
	`48`	`+ indexSQL = "CREATE UNIQUE INDEX idx_rg_name ON router_groups (name)"`
`49`	`49`	`}`
`50`		`-`
`51`		`- return nil`
	`50`	`+ return sqlDB.Client.ExecWithError(indexSQL)`
`52`	`51`	`}`