automatic reconnect with retry after connection closed

src/client/jTPCC.java

@@ -484,7 +484,7 @@ else if(newOrderWeightValue == 0 && paymentWeightValue == 0 && orderStatusWeight
 			 conn, dbType,
 			 transactionsPerTerminal, terminalWarehouseFixed,
 			 paymentWeightValue, orderStatusWeightValue,
-			 deliveryWeightValue, stockLevelWeightValue, numWarehouses, limPerMin_Terminal, this);
+			 deliveryWeightValue, stockLevelWeightValue, numWarehouses, limPerMin_Terminal, this, database, dbProps);
 
 			terminals[i] = terminal;
 			terminalNames[i] = terminalName;

src/client/jTPCCConnection.java

@@ -316,6 +316,6 @@ public void commit()
     public void rollback()
 	throws SQLException
     {
-	dbConn.rollback();
+			dbConn.rollback();
     }
 }

src/client/jTPCCTerminal.java

@@ -12,6 +12,7 @@
 import java.sql.*;
 import java.sql.Date;
 import java.util.*;
+import javax.naming.CommunicationException;
 import javax.swing.*;
 
 
@@ -45,12 +46,16 @@ public class jTPCCTerminal implements jTPCCConfig, Runnable
     jTPCCConnection     db = null;
     int                 dbType = 0;
 
+	private String database = "";
+	private Properties dbProps = null;
+
     public jTPCCTerminal
       (String terminalName, int terminalWarehouseID, int terminalDistrictID,
        Connection conn, int dbType,
        int numTransactions, boolean terminalWarehouseFixed,
        int paymentWeight, int orderStatusWeight,
-       int deliveryWeight, int stockLevelWeight, int numWarehouses, int limPerMin_Terminal, jTPCC parent) throws SQLException
+       int deliveryWeight, int stockLevelWeight, int numWarehouses, int limPerMin_Terminal, jTPCC parent,
+	   String database, Properties dbProp) throws SQLException
     {
 	this.terminalName = terminalName;
 	this.conn = conn;
@@ -76,6 +81,9 @@ public class jTPCCTerminal implements jTPCCConfig, Runnable
 	this.newOrderCounter = 0;
 	this.limPerMin_Terminal = limPerMin_Terminal;
 
+	this.database = database;
+	this.dbProps = dbProp;
+
 	this.db = new jTPCCConnection(conn, dbType);
 
 	terminalMessage("");
@@ -165,6 +173,13 @@ private void executeTransactions(int numTransactions)
 		{
 			continue;
 		}
+		catch (SQLException | CommunicationException e ){
+			try {
+				retryConnect();
+			} catch (SQLException ex) {
+				throw new RuntimeException(ex);
+			}
+		}
 		catch (Exception e)
 		{
 		    log.fatal(e.getMessage());
@@ -367,5 +382,21 @@ void transCommit() {
     } // end transCommit()
 
 
+	void retryConnect() throws SQLException {
+			Connection c = DriverManager.getConnection(this.database, this.dbProps);
+			c.setAutoCommit(false);
+			this.conn = c;
+			this.stmt = c.createStatement();
+			this.stmt.setMaxRows(200);
+			this.stmt.setFetchSize(100);
+
+			this.stmt1 = c.createStatement();
+			this.stmt1.setMaxRows(1);
+
+			this.db = new jTPCCConnection(c, dbType);
+	}
+
+
+
 
 }