Skip to content

Commit 9cc8f04

Browse files
committed
Update insbench
1 parent 36e27a3 commit 9cc8f04

File tree

1 file changed

+7
-4
lines changed

1 file changed

+7
-4
lines changed

src/bin/insbench/insbench.cpp

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,8 @@ void* inserter(void* arg)
9898
} else {
9999
con.prepare("insert", "insert into t (select generate_series($1::integer,$2::integer),ceil(random()*1000000000),ceil(random()*1000000000),ceil(random()*1000000000),ceil(random()*1000000000),ceil(random()*1000000000),ceil(random()*1000000000),ceil(random()*1000000000),ceil(random()*1000000000))");
100100
}
101-
101+
time_t curr = currTimestamp;
102+
102103
for (int i = 0; i < cfg.nIterations; i++)
103104
{
104105
work txn(con);
@@ -109,8 +110,9 @@ void* inserter(void* arg)
109110
txn.prepared("insert")(getCurrentTime())(random())(random())(random())(random())(random())(random())(random())(random()).exec();
110111
}
111112
} else {
112-
currTimestamp = i*cfg.transactionSize;
113-
txn.prepared("insert")(i*cfg.transactionSize)((i+1)*cfg.transactionSize-1).exec();
113+
txn.prepared("insert")(curr)(curr+cfg.transactionSize-1).exec();
114+
curr += cfg.transactionSize;
115+
currTimestamp = curr;
114116
}
115117
txn.commit();
116118
}
@@ -234,7 +236,8 @@ int main (int argc, char* argv[])
234236
"\t-w N\tnumber of inserters (1)\n"
235237
"\t-u N\tindex update interval (0)\n"
236238
"\t-n N\tnumber of iterations (10000)\n"
237-
"\t-i N\tnumber of indexes (8)\n"
239+
"\t-x N\tnumber of indexes (8)\n"
240+
"\t-i N\tinitial table size (1000000)\n"
238241
"\t-q\tuse system time and libpq\n"
239242
"\t-p\tno primary key\n"
240243
"\t-c STR\tdatabase connection string\n");

0 commit comments

Comments
 (0)