add @replica to outdir file, add tests for @replica

Signed-off-by: Max Englander <max@planetscale.com>
planetscale · May 19, 2023 · 1f9dd99 · 1f9dd99
1 parent e80d374
commit 1f9dd99
Show file tree

Hide file tree

Showing 2 changed files with 537 additions and 13 deletions.
diff --git a/internal/dumper/dumper.go b/internal/dumper/dumper.go
@@ -306,7 +306,7 @@ func (d *Dumper) dumpTable(conn *Connection, database string, table string, useR
 
 		if (chunkbytes / 1024 / 1024) >= d.cfg.ChunksizeInMB {
 			query := strings.Join(inserts, ";\n") + ";\n"
-			file := fmt.Sprintf("%s/%s.%s.%05d.sql", d.cfg.Outdir, database, table, fileNo)
+			file := fmt.Sprintf("%s/%s.%s.%05d.sql", d.cfg.Outdir, databaseHandle, table, fileNo)
 			err = writeFile(file, query)
 			if err != nil {
 				return err