| | |
|---|
| | | return |
|---|
| | | } |
|---|
| | | if sqlUe.Owner != a.conf.NodeName { |
|---|
| | | //ExecuteWriteSql(sqlUe.Sql, true) |
|---|
| | | //flag, _ := ExecuteSqlByGorm(sqlUe.Sql) |
|---|
| | | //fmt.Println("userEvent exec 1 ", sqlUe.Sql, ",Result:", results) |
|---|
| | | if receiveSqlInterface != nil && sqlUe.Sql !=nil && len(sqlUe.Sql) > 0 { |
|---|
| | | receiveSqlInterface.Forward(sqlUe.Sql[0]) |
|---|
| | | } |
|---|
| | |
|---|
| | | leaveMember := ev.Members[0] |
|---|
| | | leaveSql := "delete from cluster_node where node_id='" + leaveMember.Name + "'" |
|---|
| | | //fmt.Println("leaveSql:", leaveSql) |
|---|
| | | _, err := ExecuteWriteSql([]string{leaveSql}, false) |
|---|
| | | if err != nil { |
|---|
| | | //fmt.Printf("err: %s\n", err) |
|---|
| | | if !DbHandle.Execute(leaveSql) { |
|---|
| | | fmt.Println("DbHandle.Execute ret false") |
|---|
| | | } |
|---|
| | | |
|---|
| | | //fmt.Println("EventMemberLeave,current Members:", ev.Members) |
|---|
