public class DBHelper
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
DBHelper.ModelType
These ENUM constants are used to specify whether the ModelType can be PHYSICAL and LOGICAL.
|
static class |
DBHelper.ScanCriteria |
Constructor and Description |
---|
DBHelper() |
DBHelper(DBProperties dbProperties) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getClient()
Returns the client.
|
DBProperties.ConnectionPoolType |
getConnectionPoolType() |
CWMUtil.Version |
getCWMVersion()
Returns the cwmVersion.
|
java.lang.String |
getDatabaseDriver()
Returns the DBDriver.
|
java.lang.String |
getDatabaseName()
Returns the dataBaseName.
|
java.lang.String |
getDatabasePassword()
Returns the DbPassword.
|
java.lang.String |
getDatabaseSchema()
Returns the dataBaseSchema.
|
DBProperties.DatabaseType |
getDatabaseType()
Returns the databaseType.
|
java.lang.String |
getDatabaseUrl()
Returns the DBUrl.
|
java.lang.String |
getDatabaseUserName()
Returns the DbUserName.
|
java.lang.String |
getDbDriver()
Returns the dbDriver.
|
java.lang.String |
getDbName()
Returns the dbName.
|
java.lang.String |
getDbPassword()
Returns the dbPassword.
|
DBProperties |
getDBProperties()
Returns the DBProperties Object.
|
java.lang.String |
getDbSchema()
Returns the dbSchema.
|
java.lang.String |
getDbUrl()
Returns the dbUrl.
|
java.lang.String |
getDbUserName()
Returns the dbUserName.
|
java.lang.String |
getDestinationName()
Returns the destinationName.
|
java.lang.String |
getFieldSeparator()
Returns the fieldSeparator.
|
java.lang.String |
getFilePath()
Returns the filePath.
|
APIConstants.FilePathType |
getFilePathType()
Returns the path type of the given file.i.e ABSOLUTE OR RELATIVE
|
java.lang.String |
getIpAddress()
Returns the ipAddress.
|
java.lang.String |
getKerberosPrincipal() |
int |
getMaximumConnectionsPerPartition()
Returns the maximumConnectionsPerPartition.
|
int |
getMinimumConnectionsPerPartition()
Returns the minimumConnectionsPerPartition.
|
DBHelper.ModelType |
getModelType() |
int |
getPartitions()
Returns the partitions.
|
int |
getQueryBatchLimit() |
java.lang.String |
getReadOnly() |
java.lang.String |
getRowSeparator()
Returns the rowSeparator.
|
DBHelper.ScanCriteria |
getScanCriteria() |
java.lang.String |
getScanOptions()
Sets the scanOptions as specified.
|
java.util.List |
getSelectedEntities()
Returns the selectedEntities.
|
java.util.List<java.lang.String> |
getSelectedObjectsList()
Returns the selectedObjectsList.
|
java.util.Map<java.lang.String,java.util.List<java.lang.String>> |
getSelectedSynonyms()
This method returns map object in which key is schema name and value
is list of selected synonyms.
|
java.util.List<java.lang.String> |
getSelectedSynonymsList()
Returns the selectedSynonymsList.
|
java.util.Map<java.lang.String,java.util.List<java.lang.String>> |
getSelectedTables()
This method returns map object in which key is schema name and value
is list of selected tables.
|
java.util.List<java.lang.String> |
getSelectedTablesList()
Returns the selectedTablesList.
|
java.lang.StringBuilder |
getSelectedTablesString()
Returns the selectedTablesString.
|
java.util.Map<java.lang.String,java.util.List<java.lang.String>> |
getSelectedViews()
This method returns map object in which key is schema name and value
is list of selected views.
|
java.util.List<java.lang.String> |
getSelectedViewsList()
Returns the selectedViewsList.
|
java.lang.StringBuilder |
getSelectedViewsString()
Returns the selectedViewsString.
|
int |
getSshPort() |
java.lang.String |
getSystemNumber()
Returns the systemNumber.
|
java.lang.String |
getTestConnectionQuery()
Returns the testConnectionQuery.
|
java.lang.String |
getTransactionIsolation() |
boolean |
isAutoCommit()
Returns the autoCommit value.
|
boolean |
isGenerateSummary() |
boolean |
isHasAccessToDba() |
boolean |
isParseHiveComplexDataType() |
boolean |
isReadColumns()
Returns the readColumns value as True or False.
|
boolean |
isReadComments()
Returns the readComments value as True or False.
|
boolean |
isReadHeader()
Returns the readHeader value.
|
boolean |
isReadLogicalColumns()
Returns the readLogicalColumns value as True or False.
|
boolean |
isReadSynonyms()
Returns the readSynonyms value as True or False.
|
boolean |
isReadTables()
Returns the readTables value as True or False.
|
boolean |
isReadViews()
Returns the readViews value as True or False.
|
boolean |
isScanNestedRefSynonyms() |
boolean |
isTestConnectionPeriodically()
Returns the testConnectionPeriodically value as true or false.
|
boolean |
isUpdateColumnELNFlag() |
boolean |
isUpdateTableELNFlag() |
boolean |
isUseReferenceId() |
boolean |
isValidateData() |
void |
setAutoCommit(boolean autoCommit)
Sets the autoCommit value.
|
void |
setClient(java.lang.String client)
Sets the client as specified.
|
void |
setConnectionPoolType(DBProperties.ConnectionPoolType connectionPoolType) |
void |
setCWMVersion(CWMUtil.Version cwmVersion)
Sets the cwmVersion as specified.
|
void |
setDatabaseDriver(java.lang.String dbDriver)
Sets the DBDriver value as specified.
|
void |
setDatabaseName(java.lang.String dbName)
Sets the dataBaseName as specified.
|
void |
setDatabasePassword(java.lang.String dbPassword)
Sets the DbPassword as specified.
|
void |
setDatabaseSchema(java.lang.String dbSchema)
Sets the dataBaseSchema as specified.
|
void |
setDatabaseType(DBProperties.DatabaseType databaseType)
Sets the databaseType as specified.
|
void |
setDatabaseUrl(java.lang.String dbUrl)
Sets the DBUrl as specified.
|
void |
setDatabaseUserName(java.lang.String dbUserName)
Sets the DbUserName as specified.
|
void |
setDbDriver(java.lang.String dbDriver)
Sets the dbDriver as specified.
|
void |
setDbName(java.lang.String dbName)
Sets the dbName as specified.
|
void |
setDbPassword(java.lang.String dbPassword)
Sets the dbPassword as specified.
|
void |
setDbSchema(java.lang.String dbSchema)
Sets the dbSchema as specified.
|
void |
setDbUrl(java.lang.String dbUrl)
Sets the dbUrl as specified.
|
void |
setDbUserName(java.lang.String dbUserName)
Sets the dbUserName as specified.
|
void |
setDestinationName(java.lang.String destinationName)
Sets the destinationName as specified.
|
void |
setFieldSeparator(java.lang.String fieldSeparator)
sets the fieldSeparator as specified.
|
void |
setFilePath(java.lang.String filePath)
Sets the filePath as specified.
|
void |
setFilePathType(APIConstants.FilePathType filePathType)
Method sets the path type for the specified file.
|
void |
setGenerateSummary(boolean generateSummary) |
void |
setHasAccessToDba(boolean hasAccessToDba) |
void |
setIpAddress(java.lang.String ipAddress)
Sets the ipAddress as specified.
|
void |
setKerberosPrincipal(java.lang.String kerberosPrincipal) |
void |
setMaximumConnectionsPerPartition(int maximumConnectionsPerPartition)
Sets the maximumConnectionsPerPartition as specified.
|
void |
setMinimumConnectionsPerPartition(int minimumConnectionsPerPartition)
Sets the minimumConnectionsPerPartition as specified.
|
void |
setModelType(DBHelper.ModelType modelType) |
void |
setParseHiveComplexDataType(boolean parseHiveComplexDataType) |
void |
setPartitions(int partitions)
Sets the partitions as specified.
|
void |
setQueryBatchLimit(int queryBatchLimit) |
void |
setReadColumns(boolean readColumns)
Sets the readColumns value as specified.
|
void |
setReadComments(boolean readComments)
Sets the readComments as specified.
|
void |
setReadHeader(boolean readHeader)
Sets the readHeader as specified.
|
void |
setReadLogicalColumns(boolean readLogicalColumns)
Sets the readLogicalColumns as specified.
|
void |
setReadOnly(java.lang.String readOnly) |
void |
setReadSynonyms(boolean readSynonyms)
Sets the readSynonyms as specified.
|
void |
setReadTables(boolean readTables)
Sets the readTables value as specified.
|
void |
setReadViews(boolean readViews)
Sets the readViews as specified.
|
void |
setRowSeparator(java.lang.String rowSeparator)
Sets the rowSeparator as specified.
|
void |
setScanCriteria(DBHelper.ScanCriteria scanCriteria) |
void |
setScanNestedRefSynonyms(boolean scanNestedRefSynonyms) |
void |
setScanOptions(java.lang.String scanOptions)
Sets the scanOptions as specified.
|
void |
setSelectedEntities(java.util.List selectedEntities)
Sets the selectedEntities as specified.
|
void |
setSelectedObjectsList(java.util.List<java.lang.String> selectedObjectsList)
Sets the selectedObjectsList as specified.
|
void |
setSelectedSynonyms(java.util.Map<java.lang.String,java.util.List<java.lang.String>> selectedSynonyms)
This method is defined to set the selected synonyms to DBHelper Object.
|
void |
setSelectedSynonymsList(java.util.List<java.lang.String> selectedSynonymsList)
Sets the selectedSynonymsList as specified.
|
void |
setSelectedTables(java.util.Map<java.lang.String,java.util.List<java.lang.String>> selectedTables)
This method is defined to set the selected tables to DBHelper Object.
|
void |
setSelectedTablesList(java.util.List<java.lang.String> selectedTablesList)
Sets the selectedTablesList as specified.
|
void |
setSelectedTablesString(java.lang.StringBuilder selectedTablesString)
Sets the selectedTablesString as specified.
|
void |
setSelectedViews(java.util.Map<java.lang.String,java.util.List<java.lang.String>> selectedViews)
This method is defined to set the selected views to DBHelper Object.
|
void |
setSelectedViewsList(java.util.List<java.lang.String> selectedViewsList)
Sets the selectedViewsList as specified.
|
void |
setSelectedViewsString(java.lang.StringBuilder selectedViewsString)
Sets the selectedViewsString as specified.
|
void |
setSshPort(int sshPort) |
void |
setSystemNumber(java.lang.String systemNumber)
Sets the systemNumber as specified.
|
void |
setTestConnectionPeriodically(boolean _testConnectionPeriodically)
Sets the testConnectionPeriodically value as specified.
|
void |
setTestConnectionQuery(java.lang.String _testConnectionQuery)
Sets the testConnectionQuery as specified.
|
void |
setTransactionIsolation(java.lang.String transactionIsolation) |
void |
setUpdateColumnELNFlag(boolean updateColumnELNFlag) |
void |
setUpdateTableELNFlag(boolean updateTableELNFlag) |
void |
setUseReferenceId(boolean useReferenceId) |
void |
setValidateData(boolean validateData) |
public DBHelper()
public DBHelper(DBProperties dbProperties)
dbProperties
- - DBPropertiespublic boolean isReadTables()
public void setReadTables(boolean readTables)
readTables
- booleanpublic boolean isReadViews()
public void setReadViews(boolean readViews)
readViews
- booleanpublic boolean isReadSynonyms()
public void setReadSynonyms(boolean readSynonyms)
readSynonyms
- booleanpublic java.lang.String getScanOptions()
public void setScanOptions(java.lang.String scanOptions)
scanOptions
- Stringpublic java.lang.String getDatabaseUrl()
public void setDatabaseUrl(java.lang.String dbUrl)
dbUrl
- Stringpublic java.lang.String getDatabaseDriver()
public void setDatabaseDriver(java.lang.String dbDriver)
dbDriver
- Stringpublic java.lang.String getDatabaseUserName()
public void setDatabaseUserName(java.lang.String dbUserName)
dbUserName
- Stringpublic java.lang.String getDatabasePassword()
public void setDatabasePassword(java.lang.String dbPassword)
dbPassword
- Stringpublic java.lang.String getDatabaseName()
public void setDatabaseName(java.lang.String dbName)
dbName
- Stringpublic java.lang.String getDatabaseSchema()
public void setDatabaseSchema(java.lang.String dbSchema)
dbSchema
- Stringpublic boolean isReadColumns()
public void setReadColumns(boolean readColumns)
readColumns
- booleanpublic boolean isReadComments()
public void setReadComments(boolean readComments)
readComments
- booleanpublic void setSelectedViewsString(java.lang.StringBuilder selectedViewsString)
selectedViewsString
- StringBuilderpublic java.lang.StringBuilder getSelectedViewsString()
public java.lang.StringBuilder getSelectedTablesString()
public void setSelectedTablesString(java.lang.StringBuilder selectedTablesString)
selectedTablesString
- StringBuilderpublic java.lang.String getIpAddress()
public void setIpAddress(java.lang.String ipAddress)
ipAddress
- Stringpublic java.lang.String getSystemNumber()
public void setSystemNumber(java.lang.String systemNumber)
systemNumber
- Stringpublic java.lang.String getClient()
public void setClient(java.lang.String client)
client
- Stringpublic java.lang.String getDbPassword()
public void setDbPassword(java.lang.String dbPassword)
dbPassword
- Stringpublic java.lang.String getDestinationName()
public void setDestinationName(java.lang.String destinationName)
destinationName
- Stringpublic java.lang.String getFilePath()
public void setFilePath(java.lang.String filePath)
filePath
- Stringpublic APIConstants.FilePathType getFilePathType()
public void setFilePathType(APIConstants.FilePathType filePathType)
filePathType
- - Enum : Valid values are ABSOLUTE/RELATIVEpublic boolean isReadLogicalColumns()
public void setReadLogicalColumns(boolean readLogicalColumns)
readLogicalColumns
- booleanpublic java.util.List getSelectedEntities()
public void setSelectedEntities(java.util.List selectedEntities)
selectedEntities
- Listpublic DBProperties.DatabaseType getDatabaseType()
public void setDatabaseType(DBProperties.DatabaseType databaseType)
databaseType
- databaseTypepublic java.util.List<java.lang.String> getSelectedTablesList()
public void setSelectedTablesList(java.util.List<java.lang.String> selectedTablesList)
selectedTablesList
- List selectedTablesListpublic java.util.List<java.lang.String> getSelectedViewsList()
public void setSelectedViewsList(java.util.List<java.lang.String> selectedViewsList)
selectedViewsList
- List selectedViewsListpublic java.util.List<java.lang.String> getSelectedSynonymsList()
public void setSelectedSynonymsList(java.util.List<java.lang.String> selectedSynonymsList)
selectedSynonymsList
- Listpublic java.util.List<java.lang.String> getSelectedObjectsList()
public void setSelectedObjectsList(java.util.List<java.lang.String> selectedObjectsList)
selectedObjectsList
- Listpublic DBProperties getDBProperties()
public java.lang.String getDbUrl()
public void setDbUrl(java.lang.String dbUrl)
dbUrl
- Stringpublic java.lang.String getDbDriver()
public void setDbDriver(java.lang.String dbDriver)
dbDriver
- Stringpublic java.lang.String getDbUserName()
public void setDbUserName(java.lang.String dbUserName)
dbUserName
- Stringpublic java.lang.String getDbName()
public void setDbName(java.lang.String dbName)
dbName
- Stringpublic java.lang.String getDbSchema()
public void setDbSchema(java.lang.String dbSchema)
dbSchema
- Stringpublic int getPartitions()
public void setPartitions(int partitions)
partitions
- intpublic int getMinimumConnectionsPerPartition()
public void setMinimumConnectionsPerPartition(int minimumConnectionsPerPartition)
minimumConnectionsPerPartition
- intpublic int getMaximumConnectionsPerPartition()
public void setMaximumConnectionsPerPartition(int maximumConnectionsPerPartition)
maximumConnectionsPerPartition
- intpublic boolean isTestConnectionPeriodically()
public void setTestConnectionPeriodically(boolean _testConnectionPeriodically)
_testConnectionPeriodically
- booleanpublic java.lang.String getTestConnectionQuery()
public void setTestConnectionQuery(java.lang.String _testConnectionQuery)
_testConnectionQuery
- Stringpublic boolean isScanNestedRefSynonyms()
public void setScanNestedRefSynonyms(boolean scanNestedRefSynonyms)
public int getQueryBatchLimit()
public void setQueryBatchLimit(int queryBatchLimit)
public boolean isAutoCommit()
public void setAutoCommit(boolean autoCommit)
autoCommit
- booleanpublic CWMUtil.Version getCWMVersion()
public void setCWMVersion(CWMUtil.Version cwmVersion)
cwmVersion
- CWMUtilpublic boolean isReadHeader()
public void setReadHeader(boolean readHeader)
readHeader
- booleanpublic java.lang.String getFieldSeparator()
public void setFieldSeparator(java.lang.String fieldSeparator)
fieldSeparator
- Stringpublic java.lang.String getRowSeparator()
public void setRowSeparator(java.lang.String rowSeparator)
rowSeparator
- Stringpublic boolean isUseReferenceId()
public void setUseReferenceId(boolean useReferenceId)
useReferenceId
- the useReferenceId to setpublic DBHelper.ScanCriteria getScanCriteria()
public void setScanCriteria(DBHelper.ScanCriteria scanCriteria)
scanCriteria
- public java.util.Map<java.lang.String,java.util.List<java.lang.String>> getSelectedTables()
public void setSelectedTables(java.util.Map<java.lang.String,java.util.List<java.lang.String>> selectedTables)
selectedTables
- public java.util.Map<java.lang.String,java.util.List<java.lang.String>> getSelectedViews()
public void setSelectedViews(java.util.Map<java.lang.String,java.util.List<java.lang.String>> selectedViews)
selectedViews
- public java.util.Map<java.lang.String,java.util.List<java.lang.String>> getSelectedSynonyms()
public void setSelectedSynonyms(java.util.Map<java.lang.String,java.util.List<java.lang.String>> selectedSynonyms)
selectedSynonyms
- public DBProperties.ConnectionPoolType getConnectionPoolType()
public void setConnectionPoolType(DBProperties.ConnectionPoolType connectionPoolType)
connectionPoolType
- public java.lang.String getTransactionIsolation()
public void setTransactionIsolation(java.lang.String transactionIsolation)
transactionIsolation
- public java.lang.String getReadOnly()
public void setReadOnly(java.lang.String readOnly)
readOnly
- public java.lang.String getKerberosPrincipal()
public void setKerberosPrincipal(java.lang.String kerberosPrincipal)
kerberosPrincipal
- public int getSshPort()
public void setSshPort(int sshPort)
sshPort
- public DBHelper.ModelType getModelType()
public void setModelType(DBHelper.ModelType modelType)
modelType
- the modelType to setpublic boolean isUpdateTableELNFlag()
public void setUpdateTableELNFlag(boolean updateTableELNFlag)
updateTableELNFlag
- the updateTableELNFlag to setpublic boolean isUpdateColumnELNFlag()
public void setUpdateColumnELNFlag(boolean updateColumnELNFlag)
updateColumnELNFlag
- the updateColumnELNFlag to setpublic boolean isHasAccessToDba()
public void setHasAccessToDba(boolean hasAccessToDba)
public boolean isGenerateSummary()
public void setGenerateSummary(boolean generateSummary)
public boolean isValidateData()
public void setValidateData(boolean validateData)
public boolean isParseHiveComplexDataType()
public void setParseHiveComplexDataType(boolean parseHiveComplexDataType)