c8h4/postgresql
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

Change pgbench to use the table names pgbench_accounts, pgbench_branches,

Browse source 
pgbench_history, and pgbench_tellers, rather than just accounts, branches,
history, and tellers.  This is to prevent accidental conflicts with real
application tables, as has been reported to happen at least once.  Also
remove the automatic "SET search_path = public" that it did at startup,
as this seems to restrict testing flexibility without actually buying much.
Per proposal by Joshua Drake and ensuing discussion.

Joshua Drake and Tom Lane
This commit is contained in:
Tom Lane 2009-05-07 22:01:18 +00:00
parent fdd48b1852
commit 48caf91b66
2 changed files with 94 additions and 91 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

104
contrib/pgbench/pgbench.c
View file

@ -4,7 +4,7 @@
* A simple benchmark program for PostgreSQL * A simple benchmark program for PostgreSQL
* Originally written by Tatsuo Ishii and enhanced by many contributors. * Originally written by Tatsuo Ishii and enhanced by many contributors.
* *
* $PostgreSQL: pgsql/contrib/pgbench/pgbench.c,v 1.85 2009/02/27 09:30:21 petere Exp $ * $PostgreSQL: pgsql/contrib/pgbench/pgbench.c,v 1.86 2009/05/07 22:01:18 tgl Exp $
* Copyright (c) 2000-2009, PostgreSQL Global Development Group * Copyright (c) 2000-2009, PostgreSQL Global Development Group
* ALL RIGHTS RESERVED; * ALL RIGHTS RESERVED;
* *
@ -76,8 +76,8 @@ int nxacts = 0; /* number of transactions per client */
int duration = 0; /* duration in seconds */ int duration = 0; /* duration in seconds */
/* /*
* scaling factor. for example, scale = 10 will make 1000000 tuples of * scaling factor. for example, scale = 10 will make 1000000 tuples in
* accounts table. * pgbench_accounts table.
*/ */
int scale = 1; int scale = 1;
@ -181,11 +181,11 @@ static char *tpc_b = {
"\\setrandom tid 1 :ntellers\n" "\\setrandom tid 1 :ntellers\n"
"\\setrandom delta -5000 5000\n" "\\setrandom delta -5000 5000\n"
"BEGIN;\n" "BEGIN;\n"
"UPDATE accounts SET abalance = abalance + :delta WHERE aid = :aid;\n" "UPDATE pgbench_accounts SET abalance = abalance + :delta WHERE aid = :aid;\n"
"SELECT abalance FROM accounts WHERE aid = :aid;\n" "SELECT abalance FROM pgbench_accounts WHERE aid = :aid;\n"
"UPDATE tellers SET tbalance = tbalance + :delta WHERE tid = :tid;\n" "UPDATE pgbench_tellers SET tbalance = tbalance + :delta WHERE tid = :tid;\n"
"UPDATE branches SET bbalance = bbalance + :delta WHERE bid = :bid;\n" "UPDATE pgbench_branches SET bbalance = bbalance + :delta WHERE bid = :bid;\n"
"INSERT INTO history (tid, bid, aid, delta, mtime) VALUES (:tid, :bid, :aid, :delta, CURRENT_TIMESTAMP);\n" "INSERT INTO pgbench_history (tid, bid, aid, delta, mtime) VALUES (:tid, :bid, :aid, :delta, CURRENT_TIMESTAMP);\n"
"END;\n" "END;\n"
}; };
@ -199,9 +199,9 @@ static char *simple_update = {
"\\setrandom tid 1 :ntellers\n" "\\setrandom tid 1 :ntellers\n"
"\\setrandom delta -5000 5000\n" "\\setrandom delta -5000 5000\n"
"BEGIN;\n" "BEGIN;\n"
"UPDATE accounts SET abalance = abalance + :delta WHERE aid = :aid;\n" "UPDATE pgbench_accounts SET abalance = abalance + :delta WHERE aid = :aid;\n"
"SELECT abalance FROM accounts WHERE aid = :aid;\n" "SELECT abalance FROM pgbench_accounts WHERE aid = :aid;\n"
"INSERT INTO history (tid, bid, aid, delta, mtime) VALUES (:tid, :bid, :aid, :delta, CURRENT_TIMESTAMP);\n" "INSERT INTO pgbench_history (tid, bid, aid, delta, mtime) VALUES (:tid, :bid, :aid, :delta, CURRENT_TIMESTAMP);\n"
"END;\n" "END;\n"
}; };
@ -209,7 +209,7 @@ static char *simple_update = {
static char *select_only = { static char *select_only = {
"\\set naccounts 100000 * :scale\n" "\\set naccounts 100000 * :scale\n"
"\\setrandom aid 1 :naccounts\n" "\\setrandom aid 1 :naccounts\n"
"SELECT abalance FROM accounts WHERE aid = :aid;\n" "SELECT abalance FROM pgbench_accounts WHERE aid = :aid;\n"
}; };
/* Connection overhead time */ /* Connection overhead time */
@ -269,8 +269,8 @@ usage(const char *progname)
" -M {simple|extended|prepared}\n" " -M {simple|extended|prepared}\n"
" protocol for submitting queries to server (default: simple)\n" " protocol for submitting queries to server (default: simple)\n"
" -n do not run VACUUM before tests\n" " -n do not run VACUUM before tests\n"
" -N do not update tables \"tellers\" and \"branches\"\n" " -N do not update tables \"pgbench_tellers\" and \"pgbench_branches\"\n"
" -s NUM report scale factor in output\n" " -s NUM report this scale factor in output\n"
" -S perform SELECT-only transactions\n" " -S perform SELECT-only transactions\n"
" -t NUM number of transactions each client runs (default: 10)\n" " -t NUM number of transactions each client runs (default: 10)\n"
" -T NUM duration of benchmark test in seconds\n" " -T NUM duration of benchmark test in seconds\n"
@ -357,8 +357,6 @@ doConnect(void)
return NULL; return NULL;
} }
executeStatement(conn, "SET search_path = public");
return conn; return conn;
} }
@ -1001,8 +999,6 @@ disconnect_all(CState * state)
static void static void
init(void) init(void)
{ {
PGconn *con;
PGresult *res;
/* /*
* Note: TPC-B requires at least 100 bytes per row, and the "filler" * Note: TPC-B requires at least 100 bytes per row, and the "filler"
* fields in these table declarations were intended to comply with that. * fields in these table declarations were intended to comply with that.
@ -1014,22 +1010,24 @@ init(void)
* behavior. * behavior.
*/ */
static char *DDLs[] = { static char *DDLs[] = {
"drop table if exists branches", "drop table if exists pgbench_branches",
"create table branches(bid int not null,bbalance int,filler char(88)) with (fillfactor=%d)", "create table pgbench_branches(bid int not null,bbalance int,filler char(88)) with (fillfactor=%d)",
"drop table if exists tellers", "drop table if exists pgbench_tellers",
"create table tellers(tid int not null,bid int,tbalance int,filler char(84)) with (fillfactor=%d)", "create table pgbench_tellers(tid int not null,bid int,tbalance int,filler char(84)) with (fillfactor=%d)",
"drop table if exists accounts", "drop table if exists pgbench_accounts",
"create table accounts(aid int not null,bid int,abalance int,filler char(84)) with (fillfactor=%d)", "create table pgbench_accounts(aid int not null,bid int,abalance int,filler char(84)) with (fillfactor=%d)",
"drop table if exists history", "drop table if exists pgbench_history",
"create table history(tid int,bid int,aid int,delta int,mtime timestamp,filler char(22))"}; "create table pgbench_history(tid int,bid int,aid int,delta int,mtime timestamp,filler char(22))"
};
static char *DDLAFTERs[] = { static char *DDLAFTERs[] = {
"alter table branches add primary key (bid)", "alter table pgbench_branches add primary key (bid)",
"alter table tellers add primary key (tid)", "alter table pgbench_tellers add primary key (tid)",
"alter table accounts add primary key (aid)"}; "alter table pgbench_accounts add primary key (aid)"
};
PGconn *con;
PGresult *res;
char sql[256]; char sql[256];
int i; int i;
if ((con = doConnect()) == NULL) if ((con = doConnect()) == NULL)
@ -1040,9 +1038,9 @@ init(void)
/* /*
* set fillfactor for branches, tellers and accounts tables * set fillfactor for branches, tellers and accounts tables
*/ */
if ((strstr(DDLs[i], "create table branches") == DDLs[i]) || if ((strstr(DDLs[i], "create table pgbench_branches") == DDLs[i]) ||
(strstr(DDLs[i], "create table tellers") == DDLs[i]) || (strstr(DDLs[i], "create table pgbench_tellers") == DDLs[i]) ||
(strstr(DDLs[i], "create table accounts") == DDLs[i])) (strstr(DDLs[i], "create table pgbench_accounts") == DDLs[i]))
{ {
char ddl_stmt[128]; char ddl_stmt[128];
@ -1058,13 +1056,13 @@ init(void)
for (i = 0; i < nbranches * scale; i++) for (i = 0; i < nbranches * scale; i++)
{ {
snprintf(sql, 256, "insert into branches(bid,bbalance) values(%d,0)", i + 1); snprintf(sql, 256, "insert into pgbench_branches(bid,bbalance) values(%d,0)", i + 1);
executeStatement(con, sql); executeStatement(con, sql);
} }
for (i = 0; i < ntellers * scale; i++) for (i = 0; i < ntellers * scale; i++)
{ {
snprintf(sql, 256, "insert into tellers(tid,bid,tbalance) values (%d,%d,0)" snprintf(sql, 256, "insert into pgbench_tellers(tid,bid,tbalance) values (%d,%d,0)"
,i + 1, i / ntellers + 1); ,i + 1, i / ntellers + 1);
executeStatement(con, sql); executeStatement(con, sql);
} }
@ -1072,14 +1070,14 @@ init(void)
executeStatement(con, "commit"); executeStatement(con, "commit");
/* /*
* fill the accounts table with some data * fill the pgbench_accounts table with some data
*/ */
fprintf(stderr, "creating tables...\n"); fprintf(stderr, "creating tables...\n");
executeStatement(con, "begin"); executeStatement(con, "begin");
executeStatement(con, "truncate accounts"); executeStatement(con, "truncate pgbench_accounts");
res = PQexec(con, "copy accounts from stdin"); res = PQexec(con, "copy pgbench_accounts from stdin");
if (PQresultStatus(res) != PGRES_COPY_IN) if (PQresultStatus(res) != PGRES_COPY_IN)
{ {
fprintf(stderr, "%s", PQerrorMessage(con)); fprintf(stderr, "%s", PQerrorMessage(con));
@ -1122,10 +1120,10 @@ init(void)
/* vacuum */ /* vacuum */
fprintf(stderr, "vacuum..."); fprintf(stderr, "vacuum...");
executeStatement(con, "vacuum analyze branches"); executeStatement(con, "vacuum analyze pgbench_branches");
executeStatement(con, "vacuum analyze tellers"); executeStatement(con, "vacuum analyze pgbench_tellers");
executeStatement(con, "vacuum analyze accounts"); executeStatement(con, "vacuum analyze pgbench_accounts");
executeStatement(con, "vacuum analyze history"); executeStatement(con, "vacuum analyze pgbench_history");
fprintf(stderr, "done.\n"); fprintf(stderr, "done.\n");
PQfinish(con); PQfinish(con);
@ -1466,7 +1464,7 @@ printResults(
if (ttype == 0) if (ttype == 0)
s = "TPC-B (sort of)"; s = "TPC-B (sort of)";
else if (ttype == 2) else if (ttype == 2)
s = "Update only accounts"; s = "Update only pgbench_accounts";
else if (ttype == 1) else if (ttype == 1)
s = "SELECT only"; s = "SELECT only";
else else
@ -1811,9 +1809,9 @@ main(int argc, char **argv)
{ {
/* /*
* get the scaling factor that should be same as count(*) from * get the scaling factor that should be same as count(*) from
* branches if this is not a custom query * pgbench_branches if this is not a custom query
*/ */
res = PQexec(con, "select count(*) from branches"); res = PQexec(con, "select count(*) from pgbench_branches");
if (PQresultStatus(res) != PGRES_TUPLES_OK) if (PQresultStatus(res) != PGRES_TUPLES_OK)
{ {
fprintf(stderr, "%s", PQerrorMessage(con)); fprintf(stderr, "%s", PQerrorMessage(con));
@ -1822,7 +1820,7 @@ main(int argc, char **argv)
scale = atoi(PQgetvalue(res, 0, 0)); scale = atoi(PQgetvalue(res, 0, 0));
if (scale < 0) if (scale < 0)
{ {
fprintf(stderr, "count(*) from branches invalid (%d)\n", scale); fprintf(stderr, "count(*) from pgbench_branches invalid (%d)\n", scale);
exit(1); exit(1);
} }
PQclear(res); PQclear(res);
@ -1830,7 +1828,7 @@ main(int argc, char **argv)
/* warn if we override user-given -s switch */ /* warn if we override user-given -s switch */
if (scale_given) if (scale_given)
fprintf(stderr, fprintf(stderr,
"Scale option ignored, using branches table count = %d\n", "Scale option ignored, using pgbench_branches table count = %d\n",
scale); scale);
} }
@ -1854,15 +1852,15 @@ main(int argc, char **argv)
if (!is_no_vacuum) if (!is_no_vacuum)
{ {
fprintf(stderr, "starting vacuum..."); fprintf(stderr, "starting vacuum...");
executeStatement(con, "vacuum branches"); executeStatement(con, "vacuum pgbench_branches");
executeStatement(con, "vacuum tellers"); executeStatement(con, "vacuum pgbench_tellers");
executeStatement(con, "truncate history"); executeStatement(con, "truncate pgbench_history");
fprintf(stderr, "end.\n"); fprintf(stderr, "end.\n");
if (do_vacuum_accounts) if (do_vacuum_accounts)
{ {
fprintf(stderr, "starting vacuum accounts..."); fprintf(stderr, "starting vacuum pgbench_accounts...");
executeStatement(con, "vacuum analyze accounts"); executeStatement(con, "vacuum analyze pgbench_accounts");
fprintf(stderr, "end.\n"); fprintf(stderr, "end.\n");
} }
} }

81
doc/src/sgml/pgbench.sgml
View file

@ -1,4 +1,4 @@
<!-- $PostgreSQL: pgsql/doc/src/sgml/pgbench.sgml,v 1.7 2008/09/11 23:52:48 tgl Exp $ --> <!-- $PostgreSQL: pgsql/doc/src/sgml/pgbench.sgml,v 1.8 2009/05/07 22:01:18 tgl Exp $ -->
<sect1 id="pgbench"> <sect1 id="pgbench">
<title>pgbench</title> <title>pgbench</title>
@ -25,6 +25,7 @@
<programlisting> <programlisting>
transaction type: TPC-B (sort of) transaction type: TPC-B (sort of)
scaling factor: 10 scaling factor: 10
query mode: simple
number of clients: 10 number of clients: 10
number of transactions per client: 1000 number of transactions per client: 1000
number of transactions actually processed: 10000/10000 number of transactions actually processed: 10000/10000
@ -32,7 +33,7 @@ tps = 85.184871 (including connections establishing)
tps = 85.296346 (excluding connections establishing) tps = 85.296346 (excluding connections establishing)
</programlisting> </programlisting>
The first four lines just report some of the most important parameter The first five lines report some of the most important parameter
settings. The next line reports the number of transactions completed settings. The next line reports the number of transactions completed
and intended (the latter being just the product of number of clients and intended (the latter being just the product of number of clients
and number of transactions per client); these will be equal unless the run and number of transactions per client); these will be equal unless the run
@ -63,9 +64,10 @@ pgbench -i <optional> <replaceable>other-options</> </optional> <replaceable>dbn
<caution> <caution>
<para> <para>
<literal>pgbench -i</> creates four tables <structname>accounts</>, <literal>pgbench -i</> creates four tables <structname>pgbench_accounts</>,
<structname>branches</>, <structname>history</>, and <structname>pgbench_branches</>, <structname>pgbench_history</>, and
<structname>tellers</>, destroying any existing tables of these names. <structname>pgbench_tellers</>,
destroying any existing tables of these names.
Be very careful to use another database if you have tables having these Be very careful to use another database if you have tables having these
names! names!
</para> </para>
@ -76,12 +78,12 @@ pgbench -i <optional> <replaceable>other-options</> </optional> <replaceable>dbn
contain this many rows: contain this many rows:
</para> </para>
<programlisting> <programlisting>
table # of rows table # of rows
------------------------- ---------------------------------
branches 1 pgbench_branches 1
tellers 10 pgbench_tellers 10
accounts 100000 pgbench_accounts 100000
history 0 pgbench_history 0
</programlisting> </programlisting>
<para> <para>
You can (and, for most purposes, probably should) increase the number You can (and, for most purposes, probably should) increase the number
@ -134,15 +136,16 @@ pgbench <optional> <replaceable>options</> </optional> <replaceable>dbname</>
<entry><literal>-s</literal> <replaceable>scale_factor</></entry> <entry><literal>-s</literal> <replaceable>scale_factor</></entry>
<entry> <entry>
Multiply the number of rows generated by the scale factor. Multiply the number of rows generated by the scale factor.
For example, <literal>-s 100</> will imply 10,000,000 rows For example, <literal>-s 100</> will create 10,000,000 rows
in the <structname>accounts</> table. Default is 1. in the <structname>pgbench_accounts</> table. Default is 1.
</entry> </entry>
</row> </row>
<row> <row>
<entry><literal>-F</literal> <replaceable>fillfactor</></entry> <entry><literal>-F</literal> <replaceable>fillfactor</></entry>
<entry> <entry>
Create the <structname>accounts</>, <structname>tellers</> and Create the <structname>pgbench_accounts</>,
<structname>branches</> tables with the given fillfactor. <structname>pgbench_tellers</> and
<structname>pgbench_branches</> tables with the given fillfactor.
Default is 100. Default is 100.
</entry> </entry>
</row> </row>
@ -177,14 +180,15 @@ pgbench <optional> <replaceable>options</> </optional> <replaceable>dbname</>
<row> <row>
<entry><literal>-T</literal> <replaceable>seconds</></entry> <entry><literal>-T</literal> <replaceable>seconds</></entry>
<entry> <entry>
Duration of benchmark test in seconds. <literal>-t</literal> and Run the test for this many seconds, rather than a fixed number of
transactions per client. <literal>-t</literal> and
<literal>-T</literal> are mutually exclusive. <literal>-T</literal> are mutually exclusive.
</entry> </entry>
</row> </row>
<row> <row>
<entry><literal>-M</literal> <replaceable>querymode</></entry> <entry><literal>-M</literal> <replaceable>querymode</></entry>
<entry> <entry>
Protocol to use for submitting queries for the server: Protocol to use for submitting queries to the server:
<itemizedlist> <itemizedlist>
<listitem> <listitem>
<para><literal>simple</>: use simple query protocol.</para> <para><literal>simple</>: use simple query protocol.</para>
@ -203,7 +207,8 @@ pgbench <optional> <replaceable>options</> </optional> <replaceable>dbname</>
<row> <row>
<entry><literal>-N</literal></entry> <entry><literal>-N</literal></entry>
<entry> <entry>
Do not update <structname>tellers</> and <structname>branches</>. Do not update <structname>pgbench_tellers</> and
<structname>pgbench_branches</>.
This will avoid update contention on these tables, but This will avoid update contention on these tables, but
it makes the test case even less like TPC-B. it makes the test case even less like TPC-B.
</entry> </entry>
@ -226,21 +231,21 @@ pgbench <optional> <replaceable>options</> </optional> <replaceable>dbname</>
<row> <row>
<entry><literal>-n</literal></entry> <entry><literal>-n</literal></entry>
<entry> <entry>
No vacuuming is performed before running the test. Perform no vacuuming before running the test.
This option is <emphasis>necessary</> This option is <emphasis>necessary</>
if you are running a custom test scenario that does not include if you are running a custom test scenario that does not include
the standard tables <structname>accounts</>, the standard tables <structname>pgbench_accounts</>,
<structname>branches</>, <structname>history</>, and <structname>pgbench_branches</>, <structname>pgbench_history</>, and
<structname>tellers</>. <structname>pgbench_tellers</>.
</entry> </entry>
</row> </row>
<row> <row>
<entry><literal>-v</literal></entry> <entry><literal>-v</literal></entry>
<entry> <entry>
Vacuum all four standard tables before running the test. Vacuum all four standard tables before running the test.
With neither <literal>-n</> nor <literal>-v</>, pgbench will vacuum With neither <literal>-n</> nor <literal>-v</>, pgbench will vacuum the
<structname>tellers</> and <structname>branches</> tables, and <structname>pgbench_tellers</> and <structname>pgbench_branches</>
will remove all entries in <structname>history</>. tables, and will truncate <structname>pgbench_history</>.
</entry> </entry>
</row> </row>
<row> <row>
@ -271,7 +276,7 @@ pgbench <optional> <replaceable>options</> </optional> <replaceable>dbname</>
Report the specified scale factor in <application>pgbench</>'s Report the specified scale factor in <application>pgbench</>'s
output. With the built-in tests, this is not necessary; the output. With the built-in tests, this is not necessary; the
correct scale factor will be detected by counting the number of correct scale factor will be detected by counting the number of
rows in the <structname>branches</> table. However, when testing rows in the <structname>pgbench_branches</> table. However, when testing
custom benchmarks (<literal>-f</> option), the scale factor custom benchmarks (<literal>-f</> option), the scale factor
will be reported as 1 unless this option is used. will be reported as 1 unless this option is used.
</entry> </entry>
@ -323,11 +328,11 @@ pgbench <optional> <replaceable>options</> </optional> <replaceable>dbname</>
<orderedlist> <orderedlist>
<listitem><para><literal>BEGIN;</literal></para></listitem> <listitem><para><literal>BEGIN;</literal></para></listitem>
<listitem><para><literal>UPDATE accounts SET abalance = abalance + :delta WHERE aid = :aid;</literal></para></listitem> <listitem><para><literal>UPDATE pgbench_accounts SET abalance = abalance + :delta WHERE aid = :aid;</literal></para></listitem>
<listitem><para><literal>SELECT abalance FROM accounts WHERE aid = :aid;</literal></para></listitem> <listitem><para><literal>SELECT abalance FROM pgbench_accounts WHERE aid = :aid;</literal></para></listitem>
<listitem><para><literal>UPDATE tellers SET tbalance = tbalance + :delta WHERE tid = :tid;</literal></para></listitem> <listitem><para><literal>UPDATE pgbench_tellers SET tbalance = tbalance + :delta WHERE tid = :tid;</literal></para></listitem>
<listitem><para><literal>UPDATE branches SET bbalance = bbalance + :delta WHERE bid = :bid;</literal></para></listitem> <listitem><para><literal>UPDATE pgbench_branches SET bbalance = bbalance + :delta WHERE bid = :bid;</literal></para></listitem>
<listitem><para><literal>INSERT INTO history (tid, bid, aid, delta, mtime) VALUES (:tid, :bid, :aid, :delta, CURRENT_TIMESTAMP);</literal></para></listitem> <listitem><para><literal>INSERT INTO pgbench_history (tid, bid, aid, delta, mtime) VALUES (:tid, :bid, :aid, :delta, CURRENT_TIMESTAMP);</literal></para></listitem>
<listitem><para><literal>END;</literal></para></listitem> <listitem><para><literal>END;</literal></para></listitem>
</orderedlist> </orderedlist>
@ -410,7 +415,7 @@ pgbench <optional> <replaceable>options</> </optional> <replaceable>dbname</>
<listitem> <listitem>
<para> <para>
Sets variable <replaceable>varname</> to a random integer value Sets variable <replaceable>varname</> to a random integer value
between the limits <replaceable>min</> and <replaceable>max</>. between the limits <replaceable>min</> and <replaceable>max</> inclusive.
Each limit can be either an integer constant or a Each limit can be either an integer constant or a
<literal>:</><replaceable>variablename</> reference to a variable <literal>:</><replaceable>variablename</> reference to a variable
having an integer value. having an integer value.
@ -463,11 +468,11 @@ pgbench <optional> <replaceable>options</> </optional> <replaceable>dbname</>
\setrandom tid 1 :ntellers \setrandom tid 1 :ntellers
\setrandom delta -5000 5000 \setrandom delta -5000 5000
BEGIN; BEGIN;
UPDATE accounts SET abalance = abalance + :delta WHERE aid = :aid; UPDATE pgbench_accounts SET abalance = abalance + :delta WHERE aid = :aid;
SELECT abalance FROM accounts WHERE aid = :aid; SELECT abalance FROM pgbench_accounts WHERE aid = :aid;
UPDATE tellers SET tbalance = tbalance + :delta WHERE tid = :tid; UPDATE pgbench_tellers SET tbalance = tbalance + :delta WHERE tid = :tid;
UPDATE branches SET bbalance = bbalance + :delta WHERE bid = :bid; UPDATE pgbench_branches SET bbalance = bbalance + :delta WHERE bid = :bid;
INSERT INTO history (tid, bid, aid, delta, mtime) VALUES (:tid, :bid, :aid, :delta, CURRENT_TIMESTAMP); INSERT INTO pgbench_history (tid, bid, aid, delta, mtime) VALUES (:tid, :bid, :aid, :delta, CURRENT_TIMESTAMP);
END; END;
</programlisting> </programlisting>
@ -537,7 +542,7 @@ END;
(<literal>-s</>) should be at least as large as the largest number of (<literal>-s</>) should be at least as large as the largest number of
clients you intend to test (<literal>-c</>); else you'll mostly be clients you intend to test (<literal>-c</>); else you'll mostly be
measuring update contention. There are only <literal>-s</> rows in measuring update contention. There are only <literal>-s</> rows in
the <structname>branches</> table, and every transaction wants to the <structname>pgbench_branches</> table, and every transaction wants to
update one of them, so <literal>-c</> values in excess of <literal>-s</> update one of them, so <literal>-c</> values in excess of <literal>-s</>
will undoubtedly result in lots of transactions blocked waiting for will undoubtedly result in lots of transactions blocked waiting for
other transactions. other transactions.