@@ -8,10 +8,10 @@ package logic
88import (
99 gosql "database/sql"
1010 "fmt"
11- "sync/atomic"
12- "time"
1311 "regexp"
1412 "strings"
13+ "sync/atomic"
14+ "time"
1515
1616 "github.com/github/gh-ost/go/base"
1717 "github.com/github/gh-ost/go/binlog"
@@ -554,9 +554,9 @@ func (this *Applier) CreateTriggersOriginalTable() error {
554554 }
555555
556556 deleteTrigger := fmt .Sprintf (
557- "CREATE /* gh-ost */ TRIGGER `%s_del` AFTER DELETE ON %s.%s " +
558- "FOR EACH ROW " +
559- "DELETE /* gh-ost */ IGNORE FROM %s.%s WHERE %s" ,
557+ "CREATE /* gh-ost */ TRIGGER `%s_del` AFTER DELETE ON %s.%s " +
558+ "FOR EACH ROW " +
559+ "DELETE /* gh-ost */ IGNORE FROM %s.%s WHERE %s" ,
560560 prefix ,
561561 sql .EscapeName (this .migrationContext .DatabaseName ),
562562 sql .EscapeName (this .migrationContext .OriginalTableName ),
@@ -574,11 +574,10 @@ func (this *Applier) CreateTriggersOriginalTable() error {
574574 insertValues = append (insertValues , value )
575575 }
576576
577-
578577 insertTrigger := fmt .Sprintf (
579- "CREATE /* gh-ost */ TRIGGER `%s_ins` AFTER INSERT ON %s.%s " +
580- "FOR EACH ROW " +
581- "REPLACE /* gh-ost */ INTO %s.%s (%s) VALUES (%s)" ,
578+ "CREATE /* gh-ost */ TRIGGER `%s_ins` AFTER INSERT ON %s.%s " +
579+ "FOR EACH ROW " +
580+ "REPLACE /* gh-ost */ INTO %s.%s (%s) VALUES (%s)" ,
582581 prefix ,
583582 sql .EscapeName (this .migrationContext .DatabaseName ),
584583 sql .EscapeName (this .migrationContext .OriginalTableName ),
@@ -598,12 +597,12 @@ func (this *Applier) CreateTriggersOriginalTable() error {
598597 }
599598
600599 updateTrigger := fmt .Sprintf (
601- "CREATE /* gh-ost */ TRIGGER `%s_upd` AFTER UPDATE ON %s.%s " +
602- "FOR EACH ROW " +
603- "BEGIN /* gh-ost */ " +
604- "DELETE IGNORE FROM %s.%s WHERE !(%s) AND %s; " +
605- "REPLACE INTO %s.%s (%s) VALUES (%s); " +
606- "END" ,
600+ "CREATE /* gh-ost */ TRIGGER `%s_upd` AFTER UPDATE ON %s.%s " +
601+ "FOR EACH ROW " +
602+ "BEGIN /* gh-ost */ " +
603+ "DELETE IGNORE FROM %s.%s WHERE !(%s) AND %s; " +
604+ "REPLACE INTO %s.%s (%s) VALUES (%s); " +
605+ "END" ,
607606 prefix ,
608607 sql .EscapeName (this .migrationContext .DatabaseName ),
609608 sql .EscapeName (this .migrationContext .OriginalTableName ),
0 commit comments