Skip to content

Commit 045a657

Browse files
committed
adding debug and status
1 parent 8de94e3 commit 045a657

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

go/logic/migrator.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -838,13 +838,14 @@ func (this *Migrator) printMigrationStatusHint(writers ...io.Writer) {
838838
)
839839
maxLoad := this.migrationContext.GetMaxLoad()
840840
criticalLoad := this.migrationContext.GetCriticalLoad()
841-
fmt.Fprintf(w, "# chunk-size: %+v; max-lag-millis: %+vms; dml-batch-size: %+v; max-load: %s; critical-load: %s; nice-ratio: %f\n",
841+
fmt.Fprintf(w, "# chunk-size: %+v; max-lag-millis: %+vms; dml-batch-size: %+v; max-load: %s; critical-load: %s; nice-ratio: %f; where-clause: %s\n",
842842
atomic.LoadInt64(&this.migrationContext.ChunkSize),
843843
atomic.LoadInt64(&this.migrationContext.MaxLagMillisecondsThrottleThreshold),
844844
atomic.LoadInt64(&this.migrationContext.DMLBatchSize),
845845
maxLoad.String(),
846846
criticalLoad.String(),
847847
this.migrationContext.GetNiceRatio(),
848+
this.migrationContext.GetWhereClause(),
848849
)
849850
if this.migrationContext.ThrottleFlagFile != "" {
850851
setIndicator := ""

go/sql/builder.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -238,6 +238,7 @@ func BuildRangeInsertQuery(databaseName, originalTableName, ghostTableName strin
238238
databaseName, originalTableName, databaseName, ghostTableName, mappedSharedColumnsListing,
239239
sharedColumnsListing, databaseName, originalTableName, uniqueKey,
240240
rangeStartComparison, rangeEndComparison, whereClause, transactionalClause)
241+
fmt.Sprintf("the query: ", result)
241242
return result, explodedArgs, nil
242243
}
243244

0 commit comments

Comments
 (0)