| | |
| | | |
| | | 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 |
| | | } |
| | | |
| | |
| | | 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 |
| | | } |
| | | } |