org.databene.platform.db
Class DBSystem

java.lang.Object
  org.databene.model.storage.AbstractStorageSystem
      org.databene.platform.db.DBSystem

All Implemented Interfaces:

java.io.Closeable, java.io.Flushable, DescriptorProvider, StorageSystem

public class DBSystem
extends AbstractStorageSystem

RDBMS implementation of the StorageSystem interface.

Created: 27.06.2007 23:04:19

Since:

0.3

Author:

Volker Bergmann

Field Summary

protected static ArrayPropertyExtractor<java.lang.String>

nameExtractor

Constructor Summary

DBSystem()

DBSystem(java.lang.String id, java.lang.String url, java.lang.String driver, java.lang.String user, java.lang.String password)

Method Summary

void	close() Closes the database.
long	countEntities(java.lang.String tableName)
java.sql.Connection	createConnection()
void	createSequence(java.lang.String name)
void	dropSequence(java.lang.String name)
void	execute(java.lang.String sql)
void	flush() Assures that all data that has been StorageSystem.store(Entity)d, is send to the target system.
DatabaseDialect	getDialect()
java.lang.String	getDriver()
int	getFetchSize()
java.lang.String	getId() Returns a name that identifies the database
java.lang.String	getPassword()
java.lang.String	getSchema()
java.lang.String	getSystem()
java.lang.String	getTableFilter()
TypeDescriptor	getTypeDescriptor(java.lang.String tableName)
TypeDescriptor[]	getTypeDescriptors()
java.lang.String	getUrl()
java.lang.String	getUser()
Consumer<Entity>	inserter()
void	invalidate()
boolean	isBatch()
boolean	isReadOnly()
long	nextSequenceValue(java.lang.String sequenceName)
void	parseMetaData()
<T> HeavyweightTypedIterable<T>	query(java.lang.String query, Context context) Creates an Iterable for repetitive iteration through the results of the specified query.
TypedIterable<Entity>	queryEntities(java.lang.String type, java.lang.String selector, Context context) Creates an iterator that provides all entities of given type.
<T> TypedIterable<T>	queryEntityIds(java.lang.String tableName, java.lang.String selector, Context context) Queries for entity ids
void	setBatch(boolean batch)
void	setDriver(java.lang.String driver)
void	setDynamicQuerySupported(boolean dynamicQuerySupported)
void	setFetchSize(int fetchSize)
void	setId(java.lang.String id)
void	setPassword(java.lang.String password)
void	setReadOnly(boolean readOnly)
void	setSchema(java.lang.String schema)
void	setSequenceValue(java.lang.String sequenceName, long increment)
void	setTableFilter(java.lang.String tableFilter)
void	setUrl(java.lang.String url)
void	setUser(java.lang.String user)
void	store(Entity entity) Persists a new entity.
java.lang.String	toString()
void	update(Entity entity) Updates an existing entity.
Consumer<Entity>	updater()

Methods inherited from class java.lang.Object

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

Field Detail

nameExtractor

protected static final ArrayPropertyExtractor<java.lang.String> nameExtractor

Constructor Detail

DBSystem

public DBSystem()

DBSystem

public DBSystem(java.lang.String id,
                java.lang.String url,
                java.lang.String driver,
                java.lang.String user,
                java.lang.String password)

Method Detail

getId

public java.lang.String getId()

Description copied from interface: StorageSystem

Returns a name that identifies the database

setId

public void setId(java.lang.String id)

getDriver

public java.lang.String getDriver()

setDriver

public void setDriver(java.lang.String driver)

getUrl

public java.lang.String getUrl()

setUrl

public void setUrl(java.lang.String url)

getUser

public java.lang.String getUser()

setUser

public void setUser(java.lang.String user)

getPassword

public java.lang.String getPassword()

setPassword

public void setPassword(java.lang.String password)

getSchema

public java.lang.String getSchema()

setSchema

public void setSchema(java.lang.String schema)

getTableFilter

public java.lang.String getTableFilter()

setTableFilter

public void setTableFilter(java.lang.String tableFilter)

isBatch

public boolean isBatch()

Returns:

the batch

setBatch

public void setBatch(boolean batch)

Parameters:

batch - the batch to set

getFetchSize

public int getFetchSize()

Returns:

the fetchSize

setFetchSize

public void setFetchSize(int fetchSize)

Parameters:

fetchSize - the fetchSize to set

isReadOnly

public boolean isReadOnly()

setReadOnly

public void setReadOnly(boolean readOnly)

setDynamicQuerySupported

public void setDynamicQuerySupported(boolean dynamicQuerySupported)

getTypeDescriptors

public TypeDescriptor[] getTypeDescriptors()

getTypeDescriptor

public TypeDescriptor getTypeDescriptor(java.lang.String tableName)

store

public void store(Entity entity)

Description copied from interface: StorageSystem

Persists a new entity.

update

public void update(Entity entity)

Description copied from interface: StorageSystem

Updates an existing entity.

flush

public void flush()

Description copied from interface: StorageSystem

Assures that all data that has been StorageSystem.store(Entity)d, is send to the target system.

close

public void close()

Description copied from interface: StorageSystem

Closes the database.

queryEntities

public TypedIterable<Entity> queryEntities(java.lang.String type,
                                           java.lang.String selector,
                                           Context context)

Description copied from interface: StorageSystem

Creates an iterator that provides all entities of given type.

countEntities

public long countEntities(java.lang.String tableName)

queryEntityIds

public <T> TypedIterable<T> queryEntityIds(java.lang.String tableName,
                                           java.lang.String selector,
                                           Context context)

Description copied from interface: StorageSystem

Queries for entity ids

query

public <T> HeavyweightTypedIterable<T> query(java.lang.String query,
                                             Context context)

Description copied from interface: StorageSystem

Creates an Iterable for repetitive iteration through the results of the specified query.

inserter

public Consumer<Entity> inserter()

updater

public Consumer<Entity> updater()

createSequence

public void createSequence(java.lang.String name)
                    throws java.sql.SQLException

Throws:

java.sql.SQLException

dropSequence

public void dropSequence(java.lang.String name)
                  throws java.sql.SQLException

Throws:

java.sql.SQLException

execute

public void execute(java.lang.String sql)
             throws java.sql.SQLException

Throws:

java.sql.SQLException

nextSequenceValue

public long nextSequenceValue(java.lang.String sequenceName)

setSequenceValue

public void setSequenceValue(java.lang.String sequenceName,
                             long increment)
                      throws java.sql.SQLException

Throws:

java.sql.SQLException

createConnection

public java.sql.Connection createConnection()

invalidate

public void invalidate()

parseMetaData

public void parseMetaData()

getDialect

public DatabaseDialect getDialect()

getSystem

public java.lang.String getSystem()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object