Implement test utility com.mchange.v2.c3p0.test.Percent20FailConnecti…

…onTester
swaldman · Feb 25, 2024 · 7fc8de7 · 7fc8de7
1 parent 9abd109
commit 7fc8de7
Show file tree

Hide file tree

Showing 3 changed files with 50 additions and 6 deletions.
diff --git a/test/resources-local/c3p0.properties b/test/resources-local/c3p0.properties
@@ -4,7 +4,7 @@ c3p0.testConnectionOnCheckout=true
 #c3p0.minPoolSize=10
 #c3p0.maxPoolSize=40
 #c3p0.checkoutTimeout=2000
-c3p0.connectionIsValidTimeout=5
+#c3p0.connectionIsValidTimeout=5
 #c3p0.idleConnectionTestPeriod=30
 #c3p0.idleConnectionTestPeriod=1
 #c3p0.maxConnectionAge=10
@@ -31,6 +31,7 @@ c3p0.connectionIsValidTimeout=5
 #c3p0.contextClassLoaderSource=library
 #c3p0.privilegeSpawnedThreads=true
 #c3p0.connectionTesterClassName=com.mchange.v2.c3p0.test.AlwaysFailConnectionTester
+#c3p0.connectionTesterClassName=com.mchange.v2.c3p0.test.Percent20FailConnectionTester
 #c3p0.connectionTesterClassName=com.mchange.v2.c3p0.example.IsValidOnlyConnectionTester30
 #c3p0.taskRunnerFactoryClassName=com.mchange.v2.c3p0.test.LogCreationTaskRunnerFactory
 #c3p0.taskRunnerFactoryClassName=com.mchange.v2.c3p0.test.ThreadPerTaskRunnerFactory

diff --git a/test/src/com/mchange/v2/c3p0/test/AlwaysFailConnectionTester.java b/test/src/com/mchange/v2/c3p0/test/AlwaysFailConnectionTester.java
@@ -67,10 +67,7 @@ public int activeCheckConnection(Connection c, String preferredTestQuery)
 	return CONNECTION_IS_INVALID; 
     }
 
-    public boolean equals( Object o )
-    { return (o instanceof AlwaysFailConnectionTester); }
-
-    public int hashCode()
-    { return 1; }
+    public boolean equals( Object o ) { return this.getClass().equals( o.getClass() ); }
+    public int hashCode() { return this.getClass().getName().hashCode(); }
 }
 
diff --git a/test/src/com/mchange/v2/c3p0/test/Percent20FailConnectionTester.java b/test/src/com/mchange/v2/c3p0/test/Percent20FailConnectionTester.java
@@ -0,0 +1,46 @@
+package com.mchange.v2.c3p0.test;
+
+import java.sql.Connection;
+import com.mchange.v2.c3p0.QueryConnectionTester;
+import com.mchange.v2.log.MLevel;
+import com.mchange.v2.log.MLog;
+import com.mchange.v2.log.MLogger;
+
+public final class Percent20FailConnectionTester implements QueryConnectionTester
+{
+    final static MLogger logger = MLog.getLogger( Percent20FailConnectionTester.class );
+
+    {
+	//logger.log(MLevel.WARNING,  "Instantiated: " + this, new Exception("Instantiation Stack Trace.") );
+    }
+
+    private int roulette()
+    {
+	if (Math.random() < 0.20d)
+	    return CONNECTION_IS_INVALID;
+	else
+	    return CONNECTION_IS_OKAY;
+    }
+
+    public int activeCheckConnection(Connection c)
+    {
+	//logger.warning(this + ": activeCheckConnection(Connection c)");
+	return roulette(); 
+    }
+
+    public int statusOnException(Connection c, Throwable t)
+    { 
+	//logger.warning(this + ": statusOnException(Connection c, Throwable t)");
+	return roulette(); 
+    }
+
+    public int activeCheckConnection(Connection c, String preferredTestQuery)
+    { 
+	//logger.warning(this + ": activeCheckConnection(Connection c, String preferredTestQuery)");
+	return roulette(); 
+    }
+
+    public boolean equals( Object o ) { return this.getClass().equals( o.getClass() ); }
+    public int hashCode() { return this.getClass().getName().hashCode(); }
+}
+