io.druid.db

Class DbConnector

java.lang.Object

io.druid.db.DbConnector

public class DbConnector
extends Object

Constructor Summary

Constructors

Constructor and Description
DbConnector(com.google.common.base.Supplier<DbConnectorConfig> config, com.google.common.base.Supplier<DbTablesConfig> dbTables)

Method Summary

Methods

Modifier and Type	Method and Description
void	createConfigTable()
static void	createConfigTable(org.skife.jdbi.v2.IDBI dbi, String configTableName, boolean isPostgreSQL)
void	createRulesTable()
static void	createRuleTable(org.skife.jdbi.v2.IDBI dbi, String ruleTableName, boolean isPostgreSQL)
void	createSegmentTable()
static void	createSegmentTable(org.skife.jdbi.v2.IDBI dbi, String segmentTableName, boolean isPostgreSQL)
static void	createTable(org.skife.jdbi.v2.IDBI dbi, String tableName, String sql, boolean isPostgreSQL)
static void	createTaskLockTable(org.skife.jdbi.v2.IDBI dbi, String taskLocksTableName, boolean isPostgreSQL)
static void	createTaskLogTable(org.skife.jdbi.v2.IDBI dbi, String taskLogsTableName, boolean isPostgreSQL)
static void	createTaskTable(org.skife.jdbi.v2.IDBI dbi, String taskTableName, boolean isPostgreSQL)
void	createTaskTables()
org.skife.jdbi.v2.DBI	getDBI()
Void	insertOrUpdate(String tableName, String keyColumn, String valueColumn, String key, byte[] value)
boolean	isPostgreSQL()
protected static Boolean	isPostgreSQL(org.skife.jdbi.v2.Handle handle)
static Boolean	isPostgreSQL(org.skife.jdbi.v2.IDBI dbi)
byte[]	lookup(String tableName, String keyColumn, String valueColumn, String key)

Methods inherited from class java.lang.Object

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

Constructor Detail

DbConnector

@Inject
public DbConnector(com.google.common.base.Supplier<DbConnectorConfig> config,
                  com.google.common.base.Supplier<DbTablesConfig> dbTables)

Method Detail

createSegmentTable

public static void createSegmentTable(org.skife.jdbi.v2.IDBI dbi,
                      String segmentTableName,
                      boolean isPostgreSQL)

createRuleTable

public static void createRuleTable(org.skife.jdbi.v2.IDBI dbi,
                   String ruleTableName,
                   boolean isPostgreSQL)

createConfigTable

public static void createConfigTable(org.skife.jdbi.v2.IDBI dbi,
                     String configTableName,
                     boolean isPostgreSQL)

createTaskTable

public static void createTaskTable(org.skife.jdbi.v2.IDBI dbi,
                   String taskTableName,
                   boolean isPostgreSQL)

createTaskLogTable

public static void createTaskLogTable(org.skife.jdbi.v2.IDBI dbi,
                      String taskLogsTableName,
                      boolean isPostgreSQL)

createTaskLockTable

public static void createTaskLockTable(org.skife.jdbi.v2.IDBI dbi,
                       String taskLocksTableName,
                       boolean isPostgreSQL)

createTable

public static void createTable(org.skife.jdbi.v2.IDBI dbi,
               String tableName,
               String sql,
               boolean isPostgreSQL)

insertOrUpdate

public Void insertOrUpdate(String tableName,
                  String keyColumn,
                  String valueColumn,
                  String key,
                  byte[] value)
                    throws SQLException

Throws:

SQLException

lookup

public byte[] lookup(String tableName,
            String keyColumn,
            String valueColumn,
            String key)

isPostgreSQL

public static Boolean isPostgreSQL(org.skife.jdbi.v2.IDBI dbi)

isPostgreSQL

protected static Boolean isPostgreSQL(org.skife.jdbi.v2.Handle handle)
                               throws SQLException

Throws:

SQLException

getDBI

public org.skife.jdbi.v2.DBI getDBI()

isPostgreSQL

public boolean isPostgreSQL()

createSegmentTable

public void createSegmentTable()

createRulesTable

public void createRulesTable()

createConfigTable

public void createConfigTable()

createTaskTables

public void createTaskTables()