添加晓龙因业务而增加的更新

chenshijun

2019-09-04 aa3f73eef78b96c8f1a53336c5d6459098907a6b

添加晓龙因业务而增加的更新

 agent.go

@@ -14,7 +14,7 @@
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package main
package syncdb

import (
    "context"
@@ -117,14 +117,17 @@

    switch ev := event.(type) {
    case serf.UserEvent:
        var sqlUe SqlUserEvent
        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)
        err := json.Unmarshal(ev.Payload, &sqlUe)
        if err !=nil {
            fmt.Println("sqlUe unmarshal err:",err)
            return
        }
        if sqlUe.Owner != a.conf.NodeName {
            results, _ := ExecuteWriteSql(sqlUe.Sql)
            //flag, _ := ExecuteSqlByGorm(sqlUe.Sql)
            fmt.Println("userEvent exec ",sqlUe.Sql,",Result:",results)
        }

    case *serf.Query:
@@ -185,6 +188,19 @@
            //var res []*Rows
            //json.Unmarshal(bytesReturn, &res)
        }
        case serf.MemberEvent:
            if event.EventType() == serf.EventMemberLeave {
                if ev.Members !=nil && len(ev.Members) ==1 {
                    leaveMember := ev.Members[0]
                    leaveSql := "delete from cluster_node where node_id='"+leaveMember.Name+"'"
                    fmt.Println("leaveSql:",leaveSql)
                    //ExecuteSqlByGorm([]string{ leaveSql })

                    fmt.Println("EventMemberLeave,current Members:",ev.Members)
                }
                return
            }


    default:
        fmt.Printf("Unknown event type: %s\n", ev.EventType().String())
@@ -405,10 +421,23 @@
    }()
}

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", []byte(ueB), false)
    if err == nil || !strings.Contains(err.Error(), "cannot contain") {
        fmt.Println("err: ", err)
    }
@@ -480,8 +509,8 @@

    n, err := a.Agent.Join(nodes, true)
    if err != nil || n == 0 {
        a.Stop()
        fmt.Println("Stop node")
        //a.Stop()
        //fmt.Println("Stop node")
        return fmt.Errorf("Error Encrypt Key!")
    }


 agent_test.go

@@ -14,7 +14,7 @@
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package main
package syncdb

import (
    "context"

 config.go

@@ -14,7 +14,7 @@
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package main
package syncdb

import (
    "fmt"
@@ -118,6 +118,11 @@
    if c.Mode == ModeCluster && c.RetryMaxAttempts <= 0 {
        c.RetryMaxAttempts = retryMaxAttempts
    }

    serfConf.QueryResponseSizeLimit = c.QueryResponseSizeLimit
    serfConf.QuerySizeLimit = c.QuerySizeLimit
    serfConf.UserEventSizeLimit = c.UserEventSizeLimit

    return serfConf, nil
}


 db.go

@@ -1,6 +1,6 @@
// Package db exposes a lightweight abstraction over the SQLite code.
// It performs some basic mapping of lower-level types to rqlite types.
package main
package syncdb

import (
    "database/sql/driver"

 db_test.go

@@ -1,4 +1,4 @@
package main
package syncdb

import (
    "encoding/json"

 dbself.go

@@ -1,4 +1,4 @@
package main
package syncdb

import (
    "errors"

 searcher.go

@@ -1,4 +1,4 @@
package main
package syncdb

import (
    "encoding/json"