|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.databene.benerator.storage.AbstractStorageSystem
org.databene.platform.db.DBSystem
public abstract class DBSystem
Abstract class that serves as parent for classes which connect to databases using JDBC.
Created: 07.01.2013 08:11:25
Field Summary | |
---|---|
protected boolean |
batch
|
protected org.databene.jdbacl.model.Database |
database
|
protected org.databene.jdbacl.DatabaseDialect |
dialect
|
protected org.databene.jdbacl.model.DBMetaDataImporter |
importer
|
protected org.slf4j.Logger |
logger
|
protected boolean |
readOnly
|
protected java.util.Map<java.lang.String,org.databene.jdbacl.model.DBTable> |
tables
|
Fields inherited from class org.databene.benerator.storage.AbstractStorageSystem |
---|
dataModel |
Constructor Summary | |
---|---|
DBSystem(java.lang.String id,
java.lang.String environment,
DataModel dataModel)
|
|
DBSystem(java.lang.String id,
java.lang.String url,
java.lang.String driver,
java.lang.String user,
java.lang.String password,
DataModel dataModel)
|
Method Summary | |
---|---|
void |
close()
Closes the database. |
long |
countEntities(java.lang.String tableName)
|
protected java.sql.Connection |
createConnection()
|
void |
createSequence(java.lang.String name)
|
void |
dropSequence(java.lang.String name)
|
java.lang.Object |
execute(java.lang.String sql)
Executes a command on the storage system |
java.lang.String |
getCatalog()
|
abstract java.sql.Connection |
getConnection()
|
org.databene.jdbacl.model.Database |
getDbMetaData()
|
org.databene.jdbacl.DatabaseDialect |
getDialect()
|
java.lang.String |
getDriver()
|
java.lang.String |
getEnvironment()
|
java.lang.String |
getExcludeTables()
|
int |
getFetchSize()
|
java.lang.String |
getId()
Returns a name that identifies the database |
java.lang.String |
getIncludeTables()
|
java.lang.String |
getPassword()
|
java.lang.String |
getSchema()
|
protected abstract java.sql.PreparedStatement |
getSelectByPKStatement(ComplexTypeDescriptor descriptor)
|
protected abstract java.sql.PreparedStatement |
getStatement(ComplexTypeDescriptor descriptor,
boolean insert,
java.util.List<org.databene.jdbacl.ColumnInfo> columnInfos)
|
java.lang.String |
getSystem()
|
org.databene.jdbacl.model.DBTable |
getTable(java.lang.String tableName)
|
TypeDescriptor |
getTypeDescriptor(java.lang.String tableName)
|
TypeDescriptor[] |
getTypeDescriptors()
|
java.lang.String |
getUrl()
|
java.lang.String |
getUser()
|
Consumer |
inserter()
|
Consumer |
inserter(java.lang.String tableName)
|
void |
invalidate()
|
int |
invalidationCount()
|
boolean |
isBatch()
|
boolean |
isLazy()
|
boolean |
isMetaDataCache()
|
boolean |
isReadOnly()
|
ComplexTypeDescriptor |
mapTableToComplexTypeDescriptor(org.databene.jdbacl.model.DBTable table,
ComplexTypeDescriptor complexType)
|
long |
nextSequenceValue(java.lang.String sequenceName)
|
void |
parseMetaData()
|
org.databene.webdecs.DataSource<?> |
query(java.lang.String query,
boolean simplify,
org.databene.commons.Context context)
Creates an Iterable for repetitive iteration through the results of the specified query. |
org.databene.webdecs.DataSource<Entity> |
queryEntities(java.lang.String type,
java.lang.String selector,
org.databene.commons.Context context)
Creates an iterator that provides all entities of given type. |
Entity |
queryEntityById(java.lang.String tableName,
java.lang.Object id)
|
org.databene.webdecs.DataSource<?> |
queryEntityIds(java.lang.String tableName,
java.lang.String selector,
org.databene.commons.Context context)
Queries for entity ids |
void |
setAcceptUnknownColumnTypes(boolean acceptUnknownColumnTypes)
|
void |
setBatch(boolean batch)
|
void |
setCatalog(java.lang.String catalog)
|
void |
setDriver(java.lang.String driver)
|
void |
setDynamicQuerySupported(boolean dynamicQuerySupported)
|
void |
setExcludeTables(java.lang.String excludeTables)
|
void |
setFetchSize(int fetchSize)
|
void |
setId(java.lang.String id)
|
void |
setIncludeTables(java.lang.String includeTables)
|
void |
setLazy(boolean lazy)
|
void |
setMetaDataCache(boolean metaDataCache)
|
void |
setPassword(java.lang.String password)
|
void |
setReadOnly(boolean readOnly)
|
void |
setSchema(java.lang.String schema)
|
void |
setSequenceValue(java.lang.String sequenceName,
long value)
|
void |
setTableFilter(java.lang.String tableFilter)
Deprecated. |
void |
setUrl(java.lang.String url)
|
void |
setUser(java.lang.String user)
|
void |
store(Entity entity)
Persists a new entity. |
boolean |
tableExists(java.lang.String tableName)
|
java.lang.String |
toString()
|
void |
update(Entity entity)
Updates an existing entity. |
Methods inherited from class org.databene.benerator.storage.AbstractStorageSystem |
---|
getDataModel, setDataModel, updater |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.databene.benerator.StorageSystem |
---|
flush |
Field Detail |
---|
protected org.slf4j.Logger logger
protected boolean batch
protected boolean readOnly
protected org.databene.jdbacl.model.Database database
protected org.databene.jdbacl.model.DBMetaDataImporter importer
protected java.util.Map<java.lang.String,org.databene.jdbacl.model.DBTable> tables
protected org.databene.jdbacl.DatabaseDialect dialect
Constructor Detail |
---|
public DBSystem(java.lang.String id, java.lang.String url, java.lang.String driver, java.lang.String user, java.lang.String password, DataModel dataModel)
public DBSystem(java.lang.String id, java.lang.String environment, DataModel dataModel)
Method Detail |
---|
public java.lang.String getId()
StorageSystem
public void setId(java.lang.String id)
public java.lang.String getEnvironment()
public java.lang.String getDriver()
public void setDriver(java.lang.String driver)
public java.lang.String getUrl()
public void setUrl(java.lang.String url)
public java.lang.String getUser()
public void setUser(java.lang.String user)
public java.lang.String getPassword()
public void setPassword(java.lang.String password)
public java.lang.String getCatalog()
public void setCatalog(java.lang.String catalog)
public java.lang.String getSchema()
public void setSchema(java.lang.String schema)
@Deprecated public void setTableFilter(java.lang.String tableFilter)
public java.lang.String getIncludeTables()
public void setIncludeTables(java.lang.String includeTables)
public java.lang.String getExcludeTables()
public void setExcludeTables(java.lang.String excludeTables)
public boolean isMetaDataCache()
public void setMetaDataCache(boolean metaDataCache)
public boolean isBatch()
public void setBatch(boolean batch)
public int getFetchSize()
public void setFetchSize(int fetchSize)
public boolean isReadOnly()
public void setReadOnly(boolean readOnly)
public boolean isLazy()
public void setLazy(boolean lazy)
public void setDynamicQuerySupported(boolean dynamicQuerySupported)
public void setAcceptUnknownColumnTypes(boolean acceptUnknownColumnTypes)
public TypeDescriptor[] getTypeDescriptors()
public TypeDescriptor getTypeDescriptor(java.lang.String tableName)
public void store(Entity entity)
StorageSystem
public void update(Entity entity)
StorageSystem
public void close()
StorageSystem
public Entity queryEntityById(java.lang.String tableName, java.lang.Object id)
public org.databene.webdecs.DataSource<Entity> queryEntities(java.lang.String type, java.lang.String selector, org.databene.commons.Context context)
StorageSystem
public long countEntities(java.lang.String tableName)
public org.databene.webdecs.DataSource<?> queryEntityIds(java.lang.String tableName, java.lang.String selector, org.databene.commons.Context context)
StorageSystem
public org.databene.webdecs.DataSource<?> query(java.lang.String query, boolean simplify, org.databene.commons.Context context)
StorageSystem
public Consumer inserter()
public Consumer inserter(java.lang.String tableName)
public abstract java.sql.Connection getConnection()
protected abstract java.sql.PreparedStatement getSelectByPKStatement(ComplexTypeDescriptor descriptor)
public boolean tableExists(java.lang.String tableName)
public void createSequence(java.lang.String name) throws java.sql.SQLException
java.sql.SQLException
public void dropSequence(java.lang.String name)
public java.lang.Object execute(java.lang.String sql)
StorageSystem
execute
in interface StorageSystem
execute
in class AbstractStorageSystem
public long nextSequenceValue(java.lang.String sequenceName)
public void setSequenceValue(java.lang.String sequenceName, long value) throws java.sql.SQLException
java.sql.SQLException
protected java.sql.Connection createConnection()
public void invalidate()
public int invalidationCount()
public void parseMetaData()
public org.databene.jdbacl.DatabaseDialect getDialect()
public java.lang.String getSystem()
public org.databene.jdbacl.model.Database getDbMetaData()
public java.lang.String toString()
toString
in class java.lang.Object
protected abstract java.sql.PreparedStatement getStatement(ComplexTypeDescriptor descriptor, boolean insert, java.util.List<org.databene.jdbacl.ColumnInfo> columnInfos)
public ComplexTypeDescriptor mapTableToComplexTypeDescriptor(org.databene.jdbacl.model.DBTable table, ComplexTypeDescriptor complexType)
public org.databene.jdbacl.model.DBTable getTable(java.lang.String tableName)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |