public class DBConfiguration
extends java.lang.Object
DBInputFormat
, and DBOutputFormat
.
Alternatively, the properties can be set in the configuration with proper
values.Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DRIVER_CLASS_PROPERTY
The JDBC Driver class name
|
static java.lang.String |
INPUT_BOUNDING_QUERY
Input query to get the max and min values of the jdbc.input.query
|
static java.lang.String |
INPUT_CLASS_PROPERTY
Class name implementing DBWritable which will hold input tuples
|
static java.lang.String |
INPUT_CONDITIONS_PROPERTY
WHERE clause in the input SELECT statement
|
static java.lang.String |
INPUT_COUNT_QUERY
Input query to get the count of records
|
static java.lang.String |
INPUT_FIELD_NAMES_PROPERTY
Field names in the Input table
|
static java.lang.String |
INPUT_ORDER_BY_PROPERTY
ORDER BY clause in the input SELECT statement
|
static java.lang.String |
INPUT_QUERY
Whole input query, exluding LIMIT...OFFSET
|
static java.lang.String |
INPUT_TABLE_NAME_PROPERTY
Input table name
|
static java.lang.String |
OUTPUT_FIELD_COUNT_PROPERTY
Number of fields in the Output table
|
static java.lang.String |
OUTPUT_FIELD_NAMES_PROPERTY
Field names in the Output table
|
static java.lang.String |
OUTPUT_TABLE_NAME_PROPERTY
Output table name
|
static java.lang.String |
PASSWORD_PROPERTY
Password to access the database
|
static java.lang.String |
URL_PROPERTY
JDBC Database access URL
|
static java.lang.String |
USERNAME_PROPERTY
User name to access the database
|
Constructor and Description |
---|
DBConfiguration(org.apache.hadoop.conf.Configuration job) |
Modifier and Type | Method and Description |
---|---|
static void |
configureDB(org.apache.hadoop.conf.Configuration job,
java.lang.String driverClass,
java.lang.String dbUrl)
Sets the DB access related fields in the JobConf.
|
static void |
configureDB(org.apache.hadoop.conf.Configuration conf,
java.lang.String driverClass,
java.lang.String dbUrl,
java.lang.String userName,
java.lang.String passwd)
Sets the DB access related fields in the
Configuration . |
org.apache.hadoop.conf.Configuration |
getConf() |
java.sql.Connection |
getConnection()
Returns a connection object o the DB
|
java.lang.String |
getInputBoundingQuery() |
java.lang.Class<?> |
getInputClass() |
java.lang.String |
getInputConditions() |
java.lang.String |
getInputCountQuery() |
java.lang.String[] |
getInputFieldNames() |
java.lang.String |
getInputOrderBy() |
java.lang.String |
getInputQuery() |
java.lang.String |
getInputTableName() |
int |
getOutputFieldCount() |
java.lang.String[] |
getOutputFieldNames() |
java.lang.String |
getOutputTableName() |
void |
setInputBoundingQuery(java.lang.String query) |
void |
setInputClass(java.lang.Class<? extends DBWritable> inputClass) |
void |
setInputConditions(java.lang.String conditions) |
void |
setInputCountQuery(java.lang.String query) |
void |
setInputFieldNames(java.lang.String... fieldNames) |
void |
setInputOrderBy(java.lang.String orderby) |
void |
setInputQuery(java.lang.String query) |
void |
setInputTableName(java.lang.String tableName) |
void |
setOutputFieldCount(int fieldCount) |
void |
setOutputFieldNames(java.lang.String... fieldNames) |
void |
setOutputTableName(java.lang.String tableName) |
public static final java.lang.String DRIVER_CLASS_PROPERTY
public static final java.lang.String URL_PROPERTY
public static final java.lang.String USERNAME_PROPERTY
public static final java.lang.String PASSWORD_PROPERTY
public static final java.lang.String INPUT_TABLE_NAME_PROPERTY
public static final java.lang.String INPUT_FIELD_NAMES_PROPERTY
public static final java.lang.String INPUT_CONDITIONS_PROPERTY
public static final java.lang.String INPUT_ORDER_BY_PROPERTY
public static final java.lang.String INPUT_QUERY
public static final java.lang.String INPUT_COUNT_QUERY
public static final java.lang.String INPUT_BOUNDING_QUERY
public static final java.lang.String INPUT_CLASS_PROPERTY
public static final java.lang.String OUTPUT_TABLE_NAME_PROPERTY
public static final java.lang.String OUTPUT_FIELD_NAMES_PROPERTY
public static final java.lang.String OUTPUT_FIELD_COUNT_PROPERTY
public static void configureDB(org.apache.hadoop.conf.Configuration conf, java.lang.String driverClass, java.lang.String dbUrl, java.lang.String userName, java.lang.String passwd)
Configuration
.conf
- the configurationdriverClass
- JDBC Driver class namedbUrl
- JDBC DB access URL.userName
- DB access usernamepasswd
- DB access passwdpublic static void configureDB(org.apache.hadoop.conf.Configuration job, java.lang.String driverClass, java.lang.String dbUrl)
job
- the jobdriverClass
- JDBC Driver class namedbUrl
- JDBC DB access URL.public java.sql.Connection getConnection() throws java.lang.ClassNotFoundException, java.sql.SQLException
java.lang.ClassNotFoundException
java.sql.SQLException
public org.apache.hadoop.conf.Configuration getConf()
public java.lang.String getInputTableName()
public void setInputTableName(java.lang.String tableName)
public java.lang.String[] getInputFieldNames()
public void setInputFieldNames(java.lang.String... fieldNames)
public java.lang.String getInputConditions()
public void setInputConditions(java.lang.String conditions)
public java.lang.String getInputOrderBy()
public void setInputOrderBy(java.lang.String orderby)
public java.lang.String getInputQuery()
public void setInputQuery(java.lang.String query)
public java.lang.String getInputCountQuery()
public void setInputCountQuery(java.lang.String query)
public void setInputBoundingQuery(java.lang.String query)
public java.lang.String getInputBoundingQuery()
public java.lang.Class<?> getInputClass()
public void setInputClass(java.lang.Class<? extends DBWritable> inputClass)
public java.lang.String getOutputTableName()
public void setOutputTableName(java.lang.String tableName)
public java.lang.String[] getOutputFieldNames()
public void setOutputFieldNames(java.lang.String... fieldNames)
public void setOutputFieldCount(int fieldCount)
public int getOutputFieldCount()
Copyright © 2009 The Apache Software Foundation