diff --git a/reader/enhanced_reader.go b/reader/enhanced_reader.go index ece367f..fc3d754 100644 --- a/reader/enhanced_reader.go +++ b/reader/enhanced_reader.go @@ -4,7 +4,7 @@ import ( "context" "database/sql" - _ "github.com/localhots/mysql" // MySQL driver + _ "github.com/go-sql-driver/mysql" // MySQL driver "github.com/juju/errors" "github.com/localhots/bocadillo/binlog" diff --git a/reader/reader.go b/reader/reader.go index 1fc05b8..3e6eac1 100644 --- a/reader/reader.go +++ b/reader/reader.go @@ -67,7 +67,7 @@ func (r *Reader) ReadEvent() (*Event, error) { return nil, errors.Annotate(err, "read next event") } - evt := Event{Format: r.format} + evt := Event{Format: r.format, Offset: r.state.Offset} if err := evt.Header.Decode(connBuff, r.format); err != nil { return nil, errors.Annotate(err, "decode event header") } diff --git a/tests/integration_test.go b/tests/integration_test.go index 7cad2ab..7d06bf3 100644 --- a/tests/integration_test.go +++ b/tests/integration_test.go @@ -7,7 +7,7 @@ import ( "strconv" "testing" - _ "github.com/localhots/mysql" + _ "github.com/go-sql-driver/mysql" "github.com/localhots/bocadillo/binlog" "github.com/localhots/bocadillo/reader"