Examples of com.pardot.rhombus.ConnectionManager.teardown()

Class com.pardot.rhombus.ConnectionManager

Examples of com.pardot.rhombus.ConnectionManager.teardown()

com.pardot.rhombus.ConnectionManager.teardown()
Tear down all connections contained in associated object mappers and shutdown the cluster.


    //verify that if we try to get the next row it returns null
    assertEquals(null, om.getNextUpdateIndexRow(row.getRowKey()));


    //Teardown connections
    cm.teardown();
  }


  @Test
  public void testObjectWithCustomKey() throws Exception {
    //Build the connection manager

View Full Code Here

    assertEquals("A-data1", result.get("data1"));


    result = om.getByKey("customkey", "B");
    assertEquals("B-data1", result.get("data1"));


    cm.teardown();
  }


  @Test
  public void testDelete() throws Exception {
    //Build the connection manager

View Full Code Here

    //Remove the object we added
    om.delete("testtype", key3);
    //Query to get back the object from the database
    assertEquals(null, om.getByKey("testtype", key3));


    cm.teardown();
  }


  //This does not test blob or counter types
  @Test
  public void testObjectTypes() throws Exception {

View Full Code Here

        Object returnValue = returnedValues.get(returnedKey);
        assertEquals(insertValue, returnValue);
      }
    }


    cm.teardown();
  }




  @Test
  public void testDateRangeQueries() throws Exception {

View Full Code Here

    //And for results since May 14, 2013
    criteria.setStartTimestamp(1368489600000L);
    results = om.list("object_audit", criteria);
    assertEquals(5, results.size());


    cm.teardown();
  }


  @Test
  public void testNullIndexValues() throws Exception {
    logger.debug("Starting testNullIndexValues");

View Full Code Here

        }
      }
      logger.debug("{} Result: {}, Input: {}", key, result.get(key), object.get(key));
    }


    cm.teardown();
  }


  @Test
  public void testLargeCount() throws Exception {
    logger.debug("Starting testLargeCount");

View Full Code Here


    //now test the count function
    long count = om.count("object2", criteria);
    assertEquals(nDataItems, count);


    cm.teardown();
  }

View Full Code Here


    //now test the count function
    long count = om.count("object2", criteria);
    assertEquals(nDataItems, count);


    cm.teardown();
  }


  @Test
  public void testLargeCountWithLimit() throws Exception {
    logger.debug("Starting testLargeCountWithLimit");

View Full Code Here


    //now test the count function
    long count = om.count("object2", criteria);
    assertEquals(20, count);


    cm.teardown();
  }


  @Test
  public void testLargeCountWithFiltering() throws Exception {
    logger.debug("Starting testLargeCountWithFilteringt");

View Full Code Here


    //now test the count function
    long count = om.count("object2", criteria);
    assertEquals((nDataItems / 3) + 1, count);


    cm.teardown();
  }


  @Test
  public void testLargeCountWithLimitAndFiltering() throws Exception {
    logger.debug("Starting testLargeCountWithLimitAndFiltering");

View Full Code Here

0 1 2 3 4 5 6

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.