oracle.pg.rdbms

Interface OracleChangeTracker

All Known Implementing Classes:

OraclePropertyGraph

public interface OracleChangeTracker

An interface to track the changes executed over a Property Graph

Method Summary

Methods

Modifier and Type	Method and Description
void	disable() Disables the session flash back.
boolean	doesEdgeExistAt(String szEdgeID, Long longEndSCN) Validates if the edge identified by the given edge ID exist at SCN denoted by the end SCN
boolean	doesEdgeExistAt(String szEdgeID, Long longEndSCN, int iQueryDOP) Validates if the edge identified by the given edge ID exist at SCN denoted by the end SCN
boolean	doesVertexExistAt(String szVertexID, Long longEndSCN) Validates if the vertex identified by the given vertex ID exist at SCN denoted by the end SCN
boolean	doesVertexExistAt(String szVertexID, Long longEndSCN, int iQueryDOP) Validates if the vertex identified by the given vertex ID exist at SCN denoted by the end SCN
void	enableAtSCN(Long longSCN) Sets the session snapshot to the given SCN value
Long	getCurrentSCN() Returns the current SCN of this OracleChangeTracker
Iterator<EdgeChange>	getEdgeChanges(Long longStartSCN, Long longEndSCN) Returns the edge changes between the given start SCN and end SCN.
Iterator<EdgeChange>	getEdgeChanges(Long longStartSCN, Long longEndSCN, int iQueryDOP) Returns the edge changes between the given start SCN and end SCN.
Iterator<EdgeChange>	getEdgeChanges(Long longStartSCN, Long longEndSCN, int iQueryDOP, boolean bFilterOutRemovedInserts) Returns the edge changes between the given start SCN and end SCN.
Iterator<Long>	getRemovedEdges(Long longStartSCN, Long longEndSCN, int iQueryDOP, String szOptions) Returns an ordered iterator of IDs of Edges that involved in DELETE operations happened between the two given SCNs.
Iterator<Long>	getRemovedVertices(Long longStartSCN, Long longEndSCN, int iQueryDOP, String szOptions) Returns an ordered iterator of IDs of Vertices that involved in DELETE operations happened between the two given SCNs.
Iterator<VertexChange>	getVertexChanges(Long longStartSCN, Long longEndSCN) Returns the vertex changes between the given start SCN and end SCN.
Iterator<VertexChange>	getVertexChanges(Long longStartSCN, Long longEndSCN, int iQueryDOP) Returns the vertex changes between the given start SCN and end SCN.
Iterator<VertexChange>	getVertexChanges(Long longStartSCN, Long longEndSCN, int iQueryDOP, boolean bFilterOutRemovedInserts) Returns the vertex changes between the given start SCN and end SCN.

Method Detail

disable

void disable()
             throws SQLException

Disables the session flash back.

Throws:

SQLException

doesEdgeExistAt

boolean doesEdgeExistAt(String szEdgeID,
                      Long longEndSCN)
                        throws SQLException

Validates if the edge identified by the given edge ID exist at SCN denoted by the end SCN

Parameters:

szEdgeID - ID of the edge

longEndSCN - end SCN value. A NULL value will be treated as MAXVALUE to the underlying Oracle Database.

Returns:

TRUE if the edge identified by the given edge ID exist at SCN denoted by the end SCN

Throws:

SQLException

doesEdgeExistAt

boolean doesEdgeExistAt(String szEdgeID,
                      Long longEndSCN,
                      int iQueryDOP)
                        throws SQLException

Validates if the edge identified by the given edge ID exist at SCN denoted by the end SCN

Parameters:

szEdgeID - ID of the edge

longEndSCN - end SCN value. A NULL value will be treated as MAXVALUE to the underlying Oracle Database.

iQueryDOP - the degree of parallelism to be used to do the check

Returns:

TRUE if the edge identified by the given edge ID exist at SCN denoted by the end SCN

Throws:

SQLException

doesVertexExistAt

boolean doesVertexExistAt(String szVertexID,
                        Long longEndSCN)
                          throws SQLException

Validates if the vertex identified by the given vertex ID exist at SCN denoted by the end SCN

Parameters:

szVertexID - ID of the vertex

longEndSCN - end SCN value. A NULL value will be treated as MAXVALUE to the underlying Oracle Database.

Returns:

TRUE if the vertex identified by the given vertex ID exist at SCN denoted by the end SCN

Throws:

SQLException

doesVertexExistAt

boolean doesVertexExistAt(String szVertexID,
                        Long longEndSCN,
                        int iQueryDOP)
                          throws SQLException

Validates if the vertex identified by the given vertex ID exist at SCN denoted by the end SCN

Parameters:

szVertexID - ID of the vertex

longEndSCN - end SCN value. A NULL value will be treated as MAXVALUE to the underlying Oracle Database.

iQueryDOP - the degree of parallelism to be used to do the check

Returns:

TRUE if the vertex identified by the given vertex ID exist at SCN denoted by the end SCN

Throws:

SQLException

enableAtSCN

void enableAtSCN(Long longSCN)
                 throws SQLException

Sets the session snapshot to the given SCN value

Parameters:

longSCN - SCN of the snapshot

Throws:

SQLException

getCurrentSCN

Long getCurrentSCN()
                   throws SQLException

Returns the current SCN of this OracleChangeTracker

Throws:

SQLException

getEdgeChanges

Iterator<EdgeChange> getEdgeChanges(Long longStartSCN,
                                  Long longEndSCN)
                                    throws SQLException

Returns the edge changes between the given start SCN and end SCN.

Parameters:

longStartSCN - start SCN value. A NULL value will be treated as MINVALUE to the underlying Oracle Database.

longEndSCN - end SCN value. A NULL value will be treated as MAXVALUE to the underlying Oracle Database.

Throws:

SQLException

getEdgeChanges

Iterator<EdgeChange> getEdgeChanges(Long longStartSCN,
                                  Long longEndSCN,
                                  int iQueryDOP)
                                    throws SQLException

Returns the edge changes between the given start SCN and end SCN.

Parameters:

longStartSCN - start SCN value. A NULL value will be treated as MINVALUE to the underlying Oracle Database.

longEndSCN - end SCN value. A NULL value will be treated as MAXVALUE to the underlying Oracle Database.

iQueryDOP - the degree of parallelism to be used to identify changes.

Throws:

SQLException

getEdgeChanges

Iterator<EdgeChange> getEdgeChanges(Long longStartSCN,
                                  Long longEndSCN,
                                  int iQueryDOP,
                                  boolean bFilterOutRemovedInserts)
                                    throws SQLException

Returns the edge changes between the given start SCN and end SCN.

Parameters:

longStartSCN - start SCN value. A NULL value will be treated as MINVALUE to the underlying Oracle Database.

longEndSCN - end SCN value. A NULL value will be treated as MAXVALUE to the underlying Oracle Database.

iQueryDOP - the degree of parallelism to be used to identify changes.

bFilterOutRemovedInserts - if an insert has already been removed by the end of time period, then do not include it in the iterator.

Throws:

SQLException

getRemovedEdges

Iterator<Long> getRemovedEdges(Long longStartSCN,
                             Long longEndSCN,
                             int iQueryDOP,
                             String szOptions)
                               throws SQLException

Returns an ordered iterator of IDs of Edges that involved in DELETE operations happened between the two given SCNs. The DELETE operations can be initiated from REST interfaces, Blueprints APIs, or SQL layer. Note that this output contains only IDs of Edges that no longer exist at the end of the SCN range.

Parameters:

longStartSCN - start SCN

longEndSCN - end SCN

iQueryDOP - degree of parallelism to be used for the underlying query

szOptions - hints for the underlying query.

Throws:

SQLException

getRemovedVertices

Iterator<Long> getRemovedVertices(Long longStartSCN,
                                Long longEndSCN,
                                int iQueryDOP,
                                String szOptions)
                                  throws SQLException

Returns an ordered iterator of IDs of Vertices that involved in DELETE operations happened between the two given SCNs. The DELETE operations can be initiated from REST interfaces, Blueprints APIs, or SQL layer. Note that this output contains only IDs of Vertices that no longer exist at the end of the SCN range.

Parameters:

longStartSCN - start SCN

longEndSCN - end SCN

iQueryDOP - degree of parallelism to be used for the underlying query

szOptions - hints for the underlying query.

Throws:

SQLException

getVertexChanges

Iterator<VertexChange> getVertexChanges(Long longStartSCN,
                                      Long longEndSCN)
                                        throws SQLException

Returns the vertex changes between the given start SCN and end SCN.

Parameters:

longStartSCN - start SCN value. A NULL value will be treated as MINVALUE to the underlying Oracle Database.

longEndSCN - end SCN value. A NULL value will be treated as MAXVALUE to the underlying Oracle Database.

Throws:

SQLException

getVertexChanges

Iterator<VertexChange> getVertexChanges(Long longStartSCN,
                                      Long longEndSCN,
                                      int iQueryDOP)
                                        throws SQLException

Returns the vertex changes between the given start SCN and end SCN.

Parameters:

longStartSCN - start SCN value. A NULL value will be treated as MINVALUE to the underlying Oracle Database.

longEndSCN - end SCN value. A NULL value will be treated as MAXVALUE to the underlying Oracle Database.

iQueryDOP - the degree of parallelism to be used to identify changes.

Throws:

SQLException

getVertexChanges

Iterator<VertexChange> getVertexChanges(Long longStartSCN,
                                      Long longEndSCN,
                                      int iQueryDOP,
                                      boolean bFilterOutRemovedInserts)
                                        throws SQLException

Returns the vertex changes between the given start SCN and end SCN.

Parameters:

longStartSCN - start SCN value. A NULL value will be treated as MINVALUE to the underlying Oracle Database.

longEndSCN - end SCN value. A NULL value will be treated as MAXVALUE to the underlying Oracle Database.

iQueryDOP - the degree of parallelism to be used to identify changes.

bFilterOutRemovedInserts - if an insert has already been removed by the end of time period, then do not include it in the iterator.

Throws:

SQLException