syncSql add owner

liuxiaolong

2019-08-14 e302974b44a1235c7e05594193c804df994b9194

syncSql add owner

 agent.go

@@ -118,12 +118,18 @@

    switch ev := event.(type) {
    case serf.UserEvent:
        fmt.Println(string(ev.Payload))
        var sqlArr []string
        sqlArr = append(sqlArr, string(ev.Payload))
        //fmt.Println(string(ev.Payload))
        var sqlUe SqlUserEvent
        err := json.Unmarshal(ev.Payload, &sqlUe)
        if err !=nil {
            fmt.Println("sqlUe unmarshal err:",err)
            return
        }
        if sqlUe.Owner != a.conf.NodeName {
        //results, err := ExecuteWriteSql(sqlArr)
        flag, _ := ExecuteSqlByGorm(sqlArr)
        fmt.Println("userEvent exec ",sqlArr,",Result:",flag)
            flag, _ := ExecuteSqlByGorm(sqlUe.Sql)
            fmt.Println("userEvent exec ",sqlUe.Sql,",Result:",flag)
        }

    case *serf.Query:

@@ -478,10 +484,24 @@

}

type SqlUserEvent struct {
    Owner string `json:"owner"`
    Sql []string `json:"sql"`
}

//SyncSql boardcast sql to cluster
func (a *Agent) SyncSql(sqlOp string) {
func (a *Agent) SyncSql(sqlOp []string) {
    // event : use to send command to operate db.
    err := a.UserEvent("SyncSql", []byte(sqlOp), false)
    var sqlUe = SqlUserEvent{
        Owner: a.conf.NodeName,
        Sql: sqlOp,
    }
    ueB, err := json.Marshal(sqlUe)
    if err !=nil {
        fmt.Println("sqlUE marshal err:",err)
        return
    }
    err = a.UserEvent("SyncSql", ueB, false)
    if err == nil || !strings.Contains(err.Error(), "cannot contain") {
        fmt.Println("err: ", err)
    }