liuxiaolong
2020-05-14 62a20c839009db883a9056a095ebc9cbcee339d5
fix ExecuteWriteSql
1个文件已修改
8 ■■■■■ 已修改文件
sync.go 8 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
sync.go
@@ -198,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
    }
@@ -217,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
        }
    }