io.druid.metadata

Class SQLMetadataConnector

java.lang.Object

io.druid.metadata.SQLMetadataConnector

All Implemented Interfaces:

MetadataStorageConnector

Direct Known Subclasses:

DerbyConnector, MySQLConnector, PostgreSQLConnector

public abstract class SQLMetadataConnector
extends Object
implements MetadataStorageConnector

Constructor Summary

Constructors

Constructor and Description
SQLMetadataConnector(com.google.common.base.Supplier<MetadataStorageConnectorConfig> config, com.google.common.base.Supplier<MetadataStorageTablesConfig> tablesConfigSupplier)

Method Summary

Methods

Modifier and Type	Method and Description
void	createAuditTable()
void	createConfigTable()
void	createConfigTable(org.skife.jdbi.v2.IDBI dbi, String tableName)
void	createEntryTable(org.skife.jdbi.v2.IDBI dbi, String tableName)
void	createLockTable(org.skife.jdbi.v2.IDBI dbi, String tableName, String entryTypeName)
void	createLogTable(org.skife.jdbi.v2.IDBI dbi, String tableName, String entryTypeName)
void	createRulesTable()
void	createRulesTable(org.skife.jdbi.v2.IDBI dbi, String tableName)
void	createSegmentTable()
void	createSegmentTable(org.skife.jdbi.v2.IDBI dbi, String tableName)
void	createTable(org.skife.jdbi.v2.IDBI dbi, String tableName, Iterable<String> sql)
void	createTaskTables()
MetadataStorageConnectorConfig	getConfig()
protected org.apache.commons.dbcp2.BasicDataSource	getDatasource()
abstract org.skife.jdbi.v2.DBI	getDBI()
protected String	getPayloadType() SQL type to use for payload data (e.g.
protected abstract String	getSerialType() Auto-incrementing SQL type to use for IDs Must be an integer type, which values will be automatically set by the database The resulting string will be interpolated into the table creation statement, e.g.
String	getValidationQuery()
Void	insertOrUpdate(String tableName, String keyColumn, String valueColumn, String key, byte[] value)
protected boolean	isTransientException(Throwable e)
byte[]	lookup(String tableName, String keyColumn, String valueColumn, String key)
abstract boolean	tableExists(org.skife.jdbi.v2.Handle handle, String tableName)

Methods inherited from class java.lang.Object

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

Constructor Detail

SQLMetadataConnector

public SQLMetadataConnector(com.google.common.base.Supplier<MetadataStorageConnectorConfig> config,
                    com.google.common.base.Supplier<MetadataStorageTablesConfig> tablesConfigSupplier)

Method Detail

getPayloadType

protected String getPayloadType()

SQL type to use for payload data (e.g. JSON blobs). Must be a binary type, which values can be accessed using ResultSet.getBytes() The resulting string will be interpolated into the table creation statement, e.g. CREATE TABLE druid_table ( payload NOT NULL, ... )

Returns:

String representing the SQL type

getSerialType

protected abstract String getSerialType()

Auto-incrementing SQL type to use for IDs Must be an integer type, which values will be automatically set by the database The resulting string will be interpolated into the table creation statement, e.g. CREATE TABLE druid_table ( id NOT NULL, ... )

Returns:

String representing the SQL type and auto-increment statement

getValidationQuery

public String getValidationQuery()

tableExists

public abstract boolean tableExists(org.skife.jdbi.v2.Handle handle,
                  String tableName)

isTransientException

protected boolean isTransientException(Throwable e)

createTable

public void createTable(org.skife.jdbi.v2.IDBI dbi,
               String tableName,
               Iterable<String> sql)

createSegmentTable

public void createSegmentTable(org.skife.jdbi.v2.IDBI dbi,
                      String tableName)

createRulesTable

public void createRulesTable(org.skife.jdbi.v2.IDBI dbi,
                    String tableName)

createConfigTable

public void createConfigTable(org.skife.jdbi.v2.IDBI dbi,
                     String tableName)

createEntryTable

public void createEntryTable(org.skife.jdbi.v2.IDBI dbi,
                    String tableName)

createLogTable

public void createLogTable(org.skife.jdbi.v2.IDBI dbi,
                  String tableName,
                  String entryTypeName)

createLockTable

public void createLockTable(org.skife.jdbi.v2.IDBI dbi,
                   String tableName,
                   String entryTypeName)

insertOrUpdate

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

Specified by:

insertOrUpdate in interface MetadataStorageConnector

Throws:

Exception

getDBI

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

createSegmentTable

public void createSegmentTable()

Specified by:

createSegmentTable in interface MetadataStorageConnector

createRulesTable

public void createRulesTable()

Specified by:

createRulesTable in interface MetadataStorageConnector

createConfigTable

public void createConfigTable()

Specified by:

createConfigTable in interface MetadataStorageConnector

createTaskTables

public void createTaskTables()

Specified by:

createTaskTables in interface MetadataStorageConnector

lookup

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

Specified by:

lookup in interface MetadataStorageConnector

getConfig

public MetadataStorageConnectorConfig getConfig()

getDatasource

protected org.apache.commons.dbcp2.BasicDataSource getDatasource()

createAuditTable

public void createAuditTable()

Specified by:

createAuditTable in interface MetadataStorageConnector