org.datanucleus.store.json

Class JsonPersistenceHandler

java.lang.Object

org.datanucleus.store.AbstractPersistenceHandler

org.datanucleus.store.json.JsonPersistenceHandler

All Implemented Interfaces:

org.datanucleus.store.StorePersistenceHandler

Direct Known Subclasses:

CloudStoragePersistenceHandler

public class JsonPersistenceHandler
extends org.datanucleus.store.AbstractPersistenceHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.datanucleus.util.Localiser	LOCALISER_JSON Localiser for messages.

Fields inherited from class org.datanucleus.store.AbstractPersistenceHandler

LOCALISER, storeMgr

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	deleteObject(org.datanucleus.state.ObjectProvider op)
void	fetchObject(org.datanucleus.state.ObjectProvider op, int[] fieldNumbers)
Object	findObject(org.datanucleus.ExecutionContext ec, Object id)
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.
String	getURLPath(org.datanucleus.metadata.AbstractClassMetaData acmd)
String	getURLPath(org.datanucleus.state.ObjectProvider op)
String	getURLPathForQuery(org.datanucleus.metadata.AbstractClassMetaData acmd)
protected void	handleHTTPErrorCode(HttpURLConnection http)
void	insertObject(org.datanucleus.state.ObjectProvider op)
void	locateObject(org.datanucleus.state.ObjectProvider op)
protected JSONObject	read(String method, String requestUri, URLConnection conn, Map headers)
void	updateObject(org.datanucleus.state.ObjectProvider op, int[] fieldNumbers)
protected void	write(String method, String requestUri, URLConnection conn, JSONObject jsonobj, Map<String,String> headers)

Methods inherited from class org.datanucleus.store.AbstractPersistenceHandler

assertReadOnlyForUpdateOfObject, batchEnd, batchStart, deleteObjects, findObjects, insertObjects, locateObjects, useReferentialIntegrity

Methods inherited from class java.lang.Object

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

Field Detail

LOCALISER_JSON

protected static final org.datanucleus.util.Localiser LOCALISER_JSON

Localiser for messages.

Method Detail

close

public void close()

insertObject

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

updateObject

public void updateObject(org.datanucleus.state.ObjectProvider op,
                int[] fieldNumbers)

deleteObject

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

fetchObject

public void fetchObject(org.datanucleus.state.ObjectProvider op,
               int[] fieldNumbers)

findObject

public Object findObject(org.datanucleus.ExecutionContext ec,
                Object id)

locateObject

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

write

protected void write(String method,
         String requestUri,
         URLConnection conn,
         JSONObject jsonobj,
         Map<String,String> headers)

read

protected JSONObject read(String method,
              String requestUri,
              URLConnection conn,
              Map headers)

getHeaders

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

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.

Parameters:

ec - ExecutionContext

mconn - Managed Connection

candidateClass - Candidate

subclasses - Whether to include subclasses

ignoreCache - Whether to ignore the cache

Returns:

List of objects of the candidate type

getURLPath

public String getURLPath(org.datanucleus.state.ObjectProvider op)

getURLPath

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

getURLPathForQuery

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

handleHTTPErrorCode

protected void handleHTTPErrorCode(HttpURLConnection http)
                            throws IOException

Throws:

IOException