public class OraclePropertyGraph extends SQLAnalyticsGraph implements OraclePropertyGraphAnalytics, OracleChangeTracker, OraclePropertyGraphConfigurationConstants
SQLAnalyticsGraph.SortOraclePropertyGraphBase.CacheStatus, OraclePropertyGraphBase.OptimizationFlagorg.apache.tinkerpop.gremlin.structure.Graph.Exceptions, org.apache.tinkerpop.gremlin.structure.Graph.Features, org.apache.tinkerpop.gremlin.structure.Graph.Hidden, org.apache.tinkerpop.gremlin.structure.Graph.OptIn, org.apache.tinkerpop.gremlin.structure.Graph.OptIns, org.apache.tinkerpop.gremlin.structure.Graph.OptOut, org.apache.tinkerpop.gremlin.structure.Graph.OptOuts, org.apache.tinkerpop.gremlin.structure.Graph.VariablesOraclePropertyGraphConstants.QueueAction| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
ADD_EDGE_STMT_STR |
static java.lang.String |
ADD_VERTEX_STMT_STR |
static java.lang.String |
CREATE_PG_TABLES_NO_SHARDING_STMT_STR |
static java.lang.String |
CREATE_PG_TABLES_SHARDING_STMT_STR |
static java.lang.String |
CREATE_PROPERTY_NAMES_ARRAY_TYPE |
static java.lang.String |
CREATE_PROPERTY_T_ARRAY_TYPE |
static java.lang.String |
CREATE_PROPERTY_V_ARRAY_TYPE |
static java.lang.String |
CREATE_PROPERTY_VN_ARRAY_TYPE |
static java.lang.String |
DEFAULT_NUMBER_FORMAT
This constant denotes the default number format used in SQL Statements
|
static java.lang.String |
DEFAULT_TIME_DB_FORMAT
This constant denotes the default datetime format used in SQL Statements
|
static java.lang.String |
DEFAULT_TIME_FORMAT
This constant denotes the default datetime format used in SQL Statements
|
static java.lang.String |
DROP_PG_STMT_STR |
static java.lang.String |
EDGE_TABLE_SUFFIX |
static java.lang.String |
EXIST_PG_STMT_STR |
static java.lang.String |
GET_INTERNAL_ID_STMT_STR |
static java.lang.String |
GRANT_ACCESS_STMT |
static java.lang.String |
PREPARE_TWO_TABLES_EDGE_NO_ID_PROPERTY_TYPE_STMT_STR |
static java.lang.String |
PREPARE_TWO_TABLES_EDGE_STMT_STR |
static java.lang.String |
PREPARE_TWO_TABLES_VERTEX_NO_ID_PROPERTY_TYPE_STMT_STR |
static java.lang.String |
PREPARE_TWO_TABLES_VERTEX_STMT_STR |
static java.lang.String |
READ_VERTICES_PROJECTED_VARS_ALL |
static java.lang.String |
READ_VERTICES_PROJECTED_VARS_NO_VL |
static java.lang.String |
REVOKE_ACCESS_STMT |
static java.lang.String |
SKELETON_TABLE_SUFFIX |
static java.lang.String |
SNAPSHOT_TABLE_SUFFIX |
static java.lang.String |
TEXT_INDEX_TABLE_SUFFIX |
static java.lang.String |
UNEXPECTED_COLUMN_TYPE_ERROR |
static java.lang.String |
VERTEX_DISTINCT_TABLE_SUFFIX |
static java.lang.String |
VERTEX_TABLE_SUFFIX |
GRAPH_DATASOURCE_ID, GRAPH_JDBC_URL, GRAPH_NAME, GRAPH_OPTIONS, GRAPH_OWNER, GRAPH_PASSWD, GRAPH_SECURITY_LABEL, GRAPH_SECURITY_POLICY, GRAPH_SECURITY_ROW_LABEL, GRAPH_USERNAMEMG_ERR_USER_REQ_OP_CANCEL, MSG_E_AUTO_IDX_MUST_SOLR_OR_LUCENE, MSG_E_AUTO_IDX_NOT_EXIST, MSG_ERR_ARG_CANNOT_BE_NULL, MSG_ERR_ID_CANNOT_BE_NULL, MSG_ERR_NO_ELEM_TO_BE_CONSUMED, MSG_ERR_NO_OP_SUPPORTED, MSG_IDX_KEY_NOT_NULL, MSG_IDX_KEYS_NOT_NULL, MSG_TXT_IDX_NOT_FOUND, MSG_V_AUTO_IDX_MUST_SOLR_OR_LUCENE, MSG_V_AUTO_IDX_NOT_EXISTERR_ARG_CANNOT_BE_NULL, ERR_CODE_NOT_IN_LIST, ERR_DOP_CONSTRAINT, ERR_E_AUTO_IDX_MUST_SOLR_OR_LUCENE, ERR_E_AUTO_IDX_NOT_EXIST, ERR_E_DS_MUSTBE_FILE_OR_IS, ERR_E_MAX_LINE_CONSTRAINT, ERR_EDGE_DIR_NOT_BOTH, ERR_EDGE_WORK_TBL_NOT_CLEAN, ERR_GRAPH_NAME_CANT_BENULL, ERR_HIT_EXCEPTION, ERR_HIT_INTERRUPT, ERR_HIT_IO, ERR_HIT_OPGE, ERR_HIT_PARSEE, ERR_ID_CANNOT_BE_NULL, ERR_IDX_KEY_CANNOT_BE_NULL, ERR_IDX_KEY_NOT_NULL, ERR_IDX_KEYS_NOT_NULL, ERR_IN_DS_EDGE_CANTBE_NULL, ERR_IN_DS_VERT_CANTBE_NULL, ERR_IN_E_FLAT_DOESNT_EXIST, ERR_IN_V_FLAT_DOESNT_EXIST, ERR_INPUT_LIST_NOT_NULL, ERR_INPUT_NOT_NULL, ERR_INVALID_CHANGE_ACTION, ERR_INVALID_NUM_FIELDS, ERR_INVALID_NUM_NOARG, ERR_INVALID_NUMBER, ERR_INVALID_VAL, ERR_KEY_CANNOT_BE_ID, ERR_KEY_CANNOT_BE_NULL, ERR_KEY_CANNOT_BE_NULL_EMPTY, ERR_KEY_NOT_SET_TO, ERR_NO_ELEM_TO_BE_CONSUMED, ERR_NO_OP_SUPPORTED, ERR_NOT_IMPLEMENTED_YET, ERR_NOT_ORACLE_V_E, ERR_NUM_PART_CONSTRAINT, ERR_OFFSET_CONSTRAINT, ERR_OFFSET_E_MUST_BE_POS, ERR_OFFSET_V_MUST_BE_POS, ERR_OPT_FLAG_EDGE_INVALID, ERR_OPT_FLAG_VERT_INVALID, ERR_ORA_TEXT_INVALID_KEY, ERR_ORA_TEXT_ONLY_AUTO, ERR_OUTPUT_LIST_NOT_NULL, ERR_PG_ALREADY_EXISTS, ERR_PG_NOT_EMPTY, ERR_PG_NOT_NULL, ERR_SIZE_MUST_BE_POS, ERR_TIMEOUT_TAB_CREATION, ERR_TXT_IDX_NOT_FOUND, ERR_TYPE_ID_NOT_RECO, ERR_UNSUPPORTED_VAL_TYP, ERR_USER_REQ_OP_CANCEL, ERR_V_AUTO_IDX_MUST_SOLR_OR_LUCENE, ERR_V_AUTO_IDX_NOT_EXIST, ERR_V_DS_MUSTBE_FILE_OR_IS, ERR_V_MAX_LINE_CONSTRAINT, ERR_VALUE_CANNOT_BE_NULL, INFO_EMP_K_NO_P_VAL, INFO_NUL_K_NO_P_VALVERTEX_LABELCSV_DATE_TIME_FORMATS, CSV_DT_KEYWORD_BOOLEAN, CSV_DT_KEYWORD_BYTE, CSV_DT_KEYWORD_CHAR, CSV_DT_KEYWORD_DATE, CSV_DT_KEYWORD_DOUBLE, CSV_DT_KEYWORD_FLOAT, CSV_DT_KEYWORD_INTEGER, CSV_DT_KEYWORD_JSON, CSV_DT_KEYWORD_LONG, CSV_DT_KEYWORD_RDF, CSV_DT_KEYWORD_SHORT, CSV_DT_KEYWORD_SPATIAL, CSV_DT_KEYWORD_STRING, OPG_DATETIME_FORMATTYPE_DT_BOOL, TYPE_DT_BYTE, TYPE_DT_CHAR, TYPE_DT_DATE, TYPE_DT_DOUBLE, TYPE_DT_EMPTY, TYPE_DT_FLOAT, TYPE_DT_INTEGER, TYPE_DT_JSON, TYPE_DT_LONG, TYPE_DT_SERI, TYPE_DT_SHORT, TYPE_DT_SPATIAL, TYPE_DT_STRING, TYPE_DT_URI| Modifier and Type | Method and Description |
|---|---|
org.apache.tinkerpop.gremlin.structure.Edge |
addEdge(java.lang.Object id,
org.apache.tinkerpop.gremlin.structure.Vertex outVertex,
org.apache.tinkerpop.gremlin.structure.Vertex inVertex,
java.lang.String label)
Adds an edge to the graph instance.
|
org.apache.tinkerpop.gremlin.structure.Vertex |
addVertexById(java.lang.Object id)
Adds an vertex to the graph instance.
|
void |
clearRepository()
Removes all vertices and edges from this property graph instance.
|
void |
close()
Commits all the queued operations and properly closes the graph.
|
void |
commit()
Commit changes done to this property graph instance.
|
void |
commit(boolean bCommitIndices)
Commit changes done to this property graph instance.
|
long |
countEdges(int dop,
ProgressListener pll)
Counts all edges using parallel scans and the specified DOP.
|
long |
countVertices(int dop,
ProgressListener pll)
Counts all vertices using parallel scan with dop threads
|
void |
createDefaultSpatialIndexOnEdges(int dop)
This API creates a default Spatial index on edges.
|
void |
createDefaultSpatialIndexOnEdges(int dop,
boolean bLocal,
boolean bUseV2)
This API creates a default Spatial index on edges.
|
void |
createDefaultSpatialIndexOnVertices(int dop)
This API creates a default Spatial index on vertices.
|
void |
createDefaultSpatialIndexOnVertices(int dop,
boolean bLocal,
boolean bUseV2)
This API creates a default Spatial index on vertices.
|
void |
disable()
Disables the session flash back.
|
java.util.List<java.lang.String> |
disableDistinctEdgeTable()
Disables database triggers and indices of the distinct edge table
|
java.util.List<java.lang.String> |
disableDistinctVertexTable()
Disables database triggers and indices of the distinct vertex table
|
java.util.List<java.lang.String> |
disableEdgeTableConstraints()
Disables all the database constraints of the edge table.
|
java.util.List<java.lang.String> |
disableEdgeTableIndices(boolean disableGEIndices)
Disables all database indices of the edge table.
|
java.util.List<java.lang.String> |
disableVertexTableConstraints()
Disables all the database constraints of the vertex table.
|
java.util.List<java.lang.String> |
disableVertexTableIndices(boolean disableVTIndices)
Disables all database indices of the vertex table
|
void |
dispose()
Closes the graph without commiting any changes
|
boolean |
doesEdgeExistAt(java.lang.String szEdgeID,
java.lang.Long longEndSCN)
Returns TRUE if the edge identified by the given edge ID
exist at SCN denoted by the end scn
|
boolean |
doesEdgeExistAt(java.lang.String szEdgeID,
java.lang.Long longEndSCN,
int iQueryDOP)
Returns TRUE if the edge identified by the given edge ID
exist at SCN denoted by the end scn
|
boolean |
doesVertexExistAt(java.lang.String szVertexID,
java.lang.Long longEndSCN)
Returns TRUE if the vertex identified by the given vertex ID
exist at SCN denoted by the end scn
|
boolean |
doesVertexExistAt(java.lang.String szVertexID,
java.lang.Long longEndSCN,
int iQueryDOP)
Returns TRUE if the vertex identified by the given vertex ID
exist at SCN denoted by the end scn
|
void |
dropDefaultSpatialIndexOnEdges()
This API drops the default Spatial index on edges.
|
void |
dropDefaultSpatialIndexOnVertices()
This API drops the default Spatial index on vertices.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> |
edges()
Returns an iterator to all the edges in the graph.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> |
edgesByProperty(java.lang.String key,
java.lang.Object value,
java.lang.Class dtClass,
boolean acceptWildcard,
boolean useLuceneSyntax)
Return an iterable to all matching edges that have a particular key/value property.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> |
edgesByPropertyKey(java.lang.String[] propertyNames,
EdgeFilterCallback efc,
OraclePropertyGraphBase.OptimizationFlag flag)
Returns an
Iterator to all the edges in the graph that have any of the specified keys and
satisfy the specified edge filter callback. |
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> |
edgesBySCN(boolean bOrderBySVID,
java.lang.Long longEndSCN)
Returns an iterator to all the edges in the graph from the given SCN.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> |
edgesBySCN(boolean bOrderBySVID,
java.lang.Long longEndSCN,
java.lang.String[] propertyNames,
EdgeFilterCallback efc,
OraclePropertyGraphBase.OptimizationFlag flag)
Returns an
Iterator to all the edges in the graph that have any of the specified keys and
satisfy the specified edge filter callback. |
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] |
edgesBySCN(java.sql.Connection[] connArray)
Returns an array of iterators to all the edges in the graph.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] |
edgesBySCN(java.sql.Connection[] connArray,
boolean bOrderBySVID)
Returns an array of iterators to all the edges in the graph.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] |
edgesBySCN(java.sql.Connection[] connArray,
boolean bOrderBySVID,
java.lang.Long longEndSCN)
Returns an array of iterators to all the edges in the graph.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] |
edgesBySCN(java.sql.Connection[] connArray,
boolean bOrderBySVID,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID)
Returns an array of iterators to all the edges in the graph.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] |
edgesBySCN(java.sql.Connection[] connArray,
boolean bOrderBySVID,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID,
java.lang.String key)
Returns an array of iterators to all the edges in the graph that have a particular key.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] |
edgesBySCN(java.sql.Connection[] connArray,
boolean bOrderBySVID,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID,
java.lang.String[] propertyNames)
Returns an array of iterators to all the edges in the graph that have any of the specified keys.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> |
edgesBySCN(java.lang.Long longEndSCN)
Returns an iterator to all the edges in the graph from the given SCN.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> |
edgesFromResultSet(java.sql.ResultSet rs,
EdgeFilterCallback efc,
OraclePropertyGraphBase.OptimizationFlag flag)
Returns an
Iterator to all the edges from the ResultSet that
satisfy the specified edge filter callback. |
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] |
edgesNonPartitioned(java.sql.Connection[] connArray,
boolean bOrderBySVID,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
java.lang.String[] propertyNames)
Returns an array of iterators to all the edges in the graph that have any of the specified keys.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] |
edgesNonPartitioned(java.sql.Connection[] connArray,
boolean bOrderBySVID,
java.lang.Long longEndSCN,
java.lang.String[] propertyNames)
Returns an array of iterators to all the edges in the graph that have any of the specified keys.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] |
edgesPartitioned(java.sql.Connection[] connArray,
boolean skipStoreToCache,
int startPartitionID)
Returns an array of iterators to all the edges in the graph.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] |
edgesPartitioned(java.sql.Connection[] connArray,
boolean bSkipStoreToCache,
int startPartitionID,
EdgeFilterCallback efc,
OraclePropertyGraphBase.OptimizationFlag flag)
Returns an array of iterators to all the edges in the graph that
satisfy the specified edge filter callback.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] |
edgesPartitioned(java.sql.Connection[] connArray,
boolean skipStoreToCache,
int startPartitionID,
java.lang.String[] propertyNames)
Returns an array of iterators to all the edges in the graph that have any of the specified keys.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] |
edgesPartitioned(java.sql.Connection[] connArray,
boolean bOrderBySVID,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID,
java.lang.String[] propertyNames)
Returns an array of iterators to all the edges in the graph that have any of the specified keys.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] |
edgesPartitioned(java.sql.Connection[] connArray,
boolean bOrderBySVID,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID,
java.lang.String[] propertyNames,
EdgeFilterCallback efc,
OraclePropertyGraphBase.OptimizationFlag flag)
Returns an array of iterators to all the edges in the graph that
satisfy the specified edge filter callback.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] |
edgesPartitioned(java.sql.Connection[] connArray,
boolean bOrderBySVID,
java.lang.Long longEndSCN,
java.lang.String[] propertyNames)
Returns an array of iterators to all the edges in the graph that have any of the specified keys.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] |
edgesPartitioned(java.sql.ResultSet[] rsArray,
boolean bSkipStoreToCache,
EdgeFilterCallback efc,
OraclePropertyGraphBase.OptimizationFlag flag)
Returns an array of iterators to all the edges from the given array of ResultSet objects that satisfy the specified
edge filter callback.
|
void |
enableAtSCN(java.lang.Long longSCN)
Sets the session snapshot to the given SCN value
|
org.apache.tinkerpop.gremlin.structure.Graph.Features |
features()
Gets the particular features of the graph implementation for Tinkerpop 3.X
|
void |
flushUpdates()
Flushes updates into the pertinent tables.
|
java.util.LinkedList<java.lang.String> |
getConstraintNames(java.lang.String szTabName)
Gets a List of all the database constraints associated to the given table.
|
java.lang.Long |
getCurrentSCN()
Returns the current SCN by invoking DBMS FLASHBACK API.
|
java.lang.Long |
getCurrentSCNUnsafe()
Returns the current SCN by invoking DBMS FLASHBACK API.
|
int |
getDatabaseMajorVersion() |
java.lang.Class |
getDatatypeClassFromValueObjForTextIndex(java.lang.Object value)
Gets the datatype class from the given value object used when
executing a query over a text index
|
int |
getDefaultDOPPerPtn()
Returns the default DOP used for partition-wise scan
|
OracleIndexParameters |
getDefaultIndexParameters()
Get the default index parameters associated to this property graph.
|
java.lang.String |
getDistinctVertexTabIdxName(java.lang.String szCode)
Returns the name of an index of the distinct vertex table
for the specified code
|
java.lang.String |
getDistinctVertexTabName()
Returns the name of the graph distinct vertex table
|
java.lang.String |
getDistinctVertexTabNameNoSchema()
Returns the name of the graph distinct vertex table
|
OracleEdge |
getEdge(java.lang.Object id)
Returns the edge referenced by the object identifier.
|
java.util.Iterator<EdgeChange> |
getEdgeChanges(java.lang.Long longStartSCN,
java.lang.Long longEndSCN)
Returns the changes between the given start SCN and end SCN.
|
java.util.Iterator<EdgeChange> |
getEdgeChanges(java.lang.Long longStartSCN,
java.lang.Long longEndSCN,
int iQueryDOP)
Returns the edge changes between the given start SCN and end SCN.
|
java.util.Iterator<EdgeChange> |
getEdgeChanges(java.lang.Long longStartSCN,
java.lang.Long longEndSCN,
int iQueryDOP,
boolean bFilterOutRemovedInserts)
Returns the edge changes between the given start SCN and end SCN.
|
java.util.Iterator<EdgeChange> |
getEdgeChanges(java.lang.Long longStartSCN,
java.lang.Long longEndSCN,
int iQueryDOP,
boolean bFilterOutRemovedInserts,
java.lang.String[] propertyNames)
Returns the edge changes between the given start SCN and end SCN.
|
OracleEdgeBase |
getEdgeInstance(java.lang.Long eid,
boolean bCreateIfAbsentFromCache,
boolean bSkipStoreToCache)
Returns an instance of OracleEdgeBase.
|
OracleEdgeBase |
getEdgeInstance(OracleVertexBase outVertex,
OracleVertexBase inVertex,
java.lang.String edgeLabel,
java.lang.Long eid,
boolean bCreateIfAbsentFromCache,
boolean bSkipStoreToCache)
Returns an instance of OracleEdgeBase.
|
int |
getEdgePartitionsNumber()
Returns the number of HASH partitions of the edge table.
|
int |
getEdgePropertyNames(int dop,
int timeout,
java.util.Map<java.lang.String,java.lang.Class> propertyNames,
ProgressListener pl)
Gets the property names of all edges using parallel scans and the specified DOP.
|
int |
getEdgePropertyNames(int dop,
int timeout,
java.util.Set<java.lang.String> propertyNames,
ProgressListener pl)
Gets the property names of all edges using parallel scans and the specified DOP.
|
java.lang.String |
getEdgeTabIdxName(java.lang.String szCode)
Returns the name of an index of the edge table for the specified
code
|
java.lang.String |
getEdgeTabName()
Returns the name of the edge table
|
java.lang.String |
getEdgeTabNameNoSchema()
Returns the name of the edge table
|
java.lang.String |
getGraphOwner()
Returns the owner name of the graph.
|
java.util.LinkedList<java.lang.String> |
getIndexNames(java.lang.String szTabName)
Gets a List of all the database indexes associated to the given table.
|
static OraclePropertyGraph |
getInstance(Oracle oracle,
java.lang.String szGraphName)
Returns an instance of OraclePropertyGraph using the Oracle connection
and graph name provided.
|
static OraclePropertyGraph |
getInstance(Oracle oracle,
java.lang.String szGraphName,
int iHashPartitionsNum)
Returns an instance of OraclePropertyGraph using the Oracle connection
and graph name provided.
|
static OraclePropertyGraph |
getInstance(Oracle oracle,
java.lang.String szGraphName,
int iHashPartitionsNum,
int iDOP,
java.lang.String szTBS,
java.lang.String szOptions)
Returns an instance of OraclePropertyGraph using the Oracle connection
and graph name provided.
|
static OraclePropertyGraph |
getInstance(Oracle oracle,
java.lang.String szGraphName,
int iHashPartitionsNum,
int iDOP,
java.lang.String szTBS,
java.lang.String szTBSSet,
java.lang.String szOptions)
Returns an instance of OraclePropertyGraph using the Oracle connection
and graph name provided.
|
static OraclePropertyGraph |
getInstance(Oracle oracle,
java.lang.String owner,
java.lang.String szGraphName)
Returns an instance of OraclePropertyGraph using the Oracle connection
and graph name provided.
|
static OraclePropertyGraph |
getInstance(Oracle oracle,
java.lang.String szGraphOwner,
java.lang.String szGraphName,
int iHashPartitionsNum,
int iDOP,
java.lang.String szTBS,
java.lang.String szOptions)
Returns an instance of OraclePropertyGraph using the Oracle connection
and graph name provided.
|
static OraclePropertyGraph |
getInstance(Oracle oracle,
java.lang.String szGraphOwner,
java.lang.String szGraphName,
int iHashPartitionsNum,
int iDOP,
java.lang.String szTBS,
java.lang.String szTBSSet,
java.lang.String szOptions)
Returns an instance of OraclePropertyGraph using the Oracle connection
and graph name provided.
|
static OraclePropertyGraph |
getInstance(PgRdbmsGraphConfig config)
Gets an OraclePropertyGraph instance from a PGX PgRdbmsGraphConfig object
|
java.util.Set<java.lang.Long> |
getInvalidEdgeIDSet(int dop,
ProgressListener pl)
Gets a set of invalid edges that are stored in the property graph.
|
long |
getMaxEdgeID(int dop,
ProgressListener pl)
Get the maximum edge ID using parallel scan and the specified DOP.
|
long |
getMaxLabelLengthAllowedInBytes()
Get the maximum value length allowed for a label in Bytes
|
long |
getMaxPropertyNameLengthAllowedInBytes()
Get the maximum value length allowed for a property name in Bytes
|
long |
getMaxValueLengthAllowedInBytes()
Get the maximum value length allowed for a property value in Bytes
|
long |
getMaxVertexID(int dop,
ProgressListener pl)
Get maximum vertex ID using parallel scans and the specified DOP.
|
long |
getMinEdgeID(int dop,
ProgressListener pl)
Get the minimum edge ID using parallel scan with dop threads
|
long |
getMinVertexID(int dop,
ProgressListener pl)
Get minimum vertex ID using parallel scans and the specified DOP.
|
java.lang.String |
getNumberToCharSqlFormatString()
Gets the Char SQL Format used to format a number into a string
|
java.lang.String |
getOpgVersion()
Get version of OPG pl/sql packages installed in DB
|
Oracle |
getOracle()
Returns the underlying Oracle instance associated with the property graph instance
|
static Oracle |
getOracle(PgRdbmsGraphConfig config)
Gets an Oracle object from a PGX PgRdbmsGraphConfig object
|
static Oracle |
getOracle(java.lang.String datasourceId)
Gets an Oracle object from a given Datasource Id
|
OracleIndexManager |
getOracleIndexManager()
Gets the Oracle Index Manager associated to this property graph instance.
|
boolean |
getPGViewOnRDFFlag()
Validates if this property graph instance comes from a Property Graph
view over RDF data
|
int |
getQueryFetchSize()
Returns the query fetch size when scanning the vertex and edge tables
|
java.util.Iterator<java.lang.Long> |
getRemovedEdges(java.lang.Long longStartSCN,
java.lang.Long longEndSCN,
int iQueryDOP,
java.lang.String szOptions)
Returns an ordered iterator of IDs of Edges
that involved in DELETE operations happened between
the two given SCNs.
|
java.util.Iterator<java.lang.Long> |
getRemovedVertices(java.lang.Long longStartSCN,
java.lang.Long longEndSCN,
int iQueryDOP,
java.lang.String szOptions)
Returns an ordered iterator of IDs of Vertices
that involved in DELETE operations happened between
the two given SCNs.
|
int |
getRowPrefetch()
Returns the number of rows to prefetch when executing a SQL query over
the Property graph data tables
|
java.lang.String |
getSessionID()
Returns the current database Session ID
|
int |
getSessionQueryDOP()
Returns the degree of parallel query execution at the session level.
|
java.lang.String |
getSkeletonTabIdxName(java.lang.String szCode)
Returns the name of an index of the graph GT table for the specified
code
|
java.lang.String |
getSkeletonTabName()
Returns the name of the graph skeleton table
|
java.lang.String |
getSkeletonTabNameNoSchema()
Returns the name of the graph skeleton table
|
boolean |
getSkipFormNCharSettingForTextQuery()
Returns TRUE if skipFormNCharSettingForTextQuery flag is set, which is the default behavior.
|
java.lang.String |
getSnapshotTabName()
Returns the name of the PGX snapshot table
|
java.util.List<java.lang.String> |
getTableNames() |
java.lang.String |
getTablespace() |
java.lang.String |
getTablespaceSet() |
java.lang.String |
getTextIndexDirectoryPrefix()
Returns the name of this property graph instance
|
java.lang.String |
getTextIndexTabName()
Returns the name of the index metadata table
|
java.lang.String |
getTimeToCharSqlFormatString()
Gets the Char SQL Format used to format a datetime into a string
|
boolean |
getTreatTimestampTzAsStr()
Returns a flag that decides if timestamp with timezone is treated as a string (instead of a Timestamp object).
|
OracleVertex |
getVertex(java.lang.Object id)
Returns the vertex referenced by the object identifier.
|
java.util.Iterator<VertexChange> |
getVertexChanges(java.lang.Long longStartSCN,
java.lang.Long longEndSCN)
Returns the changes between the given start SCN and end SCN.
|
java.util.Iterator<VertexChange> |
getVertexChanges(java.lang.Long longStartSCN,
java.lang.Long longEndSCN,
int iQueryDOP)
Returns the vertex changes between the given start SCN and end SCN using the given
query degree of parallelism.
|
java.util.Iterator<VertexChange> |
getVertexChanges(java.lang.Long longStartSCN,
java.lang.Long longEndSCN,
int iQueryDOP,
boolean bFilterOutRemovedInserts)
Returns the vertex changes between the given start SCN and end SCN.
|
java.util.Iterator<VertexChange> |
getVertexChanges(java.lang.Long longStartSCN,
java.lang.Long longEndSCN,
int iQueryDOP,
boolean bFilterOutRemovedInserts,
java.lang.String[] propertyNames)
Returns the vertex changes between the given start SCN and end SCN.
|
java.util.Set<java.lang.Long> |
getVertexIDSet(int dop,
ProgressListener pl)
Gets a set of Vertex IDs that are stored in the property graph
|
OracleVertexBase |
getVertexInstance(java.lang.Long vid,
boolean bCreateIfAbsentFromCache,
boolean bSkipStoreToCache)
Returns an instance of OracleVertexBase.
|
int |
getVertexPartitionsNumber()
Returns the number of HASH partitions of the vertex table.
|
int |
getVertexPropertyNames(int dop,
int timeout,
java.util.Map<java.lang.String,java.lang.Class> propertyNames,
ProgressListener pl)
Gets the property names of all vertices using parallel scans and the specified DOP.
|
int |
getVertexPropertyNames(int dop,
int timeout,
java.util.Set<java.lang.String> propertyNames,
ProgressListener pl)
Gets the property names of all vertices using parallel scans and the specified DOP.
|
java.lang.String |
getVertexTabIdxName(java.lang.String szCode)
Returns the name of an index of the vertex table for the specified
code
|
java.lang.String |
getVertexTabName()
Returns the name of the vertex table
|
java.lang.String |
getVertexTabNameNoSchema()
Returns the name of the vertex table
|
java.lang.String |
getVerticesProjectedVars() |
java.sql.Date |
getVTE()
Get the end valid time used in the property graph
|
java.sql.Date |
getVTS()
Get the start valid time used in the property graph
|
void |
grantAccess(java.lang.String user,
java.lang.String privilege)
Grants access of this property graph to another user
|
boolean |
isDB11g()
Returns if this property graph instance is working against an 11g
database
|
boolean |
isFeatureSupported(SQLUtils.DbFeature dbFeature)
Checks if the given DB feature is supported
|
boolean |
isShardingDb()
This method verifies if the underlying connection is opened against a sharding DB
|
boolean |
isVirtualPropertyGraph()
Validates if this property graph instance is based on a view
|
java.sql.ResultSet[] |
parallelExecuteStatements(java.sql.PreparedStatement[] stmtArray)
Executes the given statements in parallel and returns an array of result sets
from each statement.
|
java.lang.String |
parseValueToCharSQLFormatString(java.lang.Object value)
Parses a numeric or datetime value object into the String format
required by SQL (Oracle Text) using the CharSQL formats used in this
property graph instance.
|
static java.lang.Object |
readObjFromResultSet(java.sql.ResultSet rs,
int iIdxTypeCol)
Reads a few columns: T, V, VN, VT from the result set and
constructs an Object (V in a K/V pair) depending
on the actual object type.
|
static java.lang.Object |
readObjFromResultSet(java.sql.ResultSet rs,
int iIdxTypeCol,
boolean bTreatTimestampTzAsStr)
Reads a few columns: T, V, VN, VT from the result set and
constructs an Object (V in a K/V pair) depending
on the actual object type.
|
void |
rebuildDistinctEdgeTable(java.util.List<java.lang.String> llIndices,
int dop,
java.lang.String szOptions)
Enables database triggers and indices of the distinct edge table
|
void |
rebuildDistinctVertexTable(java.util.List<java.lang.String> llIndices,
int dop,
java.lang.String szOptions)
Enables database triggers and indices of the distinct vertex table
|
void |
rebuildEdgeTableConstraints(java.util.List<java.lang.String> llConstraints,
int dop,
java.lang.String szOptions)
This method rebuilds all the database constraints of the edge table.
|
void |
rebuildEdgeTableIndices(java.util.List<java.lang.String> llIndices,
int dop,
boolean rebuildGEIndices,
java.lang.String szOptions)
Rebuilds all database indices of the edge table.
|
void |
rebuildVertexTableConstraints(java.util.List<java.lang.String> llConstraints,
int dop,
java.lang.String szOptions)
Rebuilds all the database constraints of the vertex table.
|
void |
rebuildVertexTableIndices(java.util.List<java.lang.String> llIndices,
int dop,
boolean rebuildVTIndices,
java.lang.String szOptions)
Rebuilds all database indices of the vertex table.
|
void |
refreshIndices(long lStartSCN,
long lEndSCN)
Refreshes all the text indices based on the changes done during the given
SCN window.
|
void |
removeEdge(org.apache.tinkerpop.gremlin.structure.Edge edge)
Removes the provided edge from the graph.
|
void |
removeVertex(org.apache.tinkerpop.gremlin.structure.Vertex vertex)
Removes the provided vertex from the graph.
|
void |
revokeAccess(java.lang.String user,
java.lang.String privilege)
Revoke access of this property graph from another user.
|
void |
rollback()
Rollbacks the operations done to this property graph instance
|
void |
setDefaultDOPPerPtn(int i)
This method sets the default DOP used for partition-wise scan.
|
void |
setLabel(java.lang.String policy,
java.lang.String label)
Sets the label for the current session.
|
void |
setNumberToCharSqlFormatString(java.lang.String format)
Sets the Char SQL Format used to format a number into a string
|
void |
setPGViewOnRDFFlag(boolean flag)
Specifies if this property graph instance comes from a Property Graph
view over RDF data
|
void |
setQueryFetchSize(int size)
Sets the query fetch size used when scanning the vertex and edge tables
|
void |
setRowLabel(java.lang.String policy,
java.lang.String label)
Sets the row label for the current session.
|
void |
setRowPrefetch(int i)
Sets the number of rows to prefetch when executing a SQL query over
the Property graph data tables
|
void |
setSessionQueryDOP(int dop)
Sets the degree of parallel query execution at the session level.
|
void |
setSkipFormNCharSettingForTextQuery(java.lang.String s)
This method sets a flag for skipFormNCharSettingForTextQuery
|
void |
setTimeToCharSqlFormatString(java.lang.String format)
Sets the Char SQL Format used to format a datetime into a string
|
void |
setVTE(java.sql.Date dateVTE)
Set the end valid time used in the property graph
|
void |
setVTS(java.sql.Date dateVTS)
Set the start valid time used in the property graph
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> |
sortedEdges(boolean bOrderBySVID)
Returns an iterator to all the edges in the graph.
|
boolean |
supportVertexLabels()
Validates if the property graph instance support vertex labels
|
void |
treatTimestampTzAsStr(boolean b)
This API sets a flag that decides if timestamp with timezone is treated as a string (instead of a Timestamp object).
|
<T extends org.apache.tinkerpop.gremlin.structure.Element> |
updateGraph(OpCallback<T> oc,
boolean skipStoreToCache,
int dop,
ProgressListener pl,
OpCallback.UpdateType updateType)
Removes an attribute from all edges based on the specified
EdgeOpCallback. |
<T extends org.apache.tinkerpop.gremlin.structure.Element> |
validateDistinctTableForDbVersion(java.lang.String operationType,
java.lang.Class<T> elementClass) |
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex> |
vertices()
Returns an iterator to all the vertices in the graph.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex> |
verticesByProperty(java.lang.String key,
java.lang.Object value,
java.lang.Class dtClass,
boolean acceptWildcard,
boolean useLuceneSyntax)
Return an iterable to all matching vertices that have a particular key/value property.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex> |
verticesByPropertyKey(java.lang.String[] propertyNames,
VertexFilterCallback vfc,
OraclePropertyGraphBase.OptimizationFlag flag)
Returns an
Iterator to all the vertices in the graph that have any of the specified keys and
satisfy the specified vertex filter callback. |
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] |
verticesBySCN(java.sql.Connection[] connArray)
Returns an array of iterators to all the vertices in the graph.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] |
verticesBySCN(java.sql.Connection[] connArray,
java.lang.Long longEndSCN)
Returns an array of iterators to all the vertices in the graph.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] |
verticesBySCN(java.sql.Connection[] connArray,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID)
Returns an array of iterators to all the vertices in the graph.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] |
verticesBySCN(java.sql.Connection[] connArray,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID,
java.lang.String key)
Returns an array of iterators to all the vertices in the graph that have a particular key.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] |
verticesBySCN(java.sql.Connection[] connArray,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID,
java.lang.String[] propertyNames)
Returns an array of iterators to all the vertices in the graph that have any of the specified keys.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex> |
verticesBySCN(java.lang.Long longEndSCN,
java.lang.String[] propertyNames,
VertexFilterCallback vfc,
OraclePropertyGraphBase.OptimizationFlag flag)
Returns an
Iterator to all the vertices in the graph that have any of the specified keys and
satisfy the specified vertex filter callback. |
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex> |
verticesFromResultSet(java.sql.ResultSet rs,
VertexFilterCallback vfc,
OraclePropertyGraphBase.OptimizationFlag flag)
Returns an iterator to all the relevant vertices in the graph.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] |
verticesNonPartitioned(java.sql.Connection[] connArray,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
java.lang.String[] propertyNames)
Returns an array of iterators to all the vertices in the graph that have any of the specified keys.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] |
verticesNonPartitioned(java.sql.Connection[] connArray,
java.lang.Long longEndSCN,
java.lang.String[] propertyNames)
Returns an array of iterators to all the vertices in the graph that have any of the specified keys.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] |
verticesPartitioned(java.sql.Connection[] connArray,
boolean skipStoreToCache,
int startPartitionID)
Returns an array of iterators to all the vertices in the graph.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] |
verticesPartitioned(java.sql.Connection[] connArray,
boolean skipStoreToCache,
int startPartitionID,
java.lang.String[] propertyNames)
Returns an array of iterators to all the vertices in the graph that have any of the specified keys.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] |
verticesPartitioned(java.sql.Connection[] connections,
boolean bSkipStoreToCache,
int startPartitionID,
VertexFilterCallback vfc,
OraclePropertyGraphBase.OptimizationFlag flag)
Returns an array of iterators to all the vertices in the graph that
satisfy the specified vertex filter callback.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] |
verticesPartitioned(java.sql.Connection[] connArray,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID,
java.lang.String[] propertyNames)
Returns an array of iterators to all the vertices in the graph that have any of the specified keys.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] |
verticesPartitioned(java.sql.Connection[] connArray,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID,
java.lang.String[] propertyNames,
VertexFilterCallback vfc)
Returns an array of iterators to all the vertices in the graph that
have any of the specified keys and satisfy the specified vertex filter callback.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] |
verticesPartitioned(java.sql.Connection[] connArray,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID,
java.lang.String[] propertyNames,
VertexFilterCallback vfc,
OraclePropertyGraphBase.OptimizationFlag flag)
Returns an array of iterators to all the vertices in the graph that
have any of the specified keys and satisfy the specified vertex filter callback.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] |
verticesPartitioned(java.sql.Connection[] connArray,
java.lang.Long longEndSCN,
java.lang.String[] propertyNames)
Returns an array of iterators to all the vertices in the graph that have any of the specified keys.
|
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] |
verticesPartitioned(java.sql.ResultSet[] rsArray,
boolean bSkipStoreToCache,
VertexFilterCallback vfc,
OraclePropertyGraphBase.OptimizationFlag flag)
Returns an array of iterators to all the vertices in the graph that
satisfy the specified vertex filter callback.
|
analyze, analyze, analyze, analyzeAuto, collaborativeFiltering, collaborativeFilteringCheckIntermediateError, collaborativeFilteringCleanup, collaborativeFilteringGetRecommendation, collaborativeFilteringPrep, countTriangle, countTriangle, countTriangle, countTriangleCleanup, countTrianglePrep, countTriangleRenum, countTriangleRenum, createStatTable, estimateTriangleRenum, estimateTriangleRenum, expEdgeStat, expVertexStat, findCluster, findCluster, findClusterCleanup, findClusterPrep, getTopK, getTopK, getTopK, impEdgeStat, impVertexStat, pageRank, pageRank, pageRankCleanup, pageRankPrep, shortestPath, shortestPath, shortestPath, shortestPath, shortestPath, shortestPath, shortestPathCleanup, shortestPathPrep, sparsifyGraph, sparsifyGraph, sparsifyGraphCleanup, sparsifyGraphPrepaddUpdatedEdge, addUpdatedVertex, addVertex, addVertex, adjacentEdgesFromVertices, adjacentEdgesFromVertices, clearCache, clearUpdateQueue, commitIndices, compute, compute, configuration, createIndex, decodeObject, edges, edgesByIds, edgesByIds, edgesByProperty, edgesByProperty, edgesByProperty, edgesByProperty, edgesByPropertyKey, edgesByPropertyKey, edgesByPropertyKey, getBatchSize, getCacheStatus, getConfig, getDateTimeFormatter, getDefaultEdgeOptFlag, getDefaultVertexOptFlag, getEdgeFilterCallback, getElementsProperties, getGraphName, getJustEdgeIdOptFlag, getJustVertexIdOptFlag, getOperationQueueSize, getProgressListener, getQueueSize, getShortestPath, getShortestPath, getSimpleDateFormat, getStringForObj, getVertexFilterCallback, io, isBuiltinElementsCacheDisabled, isDisposed, isEmpty, isShutdown, isSkipRefreshIndicesEnabled, isTransientPropertyGraphInstance, removeEdges, removeEdges, removeEdges, removeEdges, removeVertices, removeVertices, removeVertices, removeVertices, serializableToStr, setBatchSize, setCacheStatus, setDefaultEdgeOptFlag, setDefaultIndexParameters, setDefaultVertexOptFlag, setEdgeFilterCallback, setProgressListener, setQueueSize, setSkipRefreshIndices, setSolrJavaBinFormat, setTransientPropertyGraphInstance, setVertexFilterCallback, startTransaction, strToSerializable, sum, toString, traversal, traversal, tx, useSolrJavaBinFormat, variables, vertices, verticesByIds, verticesByIds, verticesByProperty, verticesByProperty, verticesByProperty, verticesByProperty, verticesByPropertyKey, verticesByPropertyKey, verticesByPropertyKeyequals, getClass, hashCode, notify, notifyAll, wait, wait, waitcollaborativeFiltering, collaborativeFilteringCleanup, collaborativeFilteringPrep, countTriangle, countTriangle, countTriangleCleanup, countTrianglePrep, countTriangleRenum, estimateTriangleRenum, findCluster, findClusterCleanup, findClusterPrep, pageRank, pageRankCleanup, pageRankPrep, shortestPath, shortestPath, shortestPath, shortestPath, shortestPath, shortestPathCleanup, shortestPathPrepcreateKeyIndex, createKeyIndex, createKeyIndex, dropAllAutoIndices, dropAllIndices, dropAllManualIndices, dropIndex, dropKeyIndex, dropKeyIndex, dropKeyIndex, edgesUsingTextSearch, getAutoIndex, getIndex, getIndexedKeys, getIndexParameters, getIndices, isEdgeAutoIndexEnabled, isVertexAutoIndexEnabled, refreshAutoIndices, validateIndexManager, verticesUsingTextSearchcountEdges, countEdges, countVertices, countVertices, getEdgePropertyNames, getEdgePropertyNames, getElementsProperties, getInvalidEdgeIDSet, getInvalidEdgeIDSet, getMaxEdgeID, getMaxEdgeID, getMaxVertexID, getMaxVertexID, getMinEdgeID, getMinEdgeID, getMinVertexID, getMinVertexID, getVertexIDSet, getVertexIDSet, getVertexPropertyNames, getVertexPropertyNamesaddAttributeToAllEdges, addAttributeToAllEdges, addAttributeToAllEdges, addAttributeToAllVertices, addAttributeToAllVertices, addAttributeToAllVertices, getDOPForMetadataOperations, removeAttributeFromAllEdges, removeAttributeFromAllEdges, removeAttributeFromAllEdges, removeAttributeFromAllVertices, removeAttributeFromAllVertices, removeAttributeFromAllVerticespublic static final java.lang.String ADD_EDGE_STMT_STR
public static final java.lang.String ADD_VERTEX_STMT_STR
public static final java.lang.String CREATE_PG_TABLES_NO_SHARDING_STMT_STR
public static final java.lang.String CREATE_PG_TABLES_SHARDING_STMT_STR
public static final java.lang.String CREATE_PROPERTY_NAMES_ARRAY_TYPE
public static final java.lang.String CREATE_PROPERTY_T_ARRAY_TYPE
public static final java.lang.String CREATE_PROPERTY_V_ARRAY_TYPE
public static final java.lang.String CREATE_PROPERTY_VN_ARRAY_TYPE
public static final java.lang.String DEFAULT_NUMBER_FORMAT
public static final java.lang.String DEFAULT_TIME_DB_FORMAT
public static final java.lang.String DEFAULT_TIME_FORMAT
public static final java.lang.String DROP_PG_STMT_STR
public static final java.lang.String EDGE_TABLE_SUFFIX
public static final java.lang.String EXIST_PG_STMT_STR
public static final java.lang.String GET_INTERNAL_ID_STMT_STR
public static final java.lang.String GRANT_ACCESS_STMT
public static final java.lang.String PREPARE_TWO_TABLES_EDGE_NO_ID_PROPERTY_TYPE_STMT_STR
public static final java.lang.String PREPARE_TWO_TABLES_EDGE_STMT_STR
public static final java.lang.String PREPARE_TWO_TABLES_VERTEX_NO_ID_PROPERTY_TYPE_STMT_STR
public static final java.lang.String PREPARE_TWO_TABLES_VERTEX_STMT_STR
public static final java.lang.String READ_VERTICES_PROJECTED_VARS_ALL
public static final java.lang.String READ_VERTICES_PROJECTED_VARS_NO_VL
public static final java.lang.String REVOKE_ACCESS_STMT
public static final java.lang.String SKELETON_TABLE_SUFFIX
public static final java.lang.String SNAPSHOT_TABLE_SUFFIX
public static final java.lang.String TEXT_INDEX_TABLE_SUFFIX
public static final java.lang.String UNEXPECTED_COLUMN_TYPE_ERROR
public static final java.lang.String VERTEX_DISTINCT_TABLE_SUFFIX
public static final java.lang.String VERTEX_TABLE_SUFFIX
public org.apache.tinkerpop.gremlin.structure.Edge addEdge(java.lang.Object id,
org.apache.tinkerpop.gremlin.structure.Vertex outVertex,
org.apache.tinkerpop.gremlin.structure.Vertex inVertex,
java.lang.String label)
addEdge in class OraclePropertyGraphBaseid - the id of the edgeoutVertex - has to be of type OracleVertexinVertex - has to be of type OracleVertexlabel - edge labelOracleEdge object.public org.apache.tinkerpop.gremlin.structure.Vertex addVertexById(java.lang.Object id)
addVertexById in class OraclePropertyGraphBaseid - the id of the vertexOracleVertex object.public void clearRepository()
throws java.sql.SQLException
clearRepository in class OraclePropertyGraphBasejava.sql.SQLExceptionpublic void close()
close in interface java.io.Closeableclose in interface java.lang.AutoCloseableclose in interface org.apache.tinkerpop.gremlin.structure.Graphpublic void commit()
commit in class OraclePropertyGraphBasepublic void commit(boolean bCommitIndices)
public long countEdges(int dop,
ProgressListener pll)
countEdges in interface OracleMetadataGraphdop - a positive integer defining the number of threads to use when
parallel scanning the edges.public long countVertices(int dop,
ProgressListener pll)
countVertices in interface OracleMetadataGraphdop - a positive integer defining the number of threads to use when
parallel scanning the vertices.pll - a ProgressListener object.public void createDefaultSpatialIndexOnEdges(int dop)
throws java.sql.SQLException
dop - degree of parallelism used to create the Spatial indexjava.sql.SQLExceptionpublic void createDefaultSpatialIndexOnEdges(int dop,
boolean bLocal,
boolean bUseV2)
throws java.sql.SQLException
dop - degree of parallelism used to create the Spatial indexbLocal - creates a local index if truebUseV2 - uses MDSYS.SPATIAL_INDEX_V2 as the indextype if true,
and uses MDSYS.SPATIAL_INDEX as the indextype if false.java.sql.SQLExceptionpublic void createDefaultSpatialIndexOnVertices(int dop)
throws java.sql.SQLException
dop - degree of parallelism used to create the Spatial indexjava.sql.SQLExceptionpublic void createDefaultSpatialIndexOnVertices(int dop,
boolean bLocal,
boolean bUseV2)
throws java.sql.SQLException
dop - degree of parallelism used to create the Spatial indexbLocal - creates a local index if truebUseV2 - uses MDSYS.SPATIAL_INDEX_V2 as the indextype if true,
and uses MDSYS.SPATIAL_INDEX as the indextype if false.java.sql.SQLExceptionpublic void disable()
throws java.sql.SQLException
disable in interface OracleChangeTrackerjava.sql.SQLExceptionpublic java.util.List<java.lang.String> disableDistinctEdgeTable()
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.util.List<java.lang.String> disableDistinctVertexTable()
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.util.List<java.lang.String> disableEdgeTableConstraints()
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.util.List<java.lang.String> disableEdgeTableIndices(boolean disableGEIndices)
throws java.sql.SQLException
disableGEIndices - True if should disable indices for GE$ table,
false for GT$ table.java.sql.SQLExceptionpublic java.util.List<java.lang.String> disableVertexTableConstraints()
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.util.List<java.lang.String> disableVertexTableIndices(boolean disableVTIndices)
throws java.sql.SQLException
disableVTIndices - True if should disable indices for VT$ table,
false for VD$ table.java.sql.SQLExceptionpublic void dispose()
public boolean doesEdgeExistAt(java.lang.String szEdgeID,
java.lang.Long longEndSCN)
throws java.sql.SQLException
doesEdgeExistAt in interface OracleChangeTrackerszEdgeID - ID of the edgelongEndSCN - scnjava.sql.SQLExceptionpublic boolean doesEdgeExistAt(java.lang.String szEdgeID,
java.lang.Long longEndSCN,
int iQueryDOP)
throws java.sql.SQLException
doesEdgeExistAt in interface OracleChangeTrackerszEdgeID - ID of the edgelongEndSCN - scniQueryDOP - the degree of parallelism to be used to
do the checkjava.sql.SQLExceptionpublic boolean doesVertexExistAt(java.lang.String szVertexID,
java.lang.Long longEndSCN)
throws java.sql.SQLException
doesVertexExistAt in interface OracleChangeTrackerszVertexID - ID of the vertexlongEndSCN - scnjava.sql.SQLExceptionpublic boolean doesVertexExistAt(java.lang.String szVertexID,
java.lang.Long longEndSCN,
int iQueryDOP)
throws java.sql.SQLException
doesVertexExistAt in interface OracleChangeTrackerszVertexID - ID of the vertexlongEndSCN - scniQueryDOP - the degree of parallelism to be used to
do the checkjava.sql.SQLExceptionpublic void dropDefaultSpatialIndexOnEdges()
throws java.sql.SQLException
java.sql.SQLExceptionpublic void dropDefaultSpatialIndexOnVertices()
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> edges()
edges in class OraclePropertyGraphBasepublic java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> edgesByProperty(java.lang.String key,
java.lang.Object value,
java.lang.Class dtClass,
boolean acceptWildcard,
boolean useLuceneSyntax)
edgesByProperty in class OraclePropertyGraphBasekey - the name of the property. It MUST not be NULL.value - the value of the property. It can be NULL which will cause all edges with the given key to be returned.dtClass - the class representing the datatype of the property value. This can be
used to cast the property value to a different datatype. For example, if the value is "3.01"
and dtClass is Float.Class, then this value will be treated as a 3.01f. If dtClass is
set to NULL, then the query will be executed by trying to match the value object to
all the supported datatypes.acceptWildcard - specifies if wild cards can be used in the value object. Wild cards can be used only when
an automatic text index on the given key is present.useLuceneSyntax - specifies if the value object is using an Apache Lucene Syntax (further
details on Apache Lucene Syntax can be found in https://lucene.apache.org/core/2_9_4/queryparsersyntax.html). If the
automatic index is not enabled ahd this flag is set to true, an Exception will be thrown
as Lucene Syntax is not supported for database lookups.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> edgesByPropertyKey(java.lang.String[] propertyNames,
EdgeFilterCallback efc,
OraclePropertyGraphBase.OptimizationFlag flag)
Iterator to all the edges in the graph that have any of the specified keys and
satisfy the specified edge filter callback. The information read back from
the edges will be complete or partial based on the optimization flag
specified.edgesByPropertyKey in class OraclePropertyGraphBasepropertyNames - an array of property key names. It can be NULL which implies all vertices in
the graph satisfying the edge filter callback will be returned.efc - a EdgeFilterCallback object specifying the conditions to keep a
edge in the Iterator.flag - an OptimizationFlag object specifying if a partial or complete edge object will
be returned. It can be NULL which implies the edges created must be complete.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> edgesBySCN(boolean bOrderBySVID,
java.lang.Long longEndSCN)
longEndSCN - the end SCN to read edges frombOrderBySVID - if true, the iterator will be further ordered by the SVID column
value.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> edgesBySCN(boolean bOrderBySVID,
java.lang.Long longEndSCN,
java.lang.String[] propertyNames,
EdgeFilterCallback efc,
OraclePropertyGraphBase.OptimizationFlag flag)
Iterator to all the edges in the graph that have any of the specified keys and
satisfy the specified edge filter callback. The information read back from
the edges will be complete or partial based on the optimization flag
specified.propertyNames - an array of property key names. It can be NULL which implies all vertices in
the graph satisfying the edge filter callback will be returned.bOrderBySVID - if true, the iterator will be further ordered by the SVID column
value.longEndSCN - the end SCN to read edges fromefc - a EdgeFilterCallback object specifying the conditions to keep a
edge in the Iterator.flag - an OptimizationFlag object specifying if a partial or complete edge object will
be returned. It can be NULL which implies the edges created must be complete.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesBySCN(java.sql.Connection[] connArray)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the edge table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array]. By
default, the startPartitionID is set to 0.connArray - a Connection array used for concurrent querying
inside the Oracle property graph.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesBySCN(java.sql.Connection[] connArray,
boolean bOrderBySVID)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the edge table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array]. By
default, the startPartitionID is set to 0.connArray - a Connection array used for concurrent querying
inside the Oracle property graph.bOrderBySVID - if true, the iterator will be further ordered by the SVID column
value.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesBySCN(java.sql.Connection[] connArray,
boolean bOrderBySVID,
java.lang.Long longEndSCN)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the edge table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array]. By
default, the startPartitionID is set to 0.connArray - a Connection array used for concurrent querying
inside the Oracle property graph.bOrderBySVID - if true, the iterator will be further ordered by the SVID column
value.longEndSCN - the end SCN to read edges frompublic java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesBySCN(java.sql.Connection[] connArray,
boolean bOrderBySVID,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the edge table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array].connArray - a Connection array used for concurrent querying
inside the Oracle property graph.bOrderBySVID - if true, the iterator will be further ordered by the SVID column
value.longEndSCN - the end SCN to read edges fromiStartPartitionID - the ID of the starting partitionbSkipStoreToCache - if true, the edge instances retrieved by the
scan will not be saved into cachepublic java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesBySCN(java.sql.Connection[] connArray,
boolean bOrderBySVID,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID,
java.lang.String key)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the edge table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array].key - name of the property. It can be NULL which implies all edges in
the graph will be returned.connArray - a Connection array used for concurrent querying
inside the Oracle property graph.bOrderBySVID - if true, the iterator will be further ordered by the SVID column
value.longEndSCN - the end SCN to read edges fromiStartPartitionID - the ID of the starting partitionbSkipStoreToCache - if true, the edge instances retrieved by the
scan will not be saved into cachepublic java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesBySCN(java.sql.Connection[] connArray,
boolean bOrderBySVID,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID,
java.lang.String[] propertyNames)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the edge table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array].connArray - a Connection array used for concurrent querying
inside the Oracle property graph.bOrderBySVID - if true, the iterator will be further ordered by the SVID column
value.longEndSCN - the end SCN to read edges fromiStartPartitionID - the ID of the starting partitionbSkipStoreToCache - if true, the edge instances retrieved by the
scan will not be saved into cachepropertyNames - an array of property key names. It can be NULL which implies all edges in
the graph will be returned.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> edgesBySCN(java.lang.Long longEndSCN)
longEndSCN - the end SCN to read edges frompublic java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> edgesFromResultSet(java.sql.ResultSet rs,
EdgeFilterCallback efc,
OraclePropertyGraphBase.OptimizationFlag flag)
Iterator to all the edges from the ResultSet that
satisfy the specified edge filter callback. The information read back from
the edges will be complete or partial based on the optimization flag
specified.rs - the resultset where the edges will be read from.efc - a EdgeFilterCallback object specifying the conditions to keep a
edge in the Iterator.flag - an OptimizationFlag object specifying if a partial or complete edge object will
be returned. It can be NULLl which implies the edges created must be complete.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesNonPartitioned(java.sql.Connection[] connArray,
boolean bOrderBySVID,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
java.lang.String[] propertyNames)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the edge table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array]. By
default, the startPartitionID is set to 0.connArray - a Connection array used for concurrent querying
inside the Oracle property graph.bOrderBySVID - if true, the iterator will be further ordered by the SVID column
value.longEndSCN - the end SCN to read edges frombSkipStoreToCache - if true, the edge instances retrieved by the
scan will not be saved into cachepropertyNames - an array of property key names. It can be NULL which implies all edges in
the graph will be returned.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesNonPartitioned(java.sql.Connection[] connArray,
boolean bOrderBySVID,
java.lang.Long longEndSCN,
java.lang.String[] propertyNames)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the edge table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array]. By
default, the startPartitionID is set to 0.connArray - a Connection array used for concurrent querying
inside the Oracle property graph.bOrderBySVID - if true, the iterator will be further ordered by the SVID column
value.longEndSCN - the end SCN to read edges frompropertyNames - an array of property key names. It can be NULL which implies all edges in
the graph will be returned.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesPartitioned(java.sql.Connection[] connArray,
boolean skipStoreToCache,
int startPartitionID)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the edge table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array].connArray - a Connection array used for concurrent querying
inside the Oracle property graph.startPartitionID - the ID of the starting partitionskipStoreToCache - if true, the edge instances retrieved by the
scan will not be saved into cachepublic java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesPartitioned(java.sql.Connection[] connArray,
boolean bSkipStoreToCache,
int startPartitionID,
EdgeFilterCallback efc,
OraclePropertyGraphBase.OptimizationFlag flag)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the edge table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array].connArray - a Connection array used for concurrent querying
inside the Oracle property graph.startPartitionID - the ID of the starting partitionbSkipStoreToCache - if true, the edge instances retrieved by the
scan will not be saved into cacheflag - an OptimizationFlag object specifying if a partial or complete vertex object will
be returned. It can be NULL which implies the vertices created must be complete.efc - an EdgeFilterCallback object.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesPartitioned(java.sql.Connection[] connArray,
boolean skipStoreToCache,
int startPartitionID,
java.lang.String[] propertyNames)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the edge table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array].connArray - a Connection array used for concurrent querying
inside the Oracle property graph.startPartitionID - the ID of the starting partitionskipStoreToCache - if true, the edge instances retrieved by the
scan will not be saved into cachepropertyNames - an array of property key names. It can be NULL which implies all edges in
the graph will be returned.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesPartitioned(java.sql.Connection[] connArray,
boolean bOrderBySVID,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID,
java.lang.String[] propertyNames)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the edge table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array].connArray - a Connection array used for concurrent querying
inside the Oracle property graph.bOrderBySVID - if true, the iterator will be further ordered by the SVID column
value.longEndSCN - the end SCN to read edges fromiStartPartitionID - the ID of the starting partitionbSkipStoreToCache - if true, the edge instances retrieved by the
scan will not be saved into cachepropertyNames - an array of property key names. It can be NULL which implies all edges in
the graph will be returned.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesPartitioned(java.sql.Connection[] connArray,
boolean bOrderBySVID,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID,
java.lang.String[] propertyNames,
EdgeFilterCallback efc,
OraclePropertyGraphBase.OptimizationFlag flag)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the edge table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array]. By
default, the startPartitionID is set to 0.connArray - a Connection array used for concurrent querying
inside the Oracle property graph.bOrderBySVID - if true, the iterator will be further ordered by the SVID column
value.longEndSCN - the end SCN to read edges fromiStartPartitionID - the ID of the starting partitionbSkipStoreToCache - if true, the edge instances retrieved by the
scan will not be saved into cachepropertyNames - an array of property key names. It can be NULL which implies all edges in
the graph will be returned.flag - an OptimizationFlag object specifying if a partial or complete vertex object will
be returned. It can be NULL which implies the vertices created must be complete.efc - an EdgeFilterCallback object.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesPartitioned(java.sql.Connection[] connArray,
boolean bOrderBySVID,
java.lang.Long longEndSCN,
java.lang.String[] propertyNames)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the edge table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array]. By
default, the startPartitionID is set to 0.connArray - a Connection array used for concurrent querying
inside the Oracle property graph.bOrderBySVID - if true, the iterator will be further ordered by the SVID column
value.longEndSCN - the end SCN to read edges frompropertyNames - an array of property key names. It can be NULL which implies all edges in
the graph will be returned.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesPartitioned(java.sql.ResultSet[] rsArray,
boolean bSkipStoreToCache,
EdgeFilterCallback efc,
OraclePropertyGraphBase.OptimizationFlag flag)
rsArray - a ResultSet arraybSkipStoreToCache - if true, the edge instances retrieved by the scan will not be saved into cacheflag - an OptimizationFlag object specifying if a partial or complete vertex object will be returned. It can be
NULL which implies the vertices created must be complete.efc - an EdgeFilterCallback object.public void enableAtSCN(java.lang.Long longSCN)
throws java.sql.SQLException
enableAtSCN in interface OracleChangeTrackerlongSCN - SCN of the snapshotjava.sql.SQLExceptionpublic org.apache.tinkerpop.gremlin.structure.Graph.Features features()
features in interface org.apache.tinkerpop.gremlin.structure.Graphpublic void flushUpdates()
flushUpdates in class OraclePropertyGraphBasepublic java.util.LinkedList<java.lang.String> getConstraintNames(java.lang.String szTabName)
throws java.sql.SQLException
szTabName - the name of the tablejava.sql.SQLExceptionpublic java.lang.Long getCurrentSCN()
throws java.sql.SQLException
getCurrentSCN in interface OracleChangeTrackerjava.sql.SQLExceptionpublic java.lang.Long getCurrentSCNUnsafe()
throws java.sql.SQLException
java.sql.SQLExceptionpublic int getDatabaseMajorVersion()
public java.lang.Class getDatatypeClassFromValueObjForTextIndex(java.lang.Object value)
getDatatypeClassFromValueObjForTextIndex in interface OracleIndexableGraphgetDatatypeClassFromValueObjForTextIndex in class OraclePropertyGraphBasepublic int getDefaultDOPPerPtn()
public OracleIndexParameters getDefaultIndexParameters()
getDefaultIndexParameters in interface OracleIndexableGraphgetDefaultIndexParameters in class OraclePropertyGraphBaseOracleIndexParameters object.public java.lang.String getDistinctVertexTabIdxName(java.lang.String szCode)
szCode - the index code namepublic java.lang.String getDistinctVertexTabName()
public java.lang.String getDistinctVertexTabNameNoSchema()
public OracleEdge getEdge(java.lang.Object id)
getEdge in class OraclePropertyGraphBaseid - the object identifier of the referenced edgeOracleEdge objectpublic java.util.Iterator<EdgeChange> getEdgeChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN) throws java.sql.SQLException
getEdgeChanges in interface OracleChangeTrackerlongStartSCN - 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.java.sql.SQLExceptionpublic java.util.Iterator<EdgeChange> getEdgeChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP) throws java.sql.SQLException
getEdgeChanges in interface OracleChangeTrackerlongStartSCN - 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.java.sql.SQLExceptionpublic java.util.Iterator<EdgeChange> getEdgeChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP, boolean bFilterOutRemovedInserts) throws java.sql.SQLException
getEdgeChanges in interface OracleChangeTrackerlongStartSCN - 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.java.sql.SQLExceptionpublic java.util.Iterator<EdgeChange> getEdgeChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP, boolean bFilterOutRemovedInserts, java.lang.String[] propertyNames) throws java.sql.SQLException
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.java.sql.SQLExceptionpublic OracleEdgeBase getEdgeInstance(java.lang.Long eid, boolean bCreateIfAbsentFromCache, boolean bSkipStoreToCache)
getEdgeInstance in class OraclePropertyGraphBaseeid - the id of the edgebCreateIfAbsentFromCache - if false, returns a NULL value if there
is no match in the cache.bSkipStoreToCache - if true, the vertex instance will not be
stored into the cache.public OracleEdgeBase getEdgeInstance(OracleVertexBase outVertex, OracleVertexBase inVertex, java.lang.String edgeLabel, java.lang.Long eid, boolean bCreateIfAbsentFromCache, boolean bSkipStoreToCache)
getEdgeInstance in class OraclePropertyGraphBaseeid - the id of the edgeoutVertex - the outgoing Vertex of the edgeinVertex - the incoming Vertex of the edgeedgeLabel - the label for the Edge.bCreateIfAbsentFromCache - if false, returns a NULL value if there
is no match in the cache.bSkipStoreToCache - if true, the vertex instance will not be
stored into the cache.public int getEdgePartitionsNumber()
throws java.sql.SQLException
java.sql.SQLExceptionpublic int getEdgePropertyNames(int dop,
int timeout,
java.util.Map<java.lang.String,java.lang.Class> propertyNames,
ProgressListener pl)
getEdgePropertyNames in interface OracleMetadataGraphdop - a positive integer defining the number of threads to use when
parallel scanning the edgestimeout - time out in the unit of secondspropertyNames - a map of pl - a ProgressListener object.public int getEdgePropertyNames(int dop,
int timeout,
java.util.Set<java.lang.String> propertyNames,
ProgressListener pl)
getEdgePropertyNames in interface OracleMetadataGraphdop - a positive integer defining the number of threads to use when
parallel scanning the edgestimeout - time out in the unit of secondspropertyNames - a set of property names to be returnedpl - a ProgressListener object.public java.lang.String getEdgeTabIdxName(java.lang.String szCode)
szCode - the index code namepublic java.lang.String getEdgeTabName()
getEdgeTabName in class SQLAnalyticsGraphpublic java.lang.String getEdgeTabNameNoSchema()
public java.lang.String getGraphOwner()
public java.util.LinkedList<java.lang.String> getIndexNames(java.lang.String szTabName)
throws java.sql.SQLException
szTabName - the name of the tablejava.sql.SQLExceptionpublic static OraclePropertyGraph getInstance(Oracle oracle, java.lang.String szGraphName) throws java.sql.SQLException
oracle - an Oracle objectszGraphName - the name of the graphjava.sql.SQLExceptionpublic static OraclePropertyGraph getInstance(Oracle oracle, java.lang.String szGraphName, int iHashPartitionsNum) throws java.sql.SQLException
oracle - an Oracle objectszGraphName - the name of the graphiHashPartitionsNum - number of hash partitions to be used.java.sql.SQLExceptionpublic static OraclePropertyGraph getInstance(Oracle oracle, java.lang.String szGraphName, int iHashPartitionsNum, int iDOP, java.lang.String szTBS, java.lang.String szOptions) throws java.sql.SQLException
oracle - an Oracle objectszGraphName - the name of the graphiHashPartitionsNum - number of hash partitions to be used.iDOP - degree of parallelism to be used for creating the underlying tables and indices.szTBS - the tablespace name where the property graph tables will be
created.szOptions - options to be passed on to the underlying OPG_APIS.CREATE_PG API. It can be NULL.java.sql.SQLExceptionpublic static OraclePropertyGraph getInstance(Oracle oracle, java.lang.String szGraphName, int iHashPartitionsNum, int iDOP, java.lang.String szTBS, java.lang.String szTBSSet, java.lang.String szOptions) throws java.sql.SQLException
oracle - an Oracle objectszGraphName - the name of the graphiHashPartitionsNum - number of hash partitions to be used.iDOP - degree of parallelism to be used for creating the underlying tables and indices.szTBS - the tablespace name where the property graph tables will be
created.szTBSSet - the tablespace set name where the property graph tables will be
created when using a Sharding DBszOptions - options to be passed on to the underlying OPG_APIS.CREATE_PG API. It can be NULL.java.sql.SQLExceptionpublic static OraclePropertyGraph getInstance(Oracle oracle, java.lang.String owner, java.lang.String szGraphName) throws java.sql.SQLException
oracle - an Oracle objectszGraphName - the owner of the graph. If NULL, will assume connection owner is graph owner.szGraphName - the name of the graphjava.sql.SQLExceptionpublic static OraclePropertyGraph getInstance(Oracle oracle, java.lang.String szGraphOwner, java.lang.String szGraphName, int iHashPartitionsNum, int iDOP, java.lang.String szTBS, java.lang.String szOptions) throws java.sql.SQLException
oracle - an Oracle objectszGraphName - the name of the graphszGraphOwner - owner of the graph. This may be different from the
login schema.iHashPartitionsNum - number of hash partitions to be used.iDOP - degree of parallelism to be used for creating the underlying tables and indices.szTBS - the tablespace name where the property graph tables will be
created.szOptions - options to be passed on to the underlying OPG_APIS.CREATE_PG API. It can be NULL.java.sql.SQLExceptionpublic static OraclePropertyGraph getInstance(Oracle oracle, java.lang.String szGraphOwner, java.lang.String szGraphName, int iHashPartitionsNum, int iDOP, java.lang.String szTBS, java.lang.String szTBSSet, java.lang.String szOptions) throws java.sql.SQLException
oracle - an Oracle objectszGraphName - the name of the graphszGraphOwner - owner of the graph. This may be different from the
login schema.iHashPartitionsNum - number of hash partitions to be used.iDOP - degree of parallelism to be used for creating the underlying tables and indices.szTBS - the tablespace name where the property graph tables will be
created.szOptions - options to be passed on to the underlying OPG_APIS.CREATE_PG API. It can be NULL.java.sql.SQLExceptionpublic static OraclePropertyGraph getInstance(PgRdbmsGraphConfig config) throws java.sql.SQLException
config - the PGX graph config objectjava.sql.SQLExceptionpublic java.util.Set<java.lang.Long> getInvalidEdgeIDSet(int dop,
ProgressListener pl)
getInvalidEdgeIDSet in interface OracleMetadataGraphdop - a positive integer defining the number of threads to use when
parallel scanning the vertices and edges.pl - a ProgressListener object.public long getMaxEdgeID(int dop,
ProgressListener pl)
getMaxEdgeID in interface OracleMetadataGraphdop - a positive integer defining the number of threads to use when
parallel scanning the vertices.pl - a ProgressListener object.public long getMaxLabelLengthAllowedInBytes()
OraclePropertyGraphBasegetMaxLabelLengthAllowedInBytes in class OraclePropertyGraphBasepublic long getMaxPropertyNameLengthAllowedInBytes()
OraclePropertyGraphBasegetMaxPropertyNameLengthAllowedInBytes in class OraclePropertyGraphBasepublic long getMaxValueLengthAllowedInBytes()
OraclePropertyGraphBasegetMaxValueLengthAllowedInBytes in class OraclePropertyGraphBasepublic long getMaxVertexID(int dop,
ProgressListener pl)
getMaxVertexID in interface OracleMetadataGraphdop - a positive integer defining the number of threads to use when
parallel scanning the vertices.pl - a ProgressListener object.public long getMinEdgeID(int dop,
ProgressListener pl)
getMinEdgeID in interface OracleMetadataGraphdop - a positive integer defining the number of threads to use when
parallel scanning the vertices.pl - a ProgressListener object.public long getMinVertexID(int dop,
ProgressListener pl)
getMinVertexID in interface OracleMetadataGraphdop - a positive integer defining the number of threads to use when
parallel scanning the vertices.pl - a ProgressListener object.public java.lang.String getNumberToCharSqlFormatString()
public java.lang.String getOpgVersion()
public Oracle getOracle()
getOracle in class SQLAnalyticsGraphpublic static Oracle getOracle(PgRdbmsGraphConfig config) throws java.sql.SQLException
config - the PGX graph config objectjava.sql.SQLExceptionpublic static Oracle getOracle(java.lang.String datasourceId) throws java.sql.SQLException
java.sql.SQLExceptionpublic OracleIndexManager getOracleIndexManager()
getOracleIndexManager in interface OracleIndexableGraphgetOracleIndexManager in class OraclePropertyGraphBaseOracleIndexManager object.public boolean getPGViewOnRDFFlag()
public int getQueryFetchSize()
public java.util.Iterator<java.lang.Long> getRemovedEdges(java.lang.Long longStartSCN,
java.lang.Long longEndSCN,
int iQueryDOP,
java.lang.String szOptions)
throws java.sql.SQLException
getRemovedEdges in interface OracleChangeTrackerlongStartSCN - start SCNlongEndSCN - end SCNiQueryDOP - degree of parallelism to be used for the underlying queryszOptions - hints for the underlying query.java.sql.SQLExceptionpublic java.util.Iterator<java.lang.Long> getRemovedVertices(java.lang.Long longStartSCN,
java.lang.Long longEndSCN,
int iQueryDOP,
java.lang.String szOptions)
throws java.sql.SQLException
getRemovedVertices in interface OracleChangeTrackerlongStartSCN - start SCNlongEndSCN - end SCNiQueryDOP - degree of parallelism to be used for the underlying queryszOptions - hints for the underlying query.java.sql.SQLExceptionpublic int getRowPrefetch()
public java.lang.String getSessionID()
throws java.sql.SQLException
java.sql.SQLExceptionpublic int getSessionQueryDOP()
public java.lang.String getSkeletonTabIdxName(java.lang.String szCode)
szCode - the index code namepublic java.lang.String getSkeletonTabName()
public java.lang.String getSkeletonTabNameNoSchema()
public boolean getSkipFormNCharSettingForTextQuery()
public java.lang.String getSnapshotTabName()
public java.util.List<java.lang.String> getTableNames()
public java.lang.String getTablespace()
public java.lang.String getTablespaceSet()
public java.lang.String getTextIndexDirectoryPrefix()
getTextIndexDirectoryPrefix in class OraclePropertyGraphBasepublic java.lang.String getTextIndexTabName()
public java.lang.String getTimeToCharSqlFormatString()
public boolean getTreatTimestampTzAsStr()
public OracleVertex getVertex(java.lang.Object id)
getVertex in class OraclePropertyGraphBaseid - the object identifier of the referenced vertexVertex objectpublic java.util.Iterator<VertexChange> getVertexChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN) throws java.sql.SQLException
getVertexChanges in interface OracleChangeTrackerlongStartSCN - 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.java.sql.SQLExceptionpublic java.util.Iterator<VertexChange> getVertexChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP) throws java.sql.SQLException
getVertexChanges in interface OracleChangeTrackerlongStartSCN - 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.java.sql.SQLExceptionpublic java.util.Iterator<VertexChange> getVertexChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP, boolean bFilterOutRemovedInserts) throws java.sql.SQLException
getVertexChanges in interface OracleChangeTrackerlongStartSCN - 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.java.sql.SQLExceptionpublic java.util.Iterator<VertexChange> getVertexChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP, boolean bFilterOutRemovedInserts, java.lang.String[] propertyNames) throws java.sql.SQLException
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.propertyNames - an array of property key names. It can be NULL which implies all vertices
changes will be returned.java.sql.SQLExceptionpublic java.util.Set<java.lang.Long> getVertexIDSet(int dop,
ProgressListener pl)
getVertexIDSet in interface OracleMetadataGraphdop - a positive integer defining the number of threads to use when
parallel scanning the vertices.pl - a ProgressListener object.public OracleVertexBase getVertexInstance(java.lang.Long vid, boolean bCreateIfAbsentFromCache, boolean bSkipStoreToCache)
getVertexInstance in class OraclePropertyGraphBasevid - the id of the vertexbCreateIfAbsentFromCache - if false, returns a NULL value if there
is no match in the cache.bSkipStoreToCache - if true, the vertex instance will not be
stored into the cache.public int getVertexPartitionsNumber()
throws java.sql.SQLException
java.sql.SQLExceptionpublic int getVertexPropertyNames(int dop,
int timeout,
java.util.Map<java.lang.String,java.lang.Class> propertyNames,
ProgressListener pl)
getVertexPropertyNames in interface OracleMetadataGraphdop - a positive integer defining the number of threads to use when
parallel scanning the verticestimeout - time out in the unit of secondspropertyNames - a map of pl - a ProgressListener object.public int getVertexPropertyNames(int dop,
int timeout,
java.util.Set<java.lang.String> propertyNames,
ProgressListener pl)
getVertexPropertyNames in interface OracleMetadataGraphdop - a positive integer defining the number of threads to use when
parallel scanning the verticestimeout - time out in the unit of secondspropertyNames - a set of property names to be returnedpl - a ProgressListener object.public java.lang.String getVertexTabIdxName(java.lang.String szCode)
szCode - the index code namepublic java.lang.String getVertexTabName()
public java.lang.String getVertexTabNameNoSchema()
public java.lang.String getVerticesProjectedVars()
public java.sql.Date getVTE()
public java.sql.Date getVTS()
public void grantAccess(java.lang.String user,
java.lang.String privilege)
throws java.sql.SQLException
user - name of the userprivilege - a string representing privileges. "R" for read, "S" for select, "I" for insert,
"D" for delete, and "U" for update. "RIDUS" can be used to grant read, insert, delete, update,
and select in one shot.java.sql.SQLExceptionpublic boolean isDB11g()
public boolean isFeatureSupported(SQLUtils.DbFeature dbFeature)
dbFeature - the DB feature to checkpublic boolean isShardingDb()
public boolean isVirtualPropertyGraph()
public java.sql.ResultSet[] parallelExecuteStatements(java.sql.PreparedStatement[] stmtArray)
stmtArray - the array of prepared statements to execute in parallel-public java.lang.String parseValueToCharSQLFormatString(java.lang.Object value)
value - the value to parsepublic static java.lang.Object readObjFromResultSet(java.sql.ResultSet rs,
int iIdxTypeCol)
throws java.sql.SQLException,
java.io.IOException
rs - a JDBC result setiIdxTypeCol - column index (integer) of the data type column (T)java.sql.SQLExceptionjava.io.IOExceptionpublic static java.lang.Object readObjFromResultSet(java.sql.ResultSet rs,
int iIdxTypeCol,
boolean bTreatTimestampTzAsStr)
throws java.sql.SQLException,
java.io.IOException
rs - a JDBC result setiIdxTypeCol - column index (integer) of the data type column (T)bTreatTimestampTzAsStr - if true, reads out TYPE_DT_DATE values as a string.java.sql.SQLExceptionjava.io.IOExceptionpublic void rebuildDistinctEdgeTable(java.util.List<java.lang.String> llIndices,
int dop,
java.lang.String szOptions)
throws java.sql.SQLException
java.sql.SQLExceptionpublic void rebuildDistinctVertexTable(java.util.List<java.lang.String> llIndices,
int dop,
java.lang.String szOptions)
throws java.sql.SQLException
java.sql.SQLExceptionpublic void rebuildEdgeTableConstraints(java.util.List<java.lang.String> llConstraints,
int dop,
java.lang.String szOptions)
throws java.sql.SQLException
llConstraints - a list of constraint namesdop - degree of parallelismszOptions - additional SQL options to add as hints during the rebuild.java.sql.SQLExceptionpublic void rebuildEdgeTableIndices(java.util.List<java.lang.String> llIndices,
int dop,
boolean rebuildGEIndices,
java.lang.String szOptions)
throws java.sql.SQLException
llIndices - a list of index names to rebuilddop - degree of parallelism used when rebuilding the indicesrebuildGEIndices - True if should rebuild indices for GE$ table,
false for GT$ table.szOptions - additonal SQL options used when rebuilding the indices.java.sql.SQLExceptionpublic void rebuildVertexTableConstraints(java.util.List<java.lang.String> llConstraints,
int dop,
java.lang.String szOptions)
throws java.sql.SQLException
llConstraints - a list of constraint namesdop - degree of parallelismszOptions - additional SQL options to add as hints during the rebuild.java.sql.SQLExceptionpublic void rebuildVertexTableIndices(java.util.List<java.lang.String> llIndices,
int dop,
boolean rebuildVTIndices,
java.lang.String szOptions)
throws java.sql.SQLException
llIndices - a list of index names to rebuilddop - degree of parallelism used when rebuilding the indicesrebuildVTIndices - True if should rebuild indices for VT$ table,
false for VD$ table.szOptions - additonal SQL options used when rebuilding the indices.java.sql.SQLExceptionpublic void refreshIndices(long lStartSCN,
long lEndSCN)
public void removeEdge(org.apache.tinkerpop.gremlin.structure.Edge edge)
removeEdge in class OraclePropertyGraphBaseedge - an Edge object to be removedpublic void removeVertex(org.apache.tinkerpop.gremlin.structure.Vertex vertex)
removeVertex in class OraclePropertyGraphBasevertex - a Vertex object to be removedpublic void revokeAccess(java.lang.String user,
java.lang.String privilege)
throws java.sql.SQLException
user - name of the userprivilege - a string representing privileges. "R" for read, "S" for select, "I" for insert,
"D" for delete, and "U" for update. "RIDUS" can be used to revoke read, insert, delete, update,
and select in one shot.java.sql.SQLExceptionpublic void rollback()
rollback in class OraclePropertyGraphBasepublic void setDefaultDOPPerPtn(int i)
i - default DOP used for partition-wise scan. It MUST NOT be negative.public void setLabel(java.lang.String policy,
java.lang.String label)
throws java.sql.SQLException
policy - name of the OLS policylabel - security label namejava.sql.SQLExceptionpublic void setNumberToCharSqlFormatString(java.lang.String format)
format - the format used for numeric objectspublic void setPGViewOnRDFFlag(boolean flag)
flag - use true if this property graph instance comes from a Property Graph
view over RDF datapublic void setQueryFetchSize(int size)
size - the query fetch sizepublic void setRowLabel(java.lang.String policy,
java.lang.String label)
throws java.sql.SQLException
policy - name of the OLS policylabel - security label namejava.sql.SQLExceptionpublic void setRowPrefetch(int i)
i - the prefetch sizepublic void setSessionQueryDOP(int dop)
throws java.sql.SQLException
dop - degree of parallelism. The value can be zero. If the value is negative,
then it is no op.java.sql.SQLExceptionpublic void setSkipFormNCharSettingForTextQuery(java.lang.String s)
s - can be "TRUE", "FALSE", or NULL.public void setTimeToCharSqlFormatString(java.lang.String format)
format - the format used for datetime objectspublic void setVTE(java.sql.Date dateVTE)
public void setVTS(java.sql.Date dateVTS)
public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> sortedEdges(boolean bOrderBySVID)
bOrderBySVID - if true, the iterator will be further ordered by the SVID column
value.public boolean supportVertexLabels()
OraclePropertyGraphBasesupportVertexLabels in class OraclePropertyGraphBasepublic void treatTimestampTzAsStr(boolean b)
b - treats timestamp with timezone as string if true.public <T extends org.apache.tinkerpop.gremlin.structure.Element> void updateGraph(OpCallback<T> oc, boolean skipStoreToCache, int dop, ProgressListener pl, OpCallback.UpdateType updateType)
EdgeOpCallback.
NOTE the current transaction will be committed.updateGraph in interface OracleGraphAttributeUpdateroc - a OpCallback object.skipStoreToCache - if true, the edges instances will not be
stored into the cache.dop - a positive integer defining the number of threads to use when
parallel processing the edges.pl - a ProgressListener object.public <T extends org.apache.tinkerpop.gremlin.structure.Element> void validateDistinctTableForDbVersion(java.lang.String operationType,
java.lang.Class<T> elementClass)
throws oracle.pg.common.exceptions.FeatureNotSupportedException
oracle.pg.common.exceptions.FeatureNotSupportedExceptionpublic java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex> vertices()
vertices in class OraclePropertyGraphBasepublic java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex> verticesByProperty(java.lang.String key,
java.lang.Object value,
java.lang.Class dtClass,
boolean acceptWildcard,
boolean useLuceneSyntax)
verticesByProperty in class OraclePropertyGraphBasekey - the name of the property. It MUST not be NULL.value - the value of the property. It can be NULL which will cause all vertices with the given key to be returned.dtClass - the class representing the datatype of the property value. This can be
used to cast the property value to a different datatype. For example, if the value is "3.01"
and dtClass is Float.Class, then this value will be treated as a 3.01f. If dtClass is
set to NULL, then the query will be executed by trying to match the value object to
all the supported datatypes.acceptWildcard - specifies if wild cards can be used in the value object. Wild cards can be used only when
an automatic text index on the given key is present.useLuceneSyntax - specifies if the value object is using an Apache Lucene Syntax (further
details on Apache Lucene Syntax can be found in https://lucene.apache.org/core/2_9_4/queryparsersyntax.html). If the
automatic index is not enabled ahd this flag is set to true, an Exception will be thrown
as Lucene Syntax is not supported for database lookups.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex> verticesByPropertyKey(java.lang.String[] propertyNames,
VertexFilterCallback vfc,
OraclePropertyGraphBase.OptimizationFlag flag)
Iterator to all the vertices in the graph that have any of the specified keys and
satisfy the specified vertex filter callback. The information read back from
the vertices will be complete or partial based on the optimization flag
specified.verticesByPropertyKey in class OraclePropertyGraphBasepropertyNames - an array of property key names. It can be NULL which implies all vertices in
the graph satisfying the vertex filter callback will be returned.vfc - a VertexFilterCallback object specifying the conditions to keep a
vertex in the Iterator.flag - an OptimizationFlag object specifying if a partial or complete vertex object will
be returned. It can be NULL which implies the vertices created must be complete.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesBySCN(java.sql.Connection[] connArray)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the vertex table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array]. By
default, the startPartitionID is set to 0.connArray - a Connection array used for concurrent querying
inside the Oracle property graph.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesBySCN(java.sql.Connection[] connArray,
java.lang.Long longEndSCN)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the vertex table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array]. By
default, the startPartitionID is set to 0.connArray - a Connection array used for concurrent querying
inside the Oracle property graph.longEndSCN - the end SCN to read vertices frompublic java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesBySCN(java.sql.Connection[] connArray,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the vertex table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array]. By
default, the startPartitionID is set to 0.connArray - a Connection array used for concurrent querying
inside the Oracle property graph.longEndSCN - the end SCN to read vertices fromiStartPartitionID - the ID of the starting partitionbSkipStoreToCache - if true, the vertex instances retrieved by the
scan will not be saved into cachepublic java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesBySCN(java.sql.Connection[] connArray,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID,
java.lang.String key)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the vertex table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array].connArray - a Connection array used for concurrent querying
inside the Oracle property graph.bSkipStoreToCache - if true, the vertex instances retrieved by the
scan will not be saved into cachelongEndSCN - the end SCN to read vertices fromiStartPartitionID - the ID of the starting partitionkey - name of the property. It can be NULL which implies all edges in
the graph will be returned.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesBySCN(java.sql.Connection[] connArray,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID,
java.lang.String[] propertyNames)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the vertex table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array].connArray - a Connection array used for concurrent querying
inside the Oracle property graph.longEndSCN - the end SCN to read vertices fromiStartPartitionID - the ID of the starting partitionbSkipStoreToCache - if true, the vertex instances retrieved by the
scan will not be saved into cachepropertyNames - an array of property key names. It can be NULL which implies all vertices in
the graph will be returned.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex> verticesBySCN(java.lang.Long longEndSCN,
java.lang.String[] propertyNames,
VertexFilterCallback vfc,
OraclePropertyGraphBase.OptimizationFlag flag)
Iterator to all the vertices in the graph that have any of the specified keys and
satisfy the specified vertex filter callback. The information read back from
the vertices will be complete or partial based on the optimization flag
specified.propertyNames - an array of property key names. It can be NULL which implies all vertices in
the graph satisfying the vertex filter callback will be returned.vfc - a VertexFilterCallback object specifying the conditions to keep a
vertex in the Iterator.longEndSCN - the end SCN to read vertices fromflag - an OptimizationFlag object specifying if a partial or complete vertex object will
be returned. It can be NULL which implies the vertices created must be complete.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex> verticesFromResultSet(java.sql.ResultSet rs,
VertexFilterCallback vfc,
OraclePropertyGraphBase.OptimizationFlag flag)
rs - an result set for matching verticesvfc - an optional VertexFilterCallback objectflag - an optional OptimizationFlag object to reduce object sizepublic java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesNonPartitioned(java.sql.Connection[] connArray,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
java.lang.String[] propertyNames)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the vertex table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array]. By
default, the startPartitionID is set to 0.connArray - a Connection array used for concurrent querying
inside the Oracle property graph.longEndSCN - the end SCN to read vertices frombSkipStoreToCache - if true, the vertex instances retrieved by the
scan will not be saved into cachepropertyNames - an array of property key names. It can be NULL which implies all vertices in
the graph will be returned.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesNonPartitioned(java.sql.Connection[] connArray,
java.lang.Long longEndSCN,
java.lang.String[] propertyNames)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the vertex table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array]. By
default, the startPartitionID is set to 0.connArray - a Connection array used for concurrent querying
inside the Oracle property graph.propertyNames - an array of property key names. It can be NULL which implies all vertices in
the graph will be returned.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesPartitioned(java.sql.Connection[] connArray,
boolean skipStoreToCache,
int startPartitionID)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the vertex table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array].connArray - a Connection array used for concurrent querying
inside the Oracle property graph.startPartitionID - the ID of the starting partitionskipStoreToCache - if true, the vertex instances retrieved by the
scan will not be saved into cachepublic java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesPartitioned(java.sql.Connection[] connArray,
boolean skipStoreToCache,
int startPartitionID,
java.lang.String[] propertyNames)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the vertex table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array].connArray - a Connection array used for concurrent querying
inside the Oracle property graph.startPartitionID - the ID of the starting partitionskipStoreToCache - if true, the vertex instances retrieved by the
scan will not be saved into cachepropertyNames - an array of property key names. It can be NULL which implies all vertices in
the graph will be returned.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesPartitioned(java.sql.Connection[] connections,
boolean bSkipStoreToCache,
int startPartitionID,
VertexFilterCallback vfc,
OraclePropertyGraphBase.OptimizationFlag flag)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the vertex table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array].connections - a Connection array used for concurrent querying
inside the Oracle property graph.startPartitionID - the ID of the starting partitionbSkipStoreToCache - if true, the vertex instances retrieved by the
scan will not be saved into cacheflag - an OptimizationFlag object specifying if a partial or complete vertex object will
be returned. It can be NULL which implies the vertices created must be complete.vfc - an VertexFilterCallback object.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesPartitioned(java.sql.Connection[] connArray,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID,
java.lang.String[] propertyNames)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the vertex table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array].connArray - a Connection array used for concurrent querying
inside the Oracle property graph.longEndSCN - the end SCN to read vertices fromiStartPartitionID - the ID of the starting partitionbSkipStoreToCache - if true, the vertex instances retrieved by the
scan will not be saved into cachepropertyNames - an array of property key names. It can be NULL which implies all vertices in
the graph will be returned.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesPartitioned(java.sql.Connection[] connArray,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID,
java.lang.String[] propertyNames,
VertexFilterCallback vfc)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the vertex table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array].connArray - a Connection array used for concurrent querying
inside the Oracle property graph.longEndSCN - the end SCN to read vertices fromiStartPartitionID - the ID of the starting partitionbSkipStoreToCache - if true, the vertex instances retrieved by the
scan will not be saved into cachepropertyNames - an array of property key names. It can be NULL which implies all vertices in
the graph will be returned.vfc - an VertexFilterCallback object.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesPartitioned(java.sql.Connection[] connArray,
java.lang.Long longEndSCN,
boolean bSkipStoreToCache,
int iStartPartitionID,
java.lang.String[] propertyNames,
VertexFilterCallback vfc,
OraclePropertyGraphBase.OptimizationFlag flag)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the vertex table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array].connArray - a Connection array used for concurrent querying
inside the Oracle property graph.longEndSCN - the end SCN to read vertices fromiStartPartitionID - the ID of the starting partitionbSkipStoreToCache - if true, the vertex instances retrieved by the
scan will not be saved into cachepropertyNames - an array of property key names. It can be NULL which implies all vertices in
the graph will be returned.flag - an OptimizationFlag object specifying if a partial or complete vertex object will
be returned. It can be NULL which implies the vertices created must be complete.vfc - an VertexFilterCallback object.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesPartitioned(java.sql.Connection[] connArray,
java.lang.Long longEndSCN,
java.lang.String[] propertyNames)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the vertex table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array]. By
default, the startPartitionID is set to 0.connArray - a Connection array used for concurrent querying
inside the Oracle property graph.longEndSCN - the end SCN to read vertices frompropertyNames - an array of property key names. It can be NULL which implies all vertices in
the graph will be returned.public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesPartitioned(java.sql.ResultSet[] rsArray,
boolean bSkipStoreToCache,
VertexFilterCallback vfc,
OraclePropertyGraphBase.OptimizationFlag flag)
Iterator array uses a separate connection
provided to fetch a subset of the results from the corresponding partition.
Note that we assign an integer ID (in the range of [0, N - 1]) to all the
partitions in the vertex table with N partitions. The subset of partitions queried will
consist of those partitions with ID value in the range of
[startPartitionID, startPartitionID - 1 + size of connections array]. By
default, the startPartitionID is set to 0.rsArray - a ResultSet arraybSkipStoreToCache - if true, the vertex instances retrieved by the
scan will not be saved into cacheflag - an OptimizationFlag object specifying if a partial or complete vertex object will
be returned. It can be NULL which implies the vertices created must be complete.vfc - an VertexFilterCallback object.Copyright © 2015 - 2020 Oracle and/or its affiliates. All Rights Reserved.