com.yahoo.bard.webservice.sql

Class DefaultSqlBackedClient

java.lang.Object

com.yahoo.bard.webservice.sql.DefaultSqlBackedClient

All Implemented Interfaces:

SqlBackedClient

public class DefaultSqlBackedClient
extends Object
implements SqlBackedClient

Converts druid queries to sql, executes it, and returns a druid like response.

Constructor Summary

Constructors

Constructor and Description
DefaultSqlBackedClient(DataSource dataSource, com.fasterxml.jackson.databind.ObjectMapper objectMapper) Creates a sql converter using the given database and datasource.
DefaultSqlBackedClient(String url, String driver, String username, String password, com.fasterxml.jackson.databind.ObjectMapper objectMapper) Creates a sql converter using the given database and datasource.

Method Summary

Modifier and Type	Method and Description
Future<com.fasterxml.jackson.databind.JsonNode>	executeQuery(DruidQuery<?> druidQuery, SuccessCallback successCallback, FailureCallback failureCallback) Uses a DruidQuery to fetch results from a Sql client, parses the results from Sql and returns an equivalent JsonNode to what druid would respond with.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSqlBackedClient

public DefaultSqlBackedClient(DataSource dataSource,
                              com.fasterxml.jackson.databind.ObjectMapper objectMapper)
                       throws SQLException

Creates a sql converter using the given database and datasource.

Parameters:

dataSource - The dataSource for the jdbc schema.

objectMapper - The mapper for all JSON processing.

Throws:

SQLException - if can't read from database.

DefaultSqlBackedClient

public DefaultSqlBackedClient(String url,
                              String driver,
                              String username,
                              String password,
                              com.fasterxml.jackson.databind.ObjectMapper objectMapper)
                       throws SQLException

Creates a sql converter using the given database and datasource. TODO See https://github.com/yahoo/fili/issues/511

Parameters:

url - The url location of the database to connect to.

driver - The driver (i.e. "org.h2.Driver") to connect with.

username - The username to connect to the database.

password - The password to connect to the database.

objectMapper - The mapper for all JSON processing.

Throws:

SQLException - if can't read from database.

Method Detail

executeQuery

public Future<com.fasterxml.jackson.databind.JsonNode> executeQuery(DruidQuery<?> druidQuery,
                                                                    SuccessCallback successCallback,
                                                                    FailureCallback failureCallback)

Description copied from interface: SqlBackedClient

Uses a DruidQuery to fetch results from a Sql client, parses the results from Sql and returns an equivalent JsonNode to what druid would respond with.

Specified by:

executeQuery in interface SqlBackedClient

Parameters:

druidQuery - The query to be executed.

successCallback - The callback for handling a successful result.

failureCallback - The callback for handling exceptions

Returns:

a json result replicating druid's responses.