fix: canal can't connect to mysql

.github/workflows/go.yml

@@ -19,7 +19,7 @@ jobs:
     - name: Set up Go
       uses: actions/setup-go@v4
       with:
-        go-version: '1.20'
+        go-version: '1.20.x'
 
     - name: Build
       run: go build -v ./...

cdcobserver.go

@@ -54,8 +54,10 @@ func (ob *CDCObserver) Start(ctx context.Context) error {
 	cfg.Addr = fmt.Sprintf("%s:%s", constant.DatabaseHost, port)
 	cfg.User = constant.DatabaseUsername
 	cfg.Password = constant.DatabasePassword
-	cfg.Dump.TableDB = constant.DatabaseName
-	cfg.Dump.Tables = []string{}
+	// Exclude mysql system tables
+	cfg.ExcludeTableRegex = []string{"mysql\\..*"}
+	// Disable dump by setting Dump.ExecutionPath to empty string
+	cfg.Dump.ExecutionPath = ""
 
 	c, err := canal.NewCanal(cfg)
 	if err != nil {

cdcobserver_test.go

@@ -3,6 +3,7 @@ package cdcobserver
 import (
 	"context"
 	"testing"
+	"time"
 )
 
 func TestSyncCDCChangeFromDatabase(t *testing.T) {
@@ -11,14 +12,23 @@ func TestSyncCDCChangeFromDatabase(t *testing.T) {
 	if err != nil {
 		t.Fatal(err)
 	}
+
+	defer func() {
+		cdcObserver.dc.RemoveAllContainers(ctx)
+	}()
+
+	ch := make(chan struct{})
+
+	go func() {
+		time.Sleep(5 * time.Second)
+		cdcObserver.Close(ctx)
+		close(ch)
+	}()
+
 	err = cdcObserver.Start(ctx)
 	if err != nil {
 		t.Fatal(err)
 	}
 	t.Log("start to listen the change event from local MySQL")
-
-	err = cdcObserver.Close(ctx)
-	if err != nil {
-		t.Fatal(err)
-	}
+	<-ch
 }