public class OraclePropertyGraph extends SQLAnalyticsGraph implements OraclePropertyGraphAnalytics, OracleChangeTracker, OraclePropertyGraphConfigurationConstants
SQLAnalyticsGraph.Sort
OraclePropertyGraphBase.CacheStatus, OraclePropertyGraphBase.OptimizationFlag
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 |
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 |
---|---|
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> |
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.
|
void |
enableAtSCN(java.lang.Long longSCN)
Sets the session snapshot to the given SCN value
|
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
|
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.
|
int |
getEdgePartitionsNumber()
Returns the number of HASH partitions of the edge table.
|
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 |
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
|
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)
Deprecated.
|
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.
|
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 |
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 |
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
|
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).
|
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
addEdge, addUpdatedEdge, addUpdatedVertex, addVertex, addVertex, addVertexById, adjacentEdgesFromVertices, adjacentEdgesFromVertices, clearCache, clearUpdateQueue, commitIndices, createIndex, decodeObject, edges, edges, edgesByIds, edgesByIds, edgesByProperty, edgesByProperty, edgesByProperty, edgesByProperty, edgesByProperty, edgesByPropertyKey, edgesByPropertyKey, edgesByPropertyKey, edgesByPropertyKey, getBatchSize, getCacheStatus, getConfig, getDateTimeFormatter, getDefaultEdgeOptFlag, getDefaultIndexParameters, getDefaultVertexOptFlag, getEdgeFilterCallback, getEdgeInstance, getElementsProperties, getGraphName, getJustEdgeIdOptFlag, getJustVertexIdOptFlag, getOperationQueueSize, getProgressListener, getQueueSize, getShortestPath, getShortestPath, getSimpleDateFormat, getStringForObj, getVertexFilterCallback, isBuiltinElementsCacheDisabled, isDisposed, isEmpty, isShutdown, isSkipRefreshIndicesEnabled, isTransientPropertyGraphInstance, removeEdge, removeEdges, removeEdges, removeEdges, removeEdges, removeVertex, removeVertices, removeVertices, removeVertices, removeVertices, serializableToStr, setBatchSize, setCacheStatus, setDefaultEdgeOptFlag, setDefaultIndexParameters, setDefaultVertexOptFlag, setEdgeFilterCallback, setProgressListener, setQueueSize, setSkipRefreshIndices, setSolrJavaBinFormat, setTransientPropertyGraphInstance, setVertexFilterCallback, startTransaction, strToSerializable, sum, toString, useSolrJavaBinFormat, vertices, vertices, verticesByIds, verticesByIds, verticesByProperty, verticesByProperty, verticesByProperty, verticesByProperty, verticesByProperty, verticesByPropertyKey, 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, getAutoIndex, getIndex, getIndexedKeys, getIndexParameters, getIndices, isEdgeAutoIndexEnabled, isVertexAutoIndexEnabled, refreshAutoIndices, validateIndexManager
countEdges, countEdges, countVertices, countVertices, getEdgePropertyNames, getEdgePropertyNames, getEdgePropertyNames, getEdgePropertyNames, getElementsProperties, getInvalidEdgeIDSet, getInvalidEdgeIDSet, getMaxEdgeID, getMaxEdgeID, getMaxEdgeID, getMaxVertexID, getMaxVertexID, getMaxVertexID, getMinEdgeID, getMinEdgeID, getMinEdgeID, getMinVertexID, getMinVertexID, getMinVertexID, getVertexIDSet, getVertexIDSet, getVertexPropertyNames, getVertexPropertyNames, getVertexPropertyNames, getVertexPropertyNames
addAttributeToAllEdges, addAttributeToAllEdges, addAttributeToAllEdges, addAttributeToAllVertices, addAttributeToAllVertices, addAttributeToAllVertices, getDOPForMetadataOperations, removeAttributeFromAllEdges, removeAttributeFromAllEdges, removeAttributeFromAllEdges, removeAttributeFromAllVertices, removeAttributeFromAllVertices, removeAttributeFromAllVertices, updateGraph
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 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 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
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> 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 void enableAtSCN(java.lang.Long longSCN) throws java.sql.SQLException
enableAtSCN
in interface OracleChangeTracker
longSCN
- SCN of the snapshotjava.sql.SQLException
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 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 int getEdgePartitionsNumber() throws java.sql.SQLException
java.sql.SQLException
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
objectowner
- 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 getMaxLabelLengthAllowedInBytes()
OraclePropertyGraphBase
getMaxLabelLengthAllowedInBytes
in class OraclePropertyGraphBase
public long getMaxPropertyNameLengthAllowedInBytes()
OraclePropertyGraphBase
getMaxPropertyNameLengthAllowedInBytes
in class OraclePropertyGraphBase
public long getMaxValueLengthAllowedInBytes()
OraclePropertyGraphBase
getMaxValueLengthAllowedInBytes
in class OraclePropertyGraphBase
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()
@Deprecated public OracleVertex getVertex(java.lang.Object id)
getVertex
in class OraclePropertyGraphBase
id
- the object identifier of the referenced vertexOracleVertexBase
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 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 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 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 boolean supportVertexLabels()
OraclePropertyGraphBase
supportVertexLabels
in class OraclePropertyGraphBase
public void treatTimestampTzAsStr(boolean b)
b
- treats timestamp with timezone as string if true.