db-derby-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kmars...@apache.org
Subject svn commit: r651701 - in /db/derby/code/trunk/java/testing/org/apache/derbyTesting/functionTests: master/ tests/lang/
Date Fri, 25 Apr 2008 21:14:04 GMT
Author: kmarsden
Date: Fri Apr 25 14:14:02 2008
New Revision: 651701

URL: http://svn.apache.org/viewvc?rev=651701&view=rev
Log:
DERBY-3623 Convert deadlockMode.java to JUnit

Contributed by Tiago Espinha (tiago at espinhas dot net)


Added:
    db/derby/code/trunk/java/testing/org/apache/derbyTesting/functionTests/tests/lang/DeadlockModeTest.java
  (with props)
Removed:
    db/derby/code/trunk/java/testing/org/apache/derbyTesting/functionTests/master/deadlockMode.out
    db/derby/code/trunk/java/testing/org/apache/derbyTesting/functionTests/tests/lang/deadlockMode.java
    db/derby/code/trunk/java/testing/org/apache/derbyTesting/functionTests/tests/lang/deadlockMode_derby.properties
    db/derby/code/trunk/java/testing/org/apache/derbyTesting/functionTests/tests/lang/deadlockMode_sed.properties
Modified:
    db/derby/code/trunk/java/testing/org/apache/derbyTesting/functionTests/tests/lang/LangHarnessJavaTest.java
    db/derby/code/trunk/java/testing/org/apache/derbyTesting/functionTests/tests/lang/_Suite.java

Added: db/derby/code/trunk/java/testing/org/apache/derbyTesting/functionTests/tests/lang/DeadlockModeTest.java
URL: http://svn.apache.org/viewvc/db/derby/code/trunk/java/testing/org/apache/derbyTesting/functionTests/tests/lang/DeadlockModeTest.java?rev=651701&view=auto
==============================================================================
--- db/derby/code/trunk/java/testing/org/apache/derbyTesting/functionTests/tests/lang/DeadlockModeTest.java
(added)
+++ db/derby/code/trunk/java/testing/org/apache/derbyTesting/functionTests/tests/lang/DeadlockModeTest.java
Fri Apr 25 14:14:02 2008
@@ -0,0 +1,224 @@
+/*
+ *
+ * Derby - Class DeadlockModeTest
+ *
+ * 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.functionTests.tests.lang;
+
+import java.sql.Connection;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.LinkedList;
+
+import junit.framework.Test;
+import junit.framework.TestSuite;
+
+import org.apache.derbyTesting.junit.BaseJDBCTestCase;
+import org.apache.derbyTesting.junit.CleanDatabaseTestSetup;
+import org.apache.derbyTesting.junit.DatabasePropertyTestSetup;
+import org.apache.derbyTesting.junit.Decorator;
+import org.apache.derbyTesting.junit.JDBC;
+import org.apache.derbyTesting.junit.TestConfiguration;
+
+/**
+ * This tests for deadlock which can occur if two threads get a 
+ * row lock before getting a table lock on the same table.  This can
+ * happen if the lock obtained by the insert, update or delete result set
+ * is a smaller range than the table scan result set.  The insert, update or
+ * delete result set lock is obtained first.  For example, if the insert, update
+ * or delete result set obtain a row lock and then the table scan obtains a
+ * table scan lock, deadlock can occur since two threads can obtain the row lock
+ * and then both thread will want the same table lock.
+ */
+public class DeadlockModeTest extends BaseJDBCTestCase {
+
+    /* Number of threads to use */
+    private static final int THREAD_COUNT = 20;
+    
+    /* Object used to manage the thread synching */
+    private Object syncObject = new Object();
+    
+    /* Amount of threads started so far */
+    private int startedCount = 0;
+    
+    /* Exceptions thrown by threads (if any) */
+    private LinkedList listExceptions = new LinkedList();
+    
+    /**
+     * Creates a new instance of DeadlockModeTest
+     * @param name identifier of the test
+     */
+	public DeadlockModeTest(String name) {
+	    super(name);
+	}
+    
+    /**
+     * Tests for a deadlock on concurrent accesses to the database
+     */
+    public void testThreadsUpdatingTable() throws Exception {
+        Thread [] t = new Thread[THREAD_COUNT];
+        
+        createThreads(t);
+        waitForThreads(t);
+        
+        if ( !listExceptions.isEmpty() ) {
+            fail("FAIL - " + listExceptions.size() + " threads threw exceptions");
+        }
+    }
+    
+    /**
+     * This method creates THREAD_COUNT threads which will all try to
+     * update the same table 
+     */
+    private void createThreads(Thread [] t) {
+        for (int i = 0; i < THREAD_COUNT; i++)
+        {   
+            t[i] = new Thread(new Runnable() {
+                public void run() {threadWorker(); }});
+            t[i].start();
+        }
+    }
+    
+    /**
+     * This method waits for the threads to finish their execution.
+     * This call will block the execution until signaled otherwise.
+     */
+    private void waitForThreads(Thread [] t) throws Exception {
+        for (int i = 0; i < THREAD_COUNT; i++)
+        {   
+            try {
+                t[i].join();
+            } catch (InterruptedException e){
+                assertNull(
+                        "FAIL - Exception thrown waiting for the threads",
+                        e);
+            }
+        }
+    }
+    
+    
+    /**
+     * This method has the code that each thread will be running.
+     * Since this will be running within different threads, we 
+     * can not throw exceptions, therefore we make a "bogus"
+     * assertNull(string message,Exception e) call.
+     */
+    private void threadWorker() {
+        Connection threadConnection = null;
+                
+        try {
+            synchronized (syncObject) {
+                
+                /* If a connection hasn't been opened for this thread, open one */
+                if (threadConnection == null){
+                    threadConnection = openDefaultConnection();
+                }
+                
+                /* A new thread started, so we increment the counter */
+                startedCount++;
+                
+                /* Wake all the threads to run the check below */
+                syncObject.notifyAll();
+                
+                while (startedCount < THREAD_COUNT) {
+                    syncObject.wait();
+                }
+            }          
+            Statement stmt = threadConnection.createStatement();
+            
+            /* execute a query to load cache */
+            stmt.executeUpdate("update t set i = 456 where i = 456");
+            
+            threadConnection.setAutoCommit(false);
+            
+            /* set isolation level to serializable */
+            stmt.execute("set isolation serializable");
+            
+            for (int i = 0; i < 100 ; i++) {
+                stmt.executeUpdate("update t set i = 456 where i = 456");
+                threadConnection.commit();
+            }
+        } catch (Exception e) {
+            synchronized(syncObject){
+                listExceptions.add(e);
+            }
+        }
+    }
+    
+    protected static Test baseSuite(String name) {
+        TestSuite suite = new TestSuite(name);
+        suite.addTestSuite(DeadlockModeTest.class);
+        return new CleanDatabaseTestSetup(
+                DatabasePropertyTestSetup.setLockTimeouts(suite, 2, 4)) 
+        {
+            /**
+             * Creates the tables used in the test cases.
+             * @exception SQLException if a database error occurs
+             */
+            protected void decorateSQL(Statement stmt) throws SQLException
+            {
+                stmt.execute("create table t (i int)");
+                
+                stmt.executeUpdate("insert into t values (1956)");
+        
+                stmt.executeUpdate("insert into t values (180)");
+        
+                stmt.executeUpdate("insert into t values (3)");
+            }
+        };
+    } 
+    
+    protected static Test encryptedBaseSuite(String name) {
+        TestSuite suite = new TestSuite(name);
+        suite.addTestSuite(DeadlockModeTest.class);
+        
+        return new CleanDatabaseTestSetup(
+                DatabasePropertyTestSetup.setLockTimeouts(Decorator.encryptedDatabase(suite),
2, 4)) 
+        {
+            /**
+             * Creates the tables used in the test cases.
+             * @exception SQLException if a database error occurs
+             */
+            protected void decorateSQL(Statement stmt) throws SQLException
+            {
+                stmt.execute("create table t (i int)");
+                
+                stmt.executeUpdate("insert into t values (1956)");
+        
+                stmt.executeUpdate("insert into t values (180)");
+        
+                stmt.executeUpdate("insert into t values (3)");
+            }
+        };
+    } 
+    
+    public static Test suite() {
+        TestSuite suite = new TestSuite("DeadlockModeTest ");
+        suite.addTest(
+                baseSuite("DeadlockModeTest:embedded")
+                );
+        
+        /* JSR169 does not have encryption support */
+        if ( JDBC.vmSupportsJDBC3() ) {
+            suite.addTest(
+                    encryptedBaseSuite("DeadlockModeTest:encrypted")
+                    );
+        }
+
+        return suite;        
+    }
+}

Propchange: db/derby/code/trunk/java/testing/org/apache/derbyTesting/functionTests/tests/lang/DeadlockModeTest.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: db/derby/code/trunk/java/testing/org/apache/derbyTesting/functionTests/tests/lang/LangHarnessJavaTest.java
URL: http://svn.apache.org/viewvc/db/derby/code/trunk/java/testing/org/apache/derbyTesting/functionTests/tests/lang/LangHarnessJavaTest.java?rev=651701&r1=651700&r2=651701&view=diff
==============================================================================
--- db/derby/code/trunk/java/testing/org/apache/derbyTesting/functionTests/tests/lang/LangHarnessJavaTest.java
(original)
+++ db/derby/code/trunk/java/testing/org/apache/derbyTesting/functionTests/tests/lang/LangHarnessJavaTest.java
Fri Apr 25 14:14:02 2008
@@ -62,7 +62,7 @@
         // "currentof", being converted
         // "cursor", TODO: investigate/convert
         "dbManagerLimits",
-        "deadlockMode",
+        //"deadlockMode", CONVERTED (DeadlockModeTest)
         // "declareGlobalTempTableJava", TODO: investigate/convert
         // "declareGlobalTempTableJavaJDBC30", TODO: uses TestUtil.isNetFramework()
         // "errorStream", TODO: investigate/convert

Modified: db/derby/code/trunk/java/testing/org/apache/derbyTesting/functionTests/tests/lang/_Suite.java
URL: http://svn.apache.org/viewvc/db/derby/code/trunk/java/testing/org/apache/derbyTesting/functionTests/tests/lang/_Suite.java?rev=651701&r1=651700&r2=651701&view=diff
==============================================================================
--- db/derby/code/trunk/java/testing/org/apache/derbyTesting/functionTests/tests/lang/_Suite.java
(original)
+++ db/derby/code/trunk/java/testing/org/apache/derbyTesting/functionTests/tests/lang/_Suite.java
Fri Apr 25 14:14:02 2008
@@ -130,7 +130,8 @@
         suite.addTest(OLAPTest.suite());
         suite.addTest(UniqueConstraintSetNullTest.suite());
         suite.addTest(ViewsTest.suite());
-
+        suite.addTest(DeadlockModeTest.suite());
+        
         // Add the XML tests, which exist as a separate suite
         // so that users can "run all XML tests" easily.
         suite.addTest(XMLSuite.suite());



Mime
View raw message