diff --git a/config/runR21.xml b/config/runR21.xml
index ab48dc6..b83a029 100644
--- a/config/runR21.xml
+++ b/config/runR21.xml
@@ -14,7 +14,7 @@
6000
- 1
+ 2
0
diff --git a/config/runR22.xml b/config/runR22.xml
index e79fe92..5b77ed7 100644
--- a/config/runR22.xml
+++ b/config/runR22.xml
@@ -14,7 +14,7 @@
6000
- 1
+ 2
0
diff --git a/config/runR23.xml b/config/runR23.xml
index 8ea33c3..9bf1661 100644
--- a/config/runR23.xml
+++ b/config/runR23.xml
@@ -14,7 +14,7 @@
6000
- 1
+ 2
0
diff --git a/config/runR24.xml b/config/runR24.xml
index 8e6c796..dda516b 100644
--- a/config/runR24.xml
+++ b/config/runR24.xml
@@ -14,7 +14,7 @@
6000
- 1
+ 2
0
diff --git a/config/runR25.xml b/config/runR25.xml
index 5905fda..eda60ef 100644
--- a/config/runR25.xml
+++ b/config/runR25.xml
@@ -14,7 +14,7 @@
6000
- 1
+ 2
0
diff --git a/config/runthread1.xml b/config/runthread1.xml
index 8f21bc1..68a10fe 100644
--- a/config/runthread1.xml
+++ b/config/runthread1.xml
@@ -14,7 +14,7 @@
6000
- 6
+ 20
0
diff --git a/lib/README b/lib/README
index e2b5283..d54ce67 100644
--- a/lib/README
+++ b/lib/README
@@ -1,7 +1,5 @@
# Dependencies
-A new checkout of the repository should only contain 'ant-contrib.jar'.
-
Use `ant resolve` to automatically download all of the dependencies.
You can then put any DBMS-specific jar files in this directory as needed.
diff --git a/script/config.sh b/script/config.sh
index 9d65570..cf3b876 100755
--- a/script/config.sh
+++ b/script/config.sh
@@ -16,18 +16,18 @@ new_password=
new_nodeid="main"
new_scalefactor=6000
# Test time in minutes
-new_time=60
+new_time=360
# terminals and rate for runthread1: R1, W1* and W4
-new_terminals_thread1=6
+new_terminals_thread1=20
# Total number of requests in one hour for R1 = 1000 * 6000 = 6000000
# then total rate per minute of thread1 = 1000 * 6000 / 80% / 60 = 1000 * 6000 / 48 = 125000
new_rate_thread1=125000
# terminals and rate for R2*
-new_terminals_R21=1
-new_terminals_R22=1
-new_terminals_R23=1
-new_terminals_R24=1
-new_terminals_R25=1
+new_terminals_R21=2
+new_terminals_R22=2
+new_terminals_R23=2
+new_terminals_R24=2
+new_terminals_R25=2
# Total number of requests per minute
# R21, R22, R23 = 10 * 6000 / 60 = 1000
new_rate_R21=1000
diff --git a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R1.java b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R1.java
index 69ad4b9..ed94c6f 100755
--- a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R1.java
+++ b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R1.java
@@ -39,12 +39,11 @@ public class R1 extends WEB3Procedure {
// Equality on hash in transaction table
public SQLStmt query_stmtSQL = new SQLStmt(
- "explain analyze select "
- + "to_address, from_address "
- + "from "
- + "transactions "
- + "where "
- + "hash = ? ");
+ "/* R1 */ "
+ + "explain analyze "
+ + "select to_address, from_address "
+ + "from transactions "
+ + "where hash = ? ");
private PreparedStatement query_stmt = null;
diff --git a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R21.java b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R21.java
index 8f227a7..b05b18b 100755
--- a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R21.java
+++ b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R21.java
@@ -39,11 +39,13 @@ public class R21 extends WEB3Procedure {
// top N with small N on full table scan
public SQLStmt query_stmtSQL = new SQLStmt(
- "explain analyze select "
- + "* "
+ "/* R21 */ "
+ + "explain analyze "
+ + "select * "
+ "from token_transfers "
+ "where from_address = ? "
- + "order by block_number desc limit 5 ");
+ + "order by block_number desc "
+ + "limit 5 ");
private PreparedStatement query_stmt = null;
public long run(Connection conn, Random gen, WEB3Worker w, int startNumber, int upperLimit, int numScale,
diff --git a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R22.java b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R22.java
index c2c7e85..f94847c 100755
--- a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R22.java
+++ b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R22.java
@@ -39,12 +39,11 @@ public class R22 extends WEB3Procedure {
// Aggregation with no group by on a small range
public SQLStmt query_stmtSQL = new SQLStmt(
- "explain analyze select "
- + "count(*) "
- + "from "
- + "token_transfers "
- + "where "
- + "token_address = ? ");
+ "/* R22 */ "
+ + "explain analyze "
+ + "select count(*) "
+ + "from token_transfers "
+ + "where token_address = ? ");
private PreparedStatement query_stmt = null;
public long run(Connection conn, Random gen, WEB3Worker w, int startNumber, int upperLimit, int numScale,
diff --git a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R23.java b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R23.java
index dcbd0a9..65b41a4 100755
--- a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R23.java
+++ b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R23.java
@@ -38,14 +38,15 @@ public class R23 extends WEB3Procedure {
private static final Logger LOG = Logger.getLogger(R23.class);
public SQLStmt query_stmtSQL = new SQLStmt(
- "explain analyze select * "
- + "from "
- + "token_transfers "
- + "where "
- + "token_address = ? "
+ "/* R23 */ "
+ + "explain analyze "
+ + "select * "
+ + "from token_transfers "
+ + "where token_address = ? "
+ "and block_number <= ? "
+ "and (next_block_number > ? or next_block_number = ?) "
- + "order by block_number desc limit ?");
+ + "order by block_number desc "
+ + "limit ?");
private PreparedStatement query_stmt = null;
public long run(Connection conn, Random gen, WEB3Worker w, int startNumber, int upperLimit, int numScale,
diff --git a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R24.java b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R24.java
index 3de22e8..7a98aa9 100755
--- a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R24.java
+++ b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R24.java
@@ -39,12 +39,11 @@ public class R24 extends WEB3Procedure {
// List of transactions excluding some black listed ones.
public SQLStmt query_to_address_SQL = new SQLStmt(
- "explain analyze select "
- + "count(*) "
- + "from "
- + "transactions "
- + "where "
- + "to_address not in (?, ?, ?) ");
+ "/* R24 */ "
+ + "explain analyze "
+ + "select count(*) "
+ + "from transactions "
+ + "where to_address not in (?, ?, ?) ");
private PreparedStatement query_stmt = null;
public long run(Connection conn, Random gen, WEB3Worker w, int startNumber, int upperLimit, int numScale,
diff --git a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R25.java b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R25.java
index 7c24ef0..07d0612 100755
--- a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R25.java
+++ b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R25.java
@@ -40,11 +40,11 @@ public class R25 extends WEB3Procedure {
// Constraint checking that next_block_number <= block_number in token_transfers
// Query result should be empty.
public SQLStmt query_SQL = new SQLStmt(
- "explain analyze select "
- + "count(*) "
+ "/* R25 */ "
+ + "explain analyze "
+ + "select count(*) "
+ "from token_transfers "
- + "where "
- + "next_block_number <= block_number "
+ + "where next_block_number <= block_number "
+ "group by next_block_number ");
private PreparedStatement query_stmt = null;
diff --git a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R31.java b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R31.java
index fa566e2..d5332a4 100755
--- a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R31.java
+++ b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R31.java
@@ -40,14 +40,13 @@ public class R31 extends WEB3Procedure {
// For a specific person, find transactions where this person is either a sender
// or receiver. Limit the result by the most recent timestamp.
public SQLStmt query_stmtSQL = new SQLStmt(
- "explain analyze select "
- + "* "
- + "from "
- + "transactions "
- + "where "
- + "from_address = ? or to_address = ? "
- + "order by "
- + "block_timestamp desc limit 10");
+ "/* R31 */ "
+ + "explain analyze "
+ + "select * "
+ + "from transactions "
+ + "where from_address = ? or to_address = ? "
+ + "order by block_timestamp desc "
+ + "limit 10");
private PreparedStatement query_stmt = null;
public long run(Connection conn, Random gen, WEB3Worker w, int startNumber, int upperLimit, int numScale,
diff --git a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R32.java b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R32.java
index 76483ca..19fc7d7 100755
--- a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R32.java
+++ b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R32.java
@@ -39,12 +39,12 @@ public class R32 extends WEB3Procedure {
// Top N transactions based on block timestamp.
public SQLStmt query_stmtSQL = new SQLStmt(
- "explain analyze select "
- + "* "
- + "from "
- + "transactions "
- + "order by "
- + "block_timestamp desc limit 100");
+ "/* R32 */ "
+ + "explain analyze "
+ + "select * "
+ + "from transactions "
+ + "order by block_timestamp desc "
+ + "limit 100");
private PreparedStatement query_stmt = null;
public long run(Connection conn, Random gen, WEB3Worker w, int startNumber, int upperLimit, int numScale,
diff --git a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R33.java b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R33.java
index c16ebe5..5ea6864 100755
--- a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R33.java
+++ b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R33.java
@@ -39,10 +39,10 @@ public class R33 extends WEB3Procedure {
// Find the number of unique senders (from\_address) in transactions
public SQLStmt query_stmtSQL = new SQLStmt(
- "explain analyze select "
- + "count(distinct from_address) "
- + "from "
- + "transactions ");
+ "/* R33 */ "
+ + "explain analyze "
+ + "select count(distinct from_address) "
+ + "from transactions ");
private PreparedStatement query_stmt = null;
public long run(Connection conn, Random gen, WEB3Worker w, int startNumber, int upperLimit, int numScale,
diff --git a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R34.java b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R34.java
index d15e938..548a665 100755
--- a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R34.java
+++ b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R34.java
@@ -39,14 +39,16 @@ public class R34 extends WEB3Procedure {
// Find top N senders (from\_address) by total transaction value
public SQLStmt query_stmtSQL = new SQLStmt(
- "explain analyze select "
+ "/* R34 */ "
+ + "explain analyze "
+ + "select "
+ "sum(value) as totalamount, "
+ "count(value) as transactioncount, "
+ "from_address as fromaddress "
- + "from "
- + "transactions "
+ + "from transactions "
+ "group by from_address "
- + "order by sum(value) desc limit 10");
+ + "order by sum(value) desc "
+ + "limit 10 ");
private PreparedStatement query_stmt = null;
public long run(Connection conn, Random gen, WEB3Worker w, int startNumber, int upperLimit, int numScale,
diff --git a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R35.java b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R35.java
index e18d96e..5736996 100755
--- a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R35.java
+++ b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/R35.java
@@ -40,19 +40,17 @@ public class R35 extends WEB3Procedure {
// Total count of token transfers for a specific sender and token transfers for
// recipients who are also senders in other transactions.
public SQLStmt query_stmtSQL = new SQLStmt(
- "explain analyze select "
- + "count(*) as count "
+ "/* R35 */ "
+ + "explain analyze "
+ + "select count(*) as count "
+ "from "
+ "( "
+ "select * "
- + "from "
- + "token_transfers t "
- + "where "
- + "from_address = ? "
+ + "from token_transfers t "
+ + "where from_address = ? "
+ "union all "
+ "select t2.* "
- + "from "
- + "token_transfers t2 "
+ + "from token_transfers t2 "
+ "inner join token_transfers t on t2.from_address = t.to_address "
+ "and t.value < t2.value "
+ ") as temp ");
diff --git a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W11.java b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W11.java
index e64ff9d..f7c3018 100755
--- a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W11.java
+++ b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W11.java
@@ -36,8 +36,9 @@ public class W11 extends WEB3Procedure {
private static final Logger LOG = Logger.getLogger(W11.class);
public SQLStmt query_stmtSQL = new SQLStmt(
- "explain analyze insert into "
- + "blocks "
+ "/* W11 */ "
+ + "explain analyze "
+ + "insert into blocks "
+ "values "
+ "(?, ?, ?, ?, ?,"
+ " ?, ?, ?, ?, ?,"
@@ -54,7 +55,7 @@ public long run(Connection conn, Random gen, WEB3Worker w, int startNumber, int
query_stmt = this.getPreparedStatement(conn, query_stmtSQL);
long number = numScale * WEB3Config.configBlocksCount + startNumber;
- String hash = WEB3Util.convertToBlockHashString(number, nodeid);
+ String hash = WEB3Util.convertToBlockHashString(startNumber, nodeid + "-W11");
String parent_hash = WEB3Util.convertToBlockHashString(number - 1);
String nonce = WEB3Util.randomHexString(42);
String sha3_uncles = WEB3Util.randomHashString();
diff --git a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W12.java b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W12.java
index 8962ce3..ed0b0ba 100755
--- a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W12.java
+++ b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W12.java
@@ -36,8 +36,9 @@ public class W12 extends WEB3Procedure {
private static final Logger LOG = Logger.getLogger(W12.class);
public SQLStmt query_stmtSQL = new SQLStmt(
- "explain analyze insert into "
- + "contracts "
+ "/* W12 */ "
+ + "explain analyze "
+ + "insert into contracts "
+ "values (?, ?, ?, ?, ?, ?) ");
private PreparedStatement query_stmt = null;
@@ -50,7 +51,7 @@ public long run(Connection conn, Random gen, WEB3Worker w, int startNumber, int
query_stmt = this.getPreparedStatement(conn, query_stmtSQL);
String address = WEB3Util
- .convertToContractAddressString(numScale * WEB3Config.configContractsCount + startNumber, nodeid);
+ .convertToContractAddressString(startNumber, nodeid + "-W12");
String bytecode = WEB3Util.randomStr(WEB3Util.randomNumber(1, 1000, gen));
String function_sighashes = WEB3Util.randomStr(WEB3Util.randomNumber(1, 1000, gen));
boolean is_erc20 = false; // gen.nextBoolean();
diff --git a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W13.java b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W13.java
index 9e09c78..720c7f0 100755
--- a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W13.java
+++ b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W13.java
@@ -36,8 +36,9 @@ public class W13 extends WEB3Procedure {
private static final Logger LOG = Logger.getLogger(W13.class);
public SQLStmt query_stmtSQL = new SQLStmt(
- "explain analyze insert into "
- + "transactions "
+ "/* W13 */ "
+ + "explain analyze "
+ + "insert into transactions "
+ "values "
+ "(?, ?, ?, ?, ?,"
+ " ?, ?, ?, ?, ?,"
@@ -53,9 +54,8 @@ public long run(Connection conn, Random gen, WEB3Worker w, int startNumber, int
// initializing all prepared statements
query_stmt = this.getPreparedStatement(conn, query_stmtSQL);
- String hash = WEB3Util.convertToTxnHashString(
- numScale * WEB3Config.configTransactionsCount + startNumber,
- nodeid);
+ String hash = WEB3Util.convertToTxnHashString(startNumber, nodeid + "-W13");
+ LOG.info(startNumber);
long nonce = WEB3Util.randomNumber(0, 100, gen);
long block_number = WEB3Util.randomNumber(1, numScale * WEB3Config.configBlocksCount, gen);
String block_hash = WEB3Util.convertToBlockHashString(block_number);
diff --git a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W14.java b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W14.java
index 3d6299b..d38d2c7 100755
--- a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W14.java
+++ b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W14.java
@@ -36,8 +36,9 @@ public class W14 extends WEB3Procedure {
private static final Logger LOG = Logger.getLogger(W14.class);
public SQLStmt query_stmtSQL = new SQLStmt(
- "explain analyze insert into "
- + "token_transfers "
+ "/* W14 */ "
+ + "explain analyze "
+ + "insert into token_transfers "
+ "values "
+ "(?, ?, ?, ?, ?, ?, ?)");
diff --git a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W2.java b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W2.java
index 26779eb..41aab99 100755
--- a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W2.java
+++ b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W2.java
@@ -37,8 +37,9 @@ public class W2 extends WEB3Procedure {
private static final Logger LOG = Logger.getLogger(W2.class);
public SQLStmt query_stmtSQL = new SQLStmt(
- "explain analyze insert into "
- + "transactions "
+ "/* W2 */ "
+ + "explain analyze "
+ + "insert into transactions "
+ "values "
// Java 11
// + "(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?), ".repeat(99)
@@ -59,9 +60,7 @@ public long run(Connection conn, Random gen, WEB3Worker w, int startNumber, int
// Small batch inserts (100 rows) for the transaction table.
int idx = 1;
for (int i = 0; i < 100; i++) {
- String hash = WEB3Util.convertToTxnHashString(
- 10 * numScale * WEB3Config.configTransactionsCount + 100 * startNumber + i,
- nodeid);
+ String hash = WEB3Util.convertToTxnHashString(startNumber + i, nodeid + "-W2");
long nonce = WEB3Util.randomNumber(0, 100, gen);
long block_number = WEB3Util.randomNumber(1, numScale * WEB3Config.configBlocksCount, gen);
String block_hash = WEB3Util.convertToBlockHashString(block_number);
diff --git a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W3.java b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W3.java
index d5d9e42..8addb22 100755
--- a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W3.java
+++ b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W3.java
@@ -36,7 +36,10 @@ public class W3 extends WEB3Procedure {
// Insert 1000 rows into transactions from a temp table
public SQLStmt query_stmtSQL = new SQLStmt(
- "explain analyze insert transactions select * from temp_table limit 1000 ");
+ "/* W3 */ "
+ + "explain analyze "
+ + "insert transactions "
+ + "select * from temp_table limit 1000 ");
private PreparedStatement query_stmt = null;
diff --git a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W4.java b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W4.java
index 84275b2..a7e8283 100755
--- a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W4.java
+++ b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W4.java
@@ -39,7 +39,9 @@ public class W4 extends WEB3Procedure {
private static final Logger LOG = Logger.getLogger(W4.class);
public SQLStmt query_stmtSQL = new SQLStmt(
- "explain analyze update transactions "
+ "/* W4 */ "
+ + "explain analyze "
+ + "update transactions "
+ "set gas_price = ? "
+ "where hash = ? ");
diff --git a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W51.java b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W51.java
index e73594c..752bb79 100755
--- a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W51.java
+++ b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W51.java
@@ -35,7 +35,9 @@ public class W51 extends WEB3Procedure {
private static final Logger LOG = Logger.getLogger(W51.class);
public SQLStmt query_stmtSQL = new SQLStmt(
- "explain analyze update token_transfers "
+ "/* W51 */ "
+ + "explain analyze "
+ + "update token_transfers "
+ "set value = ? "
+ "where to_address = from_address ");
diff --git a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W52.java b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W52.java
index 490db1c..bc2b7c2 100755
--- a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W52.java
+++ b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W52.java
@@ -35,7 +35,9 @@ public class W52 extends WEB3Procedure {
private static final Logger LOG = Logger.getLogger(W52.class);
public SQLStmt query_stmtSQL = new SQLStmt(
- "explain analyze update token_transfers "
+ "/* W52 */ "
+ + "explain analyze "
+ + "update token_transfers "
+ "set value = value + 1 "
+ "where from_address in "
+ "(select to_address from token_transfers) ");
diff --git a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W6.java b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W6.java
index c668a8d..afac736 100755
--- a/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W6.java
+++ b/src/com/olxpbenchmark/benchmarks/web3benchmark/procedures/W6.java
@@ -37,7 +37,9 @@ public class W6 extends WEB3Procedure {
// Single record deletes for the transaction table.
public SQLStmt query_stmtSQL = new SQLStmt(
- "explain analyze delete from transactions "
+ "/* W6 */ "
+ + "explain analyze "
+ + "delete from transactions "
+ "where hash = ? ");
private PreparedStatement query_stmt = null;