public class OraclePropertyGraph extends SQLAnalyticsGraph implements OraclePropertyGraphAnalytics, OracleChangeTracker, OraclePropertyGraphConfigurationConstants
SQLAnalyticsGraph.Sort
OraclePropertyGraphBase.CacheStatus, OraclePropertyGraphBase.OptimizationFlag
org.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.Variables
OraclePropertyGraphConstants.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_USERNAME
MG_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_EXIST
ERR_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_VAL
VERTEX_LABEL
CSV_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_FORMAT
TYPE_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, sparsifyGraphPrep
addUpdatedEdge, 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, verticesByPropertyKey
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
collaborativeFiltering, collaborativeFilteringCleanup, collaborativeFilteringPrep, countTriangle, countTriangle, countTriangleCleanup, countTrianglePrep, countTriangleRenum, estimateTriangleRenum, findCluster, findClusterCleanup, findClusterPrep, pageRank, pageRankCleanup, pageRankPrep, shortestPath, shortestPath, shortestPath, shortestPath, shortestPath, shortestPathCleanup, shortestPathPrep
createKeyIndex, createKeyIndex, createKeyIndex, dropAllAutoIndices, dropAllIndices, dropAllManualIndices, dropIndex, dropKeyIndex, dropKeyIndex, dropKeyIndex, edgesUsingTextSearch, getAutoIndex, getIndex, getIndexedKeys, getIndexParameters, getIndices, isEdgeAutoIndexEnabled, isVertexAutoIndexEnabled, refreshAutoIndices, validateIndexManager, verticesUsingTextSearch
countEdges, countEdges, countVertices, countVertices, getEdgePropertyNames, getEdgePropertyNames, getElementsProperties, getInvalidEdgeIDSet, getInvalidEdgeIDSet, getMaxEdgeID, getMaxEdgeID, getMaxVertexID, getMaxVertexID, getMinEdgeID, getMinEdgeID, getMinVertexID, getMinVertexID, getVertexIDSet, getVertexIDSet, getVertexPropertyNames, getVertexPropertyNames
addAttributeToAllEdges, addAttributeToAllEdges, addAttributeToAllEdges, addAttributeToAllVertices, addAttributeToAllVertices, addAttributeToAllVertices, getDOPForMetadataOperations, removeAttributeFromAllEdges, removeAttributeFromAllEdges, removeAttributeFromAllEdges, removeAttributeFromAllVertices, removeAttributeFromAllVertices, removeAttributeFromAllVertices
public 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 OraclePropertyGraphBase
id
- 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 OraclePropertyGraphBase
id
- the id of the vertexOracleVertex
object.public void clearRepository() throws java.sql.SQLException
clearRepository
in class OraclePropertyGraphBase
java.sql.SQLException
public void close()
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in interface org.apache.tinkerpop.gremlin.structure.Graph
public void commit()
commit
in class OraclePropertyGraphBase
public void commit(boolean bCommitIndices)
public long countEdges(int dop, ProgressListener pll)
countEdges
in interface OracleMetadataGraph
dop
- 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 OracleMetadataGraph
dop
- 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.SQLException
public 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.SQLException
public void createDefaultSpatialIndexOnVertices(int dop) throws java.sql.SQLException
dop
- degree of parallelism used to create the Spatial indexjava.sql.SQLException
public 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.SQLException
public void disable() throws java.sql.SQLException
disable
in interface OracleChangeTracker
java.sql.SQLException
public java.util.List<java.lang.String> disableDistinctEdgeTable() throws java.sql.SQLException
java.sql.SQLException
public java.util.List<java.lang.String> disableDistinctVertexTable() throws java.sql.SQLException
java.sql.SQLException
public java.util.List<java.lang.String> disableEdgeTableConstraints() throws java.sql.SQLException
java.sql.SQLException
public 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.SQLException
public java.util.List<java.lang.String> disableVertexTableConstraints() throws java.sql.SQLException
java.sql.SQLException
public 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.SQLException
public void dispose()
public boolean doesEdgeExistAt(java.lang.String szEdgeID, java.lang.Long longEndSCN) throws java.sql.SQLException
doesEdgeExistAt
in interface OracleChangeTracker
szEdgeID
- ID of the edgelongEndSCN
- scnjava.sql.SQLException
public boolean doesEdgeExistAt(java.lang.String szEdgeID, java.lang.Long longEndSCN, int iQueryDOP) throws java.sql.SQLException
doesEdgeExistAt
in interface OracleChangeTracker
szEdgeID
- ID of the edgelongEndSCN
- scniQueryDOP
- the degree of parallelism to be used to
do the checkjava.sql.SQLException
public boolean doesVertexExistAt(java.lang.String szVertexID, java.lang.Long longEndSCN) throws java.sql.SQLException
doesVertexExistAt
in interface OracleChangeTracker
szVertexID
- ID of the vertexlongEndSCN
- scnjava.sql.SQLException
public boolean doesVertexExistAt(java.lang.String szVertexID, java.lang.Long longEndSCN, int iQueryDOP) throws java.sql.SQLException
doesVertexExistAt
in interface OracleChangeTracker
szVertexID
- ID of the vertexlongEndSCN
- scniQueryDOP
- the degree of parallelism to be used to
do the checkjava.sql.SQLException
public void dropDefaultSpatialIndexOnEdges() throws java.sql.SQLException
java.sql.SQLException
public void dropDefaultSpatialIndexOnVertices() throws java.sql.SQLException
java.sql.SQLException
public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> edges()
edges
in class OraclePropertyGraphBase
public 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 OraclePropertyGraphBase
key
- 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 OraclePropertyGraphBase
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.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 OracleChangeTracker
longSCN
- SCN of the snapshotjava.sql.SQLException
public org.apache.tinkerpop.gremlin.structure.Graph.Features features()
features
in interface org.apache.tinkerpop.gremlin.structure.Graph
public void flushUpdates()
flushUpdates
in class OraclePropertyGraphBase
public java.util.LinkedList<java.lang.String> getConstraintNames(java.lang.String szTabName) throws java.sql.SQLException
szTabName
- the name of the tablejava.sql.SQLException
public java.lang.Long getCurrentSCN() throws java.sql.SQLException
getCurrentSCN
in interface OracleChangeTracker
java.sql.SQLException
public java.lang.Long getCurrentSCNUnsafe() throws java.sql.SQLException
java.sql.SQLException
public int getDatabaseMajorVersion()
public java.lang.Class getDatatypeClassFromValueObjForTextIndex(java.lang.Object value)
getDatatypeClassFromValueObjForTextIndex
in interface OracleIndexableGraph
getDatatypeClassFromValueObjForTextIndex
in class OraclePropertyGraphBase
public int getDefaultDOPPerPtn()
public OracleIndexParameters getDefaultIndexParameters()
getDefaultIndexParameters
in interface OracleIndexableGraph
getDefaultIndexParameters
in class OraclePropertyGraphBase
OracleIndexParameters
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 OraclePropertyGraphBase
id
- 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 OracleChangeTracker
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.java.sql.SQLException
public java.util.Iterator<EdgeChange> getEdgeChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP) throws java.sql.SQLException
getEdgeChanges
in interface OracleChangeTracker
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.java.sql.SQLException
public java.util.Iterator<EdgeChange> getEdgeChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP, boolean bFilterOutRemovedInserts) throws java.sql.SQLException
getEdgeChanges
in interface OracleChangeTracker
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.SQLException
public 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.SQLException
public OracleEdgeBase getEdgeInstance(java.lang.Long eid, boolean bCreateIfAbsentFromCache, boolean bSkipStoreToCache)
getEdgeInstance
in class OraclePropertyGraphBase
eid
- 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 OraclePropertyGraphBase
eid
- 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.SQLException
public int getEdgePropertyNames(int dop, int timeout, java.util.Map<java.lang.String,java.lang.Class> propertyNames, ProgressListener pl)
getEdgePropertyNames
in interface OracleMetadataGraph
dop
- 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 OracleMetadataGraph
dop
- 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 SQLAnalyticsGraph
public 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.SQLException
public static OraclePropertyGraph getInstance(Oracle oracle, java.lang.String szGraphName) throws java.sql.SQLException
oracle
- an Oracle
objectszGraphName
- the name of the graphjava.sql.SQLException
public 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.SQLException
public 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.SQLException
public 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.SQLException
public 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.SQLException
public 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.SQLException
public 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.SQLException
public static OraclePropertyGraph getInstance(PgRdbmsGraphConfig config) throws java.sql.SQLException
config
- the PGX graph config objectjava.sql.SQLException
public java.util.Set<java.lang.Long> getInvalidEdgeIDSet(int dop, ProgressListener pl)
getInvalidEdgeIDSet
in interface OracleMetadataGraph
dop
- 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 OracleMetadataGraph
dop
- a positive integer defining the number of threads to use when
parallel scanning the vertices.pl
- a ProgressListener object.public long getMaxLabelLengthAllowedInBytes()
OraclePropertyGraphBase
getMaxLabelLengthAllowedInBytes
in class OraclePropertyGraphBase
public long getMaxPropertyNameLengthAllowedInBytes()
OraclePropertyGraphBase
getMaxPropertyNameLengthAllowedInBytes
in class OraclePropertyGraphBase
public long getMaxValueLengthAllowedInBytes()
OraclePropertyGraphBase
getMaxValueLengthAllowedInBytes
in class OraclePropertyGraphBase
public long getMaxVertexID(int dop, ProgressListener pl)
getMaxVertexID
in interface OracleMetadataGraph
dop
- 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 OracleMetadataGraph
dop
- 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 OracleMetadataGraph
dop
- 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 SQLAnalyticsGraph
public static Oracle getOracle(PgRdbmsGraphConfig config) throws java.sql.SQLException
config
- the PGX graph config objectjava.sql.SQLException
public static Oracle getOracle(java.lang.String datasourceId) throws java.sql.SQLException
java.sql.SQLException
public OracleIndexManager getOracleIndexManager()
getOracleIndexManager
in interface OracleIndexableGraph
getOracleIndexManager
in class OraclePropertyGraphBase
OracleIndexManager
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 OracleChangeTracker
longStartSCN
- start SCNlongEndSCN
- end SCNiQueryDOP
- degree of parallelism to be used for the underlying queryszOptions
- hints for the underlying query.java.sql.SQLException
public 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 OracleChangeTracker
longStartSCN
- start SCNlongEndSCN
- end SCNiQueryDOP
- degree of parallelism to be used for the underlying queryszOptions
- hints for the underlying query.java.sql.SQLException
public int getRowPrefetch()
public java.lang.String getSessionID() throws java.sql.SQLException
java.sql.SQLException
public 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 OraclePropertyGraphBase
public java.lang.String getTextIndexTabName()
public java.lang.String getTimeToCharSqlFormatString()
public boolean getTreatTimestampTzAsStr()
public OracleVertex getVertex(java.lang.Object id)
getVertex
in class OraclePropertyGraphBase
id
- 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 OracleChangeTracker
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.java.sql.SQLException
public java.util.Iterator<VertexChange> getVertexChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP) throws java.sql.SQLException
getVertexChanges
in interface OracleChangeTracker
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.java.sql.SQLException
public java.util.Iterator<VertexChange> getVertexChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP, boolean bFilterOutRemovedInserts) throws java.sql.SQLException
getVertexChanges
in interface OracleChangeTracker
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.SQLException
public 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.SQLException
public java.util.Set<java.lang.Long> getVertexIDSet(int dop, ProgressListener pl)
getVertexIDSet
in interface OracleMetadataGraph
dop
- 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 OraclePropertyGraphBase
vid
- 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.SQLException
public int getVertexPropertyNames(int dop, int timeout, java.util.Map<java.lang.String,java.lang.Class> propertyNames, ProgressListener pl)
getVertexPropertyNames
in interface OracleMetadataGraph
dop
- 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 OracleMetadataGraph
dop
- 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.SQLException
public 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.SQLException
java.io.IOException
public 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.SQLException
java.io.IOException
public void rebuildDistinctEdgeTable(java.util.List<java.lang.String> llIndices, int dop, java.lang.String szOptions) throws java.sql.SQLException
java.sql.SQLException
public void rebuildDistinctVertexTable(java.util.List<java.lang.String> llIndices, int dop, java.lang.String szOptions) throws java.sql.SQLException
java.sql.SQLException
public 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.SQLException
public 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.SQLException
public 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.SQLException
public 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.SQLException
public void refreshIndices(long lStartSCN, long lEndSCN)
public void removeEdge(org.apache.tinkerpop.gremlin.structure.Edge edge)
removeEdge
in class OraclePropertyGraphBase
edge
- an Edge
object to be removedpublic void removeVertex(org.apache.tinkerpop.gremlin.structure.Vertex vertex)
removeVertex
in class OraclePropertyGraphBase
vertex
- 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.SQLException
public void rollback()
rollback
in class OraclePropertyGraphBase
public 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.SQLException
public 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.SQLException
public 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.SQLException
public 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()
OraclePropertyGraphBase
supportVertexLabels
in class OraclePropertyGraphBase
public 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 OracleGraphAttributeUpdater
oc
- 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.FeatureNotSupportedException
public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex> vertices()
vertices
in class OraclePropertyGraphBase
public 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 OraclePropertyGraphBase
key
- 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 OraclePropertyGraphBase
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
.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.