org.apache.drill.jdbc

Class JdbcTestBase

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.test.DrillTest

org.apache.drill.exec.ExecTest

org.apache.drill.jdbc.JdbcTestBase

Direct Known Subclasses:

ConnectionInfoTest, ConnectionTest, DatabaseMetaDataGetColumnsTest, Drill2128GetColumnsDataTypeNotTypeCodeIntBugsTest, Drill2439GetBooleanFailsSayingWrongTypeBugTest, Drill2461IntervalsBreakInfoSchemaBugTest, Drill2463GetNullsFailedWithAssertionsBugTest, Drill2489CallsAfterCloseThrowExceptionsTest, Drill2769UnsupportedReportsUseSqlExceptionTest, DrillResultSetTest, JdbcConnectTriesTestEmbeddedBits, JdbcDataTest, JdbcTestActionBase, JdbcTestQueryBase, LegacyPreparedStatementTest, PreparedStatementMaxRowsTest, PreparedStatementTest, ResultSetGetMethodConversionsTest, ResultSetMetaDataTest, StatementMaxRowsTest, StatementTest, TestExecutionExceptionsToClient, TestInformationSchemaColumns, TestJdbcDistQuery

public class JdbcTestBase
extends ExecTest

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JdbcTestBase.ModelAndSchema
static class	JdbcTestBase.TestDataConnection

Nested classes/interfaces inherited from class org.apache.drill.test.DrillTest

DrillTest.MemWatcher

Field Summary

Fields

Modifier and Type	Field and Description
org.junit.rules.TestRule	watcher

Fields inherited from class org.apache.drill.exec.ExecTest

c, dirTestWatcher, optionManager

Fields inherited from class org.apache.drill.test.DrillTest

logOutcome, objectMapper, REPEAT_RULE, thrownException, TIMEOUT

Constructor Summary

Constructors

Constructor and Description
JdbcTestBase()

Method Summary

Modifier and Type	Method and Description
protected static void	changeSchema(Connection conn, String schema)
protected static void	changeSchemaIfSupplied(Connection conn, Properties info) Changes schema of the given connection if the field "schema" is present in info.
protected static Connection	connect()
protected static Connection	connect(String url) Creates a connection using default parameters.
protected static Connection	connect(String url, Properties info) Creates a connection using the given parameters.
static Properties	getDefaultProperties() Returns default bag of properties that is passed to JDBC connection.
protected static void	reset() Resets the factory closing all of the active connections.
static void	setUpTestCase()
static void	tearDownTestCase()
void	testJdbcTestConnectionResettingCompatibility() Test of whether tests that get connection from JdbcTest.connect(...) work with resetting of connections.
static String	toString(ResultSet resultSet)
static String	toString(ResultSet resultSet, int expectedRecordCount)
static JdbcTestBase.ModelAndSchema	withFull(String schema)
static JdbcTestBase.ModelAndSchema	withModel(String model, String schema)
static JdbcTestBase.ModelAndSchema	withNoDefaultSchema()

Methods inherited from class org.apache.drill.exec.ExecTest

clear, getLocalFileSystem, mockDrillbitContext, mockUsDateFormatSymbols, mockUtcDateTimeZone, parseExpr, setupOptionManager

Methods inherited from class org.apache.drill.test.DrillTest

escapeJsonString, finishDrillTest, initDrillTest

Methods inherited from class java.lang.Object

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

Field Detail

watcher

public final org.junit.rules.TestRule watcher

Constructor Detail

JdbcTestBase

public JdbcTestBase()

Method Detail

setUpTestCase

public static void setUpTestCase()

connect

protected static Connection connect(String url)
                             throws SQLException

Creates a connection using default parameters.

Parameters:

url - connection URL

Throws:

SQLException - if connection fails

connect

protected static Connection connect()
                             throws SQLException

Throws:

SQLException

connect

protected static Connection connect(String url,
                                    Properties info)
                             throws SQLException

Creates a connection using the given parameters.

Parameters:

url - connection URL

info - connection info

Throws:

SQLException - if connection fails

changeSchemaIfSupplied

protected static void changeSchemaIfSupplied(Connection conn,
                                             Properties info)

Changes schema of the given connection if the field "schema" is present in info. Does nothing otherwise.

changeSchema

protected static void changeSchema(Connection conn,
                                   String schema)

reset

protected static void reset()

Resets the factory closing all of the active connections.

tearDownTestCase

public static void tearDownTestCase()
                             throws Exception

Throws:

Exception

getDefaultProperties

public static Properties getDefaultProperties()

Returns default bag of properties that is passed to JDBC connection. By default, includes options to: - turn off the web server - indicate DrillConnectionImpl to set up dfs.tmp schema location to an exclusive dir just for this test jvm

withModel

public static JdbcTestBase.ModelAndSchema withModel(String model,
                                                    String schema)

withFull

public static JdbcTestBase.ModelAndSchema withFull(String schema)

withNoDefaultSchema

public static JdbcTestBase.ModelAndSchema withNoDefaultSchema()

toString

public static String toString(ResultSet resultSet,
                              int expectedRecordCount)
                       throws SQLException

Throws:

SQLException

toString

public static String toString(ResultSet resultSet)
                       throws SQLException

Throws:

SQLException

testJdbcTestConnectionResettingCompatibility

public void testJdbcTestConnectionResettingCompatibility()

Test of whether tests that get connection from JdbcTest.connect(...) work with resetting of connections. If enabling this (failing) test method causes other test methods to fail, something needs to be fixed. (Note: Not a guaranteed test--depends on order in which test methods are run.)