com.cloupia.fw.objstore

Class ObjStore<T>

java.lang.Object

com.cloupia.fw.objstore.ObjStore<T>

public class ObjStore<T>
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.Class<T>	classOfT

Constructor Summary

Constructors

Constructor and Description
ObjStore(java.lang.Class<T> classOfT, javax.jdo.PersistenceManagerFactory pmf)

Method Summary

Modifier and Type	Method and Description
static boolean	booleanValue(java.lang.Object obj)
void	cloneObject(T src, T target)
protected void	copyObject(T src, T dest)
long	delete(java.lang.String filter)
long	delete(java.lang.String filter, java.lang.Object... prepArgs) Delete objects that match the query.
long	deleteAll()
static double	doubleValue(java.lang.Object obj)
protected javax.jdo.PersistenceManager	getPersistenceManagerForRead()
protected javax.jdo.PersistenceManager	getPersistenceManagerForWrite()
long	getSequence(java.lang.String seqName)
T	getSingleton() This is for retrieving singleton instances of an object
java.lang.String	getTableName(java.lang.Class<T> c)
void	initialize()
void	insert(java.util.Collection<T> objCollection) Insert the given collection of objects in to the data store.
void	insert(T obj) Insert the given object in to the data store.
void	insert(T[] objArray) Insert the given collection of objects in to the data store.
void	insert(T obj, boolean withException) Insert the given object in to the data store.
void	insertAsNewObject(T obj, T newObj) Copy the given object and Insert a new object in to the data store.
static int	intValue(java.lang.Object obj)
long	jdoDelete(java.lang.String query)
static long	longValue(java.lang.Object obj)
int	modifyObjects(java.lang.String query, java.util.Map<java.lang.String,java.lang.Object> newValues)
int	modifyObjects(java.lang.String query, java.lang.String property, java.lang.Object value)
void	modifySingleObject(java.lang.String query, java.util.Map<java.lang.String,java.lang.Object> newValues)
void	modifySingleObject(java.lang.String query, java.lang.String property, java.lang.Object value)
void	modifySingleObject(java.lang.String query, T newObj)
void	modifySingleObject(java.lang.String query, T newObj, java.util.Map paramValues)
void	persisteSingleton(T obj) This is for persisting singleton instances of an object
java.util.List<T>	query(java.lang.String query)
java.util.List<T>	query(java.lang.String query, java.lang.String ordering)
java.util.List<T>	query(java.lang.String query, java.lang.String ordering, boolean flushIgnoreCache) This method of query execution used to set Flush and Ignore caches parameter in Query level.
java.util.List<T>	query(java.lang.String query, java.lang.String ordering, int startIndex, int endIndex)
java.util.List<T>	query(java.lang.String query, java.lang.String ordering, int startIndex, int endIndex, boolean flushIgnoreCache)
AggregateResult	queryAggregateFields(java.lang.String fieldName, java.lang.String query)
java.util.List<T>	queryAll()
java.util.List<T>	queryAll(java.lang.String ordering)
long	queryCount(java.lang.String fieldName, java.lang.String query)
double	queryFieldAverage(java.lang.String fieldName, java.lang.String query)
java.util.List<T>	queryFilter(java.lang.String query, java.lang.String filter)
int	queryMax(java.lang.String fieldName, java.lang.String query)
java.util.List<java.lang.Object>	querySelectColumn(java.lang.String query, java.lang.String selectColumn)
java.util.List<java.lang.Object[]>	querySelectColumns(java.lang.String query)
java.util.List<java.lang.Object[]>	querySelectColumns(java.lang.String query, java.lang.String selectColumns) Query the metering records using field-by-field method (to compare performance against the Object level query)
java.util.List<java.lang.Object[]>	querySelectColumns(java.lang.String query, java.lang.String selectColumns, java.lang.String ordering, java.lang.String grouping) Query the metering records using field-by-field method (to compare performance against the Object level query)
java.util.List<T>	querySQL(java.lang.String strQuery)
long	querySum(java.lang.String fieldName, java.lang.String query)
double	querySumDouble(java.lang.String fieldName, java.lang.String query)
protected void	setField(T obj, java.util.Map<java.lang.String,java.lang.Object> newValues)
static short	shortValue(java.lang.Object obj)
protected java.lang.String	transformQuery(java.lang.String query)

Methods inherited from class java.lang.Object

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

Field Detail

classOfT

protected java.lang.Class<T> classOfT

Constructor Detail

ObjStore

public ObjStore(java.lang.Class<T> classOfT,
                javax.jdo.PersistenceManagerFactory pmf)

Method Detail

getSingleton

public T getSingleton()
               throws java.lang.Exception

This is for retrieving singleton instances of an object

Throws:

java.lang.Exception

persisteSingleton

public void persisteSingleton(T obj)
                       throws java.lang.Exception

This is for persisting singleton instances of an object

Throws:

java.lang.Exception

insert

public void insert(T obj)
            throws java.lang.Exception

Insert the given object in to the data store. If the object has explicit primary key(s) and if the given object already exists in the store, the insert operation will fail with exception.

Parameters:

obj -

Throws:

java.lang.Exception

insert

public void insert(T obj,
                   boolean withException)
            throws java.lang.Exception

Insert the given object in to the data store. If the object has explicit primary key(s) and if the given object already exists in the store, the insert operation will fail with exception. If there is any Object with ClassCast related issue, will be thrown back to the caller

Parameters:

obj -

withException - throwing specific Exception back to the caller.

Throws:

java.lang.Exception

insertAsNewObject

public void insertAsNewObject(T obj,
                              T newObj)
                       throws java.lang.Exception

Copy the given object and Insert a new object in to the data store. This method is used to retrieve and insert (copy) the same object without copying the JDO specific fields.

Parameters:

obj -

Throws:

java.lang.Exception

insert

public void insert(java.util.Collection<T> objCollection)
            throws java.lang.Exception

Insert the given collection of objects in to the data store. If the object has explicit primary key(s) and if the given object already exists in the store, the insert operation will fail with exception. Entire insert operation is handled as a transaction.

Parameters:

objCollection -

Throws:

java.lang.Exception

insert

public void insert(T[] objArray)
            throws java.lang.Exception

Insert the given collection of objects in to the data store. If the object has explicit primary key(s) and if the given object already exists in the store, the insert operation will fail with exception. Entire insert operation is handled as a transaction.

Parameters:

objArray -

Throws:

java.lang.Exception

queryCount

public long queryCount(java.lang.String fieldName,
                       java.lang.String query)
                throws java.lang.Exception

Throws:

java.lang.Exception

initialize

public void initialize()
                throws java.lang.Exception

Throws:

java.lang.Exception

querySum

public long querySum(java.lang.String fieldName,
                     java.lang.String query)
              throws java.lang.Exception

Throws:

java.lang.Exception

querySumDouble

public double querySumDouble(java.lang.String fieldName,
                             java.lang.String query)
                      throws java.lang.Exception

Throws:

java.lang.Exception

queryMax

public int queryMax(java.lang.String fieldName,
                    java.lang.String query)
             throws java.lang.Exception

Throws:

java.lang.Exception

queryFieldAverage

public double queryFieldAverage(java.lang.String fieldName,
                                java.lang.String query)
                         throws java.lang.Exception

Throws:

java.lang.Exception

queryAggregateFields

public AggregateResult queryAggregateFields(java.lang.String fieldName,
                                            java.lang.String query)
                                     throws java.lang.Exception

Throws:

java.lang.Exception

queryAll

public java.util.List<T> queryAll()
                           throws java.lang.Exception

Throws:

java.lang.Exception

queryAll

public java.util.List<T> queryAll(java.lang.String ordering)
                           throws java.lang.Exception

Throws:

java.lang.Exception

query

public java.util.List<T> query(java.lang.String query)
                        throws java.lang.Exception

Throws:

java.lang.Exception

querySQL

public java.util.List<T> querySQL(java.lang.String strQuery)
                           throws java.lang.Exception

Throws:

java.lang.Exception

queryFilter

public java.util.List<T> queryFilter(java.lang.String query,
                                     java.lang.String filter)
                              throws java.lang.Exception

Throws:

java.lang.Exception

query

public java.util.List<T> query(java.lang.String query,
                               java.lang.String ordering)
                        throws java.lang.Exception

Parameters:

query - Query string. if null returns all entries in the store

ordering - Ordering of entries by field names, space seperated

Returns:

Throws:

java.lang.Exception

query

public java.util.List<T> query(java.lang.String query,
                               java.lang.String ordering,
                               boolean flushIgnoreCache)
                        throws java.lang.Exception

This method of query execution used to set Flush and Ignore caches parameter in Query level.

Parameters:

query - - Query to Execute

ordering - - Order

flushIgnoreCache - - Setting flush and Ignore Cache for the Query Level

Returns:

- Return Query Result.

Throws:

java.lang.Exception

query

public java.util.List<T> query(java.lang.String query,
                               java.lang.String ordering,
                               int startIndex,
                               int endIndex,
                               boolean flushIgnoreCache)
                        throws java.lang.Exception

Parameters:

query - - Query to Execute

ordering - - Order

startIndex - - Start Index

endIndex - - End Index

flushIgnoreCache - - setting the Flush and Ignoring Cache for Query Level

Returns:

- Return Query Result

Throws:

java.lang.Exception

query

public java.util.List<T> query(java.lang.String query,
                               java.lang.String ordering,
                               int startIndex,
                               int endIndex)
                        throws java.lang.Exception

Throws:

java.lang.Exception

querySelectColumns

public java.util.List<java.lang.Object[]> querySelectColumns(java.lang.String query,
                                                             java.lang.String selectColumns)
                                                      throws java.lang.Exception

Query the metering records using field-by-field method (to compare performance against the Object level query)

Parameters:

query -

Returns:

Throws:

java.lang.Exception

querySelectColumn

public java.util.List<java.lang.Object> querySelectColumn(java.lang.String query,
                                                          java.lang.String selectColumn)
                                                   throws java.lang.Exception

Throws:

java.lang.Exception

querySelectColumns

public java.util.List<java.lang.Object[]> querySelectColumns(java.lang.String query,
                                                             java.lang.String selectColumns,
                                                             java.lang.String ordering,
                                                             java.lang.String grouping)
                                                      throws java.lang.Exception

Query the metering records using field-by-field method (to compare performance against the Object level query)

Parameters:

query -

selectColumns -

ordering -

grouping -

Returns:

Throws:

java.lang.Exception

querySelectColumns

public java.util.List<java.lang.Object[]> querySelectColumns(java.lang.String query)
                                                      throws java.lang.Exception

Throws:

java.lang.Exception

setField

protected void setField(T obj,
                        java.util.Map<java.lang.String,java.lang.Object> newValues)
                 throws java.lang.Exception

Throws:

java.lang.Exception

copyObject

protected void copyObject(T src,
                          T dest)
                   throws java.lang.Exception

Throws:

java.lang.Exception

cloneObject

public void cloneObject(T src,
                        T target)
                 throws java.lang.Exception

Throws:

java.lang.Exception

modifySingleObject

public void modifySingleObject(java.lang.String query,
                               java.lang.String property,
                               java.lang.Object value)
                        throws java.lang.Exception

Throws:

java.lang.Exception

modifySingleObject

public void modifySingleObject(java.lang.String query,
                               T newObj,
                               java.util.Map paramValues)
                        throws java.lang.Exception

Throws:

java.lang.Exception

modifySingleObject

public void modifySingleObject(java.lang.String query,
                               T newObj)
                        throws java.lang.Exception

Throws:

java.lang.Exception

modifySingleObject

public void modifySingleObject(java.lang.String query,
                               java.util.Map<java.lang.String,java.lang.Object> newValues)
                        throws java.lang.Exception

Throws:

java.lang.Exception

modifyObjects

public int modifyObjects(java.lang.String query,
                         java.util.Map<java.lang.String,java.lang.Object> newValues)
                  throws java.lang.Exception

Throws:

java.lang.Exception

modifyObjects

public int modifyObjects(java.lang.String query,
                         java.lang.String property,
                         java.lang.Object value)
                  throws java.lang.Exception

Throws:

java.lang.Exception

deleteAll

public long deleteAll()
               throws java.lang.Exception

Throws:

java.lang.Exception

delete

public long delete(java.lang.String filter)
            throws java.lang.Exception

Throws:

java.lang.Exception

delete

public long delete(java.lang.String filter,
                   java.lang.Object... prepArgs)
            throws java.lang.Exception

Delete objects that match the query.

Parameters:

filter -

prepArgs - variable argument

Returns:

Number of items deleted

Throws:

java.lang.Exception

getTableName

public java.lang.String getTableName(java.lang.Class<T> c)

jdoDelete

public long jdoDelete(java.lang.String query)
               throws java.lang.Exception

Throws:

java.lang.Exception

getSequence

public long getSequence(java.lang.String seqName)
                 throws java.lang.Exception

Throws:

java.lang.Exception

booleanValue

public static boolean booleanValue(java.lang.Object obj)

intValue

public static int intValue(java.lang.Object obj)

shortValue

public static short shortValue(java.lang.Object obj)

doubleValue

public static double doubleValue(java.lang.Object obj)

longValue

public static long longValue(java.lang.Object obj)

transformQuery

protected java.lang.String transformQuery(java.lang.String query)

getPersistenceManagerForRead

protected javax.jdo.PersistenceManager getPersistenceManagerForRead()

getPersistenceManagerForWrite

protected javax.jdo.PersistenceManager getPersistenceManagerForWrite()