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

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

Method Summary

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.
protected String	getURLPath(org.datanucleus.metadata.AbstractClassMetaData acmd)
protected 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, String jsonString, Map<String,String> headers)

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

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,
                     String jsonString,
                     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

options - Map of options

Returns:

List of objects of the candidate type

getURLPath

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

getURLPath

protected 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