Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 3 additions & 2 deletions client/FileBinlogReader.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,8 +11,9 @@ import (
"strings"
"time"

"github.com/SDHM/sqlregret/binlogevent"
. "github.com/SDHM/sqlregret/mysql"
"sqlregret/binlogevent"
. "sqlregret/mysql"

"github.com/cihub/seelog"
)

Expand Down
4 changes: 2 additions & 2 deletions client/FormatDescriptionLogEvent.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,8 +6,8 @@ import (
"strconv"
"strings"

. "github.com/SDHM/sqlregret/binlogevent"
"github.com/SDHM/sqlregret/mysql"
. "sqlregret/binlogevent"
"sqlregret/mysql"
)

const (
Expand Down
2 changes: 1 addition & 1 deletion client/IBinlogReader.go
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package client

import (
. "github.com/SDHM/sqlregret/mysql"
. "sqlregret/mysql"
)

type IBinlogReader interface {
Expand Down
2 changes: 1 addition & 1 deletion client/LogHeader.go
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package client

import (
"github.com/SDHM/sqlregret/mysql"
"sqlregret/mysql"
)

type LogHeader struct {
Expand Down
9 changes: 5 additions & 4 deletions client/LogParser.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,10 +8,11 @@ import (
"strings"
"time"

. "github.com/SDHM/sqlregret/binlogevent"
"github.com/SDHM/sqlregret/config"
"github.com/SDHM/sqlregret/mysql"
"github.com/SDHM/sqlregret/protocol"
. "sqlregret/binlogevent"

"sqlregret/config"
"sqlregret/mysql"
"sqlregret/protocol"
"github.com/cihub/seelog"
"github.com/golang/protobuf/proto"
)
Expand Down
5 changes: 3 additions & 2 deletions client/NetBinlogReader.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,8 +10,9 @@ import (
"strings"
"time"

"github.com/SDHM/sqlregret/binlogevent"
. "github.com/SDHM/sqlregret/mysql"
"sqlregret/binlogevent"
. "sqlregret/mysql"

"github.com/cihub/seelog"
)

Expand Down
4 changes: 2 additions & 2 deletions client/QueryLogEvent.go
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package client

import (
. "github.com/SDHM/sqlregret/binlogevent"
"github.com/SDHM/sqlregret/mysql"
. "sqlregret/binlogevent"
"sqlregret/mysql"
)

type QueryLogEvent struct {
Expand Down
2 changes: 1 addition & 1 deletion client/RotateLogEvent.go
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package client

import (
"github.com/SDHM/sqlregret/mysql"
"sqlregret/mysql"
)

type RotateLogEvent struct {
Expand Down
2 changes: 1 addition & 1 deletion client/RowsQueryEvent.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
package client

import "github.com/SDHM/sqlregret/mysql"
import "sqlregret/mysql"

type RowsQueryEvent struct {
queryString string
Expand Down
6 changes: 3 additions & 3 deletions client/SkipParse.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,9 +5,9 @@ import (
"os"
"time"

"github.com/SDHM/sqlregret/binlogevent"
"github.com/SDHM/sqlregret/config"
"github.com/SDHM/sqlregret/protocol"
"sqlregret/binlogevent"
"sqlregret/config"
"sqlregret/protocol"
)

// 返回为false 表示不过滤 返回为true 表示过滤
Expand Down
2 changes: 1 addition & 1 deletion client/TableMapLogEvent.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
package client

import . "github.com/SDHM/sqlregret/mysql"
import . "sqlregret/mysql"

type Column struct {
ColumnType byte
Expand Down
2 changes: 1 addition & 1 deletion client/TableMetaCache.go
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package client

import (
"github.com/SDHM/sqlregret/mysql"
"sqlregret/mysql"
)

type TableMetaCache struct {
Expand Down
2 changes: 1 addition & 1 deletion client/Transaction.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ package client
import (
"fmt"

"github.com/SDHM/sqlregret/config"
"sqlregret/config"
)

//收集事务消息
Expand Down
5 changes: 3 additions & 2 deletions client/previous_gtids_event.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,9 @@ package client
import (
"fmt"

. "github.com/SDHM/sqlregret/binlogevent"
"github.com/SDHM/sqlregret/mysql"
. "sqlregret/binlogevent"

"sqlregret/mysql"
)

type Previous_Gtids_Log_Event struct {
Expand Down
4 changes: 2 additions & 2 deletions instance/Instance.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,8 +5,8 @@ import (
"runtime"
"sync"

"github.com/SDHM/sqlregret/config"
"github.com/SDHM/sqlregret/parser"
"sqlregret/config"
"sqlregret/parser"
)

type Instance struct {
Expand Down
5 changes: 3 additions & 2 deletions main/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,8 +10,9 @@ import (
"strings"
"time"

"github.com/SDHM/sqlregret/config"
"github.com/SDHM/sqlregret/instance"
"sqlregret/config"
"sqlregret/instance"

"github.com/cihub/seelog"
)

Expand Down
6 changes: 3 additions & 3 deletions main/sqlregret.conf
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@
"masterPort" : 3306,
"masterAddress" : "127.0.0.1",
"slaveId" : 5,
"dbPassword" : "123456",
"defaultDbName" : "app",
"dbUsername" : "reader"
"dbPassword" : "",
"defaultDbName" : "test",
"dbUsername" : "root"
}
7 changes: 4 additions & 3 deletions parser/EventParser.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,9 +5,10 @@ import (
"fmt"
"time"

"github.com/SDHM/sqlregret/client"
"github.com/SDHM/sqlregret/config"
"github.com/SDHM/sqlregret/lifecycle"
"sqlregret/client"
"sqlregret/config"
"sqlregret/lifecycle"

"github.com/cihub/seelog"
)

Expand Down