From 2696b00c1e64dfca97db27793bcdc51c9227a04c Mon Sep 17 00:00:00 2001 From: "Gzx@151" Date: Fri, 2 Feb 2024 23:51:47 +0800 Subject: [PATCH] try to fix W13 conflict, update default terminal: thread1:6->20, R2*:1->2, add a label to every query sql --- config/runR21.xml | 2 +- config/runR22.xml | 2 +- config/runR23.xml | 2 +- config/runR24.xml | 2 +- config/runR25.xml | 2 +- config/runthread1.xml | 2 +- lib/README | 2 -- script/config.sh | 14 +++++++------- .../benchmarks/web3benchmark/procedures/R1.java | 11 +++++------ .../benchmarks/web3benchmark/procedures/R21.java | 8 +++++--- .../benchmarks/web3benchmark/procedures/R22.java | 11 +++++------ .../benchmarks/web3benchmark/procedures/R23.java | 13 +++++++------ .../benchmarks/web3benchmark/procedures/R24.java | 11 +++++------ .../benchmarks/web3benchmark/procedures/R25.java | 8 ++++---- .../benchmarks/web3benchmark/procedures/R31.java | 15 +++++++-------- .../benchmarks/web3benchmark/procedures/R32.java | 12 ++++++------ .../benchmarks/web3benchmark/procedures/R33.java | 8 ++++---- .../benchmarks/web3benchmark/procedures/R34.java | 10 ++++++---- .../benchmarks/web3benchmark/procedures/R35.java | 14 ++++++-------- .../benchmarks/web3benchmark/procedures/W11.java | 7 ++++--- .../benchmarks/web3benchmark/procedures/W12.java | 7 ++++--- .../benchmarks/web3benchmark/procedures/W13.java | 10 +++++----- .../benchmarks/web3benchmark/procedures/W14.java | 5 +++-- .../benchmarks/web3benchmark/procedures/W2.java | 9 ++++----- .../benchmarks/web3benchmark/procedures/W3.java | 5 ++++- .../benchmarks/web3benchmark/procedures/W4.java | 4 +++- .../benchmarks/web3benchmark/procedures/W51.java | 4 +++- .../benchmarks/web3benchmark/procedures/W52.java | 4 +++- .../benchmarks/web3benchmark/procedures/W6.java | 4 +++- 29 files changed, 109 insertions(+), 99 deletions(-) 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;