Commit 6419223e authored by 张宇迪's avatar 张宇迪

添加协程,更新表加锁

parent decd1aec
......@@ -202,9 +202,9 @@ COMMIT WORK; `, proxyData.Service_id, proxyData.Apply_id)
LOCK TABLE service_daliy_count IN SHARE ROW EXCLUSIVE MODE;
INSERT INTO service_daliy_count ( service_id,date,count) VALUES
(%d,'%s',%d) ON conflict (service_id,date) DO
UPDATE SET service_id =%d ,date='%s',count=(service_daliy_count.count+1);
UPDATE SET count=(service_daliy_count.count+1);
COMMIT WORK;
`, proxyData.Service_id, date, 1, proxyData.Service_id, date)
`, proxyData.Service_id, date, 1)
_, err = session.SQL(sql).Execute()
if err != nil {
fmt.Println("error******service_daliy_count更新失败:" + err.Error())
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment