org.persvr.datasource
Class DatabaseTableDataSource

java.lang.Object
  org.persvr.datasource.BaseDataSource
      org.persvr.datasource.DatabaseDataSource
          org.persvr.datasource.DatabaseTableDataSource

All Implemented Interfaces:

DataSource, WritableDataSource

public class DatabaseTableDataSource
extends DatabaseDataSource
implements WritableDataSource

Author:

Kris Zyp This is an SQL database table data source

Nested Class Summary

static class	DatabaseTableDataSource.Column
static class	DatabaseTableDataSource.RelationalColumn
static class	DatabaseTableDataSource.RelationshipType

Nested classes/interfaces inherited from class org.persvr.datasource.DatabaseDataSource

DatabaseDataSource.DatabaseAction, DatabaseDataSource.QueryIterator, DatabaseDataSource.ThreadSpecificConnectionObject

Field Summary

Fields inherited from class org.persvr.datasource.DatabaseDataSource

connectionString

Fields inherited from class org.persvr.datasource.BaseDataSource

BINARY_HEADER, BOOLEAN_FALSE, BOOLEAN_TRUE, DATE_HEADER, DECIMAL_HEADER, DOUBLE_HEADER, FUNCTION_HEADER, INTEGER_HEADER, LINK_HEADER, LONG_HEADER, OBJECT_HEADER, REQUIRED_PREFIX, STRING_HEADER, UNDEFINED

Constructor Summary

DatabaseTableDataSource()

Method Summary

protected org.persvr.datasource.DatabaseTableDataSource.ConnectionStatements	getConnectionObject() Just cast it to our specific connection object type
java.lang.Object	getFieldValue(LazyPropertyId valueId) This is called when a field value contains an unfulfilled value (ValueId)
protected java.lang.Object	getValueFromRs(java.sql.ResultSet rs) This gets the value/object for the current result set row
void	initParameters(java.util.Map<java.lang.String,java.lang.Object> parameters) This is called on initialization and provides access to the data source configuration parameters
void	mapObject(PersistableInitializer initializer, java.lang.String objectId) This is called when an object is being activated to retrieve the persisted data for a given object
java.util.Iterator	mapQuery(Query query) This is called when an object is being activated to retrieve the persisted data for a given object with a filter
protected void	mapResult(PersistableInitializer initializer, java.sql.ResultSet rs, java.lang.String objectId)
protected java.lang.String	nameInQuery(java.lang.String name)
void	recordDelete(java.lang.String objectId) This is called when an object should be deleted
void	recordListAdd(java.lang.String objectId, java.lang.Object value)
void	recordListRemoval(java.lang.String objectId, java.lang.Object value)
NewObjectPersister	recordNewObject(Persistable object) This is called when a new object is persisted
void	recordPropertyAddition(java.lang.String objectId, java.lang.String name, java.lang.Object value, int attributes) This is called when a new property is added to an object
void	recordPropertyChange(java.lang.String objectId, java.lang.String name, java.lang.Object value, int attributes) This is called when a property value is changed
void	recordPropertyRemoval(java.lang.String objectId, java.lang.String name) This is called when a property value is removed

Methods inherited from class org.persvr.datasource.DatabaseDataSource

abortTransaction, addConditionToQuery, commitTransaction, comparison, createConnection, executeAndGetGeneratedKey, numberComparisonInQuery, runStarterStatements, startTransaction, stringComparisonInQuery, testLocks, tryExecution

Methods inherited from class org.persvr.datasource.BaseDataSource

convertObjectToString, convertStringToObject, getId, hiddenId, idForString, initializeFromMap, setId

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.persvr.datasource.WritableDataSource

abortTransaction, commitTransaction, startTransaction

Methods inherited from interface org.persvr.datasource.DataSource

getId, hiddenId, setId

Constructor Detail

DatabaseTableDataSource

public DatabaseTableDataSource()

Method Detail

getValueFromRs

protected java.lang.Object getValueFromRs(java.sql.ResultSet rs)
                                   throws java.lang.Exception

Description copied from class: DatabaseDataSource

This gets the value/object for the current result set row

Specified by:

getValueFromRs in class DatabaseDataSource

Returns:

Throws:

java.lang.Exception

mapQuery

public java.util.Iterator mapQuery(Query query)
                            throws java.lang.Exception

Description copied from interface: DataSource

This is called when an object is being activated to retrieve the persisted data for a given object with a filter

Specified by:

mapQuery in interface DataSource

Returns:

Throws:

java.lang.Exception

getConnectionObject

protected org.persvr.datasource.DatabaseTableDataSource.ConnectionStatements getConnectionObject()

Just cast it to our specific connection object type

Overrides:

getConnectionObject in class DatabaseDataSource

Returns:

initParameters

public void initParameters(java.util.Map<java.lang.String,java.lang.Object> parameters)
                    throws java.lang.Exception

Description copied from interface: DataSource

This is called on initialization and provides access to the data source configuration parameters

Specified by:

initParameters in interface DataSource

Overrides:

initParameters in class DatabaseDataSource

Throws:

java.lang.Exception

getFieldValue

public java.lang.Object getFieldValue(LazyPropertyId valueId)
                               throws java.lang.Exception

Description copied from interface: DataSource

This is called when a field value contains an unfulfilled value (ValueId)

Specified by:

getFieldValue in interface DataSource

Returns:

the real value referred to by valueId

Throws:

java.lang.Exception

mapResult

protected void mapResult(PersistableInitializer initializer,
                         java.sql.ResultSet rs,
                         java.lang.String objectId)
                  throws java.sql.SQLException

Throws:

java.sql.SQLException

nameInQuery

protected java.lang.String nameInQuery(java.lang.String name)

Specified by:

nameInQuery in class DatabaseDataSource

mapObject

public void mapObject(PersistableInitializer initializer,
                      java.lang.String objectId)
               throws java.lang.Exception

Description copied from interface: DataSource

This is called when an object is being activated to retrieve the persisted data for a given object

Specified by:

mapObject in interface DataSource

Throws:

java.lang.Exception

recordListAdd

public void recordListAdd(java.lang.String objectId,
                          java.lang.Object value)
                   throws java.lang.Exception

Throws:

java.lang.Exception

recordNewObject

public NewObjectPersister recordNewObject(Persistable object)
                                   throws java.lang.Exception

Description copied from interface: WritableDataSource

This is called when a new object is persisted

Specified by:

recordNewObject in interface WritableDataSource

Returns:

persister

Throws:

java.lang.Exception

recordListRemoval

public void recordListRemoval(java.lang.String objectId,
                              java.lang.Object value)
                       throws java.lang.Exception

Throws:

java.lang.Exception

recordPropertyAddition

public void recordPropertyAddition(java.lang.String objectId,
                                   java.lang.String name,
                                   java.lang.Object value,
                                   int attributes)
                            throws java.lang.Exception

Description copied from interface: WritableDataSource

This is called when a new property is added to an object

Specified by:

recordPropertyAddition in interface WritableDataSource

value - - The value should generally be an object one of the following classes: String, Boolean, Integer, Double, Date, ObjectId, or a null If the value is an ObjectId than it indicates that it is a reference to another object. The data source can check isPersisted to see if the object has been persisted yet. If it is true than it means it means it has already been persisted. If it is false, the object has not been persisted yet. If the data source can handle a new object at this point, it should call ObjectId.persist to persist the object

attributes - TODO

Throws:

java.lang.Exception

recordPropertyChange

public void recordPropertyChange(java.lang.String objectId,
                                 java.lang.String name,
                                 java.lang.Object value,
                                 int attributes)
                          throws java.lang.Exception

Description copied from interface: WritableDataSource

This is called when a property value is changed

Specified by:

recordPropertyChange in interface WritableDataSource

attributes - TODO

Throws:

java.lang.Exception

recordPropertyRemoval

public void recordPropertyRemoval(java.lang.String objectId,
                                  java.lang.String name)
                           throws java.lang.Exception

Description copied from interface: WritableDataSource

This is called when a property value is removed

Specified by:

recordPropertyRemoval in interface WritableDataSource

Throws:

java.lang.Exception

recordDelete

public void recordDelete(java.lang.String objectId)
                  throws java.lang.Exception

Description copied from interface: WritableDataSource

This is called when an object should be deleted

Specified by:

recordDelete in interface WritableDataSource

Throws:

java.lang.Exception