基于serf的数据库同步模块库
liuxiaolong
2019-08-14 df17d827d53a89a19c43816d3a633ba49f9105ae
UserEvent exec sql use gorm
1个文件已修改
13 ■■■■■ 已修改文件
agent.go 13 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
agent.go
@@ -119,14 +119,11 @@
    switch ev := event.(type) {
    case serf.UserEvent:
        fmt.Println(string(ev.Payload))
        var tmpstringslice []string
        tmpstringslice = append(tmpstringslice, string(ev.Payload))
        fmt.Println(tmpstringslice)
        results, err := ExecuteWriteSql(tmpstringslice)
        for _, result := range results {
            fmt.Println(result, "results err: ", err)
        }
        var sqlArr []string
        sqlArr = append(sqlArr, string(ev.Payload))
        //results, err := ExecuteWriteSql(sqlArr)
        flag, _ := ExecuteSqlByGorm(sqlArr)
        fmt.Println("userEvent exec ",sqlArr,",Result:",flag)
    case *serf.Query: