diff options
author | Joe Chen <jc@unknwon.io> | 2022-06-11 11:10:25 +0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-06-11 11:10:25 +0800 |
commit | 75fbb8244086a2ad964d1c51e3bdbdfb95df90ac (patch) | |
tree | c97a7d8b17a4a351f304bfd4a7dd01a75711a1c7 /internal/cmd | |
parent | f837ea6346ac720d586eda51ab89c5c71a1f3e65 (diff) |
db: use `context` for backup and restore (#7044)
Diffstat (limited to 'internal/cmd')
-rw-r--r-- | internal/cmd/backup.go | 3 | ||||
-rw-r--r-- | internal/cmd/restore.go | 3 |
2 files changed, 4 insertions, 2 deletions
diff --git a/internal/cmd/backup.go b/internal/cmd/backup.go index c5e17e16..69d9b788 100644 --- a/internal/cmd/backup.go +++ b/internal/cmd/backup.go @@ -5,6 +5,7 @@ package cmd import ( + "context" "fmt" "io/ioutil" "os" @@ -94,7 +95,7 @@ func runBackup(c *cli.Context) error { // Database dbDir := filepath.Join(rootDir, "db") - if err = db.DumpDatabase(conn, dbDir, c.Bool("verbose")); err != nil { + if err = db.DumpDatabase(context.Background(), conn, dbDir, c.Bool("verbose")); err != nil { log.Fatal("Failed to dump database: %v", err) } if err = z.AddDir(archiveRootDir+"/db", dbDir); err != nil { diff --git a/internal/cmd/restore.go b/internal/cmd/restore.go index dfa2bfc1..f38a7fdd 100644 --- a/internal/cmd/restore.go +++ b/internal/cmd/restore.go @@ -5,6 +5,7 @@ package cmd import ( + "context" "os" "path" "path/filepath" @@ -114,7 +115,7 @@ func runRestore(c *cli.Context) error { // Database dbDir := path.Join(archivePath, "db") - if err = db.ImportDatabase(conn, dbDir, c.Bool("verbose")); err != nil { + if err = db.ImportDatabase(context.Background(), conn, dbDir, c.Bool("verbose")); err != nil { log.Fatal("Failed to import database: %v", err) } |