Package oracle.pg.rdbms.pgql

Class PgqlExecution

  • All Implemented Interfaces:
    java.lang.AutoCloseable, PgqlPreparedStatement, PgqlStatement, oracle.pgql.lang.PreparedStatement
    public class PgqlExecution
extends java.lang.Object
implements PgqlPreparedStatement
    This class implements the PgqlStatement and PgqlPreparedStatement interfaces for executing PGQL queries against graphs stored in Oracle Database.

    Refer to the documentation of these interfaces for further explanation and sample code.

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void cancel()
      Allows to cancel currently running execute operation.
      void close()
      Releases this PgqlStatment's database and JDBC resources.
      static void deleteCache​(PgqlConnection pgqlConn, java.lang.String schema, java.lang.String graphName)  
      boolean execute​(int parallel, int dynamicSampling, java.lang.String matchOptions, java.lang.String options)
      Executes a PGQL Query, Modify or Create/Drop operation on this instance's property graph.
      boolean execute​(java.lang.String pgql, int parallel, int dynamicSampling, java.lang.String matchOptions, java.lang.String options)
      Executes a PGQL Query, Modify or Create/Drop operation on this instance's property graph.
      boolean execute​(java.lang.String matchOptions, java.lang.String options)
      Executes a PGQL Query, Modify or Create/Drop operation on this instance's property graph.
      boolean execute​(java.lang.String pgql, java.lang.String matchOptions, java.lang.String options)
      Executes a PGQL Query, Modify or Create/Drop operation on this instance's property graph.
      PgqlResultSet executeQuery()
      Translates this instance's PGQL statement into a SQL statement and executes the SQL against this instance's property graph.
      PgqlResultSet executeQuery​(int timeout, int parallel, int dynamicSampling, int maxResults, java.lang.String options)
      Translates this instance's PGQL statement into a SQL statement and executes the SQL against this instance's property graph.
      PgqlResultSet executeQuery​(java.lang.String pgql, int timeout, int parallel, int dynamicSampling, int maxResults, java.lang.String options)
      Translates this instance's PGQL statement into a SQL statement and executes the SQL against this instance's property graph.
      PgqlResultSet executeQuery​(java.lang.String pgql, java.lang.String options)
      Translates this instance's PGQL statement into a SQL statement and executes the SQL against this instance's property graph.
      int getBatchSize()
      Returns the number of commands that should be batched when executing updates
      int getFetchSize()
      Returns the the number of rows that should be fetched from the database when more rows are needed for a query result.
      long getModifyCount()
      Returns the number of rows that were modified by last execute operation
      PgqlResultSet getResultSet()
      Returns the current result as a PgqlResultSet object.
      void setArray​(int parameterIndex, java.util.List<?> x)
      Sets the designated parameter to the given Java List value.
      void setBatchSize​(int batchSize)
      Sets the number of commands that should be batched when executing updates
      void setBoolean​(int parameterIndex, boolean x)
      Sets the designated parameter to the given Java boolean value.
      void setDate​(int parameterIndex, java.time.LocalDate x)
      Sets the designated parameter to the given Java LocalDate value.
      void setDouble​(int parameterIndex, double x)
      Sets the designated parameter to the given Java double value.
      void setFetchSize​(int fetchSize)
      Sets the number of rows that should be fetched from the database when more rows are needed for a query result.
      void setFloat​(int parameterIndex, float x)
      Sets the designated parameter to the given Java float value.
      void setInt​(int parameterIndex, int x)
      Sets the designated parameter to the given Java int value.
      void setLong​(int parameterIndex, long x)
      Sets the designated parameter to the given Java long value.
      void setString​(int parameterIndex, java.lang.String x)
      Sets the designated parameter to the given Java String value.
      void setTime​(int parameterIndex, java.time.LocalTime x)
      Sets the designated parameter to the given Java LocalTime value.
      void setTimestamp​(int parameterIndex, java.sql.Timestamp x)
      Sets the designated parameter to the given Java Timestamp value.
      void setTimestamp​(int parameterIndex, java.time.LocalDateTime x)
      Sets the designated parameter to the given Java LocalDateTime value.
      void setTimestampWithTimezone​(int parameterIndex, java.time.OffsetDateTime x)
      Sets the designated parameter to the given Java OffsetDateTime value.
      void setTimeWithTimezone​(int parameterIndex, java.time.OffsetTime x)
      Sets the designated parameter to the given Java OffsetTime value.
      PgqlSqlQueryTrans translateQuery()
      Translates this instance's PGQL statement into a SQL statement.
      PgqlSqlQueryTrans translateQuery​(java.lang.String pgql, int parallel, int dynamicSampling, int maxResults, java.lang.String options)
      Translates this instance's PGQL statement into a SQL statement.
      PgqlSqlQueryTrans translateQuery​(java.lang.String pgql, java.lang.String options)
      Translates this instance's PGQL statement into a SQL statement.
      PgqlSqlTrans translateStatement()
      Translates this instance's PGQL statement into a series of SQL statements.
      PgqlSqlTrans translateStatement​(int parallel, int dynamicSampling, int maxResults, java.lang.String matchOptions, java.lang.String options)
      Translates this instance's PGQL statement into a series of SQL statements.
      PgqlSqlTrans translateStatement​(java.lang.String pgql, int parallel, int dynamicSampling, int maxResults, java.lang.String matchOptions, java.lang.String options)
      Translates the given PGQL statement into a series of SQL statements.
      PgqlSqlTrans translateStatement​(java.lang.String matchOptions, java.lang.String options)
      Translates this instance's PGQL statement into a series of SQL statements.
      PgqlSqlTrans translateStatement​(java.lang.String pgql, java.lang.String matchOptions, java.lang.String options)
      Translates the given PGQL statement into a series of SQL statements.

      • Methods inherited from class java.lang.Object

        equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Field Detail

      • USER_REQUESTED_CANCEL_ERROR

        public static final java.lang.String USER_REQUESTED_CANCEL_ERROR
        See Also:
        Constant Field Values

    • Method Detail

      • getResultSet

        public PgqlResultSet getResultSet()
        Returns the current result as a PgqlResultSet object.
        Specified by:
        getResultSet in interface PgqlStatement
        Specified by:
        getResultSet in interface oracle.pgql.lang.PreparedStatement
        Returns:
        a PgqlResultSet object with the result of the last executed PGQL query, or null if the query last executed PGQL was not a Select statement

      • getModifyCount

        public long getModifyCount()
        Description copied from interface: PgqlStatement
        Returns the number of rows that were modified by last execute operation
        Specified by:
        getModifyCount in interface PgqlStatement
        Returns:
        The number of rows modified

      • setBoolean

        public void setBoolean​(int parameterIndex,
                       boolean x)
        Sets the designated parameter to the given Java boolean value.
        Specified by:
        setBoolean in interface PgqlPreparedStatement
        Specified by:
        setBoolean in interface oracle.pgql.lang.PreparedStatement
        Parameters:
        parameterIndex - the first parameter is 1, the second is 2, ...
        x - the parameter value

      • setDouble

        public void setDouble​(int parameterIndex,
                      double x)
        Sets the designated parameter to the given Java double value.
        Specified by:
        setDouble in interface PgqlPreparedStatement
        Specified by:
        setDouble in interface oracle.pgql.lang.PreparedStatement
        Parameters:
        parameterIndex - the first parameter is 1, the second is 2, ...
        x - the parameter value

      • setFloat

        public void setFloat​(int parameterIndex,
                     float x)
        Sets the designated parameter to the given Java float value.
        Specified by:
        setFloat in interface PgqlPreparedStatement
        Specified by:
        setFloat in interface oracle.pgql.lang.PreparedStatement
        Parameters:
        parameterIndex - the first parameter is 1, the second is 2, ...
        x - the parameter value

      • setInt

        public void setInt​(int parameterIndex,
                   int x)
        Sets the designated parameter to the given Java int value.
        Specified by:
        setInt in interface PgqlPreparedStatement
        Specified by:
        setInt in interface oracle.pgql.lang.PreparedStatement
        Parameters:
        parameterIndex - the first parameter is 1, the second is 2, ...
        x - the parameter value

      • setLong

        public void setLong​(int parameterIndex,
                    long x)
        Sets the designated parameter to the given Java long value.
        Specified by:
        setLong in interface PgqlPreparedStatement
        Specified by:
        setLong in interface oracle.pgql.lang.PreparedStatement
        Parameters:
        parameterIndex - the first parameter is 1, the second is 2, ...
        x - the parameter value

      • setString

        public void setString​(int parameterIndex,
                      java.lang.String x)
        Sets the designated parameter to the given Java String value.
        Specified by:
        setString in interface PgqlPreparedStatement
        Specified by:
        setString in interface oracle.pgql.lang.PreparedStatement
        Parameters:
        parameterIndex - the first parameter is 1, the second is 2, ...
        x - the parameter value

      • setTimestamp

        public void setTimestamp​(int parameterIndex,
                         java.sql.Timestamp x)
        Sets the designated parameter to the given Java Timestamp value.

        Timestamp values are assumed to be in Coordinated Universal Time (UTC).

        Specified by:
        setTimestamp in interface PgqlPreparedStatement
        Parameters:
        parameterIndex - the first parameter is 1, the second is 2, ...
        x - the parameter value

      • setDate

        public void setDate​(int parameterIndex,
                    java.time.LocalDate x)
        Sets the designated parameter to the given Java LocalDate value.
        Specified by:
        setDate in interface oracle.pgql.lang.PreparedStatement
        Parameters:
        parameterIndex - the first parameter is 1, the second is 2, ...
        x - the parameter value

      • setTime

        public void setTime​(int parameterIndex,
                    java.time.LocalTime x)
        Sets the designated parameter to the given Java LocalTime value.
        Specified by:
        setTime in interface oracle.pgql.lang.PreparedStatement
        Parameters:
        parameterIndex - the first parameter is 1, the second is 2, ...
        x - the parameter value

      • setTimestamp

        public void setTimestamp​(int parameterIndex,
                         java.time.LocalDateTime x)
        Sets the designated parameter to the given Java LocalDateTime value.
        Specified by:
        setTimestamp in interface oracle.pgql.lang.PreparedStatement
        Parameters:
        parameterIndex - the first parameter is 1, the second is 2, ...
        x - the parameter value

      • setTimeWithTimezone

        public void setTimeWithTimezone​(int parameterIndex,
                                java.time.OffsetTime x)
        Sets the designated parameter to the given Java OffsetTime value.
        Specified by:
        setTimeWithTimezone in interface oracle.pgql.lang.PreparedStatement
        Parameters:
        parameterIndex - the first parameter is 1, the second is 2, ...
        x - the parameter value

      • setTimestampWithTimezone

        public void setTimestampWithTimezone​(int parameterIndex,
                                     java.time.OffsetDateTime x)
        Sets the designated parameter to the given Java OffsetDateTime value.
        Specified by:
        setTimestampWithTimezone in interface oracle.pgql.lang.PreparedStatement
        Parameters:
        parameterIndex - the first parameter is 1, the second is 2, ...
        x - the parameter value

      • setArray

        public void setArray​(int parameterIndex,
                     java.util.List<?> x)
        Sets the designated parameter to the given Java List value.
        Specified by:
        setArray in interface oracle.pgql.lang.PreparedStatement
        Parameters:
        parameterIndex - the first parameter is 1, the second is 2, ...
        x - the parameter value

      • translateQuery

        public PgqlSqlQueryTrans translateQuery()
                                 throws PgqlToSqlException,
                                        oracle.pgql.lang.PgqlException
        Translates this instance's PGQL statement into a SQL statement.
        Specified by:
        translateQuery in interface PgqlPreparedStatement
        Returns:
        a PgqlSqlQueryTrans object with the SQL translation and column metadata for the provided PGQL query
        Throws:
        PgqlToSqlException - if a server-side error occurs during translation
        oracle.pgql.lang.PgqlException - if a server-side error occurs or this method is called on a closed Statement

      • translateQuery

        public PgqlSqlQueryTrans translateQuery​(java.lang.String pgql,
                                        java.lang.String options)
                                 throws PgqlToSqlException,
                                        oracle.pgql.lang.PgqlException
        Translates this instance's PGQL statement into a SQL statement.

        Supported query options are:

        USE_RW=F Use CONNECT BY instead of recursive WITH for unbounded path traversals.

        MAX_PATH_LEN=n Traverse at most n hops when evaluating unbounded path traversals.

        Specified by:
        translateQuery in interface PgqlStatement
        Parameters:
        pgql - the PGQL query to translate
        options - additional options used to influence query translation
        Returns:
        a PgqlSqlQueryTrans object with the SQL translation and column metadata for the provided PGQL query
        Throws:
        PgqlToSqlException - if a server-side error occurs during translation
        oracle.pgql.lang.PgqlException - if a server-side error occurs or this method is called on a closed Statement

      • translateQuery

        public PgqlSqlQueryTrans translateQuery​(java.lang.String pgql,
                                        int parallel,
                                        int dynamicSampling,
                                        int maxResults,
                                        java.lang.String options)
                                 throws PgqlToSqlException,
                                        oracle.pgql.lang.PgqlException
        Translates this instance's PGQL statement into a SQL statement.

        Supported query options are:

        USE_RW=F Use CONNECT BY instead of recursive WITH for unbounded path traversals.

        MAX_PATH_LEN=n Traverse at most n hops when evaluating unbounded path traversals.

        Specified by:
        translateQuery in interface PgqlStatement
        Parameters:
        pgql - the PGQL query to translate
        parallel - the degree of parallelism to use for query execution
        dynamicSampling - the value for dynamic sampling
        maxResults - the maximum number of rows returned
        options - additional options used to influence query translation
        Returns:
        a PgqlSqlQueryTrans object with the SQL translation and column metadata for the provided PGQL query
        Throws:
        PgqlToSqlException - if a server-side error occurs during translation
        oracle.pgql.lang.PgqlException - if a server-side error occurs or this method is called on a closed Statement

      • translateStatement

        public PgqlSqlTrans translateStatement()
                                throws PgqlToSqlException,
                                       oracle.pgql.lang.PgqlException
        Description copied from interface: PgqlPreparedStatement
        Translates this instance's PGQL statement into a series of SQL statements.
        Specified by:
        translateStatement in interface PgqlPreparedStatement
        Returns:
        the SQL statements and metadata necessary to execute the provided SQL statement
        Throws:
        PgqlToSqlException - if a server-side error occurs during translation
        oracle.pgql.lang.PgqlException - if a server-side error occurs or this method is called on a closed Statement

      • translateStatement

        public PgqlSqlTrans translateStatement​(java.lang.String matchOptions,
                                       java.lang.String options)
                                throws PgqlToSqlException,
                                       oracle.pgql.lang.PgqlException
        Description copied from interface: PgqlPreparedStatement
        Translates this instance's PGQL statement into a series of SQL statements.
        Specified by:
        translateStatement in interface PgqlPreparedStatement
        Parameters:
        matchOptions - additional options used to influence query translation and execution
        options - additional options used to influence DDL/DML translation and execution
        Returns:
        the SQL statements and metadata necessary to execute the provided SQL statement
        Throws:
        PgqlToSqlException - if a server-side error occurs during translation
        oracle.pgql.lang.PgqlException - if a server-side error occurs or this method is called on a closed Statement

      • translateStatement

        public PgqlSqlTrans translateStatement​(java.lang.String pgql,
                                       java.lang.String matchOptions,
                                       java.lang.String options)
                                throws PgqlToSqlException,
                                       oracle.pgql.lang.PgqlException
        Description copied from interface: PgqlStatement
        Translates the given PGQL statement into a series of SQL statements.
        Specified by:
        translateStatement in interface PgqlStatement
        Parameters:
        pgql - the PGQL statement to translate
        matchOptions - additional options used to influence query translation and execution
        options - additional options used to influence DDL/DML translation and execution
        Returns:
        the SQL statements and metadata necessary to execute the provided SQL statement
        Throws:
        PgqlToSqlException - if a server-side error occurs during translation
        oracle.pgql.lang.PgqlException - if a server-side error occurs or this method is called on a closed Statement

      • translateStatement

        public PgqlSqlTrans translateStatement​(int parallel,
                                       int dynamicSampling,
                                       int maxResults,
                                       java.lang.String matchOptions,
                                       java.lang.String options)
                                throws PgqlToSqlException,
                                       oracle.pgql.lang.PgqlException
        Description copied from interface: PgqlPreparedStatement
        Translates this instance's PGQL statement into a series of SQL statements.
        Specified by:
        translateStatement in interface PgqlPreparedStatement
        Parameters:
        parallel - the degree of parallelism to use for query execution
        dynamicSampling - the value for dynamic sampling
        maxResults - the maximum number of rows returned
        matchOptions - additional options used to influence query translation and execution
        options - additional options used to influence DDL/DML translation and execution
        Returns:
        the SQL statements and metadata necessary to execute the provided SQL statement
        Throws:
        PgqlToSqlException - if a server-side error occurs during translation
        oracle.pgql.lang.PgqlException - if a server-side error occurs or this method is called on a closed Statement

      • translateStatement

        public PgqlSqlTrans translateStatement​(java.lang.String pgql,
                                       int parallel,
                                       int dynamicSampling,
                                       int maxResults,
                                       java.lang.String matchOptions,
                                       java.lang.String options)
                                throws PgqlToSqlException,
                                       oracle.pgql.lang.PgqlException
        Description copied from interface: PgqlStatement
        Translates the given PGQL statement into a series of SQL statements.
        Specified by:
        translateStatement in interface PgqlStatement
        Parameters:
        pgql - the PGQL statement to translate
        parallel - the degree of parallelism to use for query execution
        dynamicSampling - the value for dynamic sampling
        maxResults - the maximum number of rows returned
        matchOptions - additional options used to influence query translation and execution
        options - additional options used to influence DDL/DML translation and execution
        Returns:
        the SQL statements and metadata necessary to execute the provided SQL statement
        Throws:
        PgqlToSqlException - if a server-side error occurs during translation
        oracle.pgql.lang.PgqlException - if a server-side error occurs or this method is called on a closed Statement

      • executeQuery

        public PgqlResultSet executeQuery()
                           throws PgqlToSqlException,
                                  oracle.pgql.lang.PgqlException
        Translates this instance's PGQL statement into a SQL statement and executes the SQL against this instance's property graph.
        Specified by:
        executeQuery in interface PgqlPreparedStatement
        Specified by:
        executeQuery in interface oracle.pgql.lang.PreparedStatement
        Returns:
        a PgqlResultSet object with the result of the provided PGQL query
        Throws:
        PgqlToSqlException - if a server-side error occurs during translation or SQL execution
        oracle.pgql.lang.PgqlException - if a server-side error occurs or this method is called on a closed Statement

      • executeQuery

        public PgqlResultSet executeQuery​(java.lang.String pgql,
                                  java.lang.String options)
                           throws PgqlToSqlException,
                                  oracle.pgql.lang.PgqlException
        Translates this instance's PGQL statement into a SQL statement and executes the SQL against this instance's property graph.

        Supported query options are:

        USE_RW=F Use CONNECT BY instead of recursive WITH for unbounded path traversals.

        MAX_PATH_LEN=n Traverse at most n hops when evaluating unbounded path traversals.

        Specified by:
        executeQuery in interface PgqlStatement
        Parameters:
        pgql - the PGQL query to execute
        options - additional options used to influence query translation and execution
        Returns:
        a PgqlResultSet object with the result of the provided PGQL query
        Throws:
        PgqlToSqlException - if a server-side error occurs during translation or SQL execution
        oracle.pgql.lang.PgqlException - if a server-side error occurs or this method is called on a closed Statement

      • executeQuery

        public PgqlResultSet executeQuery​(int timeout,
                                  int parallel,
                                  int dynamicSampling,
                                  int maxResults,
                                  java.lang.String options)
                           throws PgqlToSqlException,
                                  oracle.pgql.lang.PgqlException
        Translates this instance's PGQL statement into a SQL statement and executes the SQL against this instance's property graph.

        Supported query options are:

        USE_RW=F Use CONNECT BY instead of recursive WITH for unbounded path traversals.

        MAX_PATH_LEN=n Traverse at most n hops when evaluating unbounded path traversals.

        Specified by:
        executeQuery in interface PgqlPreparedStatement
        Parameters:
        timeout - the number of seconds for query execution to finish
        parallel - the degree of parallelism to use for query execution
        dynamicSampling - the value for dynamic sampling
        maxResults - the maximum number of rows returned
        options - additional options used to influence query translation and execution
        Returns:
        a PgqlResultSet object with the result of the provided PGQL query
        Throws:
        PgqlToSqlException - if a server-side error occurs during translation or SQL execution
        oracle.pgql.lang.PgqlException - if a server-side error occurs or this method is called on a closed Statement

      • executeQuery

        public PgqlResultSet executeQuery​(java.lang.String pgql,
                                  int timeout,
                                  int parallel,
                                  int dynamicSampling,
                                  int maxResults,
                                  java.lang.String options)
                           throws PgqlToSqlException,
                                  oracle.pgql.lang.PgqlException
        Translates this instance's PGQL statement into a SQL statement and executes the SQL against this instance's property graph.

        Supported query options are:

        USE_RW=F Use CONNECT BY instead of recursive WITH for unbounded path traversals.

        MAX_PATH_LEN=n Traverse at most n hops when evaluating unbounded path traversals.

        Specified by:
        executeQuery in interface PgqlStatement
        Parameters:
        pgql - the PGQL query to execute
        timeout - the number of seconds for query execution to finish
        parallel - the degree of parallelism to use for query execution
        dynamicSampling - the value for dynamic sampling
        maxResults - the maximum number of rows returned
        options - additional options used to influence query translation and execution
        Returns:
        a PgqlResultSet object with the result of the provided PGQL query
        Throws:
        PgqlToSqlException - if a server-side error occurs during translation or SQL execution
        oracle.pgql.lang.PgqlException - if a server-side error occurs or this method is called on a closed Statement

      • execute

        public boolean execute​(java.lang.String matchOptions,
                       java.lang.String options)
                throws PgqlToSqlException,
                       oracle.pgql.lang.PgqlException
        Executes a PGQL Query, Modify or Create/Drop operation on this instance's property graph.

        Supported query options (matchOptions) are the same as those for executeQuery.

        Supported modify options are:

        STREAMING=T Use result sets instead of temporary tables to perform update.

        AUTO_COMMIT=F Do not commit after performing the modify operation.

        DELETE_CASCADE=F Do not delete incoming/outgoing edges when deleting a vertex.

        Specified by:
        execute in interface PgqlPreparedStatement
        Parameters:
        matchOptions - additional options used to influence query translation and execution
        options - additional options used to influence modify translation and execution
        Returns:
        true if the provided PGQL query is a select, false for other statements
        Throws:
        PgqlToSqlException - if a server-side error occurs during translation or SQL execution
        oracle.pgql.lang.PgqlException - if a server-side error occurs or this method is called on a closed Statement

      • execute

        public boolean execute​(java.lang.String pgql,
                       java.lang.String matchOptions,
                       java.lang.String options)
                throws PgqlToSqlException,
                       oracle.pgql.lang.PgqlException
        Executes a PGQL Query, Modify or Create/Drop operation on this instance's property graph.

        Supported query options (matchOptions) are the same as those for executeQuery.

        Supported modify options are:

        STREAMING=T Use result sets instead of temporary tables to perform the update.

        AUTO_COMMIT=F Do not commit after performing the modify operation.

        DELETE_CASCADE=F Do not delete incoming/outgoing edges when deleting a vertex.

        Specified by:
        execute in interface PgqlStatement
        Parameters:
        pgql - the PGQL to execute
        matchOptions - additional options used to influence query translation and execution
        options - additional options used to influence modify translation and execution
        Returns:
        true if the provided PGQL query is a select, false for other statements
        Throws:
        PgqlToSqlException - if a server-side error occurs during translation or SQL execution
        oracle.pgql.lang.PgqlException - if a server-side error occurs or this method is called on a closed Statement

      • execute

        public boolean execute​(int parallel,
                       int dynamicSampling,
                       java.lang.String matchOptions,
                       java.lang.String options)
                throws PgqlToSqlException,
                       oracle.pgql.lang.PgqlException
        Executes a PGQL Query, Modify or Create/Drop operation on this instance's property graph.

        Supported query options (matchOptions) are the same as those for executeQuery.

        Supported modify options are:

        STREAMING=T Use result sets instead of temporary tables to perform the update.

        AUTO_COMMIT=F Do not commit after performing the modify operation.

        DELETE_CASCADE=F Do not delete incoming/outgoing edges when deleting a vertex.

        Specified by:
        execute in interface PgqlPreparedStatement
        Parameters:
        parallel - the degree of parallelism to use for query and modify execution
        dynamicSampling - the value for dynamic sampling
        matchOptions - additional options used to influence query translation and execution
        options - additional options used to influence modify translation and execution
        Returns:
        true if the provided PGQL query is a select, false for other statements
        Throws:
        PgqlToSqlException - if a server-side error occurs during translation or SQL execution
        oracle.pgql.lang.PgqlException - if a server-side error occurs or this method is called on a closed Statement

      • execute

        public boolean execute​(java.lang.String pgql,
                       int parallel,
                       int dynamicSampling,
                       java.lang.String matchOptions,
                       java.lang.String options)
                throws PgqlToSqlException,
                       oracle.pgql.lang.PgqlException
        Executes a PGQL Query, Modify or Create/Drop operation on this instance's property graph.

        Supported query options (matchOptions) are the same as those for executeQuery.

        Supported modify options are:

        STREAMING=T Use result sets instead of temporary tables to perform the update.

        AUTO_COMMIT=F Do not commit after performing the modify operation.

        DELETE_CASCADE=F Do not delete incoming/outgoing edges when deleting a vertex.

        Specified by:
        execute in interface PgqlStatement
        Parameters:
        pgql - the PGQL modify to execute
        parallel - the degree of parallelism to use for query and update execution
        dynamicSampling - the value for dynamic sampling
        matchOptions - additional options used to influence query translation and execution
        options - additional options used to influence modify translation and execution
        Returns:
        true if the provided PGQL query is a select, false for other statements
        Throws:
        PgqlToSqlException - if a server-side error occurs during translation or SQL execution
        oracle.pgql.lang.PgqlException - if a server-side error occurs or this method is called on a closed Statement

      • setBatchSize

        public void setBatchSize​(int batchSize)
        Sets the number of commands that should be batched when executing updates
        Specified by:
        setBatchSize in interface PgqlStatement
        Parameters:
        batchSize - the update batch size

      • setFetchSize

        public void setFetchSize​(int fetchSize)
        Sets the number of rows that should be fetched from the database when more rows are needed for a query result.
        Specified by:
        setFetchSize in interface PgqlStatement
        Parameters:
        fetchSize - the query fetch size

      • getBatchSize

        public int getBatchSize()
        Returns the number of commands that should be batched when executing updates
        Specified by:
        getBatchSize in interface PgqlStatement
        Returns:
        the update batch size

      • getFetchSize

        public int getFetchSize()
        Returns the the number of rows that should be fetched from the database when more rows are needed for a query result.
        Specified by:
        getFetchSize in interface PgqlStatement
        Returns:
        the query fetch size

      • close

        public void close()
           throws oracle.pgql.lang.PgqlException
        Releases this PgqlStatment's database and JDBC resources. Closing this PgqlStatement will close all PgqlResultSets that were created from it.
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface PgqlStatement
        Specified by:
        close in interface oracle.pgql.lang.PreparedStatement
        Throws:
        oracle.pgql.lang.PgqlException

      • cancel

        public void cancel()
            throws oracle.pgql.lang.PgqlException
        Description copied from interface: PgqlStatement
        Allows to cancel currently running execute operation. Note that cancel does not rollback already executed modifications.
        Specified by:
        cancel in interface PgqlStatement
        Throws:
        oracle.pgql.lang.PgqlException - When an error occurs while canceling current operation.

      • deleteCache

        public static void deleteCache​(PgqlConnection pgqlConn,
                               java.lang.String schema,
                               java.lang.String graphName)