fix ExecuteWriteSql

liuxiaolong

2020-05-14 62a20c839009db883a9056a095ebc9cbcee339d5

 sync.go

@@ -5,6 +5,7 @@
   sdb "basic.com/Android/syncdb.git"
   "basic.com/valib/logger.git"
   "encoding/json"
   "fmt"
   "strings"
)
type ReceiveSqlInterface2 interface {
@@ -15,7 +16,7 @@
   sdb.RegisterReceiveSqlInterface(c)
}

func InitAgent(devID string) bool {
/*func InitAgent(devID string) bool {
   var nodeIps []string
   sqlFindAllCluster := string("select * from " + dBNameCluster)
   clusters, err := sdb.ExecuteQuerySql([]string{sqlFindAllCluster})
@@ -42,7 +43,7 @@
   }

   return true
}
}*/

func SyncInit(clusterID string, password string, nodeID string, strAddrs string, snapshotPath string) bool {
   var ips []string
@@ -151,12 +152,12 @@
      sqls = append(sqls, delSql)
   }

   var dumpSqls *[]string
   dumpSqls, err := agent.GetTableDataFromCluster(syncTables)
   if dumpSqls != nil {
      for _, dumpSql := range *dumpSqls {
         sqls = append(sqls, dumpSql)
      }
   fmt.Println("len(dumpSqls):", len(*dumpSqls), "err:",err)
   if dumpSqls != nil && len(*dumpSqls) > 0 {
      sqls = append(sqls, *dumpSqls)
   } else {
      return false
   }

   logger.Debug("成功获取集群中数据,err:",err)
@@ -197,8 +198,7 @@

func UpdateClusterName(clusterName, clusterID string) bool {
   sql := string("update cluster set cluster_name='" + clusterName + "' where cluster_id='" + clusterID + "'")
   _, err := sdb.ExecuteWriteSql([]string{sql}, false)
   if err != nil {
   if !sdb.DbHandle.Execute(sql) {
      return false
   }

@@ -216,10 +216,9 @@
      agent.Shutdown()
      agent = nil

      sqls := []string{"delete from cluster_node", "delete from cluster"}
      sqls := "delete from cluster_node;delete from cluster;"

      _, err = sdb.ExecuteWriteSql(sqls, false)
      if err != nil {
      if !sdb.DbHandle.Execute(sqls) {
         return false
      }
   }