Migration CLI (#94)

* wip rel migrate cli

* cli

* try fix compatibility

* hardcode exit code

* try stage

* revert,. move cc reporter to env

* refactor cmd as internal pkg, wip test

* test getModule

* test scan migration and get migration command

* should not panic on expected error

* test exec migrate

* removed paranoid dependency

* print file  name

* fix infer by gopath

* add go1.15.x

* drop go 1.10 and 1.11

* remove old commented code

.travis.yml

@@ -23,7 +23,6 @@ _gomod_build: &gomod_build
 
 _report_coverage: &report_coverage
   env:
-    - CC_TEST_REPORTER_ID=045e6c8f64f873901bacc868224b418d9fc72dd73c40feb1af50faf3e96de15d
     - COVER=-coverprofile=c.out
   before_script:
     - curl -L https://codeclimate.com/downloads/test-reporter/test-reporter-latest-linux-amd64 > ./cc-test-reporter
@@ -42,4 +41,6 @@ jobs:
       <<: *gomod_build
     - go: "1.14.x"
       <<: *gomod_build
+    - go: "1.15.x"
+      <<: *gomod_build
       <<: *report_coverage

adapter/mysql/mysql_test.go

@@ -6,7 +6,6 @@ import (
 	"os"
 	"testing"
 
-	paranoid "github.com/Fs02/go-paranoid"
 	"github.com/Fs02/rel"
 	"github.com/Fs02/rel/adapter/specs"
 	_ "github.com/go-sql-driver/mysql"
@@ -25,7 +24,7 @@ func dsn() string {
 
 func TestAdapter_specs(t *testing.T) {
 	adapter, err := Open(dsn())
-	paranoid.Panic(err, "failed to open database connection")
+	assert.Nil(t, err)
 	defer adapter.Close()
 
 	repo := rel.New(adapter)
@@ -107,52 +106,25 @@ func TestAdapter_Open(t *testing.T) {
 	})
 }
 
-// func TestAdapter_InsertAll_error(t *testing.T) {
-// 	adapter, err := Open(dsn())
-// 	paranoid.Panic(err, "failed to open database connection")
-// 	defer adapter.Close()
-
-// 	fields := []string{"notexist"}
-// 	mutations := []map[string]interface{}{
-// 		{"notexist": "12"},
-// 		{"notexist": "13"},
-// 	}
-
-// 	_, err = adapter.InsertAll(rel.Repo{}.From("users"), fields, mutations)
-
-// 	assert.NotNil(t, err)
-// }
-
 func TestAdapter_Transaction_commitError(t *testing.T) {
 	adapter, err := Open(dsn())
-	paranoid.Panic(err, "failed to open database connection")
+	assert.Nil(t, err)
 	defer adapter.Close()
 
 	assert.NotNil(t, adapter.Commit(ctx))
 }
 
 func TestAdapter_Transaction_rollbackError(t *testing.T) {
 	adapter, err := Open(dsn())
-	paranoid.Panic(err, "failed to open database connection")
+	assert.Nil(t, err)
 	defer adapter.Close()
 
 	assert.NotNil(t, adapter.Rollback(ctx))
 }
 
-// func TestAdapter_Query_error(t *testing.T) {
-// 	adapter, err := Open(dsn())
-// 	paranoid.Panic(err, "failed to open database connection")
-// 	defer adapter.Close()
-
-// 	out := struct{}{}
-
-// 	_, err = adapter.Query(&out, "error", nil)
-// 	assert.NotNil(t, err)
-// }
-
 func TestAdapter_Exec_error(t *testing.T) {
 	adapter, err := Open(dsn())
-	paranoid.Panic(err, "failed to open database connection")
+	assert.Nil(t, err)
 	defer adapter.Close()
 
 	_, _, err = adapter.Exec(ctx, "error", nil)

adapter/postgres/postgres_test.go

@@ -6,7 +6,6 @@ import (
 	"testing"
 	"time"
 
-	"github.com/Fs02/go-paranoid"
 	"github.com/Fs02/rel"
 	"github.com/Fs02/rel/adapter/specs"
 	_ "github.com/lib/pq"
@@ -30,7 +29,7 @@ func dsn() string {
 
 func TestAdapter_specs(t *testing.T) {
 	adapter, err := Open(dsn())
-	paranoid.Panic(err, "failed to open database connection")
+	assert.Nil(t, err)
 	defer adapter.Close()
 
 	repo := rel.New(adapter)
@@ -97,52 +96,25 @@ func TestAdapter_specs(t *testing.T) {
 	specs.CheckConstraint(t, repo)
 }
 
-// func TestAdapter_InsertAll_error(t *testing.T) {
-// 	adapter, err := Open(dsn())
-// 	paranoid.Panic(err, "failed to open database connection")
-// 	defer adapter.Close()
-
-// 	fields := []string{"notexist"}
-// 	mutations := []map[string]interface{}{
-// 		{"notexist": "12"},
-// 		{"notexist": "13"},
-// 	}
-
-// 	_, err = adapter.InsertAll(rel.Repo{}.From("users"), fields, mutations)
-
-// 	assert.NotNil(t, err)
-// }
-
 func TestAdapter_Transaction_commitError(t *testing.T) {
 	adapter, err := Open(dsn())
-	paranoid.Panic(err, "failed to open database connection")
+	assert.Nil(t, err)
 	defer adapter.Close()
 
 	assert.NotNil(t, adapter.Commit(ctx))
 }
 
 func TestAdapter_Transaction_rollbackError(t *testing.T) {
 	adapter, err := Open(dsn())
-	paranoid.Panic(err, "failed to open database connection")
+	assert.Nil(t, err)
 	defer adapter.Close()
 
 	assert.NotNil(t, adapter.Rollback(ctx))
 }
 
-// func TestAdapter_Query_error(t *testing.T) {
-// 	adapter, err := Open(dsn())
-// 	paranoid.Panic(err, "failed to open database connection")
-// 	defer adapter.Close()
-
-// 	out := struct{}{}
-
-// 	_, err = adapter.Query(&out, "error", nil)
-// 	assert.NotNil(t, err)
-// }
-
 func TestAdapter_Exec_error(t *testing.T) {
 	adapter, err := Open(dsn())
-	paranoid.Panic(err, "failed to open database connection")
+	assert.Nil(t, err)
 	defer adapter.Close()
 
 	_, _, err = adapter.Exec(ctx, "error", nil)

adapter/sqlite3/sqlite3_test.go

@@ -5,7 +5,6 @@ import (
 	"os"
 	"testing"
 
-	"github.com/Fs02/go-paranoid"
 	"github.com/Fs02/rel"
 	"github.com/Fs02/rel/adapter/specs"
 	_ "github.com/mattn/go-sqlite3"
@@ -24,7 +23,7 @@ func dsn() string {
 
 func TestAdapter_specs(t *testing.T) {
 	adapter, err := Open(dsn())
-	paranoid.Panic(err, "failed to open database connection")
+	assert.Nil(t, err)
 	defer adapter.Close()
 
 	repo := rel.New(adapter)
@@ -91,52 +90,25 @@ func TestAdapter_specs(t *testing.T) {
 	specs.CheckConstraint(t, repo)
 }
 
-// func TestAdapter_InsertAll_error(t *testing.T) {
-// 	adapter, err := Open(dsn())
-// 	paranoid.Panic(err, "failed to open database connection")
-// 	defer adapter.Close()
-
-// 	fields := []string{"notexist"}
-// 	mutations := []map[string]interface{}{
-// 		{"notexist": "12"},
-// 		{"notexist": "13"},
-// 	}
-
-// 	_, err = adapter.InsertAll(rel.Repo{}.From("users"), fields, mutations)
-
-// 	assert.NotNil(t, err)
-// }
-
 func TestAdapter_Transaction_commitError(t *testing.T) {
 	adapter, err := Open(dsn())
-	paranoid.Panic(err, "failed to open database connection")
+	assert.Nil(t, err)
 	defer adapter.Close()
 
 	assert.NotNil(t, adapter.Commit(ctx))
 }
 
 func TestAdapter_Transaction_rollbackError(t *testing.T) {
 	adapter, err := Open(dsn())
-	paranoid.Panic(err, "failed to open database connection")
+	assert.Nil(t, err)
 	defer adapter.Close()
 
 	assert.NotNil(t, adapter.Rollback(ctx))
 }
 
-// func TestAdapter_Query_error(t *testing.T) {
-// 	adapter, err := Open(dsn())
-// 	paranoid.Panic(err, "failed to open database connection")
-// 	defer adapter.Close()
-
-// 	out := struct{}{}
-
-// 	_, err = adapter.Query(&out, "error", nil)
-// 	assert.NotNil(t, err)
-// }
-
 func TestAdapter_Exec_error(t *testing.T) {
 	adapter, err := Open(dsn())
-	paranoid.Panic(err, "failed to open database connection")
+	assert.Nil(t, err)
 	defer adapter.Close()
 
 	_, _, err = adapter.Exec(ctx, "error", nil)