longganhua
2019-07-18 869c0b5404d830778d9c78ddd6a03e391e33fd1e
modify query.go
1个文件已修改
18 ■■■■■ 已修改文件
command/query.go 18 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
command/query.go
@@ -3,9 +3,11 @@
import (
    "flag"
    "fmt"
    "io/ioutil"
    "strings"
    "time"
    sdb "basic.com/pubsub/syncdb.git/db"
    "github.com/hashicorp/serf/client"
    "github.com/hashicorp/serf/cmd/serf/command/agent"
    "github.com/mitchellh/cli"
@@ -217,6 +219,22 @@
        payload = payload[:n-1]
    }
    /**   my self example*/
    fmt.Println("x length is: ", len(payload))
    // // byte to file.
    sdb.Dbconn.Close()
    sdb.Dbconn = nil
    err = ioutil.WriteFile("test.db", payload, 0644)
    if err != nil {
        fmt.Println("query byte to file error!", err)
    }
    err := sdb.GetConn()
    if err != nil {
        fmt.Println("create db conn of test.db error: ", err)
    }
    /*   my self example*/
    t.ui.Info(fmt.Sprintf("Response from '%s': %s", r.From, payload))
}