org.apache.nifi.processors.standard

Class TestPutSQL

java.lang.Object

org.apache.nifi.processors.standard.TestPutSQL

public class TestPutSQL
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static org.junit.rules.TemporaryFolder	folder
protected static DBCPService	service Setting up Connection pooling is expensive operation.

Constructor Summary

Constructors

Constructor and Description
TestPutSQL()

Method Summary

Modifier and Type	Method and Description
static void	setupClass()
void	testBinaryColumnTypes()
void	testBitType()
void	testDirectStatements()
void	testFailInMiddleWithBadParameterType()
void	testFailInMiddleWithBadParameterTypeRollbackOnFailure()
void	testFailInMiddleWithBadParameterValue()
void	testFailInMiddleWithBadParameterValueRollbackOnFailure()
void	testFailInMiddleWithBadStatement()
void	testFailInMiddleWithBadStatementRollbackOnFailure()
void	testInsertWithGeneratedKeys()
void	testInvalidStatement()
void	testInvalidStatementRollbackOnFailure()
void	testMultipleFlowFilesSuccessfulInTransaction()
void	testMultipleFlowFilesSuccessfulInTransactionRollBackOnFailure()
void	testMultipleStatementsWithinFlowFile()
void	testMultipleStatementsWithinFlowFileRollbackOnFailure()
void	testNullFragmentCountRollbackOnFailure()
void	testRetryableFailure()
void	testRetryableFailureRollbackOnFailure()
void	testStatementsWithPreparedParameters()
void	testTransactionTimeout()
void	testTransactionTimeoutRollbackOnFailure()
void	testUsingDateTimeValuesWithFormatAttribute()
void	testUsingDateValuesEpochAndString()
void	testUsingSqlDataTypesWithNegativeValues()
void	testUsingTimestampValuesEpochAndString()
void	testUsingTimestampValuesWithFormatAttribute()
void	testUsingTimeValuesEpochAndString()
void	testWithNullParameter()

Methods inherited from class java.lang.Object

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

Field Detail

folder

public static org.junit.rules.TemporaryFolder folder

service

protected static DBCPService service

Setting up Connection pooling is expensive operation. So let's do this only once and reuse MockDBCPService in each test.

Constructor Detail

TestPutSQL

public TestPutSQL()

Method Detail

setupClass

public static void setupClass()
                       throws ProcessException,
                              java.sql.SQLException

Throws:

ProcessException

java.sql.SQLException

testDirectStatements

public void testDirectStatements()
                          throws InitializationException,
                                 ProcessException,
                                 java.sql.SQLException,
                                 java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

testInsertWithGeneratedKeys

public void testInsertWithGeneratedKeys()
                                 throws InitializationException,
                                        ProcessException,
                                        java.sql.SQLException,
                                        java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

testFailInMiddleWithBadStatement

public void testFailInMiddleWithBadStatement()
                                      throws InitializationException,
                                             ProcessException,
                                             java.sql.SQLException,
                                             java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

testFailInMiddleWithBadStatementRollbackOnFailure

public void testFailInMiddleWithBadStatementRollbackOnFailure()
                                                       throws InitializationException,
                                                              ProcessException,
                                                              java.sql.SQLException,
                                                              java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

testFailInMiddleWithBadParameterType

public void testFailInMiddleWithBadParameterType()
                                          throws InitializationException,
                                                 ProcessException,
                                                 java.sql.SQLException,
                                                 java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

testFailInMiddleWithBadParameterTypeRollbackOnFailure

public void testFailInMiddleWithBadParameterTypeRollbackOnFailure()
                                                           throws InitializationException,
                                                                  ProcessException,
                                                                  java.sql.SQLException,
                                                                  java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

testFailInMiddleWithBadParameterValue

public void testFailInMiddleWithBadParameterValue()
                                           throws InitializationException,
                                                  ProcessException,
                                                  java.sql.SQLException,
                                                  java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

testFailInMiddleWithBadParameterValueRollbackOnFailure

public void testFailInMiddleWithBadParameterValueRollbackOnFailure()
                                                            throws InitializationException,
                                                                   ProcessException,
                                                                   java.sql.SQLException,
                                                                   java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

testUsingSqlDataTypesWithNegativeValues

public void testUsingSqlDataTypesWithNegativeValues()
                                             throws InitializationException,
                                                    ProcessException,
                                                    java.sql.SQLException,
                                                    java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

testUsingTimestampValuesEpochAndString

public void testUsingTimestampValuesEpochAndString()
                                            throws InitializationException,
                                                   ProcessException,
                                                   java.sql.SQLException,
                                                   java.io.IOException,
                                                   java.text.ParseException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

java.text.ParseException

testUsingTimestampValuesWithFormatAttribute

public void testUsingTimestampValuesWithFormatAttribute()
                                                 throws InitializationException,
                                                        ProcessException,
                                                        java.sql.SQLException,
                                                        java.io.IOException,
                                                        java.text.ParseException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

java.text.ParseException

testUsingDateTimeValuesWithFormatAttribute

public void testUsingDateTimeValuesWithFormatAttribute()
                                                throws InitializationException,
                                                       ProcessException,
                                                       java.sql.SQLException,
                                                       java.io.IOException,
                                                       java.text.ParseException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

java.text.ParseException

testBitType

public void testBitType()
                 throws java.sql.SQLException,
                        InitializationException

Throws:

java.sql.SQLException

InitializationException

testUsingTimeValuesEpochAndString

public void testUsingTimeValuesEpochAndString()
                                       throws InitializationException,
                                              ProcessException,
                                              java.sql.SQLException,
                                              java.io.IOException,
                                              java.text.ParseException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

java.text.ParseException

testUsingDateValuesEpochAndString

public void testUsingDateValuesEpochAndString()
                                       throws InitializationException,
                                              ProcessException,
                                              java.sql.SQLException,
                                              java.io.IOException,
                                              java.text.ParseException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

java.text.ParseException

testBinaryColumnTypes

public void testBinaryColumnTypes()
                           throws InitializationException,
                                  ProcessException,
                                  java.sql.SQLException,
                                  java.io.IOException,
                                  java.text.ParseException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

java.text.ParseException

testStatementsWithPreparedParameters

public void testStatementsWithPreparedParameters()
                                          throws InitializationException,
                                                 ProcessException,
                                                 java.sql.SQLException,
                                                 java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

testMultipleStatementsWithinFlowFile

public void testMultipleStatementsWithinFlowFile()
                                          throws InitializationException,
                                                 ProcessException,
                                                 java.sql.SQLException,
                                                 java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

testMultipleStatementsWithinFlowFileRollbackOnFailure

public void testMultipleStatementsWithinFlowFileRollbackOnFailure()
                                                           throws InitializationException,
                                                                  ProcessException,
                                                                  java.sql.SQLException,
                                                                  java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

testWithNullParameter

public void testWithNullParameter()
                           throws InitializationException,
                                  ProcessException,
                                  java.sql.SQLException,
                                  java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

testInvalidStatement

public void testInvalidStatement()
                          throws InitializationException,
                                 ProcessException,
                                 java.sql.SQLException,
                                 java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

testInvalidStatementRollbackOnFailure

public void testInvalidStatementRollbackOnFailure()
                                           throws InitializationException,
                                                  ProcessException,
                                                  java.sql.SQLException,
                                                  java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

testRetryableFailure

public void testRetryableFailure()
                          throws InitializationException,
                                 ProcessException,
                                 java.sql.SQLException,
                                 java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

testRetryableFailureRollbackOnFailure

public void testRetryableFailureRollbackOnFailure()
                                           throws InitializationException,
                                                  ProcessException,
                                                  java.sql.SQLException,
                                                  java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

testMultipleFlowFilesSuccessfulInTransaction

public void testMultipleFlowFilesSuccessfulInTransaction()
                                                  throws InitializationException,
                                                         ProcessException,
                                                         java.sql.SQLException,
                                                         java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

testMultipleFlowFilesSuccessfulInTransactionRollBackOnFailure

public void testMultipleFlowFilesSuccessfulInTransactionRollBackOnFailure()
                                                                   throws InitializationException,
                                                                          ProcessException,
                                                                          java.sql.SQLException,
                                                                          java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

testTransactionTimeout

public void testTransactionTimeout()
                            throws InitializationException,
                                   ProcessException,
                                   java.sql.SQLException,
                                   java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

testTransactionTimeoutRollbackOnFailure

public void testTransactionTimeoutRollbackOnFailure()
                                             throws InitializationException,
                                                    ProcessException,
                                                    java.sql.SQLException,
                                                    java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException

testNullFragmentCountRollbackOnFailure

public void testNullFragmentCountRollbackOnFailure()
                                            throws InitializationException,
                                                   ProcessException,
                                                   java.sql.SQLException,
                                                   java.io.IOException

Throws:

InitializationException

ProcessException

java.sql.SQLException

java.io.IOException