io.druid.metadata.storage.mysql

Class MySQLConnector

java.lang.Object

io.druid.metadata.SQLMetadataConnector

io.druid.metadata.storage.mysql.MySQLConnector

All Implemented Interfaces:

MetadataStorageConnector

public class MySQLConnector
extends SQLMetadataConnector

Field Summary

Fields inherited from class io.druid.metadata.SQLMetadataConnector

DEFAULT_MAX_TRIES

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected boolean	connectorIsTransientException(Throwable e)
org.skife.jdbi.v2.DBI	getDBI()
protected String	getPayloadType() SQL type to use for payload data (e.g.
String	getQuoteString()
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.
protected int	getStreamingFetchSize() Returns the value that should be passed to statement.setFetchSize to ensure results are streamed back from the database instead of fetching the entire result set in memory.
Void	insertOrUpdate(String tableName, String keyColumn, String valueColumn, String key, byte[] value)
boolean	tableExists(org.skife.jdbi.v2.Handle handle, String tableName)

Methods inherited from class io.druid.metadata.SQLMetadataConnector

createAuditTable, createConfigTable, createConfigTable, createDataSourceTable, createDataSourceTable, createEntryTable, createLockTable, createLogTable, createPendingSegmentsTable, createPendingSegmentsTable, createRulesTable, createRulesTable, createSegmentTable, createSegmentTable, createSupervisorsTable, createSupervisorsTable, createTable, createTaskTables, deleteAllRecords, getConfig, getDatasource, getValidationQuery, inReadOnlyTransaction, isTransientException, lookup, lookupWithHandle, retryTransaction, retryWithHandle, retryWithHandle

Methods inherited from class java.lang.Object

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

Constructor Detail

MySQLConnector

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

Method Detail

getPayloadType

protected String getPayloadType()

Description copied from class: SQLMetadataConnector

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

Overrides:

getPayloadType in class SQLMetadataConnector

Returns:

String representing the SQL type

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

getQuoteString

public String getQuoteString()

Specified by:

getQuoteString in class SQLMetadataConnector

Returns:

the string that should be used to quote string fields

getStreamingFetchSize

protected int getStreamingFetchSize()

Description copied from class: SQLMetadataConnector

Returns the value that should be passed to statement.setFetchSize to ensure results are streamed back from the database instead of fetching the entire result set in memory.

Specified by:

getStreamingFetchSize in class SQLMetadataConnector

Returns:

optimal fetch size to stream results back

tableExists

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

Specified by:

tableExists in class SQLMetadataConnector

connectorIsTransientException

protected boolean connectorIsTransientException(Throwable e)

Overrides:

connectorIsTransientException in class SQLMetadataConnector

insertOrUpdate

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

Specified by:

insertOrUpdate in interface MetadataStorageConnector

Overrides:

insertOrUpdate in class SQLMetadataConnector

Throws:

Exception

getDBI

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

Specified by:

getDBI in class SQLMetadataConnector