8000 [docker_push][docker_debug_push][skip_build] · sumeetchhetri/ffead-cpp@4fd2e4e · GitHub
[go: up one dir, main page]
Skip to content

Commit 4fd2e4e

Browse files
sumeetchhetrisumeetchhetri
committed
[docker_push][docker_debug_push][skip_build]
1 parent aad0799 commit 4fd2e4e

File tree

2 files changed

+21
-15
lines changed

2 files changed

+21
-15
lines changed

‎web/te-benchmark-um-pq-async/src/TeBkUmLpqAsync.cpp

Lines changed: 16 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -200,10 +200,13 @@ void TeBkUmLpqAsyncRouter::updatesAsyncChQ(void* ctx, bool status, std::string q
200200
std::vector<TeBkUmLpqAsyncWorld>* vec = (std::vector<TeBkUmLpqAsyncWorld>*)req->d;
201201

202202
std::stringstream ss;
203-
ss << "update world as t set randomnumber = c.randomnumber from (values";
203+
//ss << "update world as t set randomnumber = c.randomnumber from (values";
204204

205205
std::vector<LibpqParam> pars;
206206

207+
LibpqDataSourceImpl* sqli = req->sqli;
208+
209+
void* areq = NULL;
207210
int queryCount = (int)vec->size();
208211
for (int c = 0; c < queryCount; ++c) {
209212
int newRandomNumber = rand() % 10000 + 1;
@@ -214,14 +217,20 @@ void TeBkUmLpqAsyncRouter::updatesAsyncChQ(void* ctx, bool status, std::string q
214217
}
215218
}
216219
vec->at(c).setRandomNumber(newRandomNumber);
217-
ss << "(" << vec->at(c).getId() << "," << newRandomNumber << ")";
218-
if(c!=queryCount-1) {
219-
ss << ",";
220+
if(areq==NULL) {
221+
areq = sqli->beginAsync(areq);
222+
} else {
223+
sqli->beginAsync(areq);
220224
}
225+
ss.str(std::string());
226+
ss << "update world set randomnumber = " << newRandomNumber << " where id = " << vec->at(c).getId();
227+
sqli->executeUpdateQueryAsync(ss.str(), pars, NULL, NULL, areq, false);
228+
sqli->commitAsync(areq);
229+
/*if(c!=queryCount-1) {
230+
ss << ",";
231+
}*/
221232
}
222-
ss << ") as c(id, randomnumber) where c.id = t.id";
223-
224-
LibpqDataSourceImpl* sqli = req->sqli;
233+
//ss << ") as c(id, randomnumber) where c.id = t.id";
225234

226235
AsyncReq* ar = new AsyncReq;
227236
ar->sif = req->sif;
@@ -231,9 +240,6 @@ void TeBkUmLpqAsyncRouter::updatesAsyncChQ(void* ctx, bool status, std::string q
231240
req->sif = NULL;
232241

233242
try {
234-
void* areq = sqli->beginAsync();
235-
sqli->executeUpdateQueryAsync(ss.str(), pars, NULL, NULL, areq, false);
236-
sqli->commitAsync(areq);
237243
sqli->completeAsync(areq, ar, &TeBkUmLpqAsyncRouter::updatesAsyncChU);
238244
} catch(const std::exception& e) {
239245
throw e;

‎web/te-benchmark-um-pq/src/TeBkUmLpq.cpp

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -242,7 +242,7 @@ void TeBkUmLpqRouter::updatesMulti(const char* q, int ql, std::vector<TeBkUmLpqW
242242

243243
try {
244244
std::stringstream ss, ssq;
245-
ss << "begin;update world as t set randomnumber = c.randomnumber from (values";
245+
//ss << "begin;update world as t set randomnumber = c.randomnumber from (values";
246246

247247
UpdQrData updt;
248248
updt.wlist = &wlst;
@@ -256,7 +256,7 @@ void TeBkUmLpqRouter::updatesMulti(const char* q, int ql, std::vector<TeBkUmLpqW
256256
}
257257

258258
sqli->executeMultiQuery(ssq.str(), &updt, &TeBkUmLpqRouter::updatesMultiUtil, &TeBkUmLpqRouter::updatesMultiUtilCh);
259-
ss << ") as c(id, randomnumber) where c.id = t.id;commit";
259+
//ss << ") as c(id, randomnumber) where c.id = t.id;commit";
260260

261261
if(!updt.status) {
262262
return;
@@ -289,11 +289,11 @@ void TeBkUmLpqRouter::updatesMultiUtil(void* ctx, int rn, std::vector<LibpqRes>&
289289
}
290290
w.setRandomNumber(newRandomNumber);
291291
updt->wlist->push_back(w);
292-
*ss << "(" << w.getId() << "," << w.getRandomNumber() << ")";
293-
updt->queryCount--;
292+
*ss << "begin;update world set randomnumber = " << newRandomNumber << " where id = " << w.getId() << ";commit;";
293+
/*updt->queryCount--;
294294
if(updt->queryCount>0) {
295295
*ss << ",";
296-
}
296+
}*/
297297
}
298298
void TeBkUmLpqRouter::updatesMultiUtilCh(void* ctx, bool status, std::string query, int counter) {
299299
UpdQrData* updt = (UpdQrData*)ctx;

0 commit comments

Comments
 (0)
0