public class OraclePropertyGraphUtils extends OraclePropertyGraphUtilsBase
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, TYPE_DT_JSON, TYPE_DT_SPATIAL, TYPE_DT_URI| Constructor and Description |
|---|
OraclePropertyGraphUtils() |
| Modifier and Type | Method and Description |
|---|---|
static boolean |
checkSnapshotExist(java.lang.String szGraphName, java.lang.String tableOwner, java.sql.Connection conn, long lSnapshotID)
This method returns TRUE if a particular snapshot exists for a given property graph
|
static boolean |
checkSnapshotTableExist(java.lang.String szGraphName, java.lang.String tableOwner, java.sql.Connection conn)
This method returns TRUE if a designated table for storing snapshots exists for a given property graph
|
static void |
clearPropertyGraph(Oracle oracle, java.lang.String szGraphName)
This method clears the contents from the underlying schema objects for the specified property graph.
|
static void |
clearTwoTablesGraphTab(java.sql.Connection conn, java.lang.String tableName)
Truncate the given table (from the two tables approach)
|
static void |
cloneGraph(java.sql.Connection conn, java.lang.String szOrgGraphName, java.lang.String szNewGraphName, int iDOP, int iNumSubPtns, java.lang.String szTBS, java.lang.String szOptions)
This method makes a clone of a given graph.
|
static void |
copyGraph(Oracle oracle, java.lang.String graphName, java.lang.String newGraphName)
Copy the property graph (including its associated tables) to the specified graph name (if it is not empty).
|
static void |
copyGraph(Oracle oracle, java.lang.String graphName, java.lang.String newGraphName, int dop)
Copy the property graph (including its associated tables) to the specified graph name (if it is not empty).
|
static void |
createSnapshotTable(java.lang.String szGraphName, java.lang.String tableOwner, java.sql.Connection conn, int dop, java.lang.String options, java.lang.String tablespace, boolean nologging)
This method creates the snapshot table for storing in-memory graphs
|
static void |
dropPropertyGraph(Oracle oracle, java.lang.String szGraphName)
Drops the specified property graph (including its associated tables).
|
static void |
dropPropertyGraphTables(Oracle oracle, java.lang.String szGraphName)
Drops the underlying tables of specified property graph (including its associated tables).
|
static void |
dropTable(java.sql.Connection conn, java.lang.String tableName)
Drop the specified table
|
static boolean |
existsGraph(Oracle conn, java.lang.String graphName)
Checks if the specified property graph already exists in the database
|
static void |
exportEdgeFlatFile(OraclePropertyGraph pg, java.io.OutputStream osEdge, int dop, boolean append, boolean closeStream)
This function exports the edges of a given property graph into OPE flat file
|
static void |
exportFlatFiles(OraclePropertyGraph pg, java.io.OutputStream osVertex, java.io.OutputStream osEdge, int dop, boolean append)
This function exports a given property graph into two flat files: one for vertices and the other for edges.
|
static void |
exportFlatFiles(OraclePropertyGraph pg, java.io.OutputStream osVertex, java.io.OutputStream osEdge, int dop, boolean append, boolean closeStreams)
This function exports a given property graph into two flat files: one for vertices and the other for edges.
|
static void |
exportFlatFiles(OraclePropertyGraph pg, java.lang.String vertexFileName, java.lang.String edgeFileName, boolean append)
This function exports a given property graph into two flat files: one for vertices and the other for edges.
|
static void |
exportFlatFiles(OraclePropertyGraph pg, java.lang.String vertexFileName, java.lang.String edgeFileName, int dop, boolean append)
This function exports a given property graph into two flat files: one for vertices and the other for edges.
|
static void |
exportFlatFiles(java.lang.String jdbcUrl, java.lang.String user, java.lang.String password, java.lang.String propertyGraphName, java.lang.String vertexFileName, java.lang.String edgeFileName)
This function exports a given property graph into two flat files: one for vertices and the other for edges.
|
static void |
exportVertexFlatFile(OraclePropertyGraph pg, java.io.OutputStream osVertex, int dop, boolean append, boolean closeStream)
This function exports the vertices of a given property graph into OPV flat file
|
static javax.sql.DataSource |
getDataSource(java.lang.String dsName)
Gets a DataSource object from the given data source name
|
static java.util.List<java.lang.String> |
getGraphNames(Oracle oracle)
List all the names of the property graphs stored in the given database
|
static oracle.pgx.common.types.PropertyType |
getIdTypeAsPropertyType(oracle.pgx.common.types.IdType type)
Converts a
IdType object into a PropertyType object |
static boolean |
hasTable(java.sql.Connection conn, java.lang.String tableName, java.lang.String tableOwner)
Verifies if the specified table exists in the given Oracle Database
|
static void |
prepareTwoTablesGraphEdgeTab(java.sql.Connection conn, java.lang.String schema, java.lang.String edgeTableName, java.util.List<java.lang.String> propertyNames, java.util.List<oracle.pgx.common.types.PropertyType> propertyTypes, java.lang.String tablespaceName, java.lang.String storageOptions, boolean nologging)
Creates and prepares an Edge table representing all the edges in a graph using a Two Tables approach.
|
static void |
prepareTwoTablesGraphEdgeTab(java.sql.Connection conn, java.lang.String schema, java.lang.String edgeTableName, java.util.List<java.lang.String> propertyNames, java.util.List<oracle.pgx.common.types.PropertyType> propertyTypes, java.lang.String tablespaceName, java.lang.String storageOptions, boolean nologging, java.util.Map<java.lang.String,java.lang.String> elementMapping)
Creates and prepares an Edge table representing all the edges in a graph using a Two Tables approach.
|
static void |
prepareTwoTablesGraphEdgeTab(java.sql.Connection conn, java.lang.String schema, java.lang.String edgeTableName, java.util.List<java.lang.String> propertyNames, java.util.List<oracle.pgx.common.types.PropertyType> propertyTypes, java.lang.String tablespaceName, java.lang.String storageOptions, boolean nologging, java.util.Map<java.lang.String,java.lang.String> elementMapping, oracle.pgx.common.types.IdType edgeIDType, oracle.pgx.common.types.IdType vertexIDType)
Creates and prepares an Edge table representing all the edges in a graph using a Two Tables approach.
|
static void |
prepareTwoTablesGraphEdgeTab(java.sql.Connection conn, java.lang.String schema, java.lang.String edgeTableName, java.util.List<java.lang.String> propertyNames, java.util.List<oracle.pgx.common.types.PropertyType> propertyTypes, java.lang.String tablespaceName, java.lang.String storageOptions, boolean nologging, java.util.Map<java.lang.String,java.lang.String> elementMapping, oracle.pgx.common.types.IdType edgeIDType, oracle.pgx.common.types.IdType vertexIDType, boolean hasEdgeLabel)
Creates and prepares an Edge table representing all the edges in a graph using a Two Tables approach.
|
static void |
prepareTwoTablesGraphEdgeTab(java.sql.Connection conn, java.lang.String schema, java.lang.String edgeTableName, java.util.List<java.lang.String> propertyNames, java.util.List<oracle.pgx.common.types.PropertyType> propertyTypes, java.lang.String tablespaceName, java.lang.String storageOptions, boolean nologging, java.util.Map<java.lang.String,java.lang.String> elementMapping, oracle.pgx.common.types.IdType edgeIDType, oracle.pgx.common.types.IdType vertexIDType, boolean hasEdgeLabel, boolean hasEdgeID)
Creates and prepares an Edge table representing all the edges in a graph using a Two Tables approach.
|
static void |
prepareTwoTablesGraphVertexTab(java.sql.Connection conn, java.lang.String schema, java.lang.String vertexTableName, java.util.List<java.lang.String> propertyNames, java.util.List<oracle.pgx.common.types.PropertyType> propertyTypes, java.lang.String tablespaceName, java.lang.String storageOptions, boolean nologging)
Creates and prepares a Vertex table representing all the vertices in a graph using a TwoTables approach.
|
static void |
prepareTwoTablesGraphVertexTab(java.sql.Connection conn, java.lang.String schema, java.lang.String vertexTableName, java.util.List<java.lang.String> propertyNames, java.util.List<oracle.pgx.common.types.PropertyType> propertyTypes, java.lang.String tablespaceName, java.lang.String storageOptions, boolean nologging, java.util.Map<java.lang.String,java.lang.String> elementMapping)
Creates and prepares a Vertex table representing all the vertices in a graph using a TwoTables approach.
|
static void |
prepareTwoTablesGraphVertexTab(java.sql.Connection conn, java.lang.String schema, java.lang.String vertexTableName, java.util.List<java.lang.String> propertyNames, java.util.List<oracle.pgx.common.types.PropertyType> propertyTypes, java.lang.String tablespaceName, java.lang.String storageOptions, boolean nologging, java.util.Map<java.lang.String,java.lang.String> elementMapping, oracle.pgx.common.types.IdType vertexIDType)
Creates and prepares a Vertex table representing all the vertices in a graph using a TwoTables approach.
|
static void |
quietlyCloseConnections(Oracle[] oracleArray, java.sql.Connection[] connections)
Quietly close an array of
Oracle objects handling connections to an Oracle Database. |
static void |
readBinaryInMemGraphSnapshot(java.lang.String szGraphName, java.lang.String tableOwner, java.sql.Connection conn, java.io.OutputStream[] os, long lSnapshotID, int dop)
Reads an In-Memory Graph Snapshot (binary file) from the snapshot SS$ table and writes it into the given outputstream.
|
static java.sql.ResultSet[] |
readTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String edgeTableName, int iTotalSplits, int iStartSplitID)
Gets an array of
ResultSet objects that hold all the edges in the edge (from Two Tables approach). |
static java.sql.ResultSet[] |
readTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String edgeTableName, java.util.List<java.lang.String> propertyNames, int iTotalSplits, int iStartSplitID)
Gets an array of
ResultSet objects that hold all the edges in the edge (from Two Tables approach). |
static java.sql.ResultSet[] |
readTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String edgeTableName, java.util.List<java.lang.String> propertyNames, int iTotalSplits, int iStartSplitID, java.util.Map<java.lang.String,java.lang.String> elementMapping)
Gets an array of
ResultSet objects that hold all the edges in the edge (from Two Tables approach). |
static java.sql.ResultSet[] |
readTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String edgeTableName, java.util.List<java.lang.String> propertyNames, int iTotalSplits, int iStartSplitID, java.util.Map<java.lang.String,java.lang.String> elementMapping, oracle.pgx.common.types.IdType edgeIDType)
Gets an array of
ResultSet objects that hold all the edges in the edge (from Two Tables approach). |
static java.sql.ResultSet[] |
readTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String edgeTableName, java.util.List<java.lang.String> propertyNames, int iTotalSplits, int iStartSplitID, java.util.Map<java.lang.String,java.lang.String> elementMapping, oracle.pgx.common.types.IdType edgeIDType, boolean hasEdgeLabel)
Gets an array of
ResultSet objects that hold all the edges in the edge (from Two Tables approach). |
static java.sql.ResultSet[] |
readTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String edgeTableName, java.util.List<java.lang.String> propertyNames, int iTotalSplits, int iStartSplitID, java.util.Map<java.lang.String,java.lang.String> elementMapping, oracle.pgx.common.types.IdType edgeIDType, boolean hasEdgeLabel, boolean hasEdgeId, oracle.pgx.common.types.IdType vertexIDType)
Gets an array of
ResultSet objects that hold all the edges in the edge (from Two Tables approach). |
static java.sql.ResultSet[] |
readTwoTablesGraphVertexAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String vertexTableName, int iTotalSplits, int iStartSplitID)
Gets an array of
ResultSet objects that hold all the vertices in the vertex (from Two Tables approach). |
static java.sql.ResultSet[] |
readTwoTablesGraphVertexAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String vertexTableName, java.util.List<java.lang.String> propertyNames, int iTotalSplits, int iStartSplitID)
Gets an array of
ResultSet objects that hold all the vertices in the vertex (from Two Tables approach). |
static java.sql.ResultSet[] |
readTwoTablesGraphVertexAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String vertexTableName, java.util.List<java.lang.String> propertyNames, int iTotalSplits, int iStartSplitID, java.util.Map<java.lang.String,java.lang.String> elementMapping)
Gets an array of
ResultSet objects that hold all the vertices in the vertex (from Two Tables approach). |
static java.sql.ResultSet[] |
readTwoTablesGraphVertexAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String vertexTableName, java.util.List<java.lang.String> propertyNames, int iTotalSplits, int iStartSplitID, java.util.Map<java.lang.String,java.lang.String> elementMapping, oracle.pgx.common.types.IdType vertexIDType)
Gets an array of
ResultSet objects that hold all the vertices in the vertex (from Two Tables approach). |
static void |
renameGraph(Oracle oracle, java.lang.String graphName, java.lang.String newGraphName)
Renames the property graph (including its associated tables) to the specified graph name (if it does not exists or is not empty).
|
static void |
renameGraph(Oracle oracle, java.lang.String graphName, java.lang.String newGraphName, boolean nologging, java.lang.String szOptions)
Renames the property graph (including its associated tables) to the specified graph name (if it does not exists or is not empty).
|
static void |
storeBinaryInMemGraphSnapshot(java.lang.String szGraphName, java.lang.String tableOwner, java.sql.Connection conn, java.io.InputStream is, long lSnapshotID, int dop)
Stores an In-Memory Graph Snapshot (binary file) into the snapshot SS$ table.
|
static void |
storeBinaryInMemGraphSnapshot(java.lang.String szGraphName, java.lang.String tableOwner, java.sql.Connection conn, java.io.InputStream is, long lSnapshotID, long lTimestamp, int dop)
Stores an In-Memory Graph Snapshot (binary file) into the snapshot SS$ table.
|
static void |
validateEdgeFlatFileSyntax(java.io.InputStream is, boolean continueOnError, java.io.PrintStream psOutput)
This method validates the syntax of given PG edge file
|
static void |
validatePGFlatFiles(java.lang.String vertexFile, java.lang.String edgeFile, boolean continueOnError)
This method validates the syntax of given PG vertex and edge file
|
static void |
validateVertexFlatFileSyntax(java.io.InputStream is, boolean continueOnError, java.io.PrintStream psOutput)
This method validates the syntax of given PG vertex file
|
static void |
writeTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String edgeTableName, int batchSize, java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] edges)
Reads a set of edges from an array of Iterables and writes all the appropiate information into the given edge table (from Two Tables approach).
|
static void |
writeTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String edgeTableName, int batchSize, java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] edges, java.util.Map<java.lang.String,java.lang.String> elementMapping)
Reads a set of edges from an array of Iterables and writes all the appropiate information into the given edge table (from Two Tables approach).
|
static void |
writeTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String edgeTableName, int batchSize, java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] edges, java.util.Map<java.lang.String,java.lang.String> elementMapping, oracle.pgx.common.types.IdType edgeIDType, oracle.pgx.common.types.IdType vertexIDType)
Reads a set of edges from an array of Iterables and writes all the appropiate information into the given edge table (from Two Tables approach).
|
static void |
writeTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String edgeTableName, int batchSize, java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] edges, java.util.Map<java.lang.String,java.lang.String> elementMapping, oracle.pgx.common.types.IdType edgeIDType, oracle.pgx.common.types.IdType vertexIDType, boolean hasEdgeLabel)
Reads a set of edges from an array of Iterables and writes all the appropiate information into the given edge table (from Two Tables approach).
|
static void |
writeTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String edgeTableName, int batchSize, java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] edges, java.util.Map<java.lang.String,java.lang.String> elementMapping, oracle.pgx.common.types.IdType edgeIDType, oracle.pgx.common.types.IdType vertexIDType, boolean hasEdgeLabel, boolean hasEdgeId)
Reads a set of edges from an array of Iterables and writes all the appropiate information into the given edge table (from Two Tables approach).
|
static void |
writeTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String edgeTableName, int batchSize, java.util.Iterator<com.tinkerpop.blueprints.Edge>[] edges)
Reads a set of edges from an array of Iterators and writes all the appropiate information into the given edge table (from Two Tables approach).
|
static void |
writeTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String edgeTableName, int batchSize, java.util.Iterator<com.tinkerpop.blueprints.Edge>[] edges, java.util.Map<java.lang.String,java.lang.String> elementMapping)
Reads a set of edges from an array of Iterators and writes all the appropiate information into the given edge table (from Two Tables approach).
|
static void |
writeTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String edgeTableName, int batchSize, java.util.Iterator<com.tinkerpop.blueprints.Edge>[] edges, java.util.Map<java.lang.String,java.lang.String> elementMapping, oracle.pgx.common.types.IdType vertexIDType, oracle.pgx.common.types.IdType edgeIDType)
Reads a set of edges from an array of Iterators and writes all the appropiate information into the given edge table (from Two Tables approach).
|
static void |
writeTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String edgeTableName, int batchSize, java.util.Iterator<com.tinkerpop.blueprints.Edge>[] edges, java.util.Map<java.lang.String,java.lang.String> elementMapping, oracle.pgx.common.types.IdType vertexIDType, oracle.pgx.common.types.IdType edgeIDType, boolean hasEdgeLabel)
Reads a set of edges from an array of Iterators and writes all the appropiate information into the given edge table (from Two Tables approach).
|
static void |
writeTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String edgeTableName, int batchSize, java.util.Iterator<com.tinkerpop.blueprints.Edge>[] edges, java.util.Map<java.lang.String,java.lang.String> elementMapping, oracle.pgx.common.types.IdType vertexIDType, oracle.pgx.common.types.IdType edgeIDType, boolean hasEdgeLabel, boolean hasEdgeId)
Reads a set of edges from an array of Iterators and writes all the appropiate information into the given edge table (from Two Tables approach).
|
static void |
writeTwoTablesGraphVertexAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String vertexTableName, int batchSize, java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] vertices)
Reads a set of vertices from an array of Iterables and writes all the appropiate information into the given vertex table (from Two Tables approach).
|
static void |
writeTwoTablesGraphVertexAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String vertexTableName, int batchSize, java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] vertices, java.util.Map<java.lang.String,java.lang.String> elementMappings)
Reads a set of vertices from an array of Iterables and writes all the appropiate information into the given vertex table (from Two Tables approach).
|
static void |
writeTwoTablesGraphVertexAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String vertexTableName, int batchSize, java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] vertices, java.util.Map<java.lang.String,java.lang.String> elementMappings, oracle.pgx.common.types.IdType vertexIDType)
Reads a set of vertices from an array of Iterables and writes all the appropiate information into the given vertex table (from Two Tables approach).
|
static void |
writeTwoTablesGraphVertexAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String vertexTableName, int batchSize, java.util.Iterator<com.tinkerpop.blueprints.Vertex>[] vertices)
Reads a set of vertices from an array of Iterators and writes all the appropiate information into the given vertex table (from Two Tables approach).
|
static void |
writeTwoTablesGraphVertexAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String vertexTableName, int batchSize, java.util.Iterator<com.tinkerpop.blueprints.Vertex>[] vertices, java.util.Map<java.lang.String,java.lang.String> elementMapping)
Reads a set of vertices from an array of Iterators and writes all the appropiate information into the given vertex table (from Two Tables approach).
|
static void |
writeTwoTablesGraphVertexAndProperties(java.sql.Connection[] conns, java.lang.String schema, java.lang.String vertexTableName, int batchSize, java.util.Iterator<com.tinkerpop.blueprints.Vertex>[] vertices, java.util.Map<java.lang.String,java.lang.String> elementMapping, oracle.pgx.common.types.IdType vertexIDType)
Reads a set of vertices from an array of Iterators and writes all the appropiate information into the given vertex table (from Two Tables approach).
|
compareFiles, compareValueObjects, convertCSV2OPE, convertCSV2OPE, convertCSV2OPE, convertCSV2OPE, convertCSV2OPE, convertCSV2OPE, convertCSV2OPV, convertCSV2OPV, convertCSV2OPV, convertCSV2OPV, convertRDBMSTable2OPE, convertRDBMSTable2OPE, convertRDBMSTable2OPV, escape, exportEdges, exportFlatFiles, exportFlatFiles, exportFlatFiles, exportGML, exportGML, exportGraphML, exportGraphML, exportGraphSON, exportGraphSON, exportVertices, getDatatypeAsPropertyType, handleGZipInputStream, importGML, importGML, importGraphML, importGraphML, importGraphSON, importGraphSON, listify, outputEdgeRecord, outputVertexRecord, prepareConfigEdgePropertiesFromOPVFile, prepareConfigVertexPropertiesFromOPVFile, quietlyClose, quietlyClose, quietlyClose, quietlyCloseResultSet, quietlyCloseResultSetAndStmt, quietlyCloseResultSetAndStmt, quietlyCloseStmt, quietlyShutdown, setExceptionHandlers, size, splitAndLoad, unescape, validateSources, writeValue
public static boolean checkSnapshotExist(java.lang.String szGraphName,
java.lang.String tableOwner,
java.sql.Connection conn,
long lSnapshotID)
throws java.sql.SQLException
szGraphName - the graph name where to get the snapshottableOwner - the owner of the snapshot tableconn - an Oracle connectionlSnapshotID - the ID of the snapshot to writejava.sql.SQLException
public static boolean checkSnapshotTableExist(java.lang.String szGraphName,
java.lang.String tableOwner,
java.sql.Connection conn)
throws java.sql.SQLException
szGraphName - the graph name where to get the snapshottableOwner - the owner of the snapshot tableconn - an Oracle connectionjava.sql.SQLExceptionpublic static void clearPropertyGraph(Oracle oracle, java.lang.String szGraphName) throws java.sql.SQLException
java.sql.SQLException
public static void clearTwoTablesGraphTab(java.sql.Connection conn,
java.lang.String tableName)
public static void cloneGraph(java.sql.Connection conn,
java.lang.String szOrgGraphName,
java.lang.String szNewGraphName,
int iDOP,
int iNumSubPtns,
java.lang.String szTBS,
java.lang.String szOptions)
throws java.sql.SQLException
conn - a JDBC connection to Oracle DatabaseszOrgGraphName - name of the original graphszNewGraphName - name of the new graphiDOP - degree of parallelismiNumSubPtns - number of sub partitions to be used for the new graph. Has to be a positive integer (and a power of 2)szTBS - name of the tablespace to be used for the new graphszOptions - options to be passed on to the underlying PL/SQL API.java.sql.SQLExceptionpublic static void copyGraph(Oracle oracle, java.lang.String graphName, java.lang.String newGraphName) throws java.io.IOException, java.lang.Exception
oracle - an Oracle connection to the database where the property graph is stored.graphName - the name of the property graph to be copiednewGraphName - the new name of the graphjava.io.IOExceptionjava.lang.Exceptionpublic static void copyGraph(Oracle oracle, java.lang.String graphName, java.lang.String newGraphName, int dop) throws java.io.IOException, java.lang.Exception
oracle - an Oracle connection to the database where the property graph is stored.graphName - the name of the property graph to be copiednewGraphName - the new name of the graphdop - the degree of parallelism to use when copying the data from one graph to the otherjava.io.IOExceptionjava.lang.Exception
public static void createSnapshotTable(java.lang.String szGraphName,
java.lang.String tableOwner,
java.sql.Connection conn,
int dop,
java.lang.String options,
java.lang.String tablespace,
boolean nologging)
throws java.sql.SQLException
java.sql.SQLExceptionpublic static void dropPropertyGraph(Oracle oracle, java.lang.String szGraphName) throws java.sql.SQLException
oracle - an Oracle connection to the database where the property graph is stored.szGraphName - the name of the graph to drop.java.sql.SQLExceptionpublic static void dropPropertyGraphTables(Oracle oracle, java.lang.String szGraphName) throws java.sql.SQLException
oracle - an Oracle connection to the database where the property graph is stored.szGraphName - the name of the graph to drop.java.sql.SQLException
public static void dropTable(java.sql.Connection conn,
java.lang.String tableName)
throws java.sql.SQLException
conn - a Connection to Oracle DatabasetableName - the name of the tablejava.sql.SQLExceptionpublic static boolean existsGraph(Oracle conn, java.lang.String graphName)
conn - a Oracle connection to the databasegraphName - the name of the property graphjava.io.IOExceptionpublic static void exportEdgeFlatFile(OraclePropertyGraph pg, java.io.OutputStream osEdge, int dop, boolean append, boolean closeStream) throws java.io.IOException, java.io.FileNotFoundException
pg - the property graph that will be exported into flat filesosEdge - an OutputStream object for the edge flat filedop - the degree of parallelism used when writing the data into the flat file. This will use multiple threads to optimize writing performance.append - if false, overwrite the existing flat file removing all existing data.closeStream - whether to close the OutputStream or notjava.io.IOExceptionjava.io.FileNotFoundExceptionpublic static void exportFlatFiles(OraclePropertyGraph pg, java.io.OutputStream osVertex, java.io.OutputStream osEdge, int dop, boolean append) throws java.io.IOException, java.io.FileNotFoundException
pg - the property graph that will be exported into flat filesosVertex - an OutputStream object for the vertex flat fileosEdge - an OutputStream object for the edge flat filedop - the degree of parallelism used when writing the data into the flat files. This will use multiple threads to optimize writing performance.append - if false, overwrite the existing flat files removing all existing data.java.io.IOExceptionjava.io.FileNotFoundExceptionpublic static void exportFlatFiles(OraclePropertyGraph pg, java.io.OutputStream osVertex, java.io.OutputStream osEdge, int dop, boolean append, boolean closeStreams) throws java.io.IOException, java.io.FileNotFoundException
pg - the property graph that will be exported into flat filesosVertex - an OutputStream object for the vertex flat fileosEdge - an OutputStream object for the edge flat filedop - the degree of parallelism used when writing the data into the flat files. This will use multiple threads to optimize writing performance.append - if false, overwrite the existing flat files removing all existing data.closeStreams - whether to close the OutputStreams or notjava.io.IOExceptionjava.io.FileNotFoundExceptionpublic static final void exportFlatFiles(OraclePropertyGraph pg, java.lang.String vertexFileName, java.lang.String edgeFileName, boolean append) throws java.io.IOException, java.io.FileNotFoundException
pg - the property graph that will be exported into flat filesvertexFileName - the name of the vertex flat file e.g. graph.opvedgeFileName - the name of the edge flat file e.g. graph.opeappend - if false, overwrite the existing flat files removing all existing data.java.io.IOExceptionjava.io.FileNotFoundExceptionpublic static final void exportFlatFiles(OraclePropertyGraph pg, java.lang.String vertexFileName, java.lang.String edgeFileName, int dop, boolean append) throws java.io.IOException, java.io.FileNotFoundException
pg - the property graph that will be exported into flat filesvertexFileName - the name of the vertex flat file e.g. graph.opvedgeFileName - the name of the edge flat file e.g. graph.opedop - the degree of parallelism used when writing the data into the flat files. This will use multiple threads to optimize writing performance.append - if false, overwrite the existing flat files removing all existing data.java.io.IOExceptionjava.io.FileNotFoundException
public static void exportFlatFiles(java.lang.String jdbcUrl,
java.lang.String user,
java.lang.String password,
java.lang.String propertyGraphName,
java.lang.String vertexFileName,
java.lang.String edgeFileName)
throws java.sql.SQLException,
java.io.IOException,
java.io.FileNotFoundException
jdbcUrl - JDBC URL that identifies an Oracle databaseuser - username of a database schemapassword - password to authenticatepropertyGraphName - the name of the property graph to exportvertexFileName - the name of the vertex flat file e.g. graph.opvedgeFileName - the name of the edge flat file e.g. graph.opejava.sql.SQLExceptionjava.io.IOExceptionjava.io.FileNotFoundExceptionpublic static void exportVertexFlatFile(OraclePropertyGraph pg, java.io.OutputStream osVertex, int dop, boolean append, boolean closeStream) throws java.io.IOException, java.io.FileNotFoundException
pg - the property graph that will be exported into flat filesosVertex - an OutputStream object for the vertex flat filedop - the degree of parallelism used when writing the data into the flat file. This will use multiple threads to optimize writing performance.append - if false, overwrite the existing flat file removing all existing data.closeStream - whether to close the OutputStream or notjava.io.IOExceptionjava.io.FileNotFoundException
public static javax.sql.DataSource getDataSource(java.lang.String dsName)
throws java.sql.SQLException,
javax.naming.NamingException
dsName - the data source namejava.sql.SQLExceptionjavax.naming.NamingExceptionpublic static java.util.List<java.lang.String> getGraphNames(Oracle oracle)
oracle - an Oracle connection to the database where the property graph is stored.public static oracle.pgx.common.types.PropertyType getIdTypeAsPropertyType(oracle.pgx.common.types.IdType type)
IdType object into a PropertyType object
public static boolean hasTable(java.sql.Connection conn,
java.lang.String tableName,
java.lang.String tableOwner)
conn - a Connection to Oracle DatabasetableName - the name of the tabletableOwner - the owner of the table
public static void prepareTwoTablesGraphEdgeTab(java.sql.Connection conn,
java.lang.String schema,
java.lang.String edgeTableName,
java.util.List<java.lang.String> propertyNames,
java.util.List<oracle.pgx.common.types.PropertyType> propertyTypes,
java.lang.String tablespaceName,
java.lang.String storageOptions,
boolean nologging)
conn - a Oracle connection to the databaseschema - the schema where the table will be created (owner)edgeTableName - the name of the edge tablepropertyNames - the list of property names that will be used as column names of the tablepropertyTypes - the list of property types that will be used as data types for the columns of the tabletablespaceName - the tablespace where the table will be createdstorageOptions - the storage options that will be used when creating the table e.g. "COMPACT=T"nologging - if logging is enabled
public static void prepareTwoTablesGraphEdgeTab(java.sql.Connection conn,
java.lang.String schema,
java.lang.String edgeTableName,
java.util.List<java.lang.String> propertyNames,
java.util.List<oracle.pgx.common.types.PropertyType> propertyTypes,
java.lang.String tablespaceName,
java.lang.String storageOptions,
boolean nologging,
java.util.Map<java.lang.String,java.lang.String> elementMapping)
conn - a Oracle connection to the databaseschema - the schema where the table will be created (owner)edgeTableName - the name of the edge tablepropertyNames - the list of property names that will be used as column names of the tablepropertyTypes - the list of property types that will be used as data types for the columns of the tabletablespaceName - the tablespace where the table will be createdstorageOptions - the storage options that will be used when creating the table e.g. "COMPACT=T"nologging - if logging is enabled
public static void prepareTwoTablesGraphEdgeTab(java.sql.Connection conn,
java.lang.String schema,
java.lang.String edgeTableName,
java.util.List<java.lang.String> propertyNames,
java.util.List<oracle.pgx.common.types.PropertyType> propertyTypes,
java.lang.String tablespaceName,
java.lang.String storageOptions,
boolean nologging,
java.util.Map<java.lang.String,java.lang.String> elementMapping,
oracle.pgx.common.types.IdType edgeIDType,
oracle.pgx.common.types.IdType vertexIDType)
conn - a Oracle connection to the databaseschema - the schema where the table will be created (owner)edgeTableName - the name of the edge tablepropertyNames - the list of property names that will be used as column names of the tablepropertyTypes - the list of property types that will be used as data types for the columns of the tabletablespaceName - the tablespace where the table will be createdstorageOptions - the storage options that will be used when creating the table e.g. "COMPACT=T"nologging - if logging is enabled
public static void prepareTwoTablesGraphEdgeTab(java.sql.Connection conn,
java.lang.String schema,
java.lang.String edgeTableName,
java.util.List<java.lang.String> propertyNames,
java.util.List<oracle.pgx.common.types.PropertyType> propertyTypes,
java.lang.String tablespaceName,
java.lang.String storageOptions,
boolean nologging,
java.util.Map<java.lang.String,java.lang.String> elementMapping,
oracle.pgx.common.types.IdType edgeIDType,
oracle.pgx.common.types.IdType vertexIDType,
boolean hasEdgeLabel)
conn - a Oracle connection to the databaseschema - the schema where the table will be created (owner)edgeTableName - the name of the edge tablepropertyNames - the list of property names that will be used as column names of the tablepropertyTypes - the list of property types that will be used as data types for the columns of the tabletablespaceName - the tablespace where the table will be createdstorageOptions - the storage options that will be used when creating the table e.g. "COMPACT=T"nologging - if logging is enabled
public static void prepareTwoTablesGraphEdgeTab(java.sql.Connection conn,
java.lang.String schema,
java.lang.String edgeTableName,
java.util.List<java.lang.String> propertyNames,
java.util.List<oracle.pgx.common.types.PropertyType> propertyTypes,
java.lang.String tablespaceName,
java.lang.String storageOptions,
boolean nologging,
java.util.Map<java.lang.String,java.lang.String> elementMapping,
oracle.pgx.common.types.IdType edgeIDType,
oracle.pgx.common.types.IdType vertexIDType,
boolean hasEdgeLabel,
boolean hasEdgeID)
conn - a Oracle connection to the databaseschema - the schema where the table will be created (owner)edgeTableName - the name of the edge tablepropertyNames - the list of property names that will be used as column names of the tablepropertyTypes - the list of property types that will be used as data types for the columns of the tabletablespaceName - the tablespace where the table will be createdstorageOptions - the storage options that will be used when creating the table e.g. "COMPACT=T"nologging - if logging is enabled
public static void prepareTwoTablesGraphVertexTab(java.sql.Connection conn,
java.lang.String schema,
java.lang.String vertexTableName,
java.util.List<java.lang.String> propertyNames,
java.util.List<oracle.pgx.common.types.PropertyType> propertyTypes,
java.lang.String tablespaceName,
java.lang.String storageOptions,
boolean nologging)
conn - a Oracle connection to the databaseschema - the schema where the table will be created (owner)vertexTableName - the name of the edge tablepropertyNames - the list of property names that will be used as column names of the tablepropertyTypes - the list of property types that will be used as data types for the columns of the tabletablespaceName - the tablespace where the table will be createdstorageOptions - the storage options that will be used when creating the table e.g. "COMPACT=T"nologging - if logging is enabled
public static void prepareTwoTablesGraphVertexTab(java.sql.Connection conn,
java.lang.String schema,
java.lang.String vertexTableName,
java.util.List<java.lang.String> propertyNames,
java.util.List<oracle.pgx.common.types.PropertyType> propertyTypes,
java.lang.String tablespaceName,
java.lang.String storageOptions,
boolean nologging,
java.util.Map<java.lang.String,java.lang.String> elementMapping)
conn - a Oracle connection to the databaseschema - the schema where the table will be created (owner)vertexTableName - the name of the edge tablepropertyNames - the list of property names that will be used as column names of the tablepropertyTypes - the list of property types that will be used as data types for the columns of the tabletablespaceName - the tablespace where the table will be createdstorageOptions - the storage options that will be used when creating the table e.g. "COMPACT=T"nologging - if logging is enabled
public static void prepareTwoTablesGraphVertexTab(java.sql.Connection conn,
java.lang.String schema,
java.lang.String vertexTableName,
java.util.List<java.lang.String> propertyNames,
java.util.List<oracle.pgx.common.types.PropertyType> propertyTypes,
java.lang.String tablespaceName,
java.lang.String storageOptions,
boolean nologging,
java.util.Map<java.lang.String,java.lang.String> elementMapping,
oracle.pgx.common.types.IdType vertexIDType)
conn - a Oracle connection to the databaseschema - the schema where the table will be created (owner)vertexTableName - the name of the edge tablepropertyNames - the list of property names that will be used as column names of the tablepropertyTypes - the list of property types that will be used as data types for the columns of the tabletablespaceName - the tablespace where the table will be createdstorageOptions - the storage options that will be used when creating the table e.g. "COMPACT=T"nologging - if logging is enabledpublic static void quietlyCloseConnections(Oracle[] oracleArray, java.sql.Connection[] connections)
Oracle objects handling connections to an Oracle Database.oracleArray - the array of Oracle connections to be closed.connections - the array of Connection objects obtained from the Oracle objects.
public static void readBinaryInMemGraphSnapshot(java.lang.String szGraphName,
java.lang.String tableOwner,
java.sql.Connection conn,
java.io.OutputStream[] os,
long lSnapshotID,
int dop)
throws OraclePropertyGraphException,
java.sql.SQLException
szGraphName - the graph name where to get the snapshottableOwner - the owner of the snapshot tableconn - an Oracle connectionos - an array of OutputStream objects where the in-memory graph binary files will be written.lSnapshotID - the ID of the snapshot to readdop - the degree of parallelism to use when reading the snapshotOraclePropertyGraphExceptionjava.sql.SQLExceptionOraclePropertyGraphException
public static java.sql.ResultSet[] readTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String edgeTableName,
int iTotalSplits,
int iStartSplitID)
ResultSet objects that hold all the edges in the edge (from Two Tables approach). Each element in the ResultSet array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by the given # of total splits. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array]. The attributes included in the result set will include the edge information (EID, EL, SVID, DVID), as well as the defined Key/value properties.conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)edgeTableName - the name of the edge tableiTotalSplits - the total number of splitsiStartSplitID - the ID of the starting split.Iterable object.
public static java.sql.ResultSet[] readTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String edgeTableName,
java.util.List<java.lang.String> propertyNames,
int iTotalSplits,
int iStartSplitID)
ResultSet objects that hold all the edges in the edge (from Two Tables approach). Each element in the ResultSet array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by the given # of total splits. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array]. The attributes included in the result set will be defined based on the given property names list. If the list is set to NULL, all the columns of the table will be retrieved: this includes the edge information (EID, EL, SVID, DVID), as well as the defined Key/value properties. If the list is set empty, the result set will only include the edge information such as EID, EL, SVID, DVID. In any other case, the result set will include the edge information plus the given list of properties.conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)edgeTableName - the name of the edge tablepropertyNames - the list of property names to projectiTotalSplits - the total number of splitsiStartSplitID - the ID of the starting split.Iterable object.
public static java.sql.ResultSet[] readTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String edgeTableName,
java.util.List<java.lang.String> propertyNames,
int iTotalSplits,
int iStartSplitID,
java.util.Map<java.lang.String,java.lang.String> elementMapping)
ResultSet objects that hold all the edges in the edge (from Two Tables approach). Each element in the ResultSet array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by the given # of total splits. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array]. The attributes included in the result set will be defined based on the given property names list. If the list is set to NULL, all the columns of the table will be retrieved: this includes the edge information (EID, EL, SVID, DVID), as well as the defined Key/value properties. If the list is set empty, the result set will only include the edge information such as EID, EL, SVID, DVID. In any other case, the result set will include the edge information plus the given list of properties.conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)edgeTableName - the name of the edge tablepropertyNames - the list of property names to projectiTotalSplits - the total number of splitsiStartSplitID - the ID of the starting split.Iterable object.
public static java.sql.ResultSet[] readTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String edgeTableName,
java.util.List<java.lang.String> propertyNames,
int iTotalSplits,
int iStartSplitID,
java.util.Map<java.lang.String,java.lang.String> elementMapping,
oracle.pgx.common.types.IdType edgeIDType)
ResultSet objects that hold all the edges in the edge (from Two Tables approach). Each element in the ResultSet array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by the given # of total splits. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array]. The attributes included in the result set will be defined based on the given property names list. If the list is set to NULL, all the columns of the table will be retrieved: this includes the edge information (EID, EL, SVID, DVID), as well as the defined Key/value properties. If the list is set empty, the result set will only include the edge information such as EID, EL, SVID, DVID. In any other case, the result set will include the edge information plus the given list of properties.conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)edgeTableName - the name of the edge tablepropertyNames - the list of property names to projectiTotalSplits - the total number of splitsiStartSplitID - the ID of the starting split.Iterable object.
public static java.sql.ResultSet[] readTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String edgeTableName,
java.util.List<java.lang.String> propertyNames,
int iTotalSplits,
int iStartSplitID,
java.util.Map<java.lang.String,java.lang.String> elementMapping,
oracle.pgx.common.types.IdType edgeIDType,
boolean hasEdgeLabel)
ResultSet objects that hold all the edges in the edge (from Two Tables approach). Each element in the ResultSet array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by the given # of total splits. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array]. The attributes included in the result set will be defined based on the given property names list. If the list is set to NULL, all the columns of the table will be retrieved: this includes the edge information (EID, EL, SVID, DVID), as well as the defined Key/value properties. If the list is set empty, the result set will only include the edge information such as EID, EL, SVID, DVID. In any other case, the result set will include the edge information plus the given list of properties.conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)edgeTableName - the name of the edge tablepropertyNames - the list of property names to projectiTotalSplits - the total number of splitsiStartSplitID - the ID of the starting split.Iterable object.
public static java.sql.ResultSet[] readTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String edgeTableName,
java.util.List<java.lang.String> propertyNames,
int iTotalSplits,
int iStartSplitID,
java.util.Map<java.lang.String,java.lang.String> elementMapping,
oracle.pgx.common.types.IdType edgeIDType,
boolean hasEdgeLabel,
boolean hasEdgeId,
oracle.pgx.common.types.IdType vertexIDType)
ResultSet objects that hold all the edges in the edge (from Two Tables approach). Each element in the ResultSet array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by the given # of total splits. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array]. The attributes included in the result set will be defined based on the given property names list. If the list is set to NULL, all the columns of the table will be retrieved: this includes the edge information (EID, EL, SVID, DVID), as well as the defined Key/value properties. If the list is set empty, the result set will only include the edge information such as EID, EL, SVID, DVID. In any other case, the result set will include the edge information plus the given list of properties.conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)edgeTableName - the name of the edge tablepropertyNames - the list of property names to projectiTotalSplits - the total number of splitsiStartSplitID - the ID of the starting split.Iterable object.
public static java.sql.ResultSet[] readTwoTablesGraphVertexAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String vertexTableName,
int iTotalSplits,
int iStartSplitID)
ResultSet objects that hold all the vertices in the vertex (from Two Tables approach). Each element in the ResultSet array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by the given # of total splits. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array]. The attributes included in the result set will include the vertex information (VID), as well as the defined Key/value properties.conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)vertexTableName - the name of the edge tableiTotalSplits - the total number of splitsiStartSplitID - the ID of the starting split.Iterable object.
public static java.sql.ResultSet[] readTwoTablesGraphVertexAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String vertexTableName,
java.util.List<java.lang.String> propertyNames,
int iTotalSplits,
int iStartSplitID)
ResultSet objects that hold all the vertices in the vertex (from Two Tables approach). Each element in the ResultSet array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by the given # of total splits. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array]. The attributes included in the result set will be defined based on the given property names list. If the list is set to NULL, all the columns of the table will be retrieved: this includes the vertex information (VID), as well as the defined Key/value properties. If the list is set empty, the result set will only include the vertex information (VID). In any other case, the result set will include the edge information plus the given list of properties.conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)vertexTableName - the name of the vertex tablepropertyNames - the list of property names to projectiTotalSplits - the total number of splitsiStartSplitID - the ID of the starting split.Iterable object.
public static java.sql.ResultSet[] readTwoTablesGraphVertexAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String vertexTableName,
java.util.List<java.lang.String> propertyNames,
int iTotalSplits,
int iStartSplitID,
java.util.Map<java.lang.String,java.lang.String> elementMapping)
ResultSet objects that hold all the vertices in the vertex (from Two Tables approach). Each element in the ResultSet array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by the given # of total splits. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array]. The attributes included in the result set will be defined based on the given property names list. If the list is set to NULL, all the columns of the table will be retrieved: this includes the vertex information (VID), as well as the defined Key/value properties. If the list is set empty, the result set will only include the vertex information (VID). In any other case, the result set will include the edge information plus the given list of properties.conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)vertexTableName - the name of the vertex tablepropertyNames - the list of property names to projectiTotalSplits - the total number of splitsiStartSplitID - the ID of the starting split.Iterable object.
public static java.sql.ResultSet[] readTwoTablesGraphVertexAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String vertexTableName,
java.util.List<java.lang.String> propertyNames,
int iTotalSplits,
int iStartSplitID,
java.util.Map<java.lang.String,java.lang.String> elementMapping,
oracle.pgx.common.types.IdType vertexIDType)
ResultSet objects that hold all the vertices in the vertex (from Two Tables approach). Each element in the ResultSet array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by the given # of total splits. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array]. The attributes included in the result set will be defined based on the given property names list. If the list is set to NULL, all the columns of the table will be retrieved: this includes the vertex information (VID), as well as the defined Key/value properties. If the list is set empty, the result set will only include the vertex information (VID). In any other case, the result set will include the edge information plus the given list of properties.conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)vertexTableName - the name of the vertex tablepropertyNames - the list of property names to projectiTotalSplits - the total number of splitsiStartSplitID - the ID of the starting split.Iterable object.public static void renameGraph(Oracle oracle, java.lang.String graphName, java.lang.String newGraphName) throws java.io.IOException, java.lang.Exception
oracle - an Oracle connection to the database where the property graph is stored.graphName - the name of the property graph to be renamednewGraphName - the new name of the property graph.java.io.IOExceptionjava.lang.Exceptionpublic static void renameGraph(Oracle oracle, java.lang.String graphName, java.lang.String newGraphName, boolean nologging, java.lang.String szOptions) throws java.io.IOException, java.lang.Exception
oracle - an Oracle connection to the database where the property graph is stored.graphName - the name of the property graph to be renamednewGraphName - the new name of the property graph.nologging - if logging is enabled on the underlying PL/SQL API.szOptions - options to be passed on to the underlying PL/SQL API.java.io.IOExceptionjava.lang.Exception
public static void storeBinaryInMemGraphSnapshot(java.lang.String szGraphName,
java.lang.String tableOwner,
java.sql.Connection conn,
java.io.InputStream is,
long lSnapshotID,
int dop)
throws OraclePropertyGraphException
szGraphName - the graph name where to get the snapshottableOwner - the owner of the snapshot tableconn - an Oracle connectionis - an InputStream objects where the in-memory graph binary files will be read.lSnapshotID - the ID of the snapshot to writedop - the degree of parallelism to use when writing the snapshotOraclePropertyGraphExceptionjava.sql.SQLExceptionOraclePropertyGraphException
public static void storeBinaryInMemGraphSnapshot(java.lang.String szGraphName,
java.lang.String tableOwner,
java.sql.Connection conn,
java.io.InputStream is,
long lSnapshotID,
long lTimestamp,
int dop)
throws OraclePropertyGraphException
szGraphName - the graph name where to get the snapshottableOwner - the owner of the snapshot tableconn - an Oracle connectionis - an InputStream objects where the in-memory graph binary files will be read.lSnapshotID - the ID of the snapshot to writedop - the degree of parallelism to use when writing the snapshotOraclePropertyGraphExceptionjava.sql.SQLExceptionOraclePropertyGraphException
public static void validateEdgeFlatFileSyntax(java.io.InputStream is,
boolean continueOnError,
java.io.PrintStream psOutput)
public static void validatePGFlatFiles(java.lang.String vertexFile,
java.lang.String edgeFile,
boolean continueOnError)
public static void validateVertexFlatFileSyntax(java.io.InputStream is,
boolean continueOnError,
java.io.PrintStream psOutput)
public static void writeTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String edgeTableName,
int batchSize,
java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] edges)
conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)edgeTableName - the name of the edge tablebatchSize - the batch size used in the prepared statementsedges - an array of Edge edge iterables
public static void writeTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String edgeTableName,
int batchSize,
java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] edges,
java.util.Map<java.lang.String,java.lang.String> elementMapping)
conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)edgeTableName - the name of the edge tablebatchSize - the batch size used in the prepared statementsedges - an array of Edge edge iterableselementMapping - a map specifying the column names where the element attributes as EID, SVID, DVID should be stored.
public static void writeTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String edgeTableName,
int batchSize,
java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] edges,
java.util.Map<java.lang.String,java.lang.String> elementMapping,
oracle.pgx.common.types.IdType edgeIDType,
oracle.pgx.common.types.IdType vertexIDType)
conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)edgeTableName - the name of the edge tablebatchSize - the batch size used in the prepared statementsedges - an array of Edge edge iterableselementMapping - a map specifying the column names where the element attributes as EID, SVID, DVID should be stored.edgeIDType - the property type of the edge IDsvertexIDType - the property type of the vertex IDs
public static void writeTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String edgeTableName,
int batchSize,
java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] edges,
java.util.Map<java.lang.String,java.lang.String> elementMapping,
oracle.pgx.common.types.IdType edgeIDType,
oracle.pgx.common.types.IdType vertexIDType,
boolean hasEdgeLabel)
conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)edgeTableName - the name of the edge tablebatchSize - the batch size used in the prepared statementsedges - an array of Edge edge iterableselementMapping - a map specifying the column names where the element attributes as EID, SVID, DVID should be stored.edgeIDType - the property type of the edge IDsvertexIDType - the property type of the vertex IDs
public static void writeTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String edgeTableName,
int batchSize,
java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] edges,
java.util.Map<java.lang.String,java.lang.String> elementMapping,
oracle.pgx.common.types.IdType edgeIDType,
oracle.pgx.common.types.IdType vertexIDType,
boolean hasEdgeLabel,
boolean hasEdgeId)
conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)edgeTableName - the name of the edge tablebatchSize - the batch size used in the prepared statementsedges - an array of Edge edge iterableselementMapping - a map specifying the column names where the element attributes as EID, SVID, DVID should be stored.edgeIDType - the property type of the edge IDsvertexIDType - the property type of the vertex IDs
public static void writeTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String edgeTableName,
int batchSize,
java.util.Iterator<com.tinkerpop.blueprints.Edge>[] edges)
conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)edgeTableName - the name of the edge tablebatchSize - the batch size used in the prepared statementsedges - an array of Edge edge iterators
public static void writeTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String edgeTableName,
int batchSize,
java.util.Iterator<com.tinkerpop.blueprints.Edge>[] edges,
java.util.Map<java.lang.String,java.lang.String> elementMapping)
conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)edgeTableName - the name of the edge tablebatchSize - the batch size used in the prepared statementsedges - an array of Edge edge iteratorselementMapping - a map specifying the column names where the element attributes as EID, SVID, DVID should be stored.
public static void writeTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String edgeTableName,
int batchSize,
java.util.Iterator<com.tinkerpop.blueprints.Edge>[] edges,
java.util.Map<java.lang.String,java.lang.String> elementMapping,
oracle.pgx.common.types.IdType vertexIDType,
oracle.pgx.common.types.IdType edgeIDType)
conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)edgeTableName - the name of the edge tablebatchSize - the batch size used in the prepared statementsedges - an array of Edge edge iteratorselementMapping - a map specifying the column names where the element attributes as EID, SVID, DVID should be stored.edgeIDType - the property type of the edge IDsvertexIDType - the property type of the vertex IDs
public static void writeTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String edgeTableName,
int batchSize,
java.util.Iterator<com.tinkerpop.blueprints.Edge>[] edges,
java.util.Map<java.lang.String,java.lang.String> elementMapping,
oracle.pgx.common.types.IdType vertexIDType,
oracle.pgx.common.types.IdType edgeIDType,
boolean hasEdgeLabel)
conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)edgeTableName - the name of the edge tablebatchSize - the batch size used in the prepared statementsedges - an array of Edge edge iteratorselementMapping - a map specifying the column names where the element attributes as EID, SVID, DVID should be stored.edgeIDType - the property type of the edge IDsvertexIDType - the property type of the vertex IDs
public static void writeTwoTablesGraphEdgeAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String edgeTableName,
int batchSize,
java.util.Iterator<com.tinkerpop.blueprints.Edge>[] edges,
java.util.Map<java.lang.String,java.lang.String> elementMapping,
oracle.pgx.common.types.IdType vertexIDType,
oracle.pgx.common.types.IdType edgeIDType,
boolean hasEdgeLabel,
boolean hasEdgeId)
conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)edgeTableName - the name of the edge tablebatchSize - the batch size used in the prepared statementsedges - an array of Edge edge iteratorselementMapping - a map specifying the column names where the element attributes as EID, SVID, DVID should be stored.edgeIDType - the property type of the edge IDsvertexIDType - the property type of the vertex IDs
public static void writeTwoTablesGraphVertexAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String vertexTableName,
int batchSize,
java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] vertices)
conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)vertexTableName - the name of the vertex tablebatchSize - the batch size used in the prepared statementsvertices - an array of Vertex vertex iterables
public static void writeTwoTablesGraphVertexAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String vertexTableName,
int batchSize,
java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] vertices,
java.util.Map<java.lang.String,java.lang.String> elementMappings)
conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)vertexTableName - the name of the vertex tablebatchSize - the batch size used in the prepared statementsvertices - an array of Vertex vertex iterableselementMappings - a map specifying the column names where the element attributes as VID should be stored.
public static void writeTwoTablesGraphVertexAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String vertexTableName,
int batchSize,
java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] vertices,
java.util.Map<java.lang.String,java.lang.String> elementMappings,
oracle.pgx.common.types.IdType vertexIDType)
conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)vertexTableName - the name of the vertex tablebatchSize - the batch size used in the prepared statementsvertices - an array of Vertex vertex iterableselementMappings - a map specifying the column names where the element attributes as VID should be stored.vertexIDType - the property type of the vertex IDs
public static void writeTwoTablesGraphVertexAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String vertexTableName,
int batchSize,
java.util.Iterator<com.tinkerpop.blueprints.Vertex>[] vertices)
conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)vertexTableName - the name of the vertex tablebatchSize - the batch size used in the prepared statementsvertices - an array of Vertex vertex iterators
public static void writeTwoTablesGraphVertexAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String vertexTableName,
int batchSize,
java.util.Iterator<com.tinkerpop.blueprints.Vertex>[] vertices,
java.util.Map<java.lang.String,java.lang.String> elementMapping)
conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)vertexTableName - the name of the vertex tablebatchSize - the batch size used in the prepared statementsvertices - an array of Vertex vertex iteratorselementMapping - a map specifying the column names where the element attributes as VID should be stored.
public static void writeTwoTablesGraphVertexAndProperties(java.sql.Connection[] conns,
java.lang.String schema,
java.lang.String vertexTableName,
int batchSize,
java.util.Iterator<com.tinkerpop.blueprints.Vertex>[] vertices,
java.util.Map<java.lang.String,java.lang.String> elementMapping,
oracle.pgx.common.types.IdType vertexIDType)
conns - an array of Oracle connections to the databaseschema - the schema where the table was created (owner)vertexTableName - the name of the vertex tablebatchSize - the batch size used in the prepared statementsvertices - an array of Vertex vertex iteratorselementMapping - a map specifying the column names where the element attributes as VID should be stored.vertexIDType - the property type of the vertex IDsCopyright © 2017, 2018 Oracle and/or its affiliates. All Rights Reserved.