From 276b6c1e48da226a1c863d78c0f1d122791a1354 Mon Sep 17 00:00:00 2001
From: c9s <yoan@maicoin.com>
Date: Sat, 6 Feb 2021 09:52:53 +0800
Subject: [PATCH] drop the legacy upgradeDB

---
 pkg/bbgo/db.go        | 29 -----------------------------
 rockhopper_mysql.yaml |  2 +-
 2 files changed, 1 insertion(+), 30 deletions(-)

diff --git a/pkg/bbgo/db.go b/pkg/bbgo/db.go
index 0ff4f0d13..50431f02c 100644
--- a/pkg/bbgo/db.go
+++ b/pkg/bbgo/db.go
@@ -1,13 +1,9 @@
 package bbgo
 
 import (
-	"context"
-	"database/sql"
-
 	// register the go migrations
 	_ "github.com/c9s/bbgo/pkg/migrations"
 
-	"github.com/c9s/rockhopper"
 	"github.com/go-sql-driver/mysql"
 	"github.com/jmoiron/sqlx"
 )
@@ -23,28 +19,3 @@ func ConnectMySQL(dsn string) (*sqlx.DB, error) {
 	return sqlx.Connect("mysql", dsn)
 }
 
-func upgradeDB(ctx context.Context, driver string, db *sql.DB) error {
-	dialect, err := rockhopper.LoadDialect(driver)
-	if err != nil {
-		return err
-	}
-
-	loader := &rockhopper.GoMigrationLoader{}
-	migrations, err := loader.Load()
-	if err != nil {
-		return err
-	}
-
-	rh := rockhopper.New(driver, dialect, db)
-
-	currentVersion, err := rh.CurrentVersion()
-	if err != nil {
-		return err
-	}
-
-	if err := rockhopper.Up(ctx, rh, migrations, currentVersion, 0); err != nil {
-		return err
-	}
-
-	return nil
-}
diff --git a/rockhopper_mysql.yaml b/rockhopper_mysql.yaml
index 01e86e7bf..6dde3ff23 100644
--- a/rockhopper_mysql.yaml
+++ b/rockhopper_mysql.yaml
@@ -2,4 +2,4 @@
 driver: mysql
 dialect: mysql
 dsn: "root@tcp(localhost:3306)/bbgo?parseTime=true"
-migrationsDir: migrations
+migrationsDir: migrations/mysql