org.xbib.elasticsearch.river.jdbc.strategy.simple

Class SimpleRiverScheduleTests

java.lang.Object

org.testng.Assert

org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverScheduleTests

public class SimpleRiverScheduleTests
extends AbstractSimpleRiverTest

Field Summary

Fields inherited from class org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

context, source

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

cluster, index, logger, type

Constructor Summary

Constructors

Constructor and Description
SimpleRiverScheduleTests()

Method Summary

Methods

Modifier and Type	Method and Description
SimpleRiverContext	newRiverContext()
RiverSource	newRiverSource()
void	testSimpleSchedule(String riverResource, String sql) Product table star select, scheduled for more than two runs
void	testTimestamps(String riverResource, String sql) Test read and write of timestamps in a table.

Methods inherited from class org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

afterMethod, beforeMethod, createRandomProducts, createRandomProductsJob, createRiver, createTimestampedLogs, performRiver, 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

SimpleRiverScheduleTests

public SimpleRiverScheduleTests()

Method Detail

newRiverSource

public RiverSource newRiverSource()

Specified by:

newRiverSource in class AbstractSimpleRiverTest

newRiverContext

public SimpleRiverContext newRiverContext()

Specified by:

newRiverContext in class AbstractSimpleRiverTest

testSimpleSchedule

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

Product table star select, scheduled for more than two runs

Parameters:

riverResource - the river resource

sql - the SQL statement

Throws:

Exception - if test fails

testTimestamps

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

Test read and write of timestamps in a table. We create 100 timestamps over hour interval, current timestamp $now is in the center. Selecting timestamps from $now, there should be at least 50 rows/hits per run, if $now works.

Parameters:

riverResource - the river JSON resource

sql - the sql statement to select timestamps

Throws:

Exception