1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
|
/*
Derby - Class org.apache.derbyTesting.system.nstest.tester.Tester2
Licensed to the Apache Software Foundation (ASF) under one or more
contributor license agreements. See the NOTICE file distributed with
this work for additional information regarding copyright ownership.
The ASF licenses this file to You under the Apache License, Version 2.0
(the "License"); you may not use this file except in compliance with
the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package org.apache.derbyTesting.system.nstest.tester;
import java.sql.Connection;
import org.apache.derbyTesting.system.nstest.NsTest;
/**
* Tester2 - Threads that frequently opens and closed based on a random choice of number
*/
public class Tester2 extends TesterObject {
//*******************************************************************************
//
// Constructor. Get's the name of the thread running this for use in messages
//
//*******************************************************************************
public Tester2(String name) {
super(name);
}
//**************************************************************************************
//
// This starts the acutal test operations. Overrides the startTesting() of parent.
// Tester2 profile -
// The connection is frequently opened and closed based on
// a random choice between 1 and MAX_OPERATIONS_PER_CONN number of
// transaction batches committed by this client type. This client will
// do Insert/Update/Delete and simple Select queries over a
// small to medium set of data determined randomly over MAX_LOW_STRESS_ROWS rows.
//
//***************************************************************************************
public void startTesting() {
//The following loop will be done nstest.MAX_ITERATIONS times after which we exit the thread
// Note that the connection is frequently opened & closed. Autocommit is left on, so
// per connection, we make MAX_OPERATIONS_PER_CONN number of transaction batches
// Each transaction batch works over MAX_LOW_STRESS_ROWS number of rows, with each row working
// as one transaction (since autocommit is on)
for (int i = 0; i < NsTest.MAX_ITERATIONS; i++) {
//the connection will now open. It closes at the end of the loop
connex = getConnection();
if (connex == null) {
NsTest.logger.println("FAIL: " + getThread_id()
+ " could not get database connection");
return; //quit
}
//set autocommit to false to keep transaction control in your hand
//Too many deadlocks amd locking issues if this is not commented out
try {
connex.setAutoCommit(false);
} catch (Exception e) {
NsTest.logger.println("FAIL: " + getThread_id()
+ "'s setAutoCommit() failed:");
printException("setting AutoCommit in Tester2", e);
// if you can't change the autocommit state, the connection is unusable.
// get out of here.
return;
}
//also set isolation level to Connection.TRANSACTION_READ_UNCOMMITTED to reduce number of
// deadlocks
setIsolationLevel(Connection.TRANSACTION_READ_UNCOMMITTED);
//Now do MAX_OPERATIONS_PER_CONN transaction batches within this connection
for (int numOp = 1; numOp < NsTest.MAX_OPERATIONS_PER_CONN; numOp++) {
//Now loop through nstest.MAX_LOW_STRESS_ROWS number of times/rows
// Here, we do randomly do either insert/update/delete operations or one select
int rnum = (int) (Math.random() * 100) % 4; //returns 0, 1, 2, 3
switch (rnum) {
case 0: //do a select operation
try {
int numSelected = doSelectOperation(NsTest.MAX_LOW_STRESS_ROWS);
NsTest.logger.println(getThread_id() + " selected "
+ numSelected + " rows");
} catch (Exception e) {
NsTest.logger.println("doSelect in thread " + getThread_id()
+ " threw ");
printException("doSelectOperation() in Tester2", e);
}
break;
case 1: //do Insert/Update/Delete operations
case 2: //do Insert/Update/Delete operations
case 3: //do Insert/Update/Delete operations
for (int j = 0; j < NsTest.MAX_LOW_STRESS_ROWS; j++) {
doIUDOperation();
}
break;
}
//Letting this be even though autocommit is on so that if later on if we decide to turn
// autocommit off, this automatically takes effect.
//commit
try {
connex.commit();
} catch (Exception e) {
NsTest.logger.println("FAIL: " + getThread_id()
+ "'s commit() failed:");
printException("committing Xn in Tester2", e);
// if you can't commit, the connection is unusable.
// get out of here.
return;
}
}//end of for(int numOp=1...)
//close the connection for the next iteration
closeConnection();
}//end of for (int i=0;...)
NsTest.logger.println("Thread " + getThread_id() + " is now terminating");
}//end of startTesting()
}
|
