org.apache.lens.driver.jdbc

Class JDBCResultSet

java.lang.Object

org.apache.lens.server.api.driver.LensResultSet

org.apache.lens.server.api.driver.InMemoryResultSet

org.apache.lens.driver.jdbc.JDBCResultSet

public class JDBCResultSet
extends InMemoryResultSet

The Class JDBCResultSet.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JDBCResultSet.FieldSchemaData FieldSchemaData is created so that we don't save FieldSchema as some classes used by it don't have default constructors which are required by jackson
static class	JDBCResultSet.JDBCResultSetMetadata Result set metadata of a JDBC query

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.log4j.Logger	LOG The Constant LOG.

Constructor Summary

Constructors

Constructor and Description
JDBCResultSet(org.apache.lens.driver.jdbc.JDBCDriver.QueryResult queryResult, ResultSet resultSet, boolean closeAfterFetch) Instantiates a new JDBC result set.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Close.
static String	getHiveTypeForSQLType(int index, ResultSetMetaData rsmeta) Gets the hive type for sql type.
LensResultSetMetadata	getMetadata() Get the result set metadata
boolean	hasNext() Whether there is another result row available.
ResultRow	next() Read the next result row.
boolean	seekToStart()
void	setFetchSize(int size) Set number of rows to be fetched at time
int	size() Get the size of the result set.

Methods inherited from class org.apache.lens.server.api.driver.InMemoryResultSet

toQueryResult

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.apache.log4j.Logger LOG

The Constant LOG.

Constructor Detail

JDBCResultSet

public JDBCResultSet(org.apache.lens.driver.jdbc.JDBCDriver.QueryResult queryResult,
             ResultSet resultSet,
             boolean closeAfterFetch)
              throws LensException

Instantiates a new JDBC result set.

Parameters:

queryResult - the query result

resultSet - the result set

closeAfterFetch - the close after fetch

Throws:

LensException

Method Detail

size

public int size()
         throws LensException

Description copied from class: LensResultSet

Get the size of the result set.

Specified by:

size in class LensResultSet

Returns:

The size if available, -1 if not available.

Throws:

LensException - the lens exception

getMetadata

public LensResultSetMetadata getMetadata()
                                  throws LensException

Description copied from class: LensResultSet

Get the result set metadata

Specified by:

getMetadata in class LensResultSet

Returns:

Returns LensResultSetMetadata

Throws:

LensException

getHiveTypeForSQLType

public static String getHiveTypeForSQLType(int index,
                           ResultSetMetaData rsmeta)
                                    throws SQLException

Gets the hive type for sql type.

Parameters:

index - the index

rsmeta - the rsmeta

Returns:

the hive type for sql type

Throws:

SQLException - the SQL exception

setFetchSize

public void setFetchSize(int size)
                  throws LensException

Description copied from class: InMemoryResultSet

Set number of rows to be fetched at time

Specified by:

setFetchSize in class InMemoryResultSet

Throws:

LensException

next

public ResultRow next()
               throws LensException

Description copied from class: InMemoryResultSet

Read the next result row.

Specified by:

next in class InMemoryResultSet

Returns:

The row as list of object

Throws:

LensException - the lens exception

seekToStart

public boolean seekToStart()
                    throws LensException

Specified by:

seekToStart in class InMemoryResultSet

Throws:

LensException

hasNext

public boolean hasNext()
                throws LensException

Description copied from class: InMemoryResultSet

Whether there is another result row available.

Specified by:

hasNext in class InMemoryResultSet

Returns:

true if next row if available, false otherwise

Throws:

LensException - the lens exception

close

public void close()

Close.