Commit 5fe39203 authored by 张宇迪's avatar 张宇迪

update

parent ce045097
...@@ -214,10 +214,10 @@ COMMIT WORK; ...@@ -214,10 +214,10 @@ COMMIT WORK;
sql3 := fmt.Sprintf(`BEGIN WORK; sql3 := fmt.Sprintf(`BEGIN WORK;
LOCK TABLE service_count_person IN SHARE ROW EXCLUSIVE MODE; LOCK TABLE service_count_person IN SHARE ROW EXCLUSIVE MODE;
INSERT INTO service_count_person ( user_id,date,count) VALUES INSERT INTO service_count_person ( user_id,date,count) VALUES
(%d,'%s',%d) ON conflict (user_id,date) DO ('%s','%s',%d) ON conflict (user_id,date) DO
UPDATE SET count=(service_count_person.count+1); UPDATE SET count=(service_count_person.count+1);
COMMIT WORK; COMMIT WORK;
`, proxyData.Service_id, date, 1) `, proxyData.User_id, date, 1)
_, err = session.SQL(sql3).Execute() _, err = session.SQL(sql3).Execute()
if err != nil { if err != nil {
fmt.Println("error****** service_count_person 更新失败:" + err.Error()) fmt.Println("error****** service_count_person 更新失败:" + 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