@@ -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"
@@ -557,9 +557,9 @@ func (this *Applier) CreateTriggersOriginalTable() error {
557557 }
558558
559559 deleteTrigger := fmt .Sprintf (
560- "CREATE /* gh-ost */ TRIGGER `%s_del` AFTER DELETE ON %s.%s " +
561- "FOR EACH ROW " +
562- "DELETE /* gh-ost */ IGNORE FROM %s.%s WHERE %s" ,
560+ "CREATE /* gh-ost */ TRIGGER `%s_del` AFTER DELETE ON %s.%s " +
561+ "FOR EACH ROW " +
562+ "DELETE /* gh-ost */ IGNORE FROM %s.%s WHERE %s" ,
563563 prefix ,
564564 sql .EscapeName (this .migrationContext .DatabaseName ),
565565 sql .EscapeName (this .migrationContext .OriginalTableName ),
@@ -577,11 +577,10 @@ func (this *Applier) CreateTriggersOriginalTable() error {
577577 insertValues = append (insertValues , value )
578578 }
579579
580-
581580 insertTrigger := fmt .Sprintf (
582- "CREATE /* gh-ost */ TRIGGER `%s_ins` AFTER INSERT ON %s.%s " +
583- "FOR EACH ROW " +
584- "REPLACE /* gh-ost */ INTO %s.%s (%s) VALUES (%s)" ,
581+ "CREATE /* gh-ost */ TRIGGER `%s_ins` AFTER INSERT ON %s.%s " +
582+ "FOR EACH ROW " +
583+ "REPLACE /* gh-ost */ INTO %s.%s (%s) VALUES (%s)" ,
585584 prefix ,
586585 sql .EscapeName (this .migrationContext .DatabaseName ),
587586 sql .EscapeName (this .migrationContext .OriginalTableName ),
@@ -601,12 +600,12 @@ func (this *Applier) CreateTriggersOriginalTable() error {
601600 }
602601
603602 updateTrigger := fmt .Sprintf (
604- "CREATE /* gh-ost */ TRIGGER `%s_upd` AFTER UPDATE ON %s.%s " +
605- "FOR EACH ROW " +
606- "BEGIN /* gh-ost */ " +
607- "DELETE IGNORE FROM %s.%s WHERE !(%s) AND %s; " +
608- "REPLACE INTO %s.%s (%s) VALUES (%s); " +
609- "END" ,
603+ "CREATE /* gh-ost */ TRIGGER `%s_upd` AFTER UPDATE ON %s.%s " +
604+ "FOR EACH ROW " +
605+ "BEGIN /* gh-ost */ " +
606+ "DELETE IGNORE FROM %s.%s WHERE !(%s) AND %s; " +
607+ "REPLACE INTO %s.%s (%s) VALUES (%s); " +
608+ "END" ,
610609 prefix ,
611610 sql .EscapeName (this .migrationContext .DatabaseName ),
612611 sql .EscapeName (this .migrationContext .OriginalTableName ),
0 commit comments