org.apache.storm.jdbc.common

Class JdbcClient

java.lang.Object

org.apache.storm.jdbc.common.JdbcClient

public class JdbcClient
extends Object

Constructor Summary

Constructors

Constructor and Description
JdbcClient(ConnectionProvider connectionProvider, int queryTimeoutSecs)

Method Summary

Modifier and Type	Method and Description
void	executeInsertQuery(String query, List<List<Column>> columnLists)
void	executeSql(String sql)
List<Column>	getColumnSchema(String tableName)
void	insert(String tableName, List<List<Column>> columnLists)
List<List<Column>>	select(String sqlQuery, List<Column> queryParams)

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcClient

public JdbcClient(ConnectionProvider connectionProvider,
                  int queryTimeoutSecs)

Method Detail

insert

public void insert(String tableName,
                   List<List<Column>> columnLists)

executeInsertQuery

public void executeInsertQuery(String query,
                               List<List<Column>> columnLists)

select

public List<List<Column>> select(String sqlQuery,
                                 List<Column> queryParams)

getColumnSchema

public List<Column> getColumnSchema(String tableName)

executeSql

public void executeSql(String sql)