From 07cb5ec7dc992d5b022a4bb94da41aba9c5761e5 Mon Sep 17 00:00:00 2001 From: Lunny Xiao Date: Sat, 21 Mar 2020 23:46:46 +0800 Subject: [PATCH] Fix dump --- engine.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/engine.go b/engine.go index 555b4e9b..4694e1c0 100644 --- a/engine.go +++ b/engine.go @@ -375,6 +375,10 @@ func (engine *Engine) dumpTables(tables []*schemas.Table, w io.Writer, tp ...sch if dstDialect.URI().Schema != "" { tableName = fmt.Sprintf("%s.%s", dstDialect.URI().Schema, table.Name) } + originalTableName := table.Name + if engine.dialect.URI().Schema != "" { + originalTableName = fmt.Sprintf("%s.%s", engine.dialect.URI().Schema, table.Name) + } if i > 0 { _, err = io.WriteString(w, "\n") if err != nil { @@ -403,7 +407,7 @@ func (engine *Engine) dumpTables(tables []*schemas.Table, w io.Writer, tp ...sch colNames := engine.dialect.Quoter().Join(cols, ", ") destColNames := dstDialect.Quoter().Join(cols, ", ") - rows, err := engine.DB().QueryContext(engine.defaultContext, "SELECT "+colNames+" FROM "+engine.Quote(table.Name)) + rows, err := engine.DB().QueryContext(engine.defaultContext, "SELECT "+colNames+" FROM "+engine.Quote(originalTableName)) if err != nil { return err }