Commit ce045097 authored by 张宇迪's avatar 张宇迪

添加协程,更新表加锁

parent 6419223e
...@@ -211,6 +211,19 @@ COMMIT WORK; ...@@ -211,6 +211,19 @@ COMMIT WORK;
session.Rollback() session.Rollback()
return return
} }
sql3 := fmt.Sprintf(`BEGIN WORK;
LOCK TABLE service_count_person IN SHARE ROW EXCLUSIVE MODE;
INSERT INTO service_count_person ( user_id,date,count) VALUES
(%d,'%s',%d) ON conflict (user_id,date) DO
UPDATE SET count=(service_count_person.count+1);
COMMIT WORK;
`, proxyData.Service_id, date, 1)
_, err = session.SQL(sql3).Execute()
if err != nil {
fmt.Println("error****** service_count_person 更新失败:" + err.Error())
session.Rollback()
return
}
session.Commit() session.Commit()
//查询service_daliy_count 表有更新没有插入 //查询service_daliy_count 表有更新没有插入
return return
......
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