CVS update of carob/test/10-Connection (2 files)

    Date: Friday, February 24, 2006 @ 12:58:06
  Author: gilles
    Path: /cvsroot/carob/carob/test/10-Connection

   Added: TestFailOver.cpp (1.1) TestFailOver.hpp (1.1)

(new files)
Added failover testing
Only two tests enabled because because big one requires user interaction


------------------+
 TestFailOver.cpp |  164 +++++++++++++++++++++++++++++++++++++++++++++++++++++
 TestFailOver.hpp |   69 ++++++++++++++++++++++
 2 files changed, 233 insertions(+)


Index: carob/test/10-Connection/TestFailOver.cpp
diff -u /dev/null carob/test/10-Connection/TestFailOver.cpp:1.1
--- /dev/null   Fri Feb 24 12:58:06 2006
+++ carob/test/10-Connection/TestFailOver.cpp   Fri Feb 24 12:58:06 2006
@@ -0,0 +1,164 @@
+/*
+ * Sequoia: Database clustering technology.
+ * Copyright (C) 2005-2006 Continuent, Inc.
+ * Contact: sequoia-NAAfj4rwCWAYtQj7fl1lsA@xxxxxxxxxxxxxxxx
+ * 
+ * Licensed 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.
+ *
+ * Initial developer(s): Gilles Rayrat
+ * Contributor(s): 
+ */
+
+#include "TestFailOver.hpp"
+
+#include "Statement.hpp"
+#include "Connection.hpp"
+
+#include "Common.hpp"
+
+#include <string>
+#include <iostream>
+
+using std::wstring;
+
+using namespace CarobNS;
+
+void TestFailOver::setUp()
+{
+}
+
+void TestFailOver::tearDown()
+{
+}
+
+void TestFailOver::testReconnectNoControllers()
+{
+  // this is a dummy port
+  ConnectionParameters connectionPrms(L"localhost",
+                                      12345,
+                                      L"myDB",
+                                      L"user",
+                                      L"",
+                                      DEBUG_LEVEL_DEBUG);
+  // 1st try with only 1 failing ctrler
+  try
+  {
+    Connection* connectionPtr = new Connection(connectionPrms);
+    connectionPtr->setAutoCommit(false); //just to avoid unused variable 
warning
+  }
+  catch (ConnectionException ce)
+  {
+    if (isInfoEnabled())
+      logError(L"TestFailOver::testReconnectNoControllers",
+          L"new Connection throw connection exception (this is ok): "
+          + ce.description());
+  }
+  // 2nd try with 2 (first one is now suspected of failure...
+  connectionPrms.addController(L"localhost", 12346);
+  connectionPrms.addController(L"localhost", 12347);
+  try
+  {
+    Connection* connectionPtr = new Connection(connectionPrms);
+    connectionPtr->setAutoCommit(false); //just to avoid unused variable 
warning
+  }
+  catch (ConnectionException ce)
+  {
+    if (isInfoEnabled())
+      logError(L"TestFailOver::testReconnectNoControllers",
+          L"new Connection throw connection exception (this is ok): "
+          + ce.description());
+  }
+}
+
+void TestFailOver::testConnectOnlyOneControllerUp()
+{
+  // this is a dummy port
+  ConnectionParameters connectionPrms(L"localhost",
+                                      12348,
+                                      L"myDB",
+                                      L"user",
+                                      L"",
+                                      DEBUG_LEVEL_DEBUG);
+  // 2nd controller is down too
+  connectionPrms.addController(L"localhost", 12349);
+  // 3rd controller is ok
+  connectionPrms.addController(L"localhost", 25322);
+  // 4th is down
+  connectionPrms.addController(L"localhost", 12350);
+  Connection* connectionPtr = new Connection(connectionPrms);
+  //no exception.. good. clean the connection
+  delete connectionPtr;
+}
+
+void TestFailOver::testReconnect()
+{
+  // this is a dummy controller
+  ConnectionParameters connectionPrms(L"localhost",
+                                      25324,
+                                      L"myDB",
+                                      L"user",
+                                      L"",
+                                      DEBUG_LEVEL_DEBUG);
+  // this one will work
+  connectionPrms.addController(L"localhost", 25322);
+  // this one too
+  connectionPrms.addController(L"localhost", 25323);
+  Connection* connectionPtr = new Connection(connectionPrms);
+  Statement* statementPtr = connectionPtr->createStatement();
+
+  wstring fctName(L"TestExecWriteRequest::testReconnect");
+  wstring requestBegin = L"UPDATE product SET cost=";
+  wstring requestEnd = L" where id=";
+
+//  int nbRowsAffected;
+  bool rsuc;
+  if (isInfoEnabled())
+    logInfo(fctName, L"Executing 1000 writes");
+  for (int i=0; i<1000; i++)
+  {
+    try
+    {
+//      nbRowsAffected = statementPtr->executeUpdate(
+//          requestBegin + toWString(i) + requestEnd + toWString(i%50));
+      rsuc = statementPtr->execute(
+          requestBegin + toWString(i) + requestEnd + toWString(i%50));
+    }
+    catch (NoMoreControllerException nmce)
+    {
+      if (isInfoEnabled())
+          logError(fctName, L"Write failed (this is ok). Exception:"
+              + nmce.description());      
+    }
+//    CPPUNIT_ASSERT(nbRowsAffected == 1);
+    CPPUNIT_ASSERT(rsuc == false);
+    sleep(1);
+  }
+}
+
+CppUnit::Test* TestFailOver::suite()
+{
+  CppUnit::TestSuite *suiteOfTests = new CppUnit::TestSuite( "TestFailOver" );
+  suiteOfTests->addTest(new CppUnit::TestCaller<TestFailOver>(
+                                 "TestFailOver::testReconnectNoControllers",
+                                 &TestFailOver::testReconnectNoControllers));
+  suiteOfTests->addTest(new CppUnit::TestCaller<TestFailOver>(
+                                 
"TestFailOver::testConnectOnlyOneControllerUp",
+                                 
&TestFailOver::testConnectOnlyOneControllerUp));
+//disabled test: needs user interaction
+/*  suiteOfTests->addTest(new CppUnit::TestCaller<TestFailOver>(
+                                 "TestFailOver::testReconnect",
+                                 &TestFailOver::testReconnect));
+*/
+
+  return suiteOfTests;
+}
Index: carob/test/10-Connection/TestFailOver.hpp
diff -u /dev/null carob/test/10-Connection/TestFailOver.hpp:1.1
--- /dev/null   Fri Feb 24 12:58:06 2006
+++ carob/test/10-Connection/TestFailOver.hpp   Fri Feb 24 12:58:06 2006
@@ -0,0 +1,69 @@
+/*
+ * Sequoia: Database clustering technology.
+ * Copyright (C) 2005-2006 Continuent, Inc.
+ * Contact: sequoia-NAAfj4rwCWAYtQj7fl1lsA@xxxxxxxxxxxxxxxx
+ * 
+ * Licensed 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.
+ *
+ * Initial developer(s): Gilles Rayrat
+ * Contributor(s): 
+ */
+
+#ifndef TESTFAILOVER_H_
+#define TESTFAILOVER_H_
+
+
+#include <cppunit/TestFixture.h>
+#include <cppunit/TestCase.h>
+#include <cppunit/TestSuite.h>
+#include <cppunit/TestCaller.h>
+
+#include "Connection.hpp"
+
+/**
+ * Test class for controller connection policy
+ * Tests suspected controller queuing and update
+ * A controller *MUST* run locally for test success !!!
+ */
+class TestFailOver : CppUnit::TestFixture
+{
+public:
+  /** Suite of tests to be run */
+  static CppUnit::Test* suite();
+
+  /** Nothing to setup / tear down*/
+  void setUp();
+  void tearDown();
+  /**
+   * Tries to connect to 1 then 2 failing controllers (actually with dummy 
ports)
+   */
+  void testReconnectNoControllers();
+  /**
+   * Tries to connect to a list of controller in which only 1 ctrller is up
+   */
+  void testConnectOnlyOneControllerUp();
+  /**
+   * USER INTERACTION NEEDED !
+   * Launches 1000 write requests having 2 controllers.
+   * During these writes, the user has to stop one of the controllers and check
+   * that the other one is connected to silently
+   * Stop controller preferably with iptables. Command for iptables:
+   * > iptables -A INPUT -i lo -p tcp --dport 25322 -d localhost -j REJECT 
--reject-with tcp-reset
+   * to restore traffic:
+   * > iptables -D INPUT 1
+   */
+  void testReconnect();
+private:
+};
+
+#endif /*TESTFAILOVER_H_*/