org.datanucleus.store.json

Class CloudStoragePersistenceHandler

java.lang.Object

org.datanucleus.store.AbstractPersistenceHandler

org.datanucleus.store.json.JsonPersistenceHandler

org.datanucleus.store.json.CloudStoragePersistenceHandler

All Implemented Interfaces:

org.datanucleus.store.StorePersistenceHandler

Direct Known Subclasses:

AmazonS3PersistenceHandler, GoogleStoragePersistenceHandler

public abstract class CloudStoragePersistenceHandler
extends JsonPersistenceHandler

Nested Class Summary

Nested classes/interfaces inherited from interface org.datanucleus.store.StorePersistenceHandler

org.datanucleus.store.StorePersistenceHandler.PersistenceBatchType

Field Summary

Fields inherited from class org.datanucleus.store.AbstractPersistenceHandler

storeMgr

Constructor Summary

Constructors

Constructor and Description
CloudStoragePersistenceHandler(org.datanucleus.store.StoreManager storeMgr)

Method Summary

Modifier and Type	Method and Description
protected void	createBucket(URLConnection conn, Map headers)
protected Map	getHeaderForBucket()
protected Map<String,String>	getHeaders(String httpVerb, Map<String,String> options)
List	getObjectsOfCandidateType(org.datanucleus.ExecutionContext ec, org.datanucleus.store.connection.ManagedConnection mconn, Class candidateClass, boolean subclasses, boolean ignoreCache, Map options) Convenience method to get all objects of the candidate type from the specified connection.
protected abstract String	getRealmName()
String	getURLPathForQuery(org.datanucleus.metadata.AbstractClassMetaData acmd) URL path for querying in the cloud storage.
void	insertObject(org.datanucleus.state.ObjectProvider op)

Methods inherited from class org.datanucleus.store.json.JsonPersistenceHandler

close, deleteObject, fetchObject, findObject, getURLPath, getURLPath, handleHTTPErrorCode, locateObject, read, updateObject, write

Methods inherited from class org.datanucleus.store.AbstractPersistenceHandler

assertReadOnlyForUpdateOfObject, findObjectForUnique

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.datanucleus.store.StorePersistenceHandler

batchEnd, batchStart, deleteObjects, fetchObjects, findObjects, insertObjects, locateObjects

Constructor Detail

CloudStoragePersistenceHandler

public CloudStoragePersistenceHandler(org.datanucleus.store.StoreManager storeMgr)

Method Detail

insertObject

public void insertObject(org.datanucleus.state.ObjectProvider op)

Specified by:

insertObject in interface org.datanucleus.store.StorePersistenceHandler

Overrides:

insertObject in class JsonPersistenceHandler

createBucket

protected void createBucket(URLConnection conn,
                            Map headers)

getHeaders

protected Map<String,String> getHeaders(String httpVerb,
                                        Map<String,String> options)

Overrides:

getHeaders in class JsonPersistenceHandler

getRealmName

protected abstract String getRealmName()

getHeaderForBucket

protected Map getHeaderForBucket()

getObjectsOfCandidateType

public List getObjectsOfCandidateType(org.datanucleus.ExecutionContext ec,
                                      org.datanucleus.store.connection.ManagedConnection mconn,
                                      Class candidateClass,
                                      boolean subclasses,
                                      boolean ignoreCache,
                                      Map options)

Convenience method to get all objects of the candidate type from the specified connection.

Overrides:

getObjectsOfCandidateType in class JsonPersistenceHandler

Parameters:

ec - ExecutionContext

mconn - Managed Connection

candidateClass - Candidate

subclasses - Whether to include subclasses

ignoreCache - Whether to ignore the cache

options - Map of options

Returns:

List of objects of the candidate type

getURLPathForQuery

public String getURLPathForQuery(org.datanucleus.metadata.AbstractClassMetaData acmd)

URL path for querying in the cloud storage. it lists all entries for the bucket+a prefix

Overrides:

getURLPathForQuery in class JsonPersistenceHandler