octoleo/gh-ost
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

DML write wrapped in transaction

Browse Source 
- solving the golang problem: 'sql: converting Exec argument #2's type: uint64 values with high bit set are not supported'
This commit is contained in:
Shlomi Noach 2016-08-18 13:31:53 +02:00
parent d9ae2f3942
commit 74593ec010
2 changed files with 18 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
go/logic/applier.go
View File

@ -854,31 +854,32 @@ func (this *Applier) ApplyDMLEventQuery(dmlEvent *binlog.BinlogDMLEvent) error {
return err return err
} }
// TODO The below is commented, and is in preparation for transactional writes on the ghost tables. // TODO The below is in preparation for transactional writes on the ghost tables.
// Such writes would be, for example: // Such writes would be, for example:
// - prepended with sql_mode setup // - prepended with sql_mode setup
// - prepended with time zone setup
// - prepended with SET SQL_LOG_BIN=0 // - prepended with SET SQL_LOG_BIN=0
// - prepended with SET FK_CHECKS=0 // - prepended with SET FK_CHECKS=0
// etc. // etc.
// //
// Current known problem: https://github.com/golang/go/issues/9373 -- bitint unsigned values, not supported in database/sql // a known problem: https://github.com/golang/go/issues/9373 -- bitint unsigned values, not supported in database/sql
// is solved by silently converting unsigned bigints to string values.
// //
// err = func() error { err = func() error {
// tx, err := this.db.Begin() tx, err := this.db.Begin()
// if err != nil { if err != nil {
// return err return err
// } }
// if _, err := tx.Exec(query, args...); err != nil { if _, err := tx.Exec(query, args...); err != nil {
// return err return err
// } }
// if err := tx.Commit(); err != nil { if err := tx.Commit(); err != nil {
// return err return err
// } }
// return nil return nil
// }() }()
_, err = sqlutils.Exec(this.db, query, args...)
if err == nil { if err == nil {
atomic.AddInt64(&this.migrationContext.TotalDMLEventsApplied, 1) atomic.AddInt64(&this.migrationContext.TotalDMLEventsApplied, 1)
} }

2
go/sql/builder.go
View File

@ -47,7 +47,7 @@ func fixArgType(arg interface{}, isUnsigned bool) interface{} {
return uint32(i) return uint32(i)
} }
if i, ok := arg.(int64); ok { if i, ok := arg.(int64); ok {
return uint64(i) return strconv.FormatUint(uint64(i), 10)
} }
if i, ok := arg.(int); ok { if i, ok := arg.(int); ok {
return uint(i) return uint(i)