Package scriptella.jdbc

Class JdbcConnection

java.lang.Object
scriptella.spi.AbstractConnection
scriptella.jdbc.JdbcConnection
All Implemented Interfaces:
Connection, NativeConnectionProvider
Direct Known Subclasses:
OracleConnection
public class JdbcConnection extends AbstractConnection implements NativeConnectionProvider
Represents a JDBC connection. TODO Extract JDBCConnectionParameters class and JDBCStatementFactory as described in statement cache
Version:
1.0
Author:
Fyodor Kupolov

  • Field Details

    • STATEMENT_CACHE_KEY

      public static final String STATEMENT_CACHE_KEY
      See Also:

    • STATEMENT_SEPARATOR_KEY

      public static final String STATEMENT_SEPARATOR_KEY
      See Also:

    • STATEMENT_SEPARATOR_SINGLELINE_KEY

      public static final String STATEMENT_SEPARATOR_SINGLELINE_KEY
      See Also:

    • STATEMENT_BATCH_SIZE

      public static final String STATEMENT_BATCH_SIZE
      See Also:

    • STATEMENT_FETCH_SIZE

      public static final String STATEMENT_FETCH_SIZE
      See Also:

    • KEEPFORMAT_KEY

      public static final String KEEPFORMAT_KEY
      See Also:

    • AUTOCOMMIT_KEY

      public static final String AUTOCOMMIT_KEY
      See Also:

    • AUTOCOMMIT_SIZE_KEY

      public static final String AUTOCOMMIT_SIZE_KEY
      See Also:

    • FLUSH_BEFORE_QUERY

      public static final String FLUSH_BEFORE_QUERY
      See Also:

    • TRANSACTION_ISOLATION_KEY

      public static final String TRANSACTION_ISOLATION_KEY
      See Also:

    • TRANSACTION_ISOLATION_READ_UNCOMMITTED

      public static final String TRANSACTION_ISOLATION_READ_UNCOMMITTED
      See Also:

    • TRANSACTION_ISOLATION_READ_COMMITTED

      public static final String TRANSACTION_ISOLATION_READ_COMMITTED
      See Also:

    • TRANSACTION_ISOLATION_REPEATABLE_READ

      public static final String TRANSACTION_ISOLATION_REPEATABLE_READ
      See Also:

    • TRANSACTION_ISOLATION_SERIALIZABLE

      public static final String TRANSACTION_ISOLATION_SERIALIZABLE
      See Also:

    • statementCacheSize

      protected int statementCacheSize

    • statementBatchSize

      protected int statementBatchSize

    • statementFetchSize

      protected int statementFetchSize

    • flushBeforeQuery

      protected boolean flushBeforeQuery

    • separator

      protected String separator

    • separatorSingleLine

      protected boolean separatorSingleLine

    • keepformat

      protected boolean keepformat

    • autocommitSize

      protected int autocommitSize

  • Constructor Details

  • Method Details

    • getProgressCounter

      public AbstractConnection.StatementCounter getProgressCounter()
      Description copied from interface: Connection
      Optional live progress counter. Called on the execution thread only. Return a stable in-memory counter updated with the same semantics as Connection.getExecutedStatementsCount(), or null if unavailable. The reporter reads only its volatile value, never this connection. The counter must remain valid after close. Existing providers need not implement this method.
      Specified by:
      getProgressCounter in interface Connection

    • init

      protected void init(ConnectionParameters parameters)
      Called in constructor
      Parameters:
      parameters - connection parameters.

    • getUpdateCount

      public long getUpdateCount()
      Description copied from interface: Connection
      Returns the sum of positive update counts, or zero when unsupported.
      Specified by:
      getUpdateCount in interface Connection

    • initDialectIdentifier

      protected void initDialectIdentifier()
      Initializes dialect identifier for connection. If driver doesn't support DatabaseMetaData or other problem occurs, DialectIdentifier.NULL_DIALECT is used.

      May be overriden by subclasses.

    • executeScript

      public void executeScript(Resource scriptContent, ParametersCallback parametersCallback)
      Description copied from interface: Connection
      Executes a script specified by its content.

      scriptContent may be used as a key for caching purposes, i.e. provider may precompile scripts and use compiled versions for subsequent executions. Please note that only inline text resources can be safely cached.

      Specified by:
      executeScript in interface Connection
      Parameters:
      scriptContent - script content. Cannot be null.
      parametersCallback - callback to get parameter values. Cannot be null.

    • executeQuery

      public void executeQuery(Resource queryContent, ParametersCallback parametersCallback, QueryCallback queryCallback)
      Description copied from interface: Connection
      Executes a query specified by its content.

      Specified by:
      executeQuery in interface Connection
      Parameters:
      queryContent - query content. Cannot be null.
      parametersCallback - callback to get parameter values. Cannot be null.
      queryCallback - callback to call for each result set element produced by this query. Cannot be null.
      See Also:

    • newStatementCache

      protected scriptella.jdbc.StatementCache newStatementCache()
      Creates an instance of statement cache.
      Returns:
      new instance of statement cache.

    • commit

      public void commit()
      Description copied from interface: Connection
      Commits a current transaction (if any).

      Throwing an error during commit phase cause rollback.

      Specified by:
      commit in interface Connection
      Overrides:
      commit in class AbstractConnection

    • rollback

      public void rollback()
      Description copied from interface: Connection
      Rolls back a current transaction (if any).
      Specified by:
      rollback in interface Connection
      Overrides:
      rollback in class AbstractConnection

    • flush

      public void flush() throws ProviderException
      Throws:
      ProviderException

    • close

      public void close()
      Description copied from interface: Connection
      Closes the connection and releases all related resources.
      Specified by:
      close in interface Connection

    • getNativeConnection

      public Connection getNativeConnection()
      Description copied from interface: NativeConnectionProvider
      Returns the native connection which is wrapped by this object or null if this information is not available.
      Specified by:
      getNativeConnection in interface NativeConnectionProvider
      Returns:
      native connection which is wrapped by this object.

    • toString

      public String toString()
      Specified by:
      toString in interface Connection
      Overrides:
      toString in class AbstractConnection
      Returns:
      meaningful label for connection