syncdb.go

longganhua

2019-07-18 fc8d3a64d69d0eb08783d1cbe85bc2b3835a49e8

 command/query.go

@@ -107,6 +107,7 @@
      payload = []byte(args[1])
   }

   fmt.Println("query send len payload", len(payload))
   cl, err := RPCClient(*rpcAddr, *rpcAuth)
   if err != nil {
      c.Ui.Error(fmt.Sprintf("Error connecting to Serf agent: %s", err))
@@ -167,6 +168,7 @@
            break OUTER
         }
         handler.ResponseReceived(r)
         fmt.Println("enter respch: r.payload", r.Payload)

      case <-c.ShutdownCh:
         return 1
@@ -220,16 +222,16 @@
   }

   /**   my self example*/
   fmt.Println("x length is: ", len(payload))
   fmt.Println("x length is: ", payload)

   // // byte to file.
   sdb.Dbconn.Close()
   sdb.Dbconn = nil
   err = ioutil.WriteFile("test.db", payload, 0644)
   err := ioutil.WriteFile("test.db", payload, 0644)
   if err != nil {
      fmt.Println("query byte to file error!", err)
   }
   err := sdb.GetConn()
   err = sdb.GetConn()
   if err != nil {
      fmt.Println("create db conn of test.db error: ", err)
   }