sql version => test the case of online

collect.go

@@ -59,8 +59,9 @@ func collectCopyCountLiveAnchors(cxt *WorkerContext) {
 					}
 					c.CountMap = string(data)
 
-					err = T.CountLiveAnchors.Create(c).Error
-
+					insertsql := fmt.Sprintf("insert ignore into %s(uid, is_counted, count_map, create_at) values(?,?,?,?)", Tables.CountLiveAnchors)
+					_, err = db.Exec(insertsql, c.UID, c.IsCounted, c.CountMap, c.CreateAt)
+					if err != nil {
 						switch merr := err.(*mysql.MySQLError); merr.Number {
 						case 1062:
 
@@ -69,6 +70,7 @@ func collectCopyCountLiveAnchors(cxt *WorkerContext) {
 						}
 					}
 				}
+			}
 		})
 
 		ps.Wait(time.Second * 5)