ch to Forward

liuxiaolong

2020-05-13 747d5e974957607043846ee872467a542d284ecf

ch to Forward

 agent.go

@@ -131,11 +131,11 @@
}

type DbHandler interface {
    Execute(sql string) bool
    Forward(sql string) bool
}

type DbDumpHandler interface {
    Dump(tables string) string
    Forward(tables string) string
}

//数据库execute句柄
@@ -213,7 +213,7 @@
            var tableNames []string
            json.Unmarshal(ev.Payload, &tableNames)

            dumpData := dbDumpH.Dump(strings.Join(tableNames, ","))
            dumpData := dbDumpH.Forward(strings.Join(tableNames, ","))

            bytesReturn, _ := json.Marshal(dumpData)
            //fmt.Println("results: ", bytesReturn)