Class DeployedAssetsProvider
- java.lang.Object
-
- com.ibm.di.connector.dpa.provider.DeployedAssetsProvider
-
public class DeployedAssetsProvider extends java.lang.Object
This class defines CRUD methods for deployed assets.
-
-
Field Summary
Fields Modifier and Type Field Description protected static java.lang.String
SQL_SELECT_DEPLOYEDASSET
-
Constructor Summary
Constructors Constructor Description DeployedAssetsProvider(java.lang.String jdbcUrl, java.lang.String dbUsername, java.lang.String dbPassword)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
closeConnection()
boolean
deleteInstance(ClassInstance instance)
protected int
executeQuery(SQLQuery query)
protected boolean
exists(ClassInstance instance)
protected ClassDefinitionFactory
getClassdefFactory()
java.sql.Connection
getConnection()
ConnectorLog
getLog()
protected java.lang.Object
getObject(java.lang.String sql, java.lang.Object defaultValue)
protected java.lang.String
getSQL(java.lang.String queryName)
void
init()
boolean
isIgnoreFieldErrors()
void
loadInstance(ClassInstance instance, boolean loadReferences)
boolean
saveInstance(ClassInstance instance)
java.util.Iterator<ClassInstance>
selectAssets(SQLQuery query, java.lang.String assetClass)
java.util.Iterator<ClassInstance>
selectAssets(java.lang.String assetClass)
void
setClassdefFactory(ClassDefinitionFactory classdefFactory)
void
setIgnoreFieldErrors(boolean ignoreFieldErrors)
void
setLog(ConnectorLog log)
-
-
-
Field Detail
-
SQL_SELECT_DEPLOYEDASSET
protected static final java.lang.String SQL_SELECT_DEPLOYEDASSET
- See Also:
- Constant Field Values
-
-
Method Detail
-
init
public void init() throws java.io.IOException
- Throws:
java.io.IOException
-
getLog
public ConnectorLog getLog()
- Returns:
- ConnectorLog
-
setLog
public void setLog(ConnectorLog log)
- Parameters:
log
-
-
setClassdefFactory
public void setClassdefFactory(ClassDefinitionFactory classdefFactory)
- Parameters:
classdefFactory
-
-
getConnection
public java.sql.Connection getConnection() throws java.sql.SQLException
- Returns:
- Connection
- Throws:
java.sql.SQLException
-
closeConnection
public void closeConnection() throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
isIgnoreFieldErrors
public boolean isIgnoreFieldErrors()
- Returns:
- boolean
-
setIgnoreFieldErrors
public void setIgnoreFieldErrors(boolean ignoreFieldErrors)
- Parameters:
ignoreFieldErrors
-
-
selectAssets
public java.util.Iterator<ClassInstance> selectAssets(java.lang.String assetClass) throws java.sql.SQLException
- Parameters:
assetClass
-- Returns:
- Iterator
- Throws:
java.sql.SQLException
-
selectAssets
public java.util.Iterator<ClassInstance> selectAssets(SQLQuery query, java.lang.String assetClass) throws java.sql.SQLException
- Parameters:
query
-assetClass
-- Returns:
- Iterator
- Throws:
java.sql.SQLException
-
loadInstance
public void loadInstance(ClassInstance instance, boolean loadReferences) throws java.sql.SQLException, java.io.IOException
- Parameters:
instance
-loadReferences
-- Throws:
java.sql.SQLException
java.io.IOException
-
saveInstance
public boolean saveInstance(ClassInstance instance) throws java.sql.SQLException, DPAException
- Parameters:
instance
-- Returns:
- boolean
- Throws:
java.sql.SQLException
DPAException
-
deleteInstance
public boolean deleteInstance(ClassInstance instance) throws java.sql.SQLException, java.io.IOException, DPAException
- Parameters:
instance
-- Returns:
- boolean
- Throws:
java.sql.SQLException
java.io.IOException
DPAException
-
getClassdefFactory
protected ClassDefinitionFactory getClassdefFactory()
- Returns:
- ClassDefinitionFactory
-
getSQL
protected java.lang.String getSQL(java.lang.String queryName)
- Parameters:
queryName
-- Returns:
- String
-
exists
protected boolean exists(ClassInstance instance) throws java.sql.SQLException, java.io.IOException
- Parameters:
instance
-- Returns:
- boolean
- Throws:
java.sql.SQLException
java.io.IOException
-
getObject
protected java.lang.Object getObject(java.lang.String sql, java.lang.Object defaultValue) throws java.sql.SQLException
- Parameters:
sql
-defaultValue
-- Returns:
- Object
- Throws:
java.sql.SQLException
-
executeQuery
protected int executeQuery(SQLQuery query) throws java.sql.SQLException
- Parameters:
query
-- Returns:
- int
- Throws:
java.sql.SQLException
-
-