io.druid.metadata.storage.derby

Class DerbyConnector

java.lang.Object

io.druid.metadata.SQLMetadataConnector

io.druid.metadata.storage.derby.DerbyConnector

All Implemented Interfaces:

MetadataStorageConnector

public class DerbyConnector
extends SQLMetadataConnector

Constructor Summary

Constructors

Constructor and Description
DerbyConnector(com.google.common.base.Supplier<MetadataStorageConnectorConfig> config, com.google.common.base.Supplier<MetadataStorageTablesConfig> dbTables)
DerbyConnector(com.google.common.base.Supplier<MetadataStorageConnectorConfig> config, com.google.common.base.Supplier<MetadataStorageTablesConfig> dbTables, org.skife.jdbi.v2.DBI dbi)

Method Summary

Methods

Modifier and Type	Method and Description
org.skife.jdbi.v2.DBI	getDBI()
protected 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()
boolean	tableExists(org.skife.jdbi.v2.Handle handle, String tableName)

Methods inherited from class io.druid.metadata.SQLMetadataConnector

createConfigTable, createConfigTable, createEntryTable, createLockTable, createLogTable, createRulesTable, createRulesTable, createSegmentTable, createSegmentTable, createTable, createTaskTables, getConfig, getDatasource, getPayloadType, insertOrUpdate, isTransientException, lookup

Methods inherited from class java.lang.Object

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

Constructor Detail

DerbyConnector

@Inject
public DerbyConnector(com.google.common.base.Supplier<MetadataStorageConnectorConfig> config,
                     com.google.common.base.Supplier<MetadataStorageTablesConfig> dbTables)

DerbyConnector

public DerbyConnector(com.google.common.base.Supplier<MetadataStorageConnectorConfig> config,
              com.google.common.base.Supplier<MetadataStorageTablesConfig> dbTables,
              org.skife.jdbi.v2.DBI dbi)

Method Detail

tableExists

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

Specified by:

tableExists in class SQLMetadataConnector

getSerialType

protected String getSerialType()

Description copied from class: SQLMetadataConnector

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, ... )

Specified by:

getSerialType in class SQLMetadataConnector

Returns:

String representing the SQL type and auto-increment statement

getDBI

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

Specified by:

getDBI in class SQLMetadataConnector

getValidationQuery

public String getValidationQuery()

Overrides:

getValidationQuery in class SQLMetadataConnector