org.xbib.elasticsearch.river.jdbc.strategy.column

Class ColumnRiverSourceTests

java.lang.Object

org.testng.Assert

org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

org.xbib.elasticsearch.river.jdbc.strategy.column.AbstractColumnRiverTest

org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverSourceTests

public class ColumnRiverSourceTests
extends AbstractColumnRiverTest

Field Summary

Fields inherited from class org.xbib.elasticsearch.river.jdbc.strategy.column.AbstractColumnRiverTest

context, source

Fields inherited from class org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

cluster, index, type

Constructor Summary

Constructors

Constructor and Description
ColumnRiverSourceTests()

Method Summary

Methods

Modifier and Type	Method and Description
ColumnRiverContext	newRiverContext()
ColumnRiverSource	newRiverSource()
void	testCreateObjects_configurationWithSqlParams(String riverResource, String sql)
void	testCreateObjects_configurationWithWherePlaceholder(String riverResource, String sql)
void	testCreateObjects_withLastRunTimeStampOverlap(String riverResource, String sql)
void	testCreateObjects(String riverResource, String sql)
void	testRemoveObjects_configurationWithWherePlaceholder(String riverResource, String insertSql)
void	testRemoveObjects(String riverResource, String insertSql)

Methods inherited from class org.xbib.elasticsearch.river.jdbc.strategy.column.AbstractColumnRiverTest

afterMethod, beforeMethod, createRiver, performRiver, riverSettings, waitForActiveRiver, waitForActiveRiver, waitForInactiveRiver, waitForInactiveRiver, waitForRiver, waitForRiver

Methods inherited from class org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

assertHits, assertTimestampSort, buildNode, client, getClusterName, getNodeSettings, setClusterName, startNode, startNodes, stopNodes, waitForYellow

Methods inherited from class org.testng.Assert

assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEqualsNoOrder, assertEqualsNoOrder, assertFalse, assertFalse, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotNull, assertNotNull, assertNotSame, assertNotSame, assertNull, assertNull, assertSame, assertSame, assertTrue, assertTrue, fail, fail, fail

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ColumnRiverSourceTests

public ColumnRiverSourceTests()

Method Detail

newRiverSource

public ColumnRiverSource newRiverSource()

Specified by:

newRiverSource in class AbstractColumnRiverTest

newRiverContext

public ColumnRiverContext newRiverContext()

Specified by:

newRiverContext in class AbstractColumnRiverTest

testCreateObjects

public void testCreateObjects(String riverResource,
                     String sql)
                       throws Exception

Throws:

Exception

testCreateObjects_configurationWithWherePlaceholder

public void testCreateObjects_configurationWithWherePlaceholder(String riverResource,
                                                       String sql)
                                                         throws Exception

Throws:

Exception

testCreateObjects_configurationWithSqlParams

public void testCreateObjects_configurationWithSqlParams(String riverResource,
                                                String sql)
                                                  throws Exception

Throws:

Exception

testRemoveObjects

public void testRemoveObjects(String riverResource,
                     String insertSql)
                       throws Exception

Throws:

Exception

testRemoveObjects_configurationWithWherePlaceholder

public void testRemoveObjects_configurationWithWherePlaceholder(String riverResource,
                                                       String insertSql)
                                                         throws Exception

Throws:

Exception

testCreateObjects_withLastRunTimeStampOverlap

public void testCreateObjects_withLastRunTimeStampOverlap(String riverResource,
                                                 String sql)
                                                   throws Exception

Throws:

Exception