Module io.helidon.dbclient
Package io.helidon.dbclient

Interface DbExecute

All Known Subinterfaces:
DbTransaction
All Known Implementing Classes:
AbstractDbExecute, MongoDbExecute, MongoDbTransaction
public interface DbExecute
Database executor.

The database executor provides methods to create DbStatement instances for different types of database statements.

The recommended approach is to use named statements, as that allows better metrics, tracing, logging etc. In case an unnamed statement is used, a name must be generated

There are five methods for each DbStatementType, example for query (the implementation detail is for the default implementation, providers may differ):

  1. DbStatement createNamedQuery(String, String) - full control over the name and content of the statement
  2. DbStatement createNamedQuery(String) - use statement text from configuration
  3. DbStatement createQuery(String) - use the provided statement, name is generated
  4. DbRowResult namedQuery(String, Object...) - shortcut method to a named query with a list of parameters (or with no parameters at all)
  5. DbRowResult query(String, Object...) - shortcut method to unnamed query with a list of parameters (or with no parameters at all)
The first three methods return a statement that can have parameters configured (and other details modified). The last two methods directly execute the statement and provide appropriate response for future processing. All the methods are non-blocking.

  • Method Details

    • createNamedQuery

      DbStatementQuery createNamedQuery(String statementName, String statement)
      Create a database query using a named statement passed as argument.
      Parameters:
      statementName - the name of the statement
      statement - the query statement
      Returns:
      database statement that can process query returning multiple rows

    • createNamedQuery

      DbStatementQuery createNamedQuery(String statementName)
      Create a database query using a statement defined in the configuration file.
      Parameters:
      statementName - the name of the configuration node with statement
      Returns:
      database statement that can process query returning multiple rows

    • createQuery

      DbStatementQuery createQuery(String statement)
      Create a database query using a statement passed as an argument.
      Parameters:
      statement - the query statement to be executed
      Returns:
      database statement that can process the query returning multiple rows

    • namedQuery

      default Multi<DbRow> namedQuery(String statementName, Object... parameters)
      Create and execute a database query using a statement defined in the configuration file.
      Parameters:
      statementName - the name of the configuration node with statement
      parameters - query parameters to set
      Returns:
      database query execution result which can contain multiple rows

    • query

      default Multi<DbRow> query(String statement, Object... parameters)
      Create and execute a database query using a statement passed as an argument.
      Parameters:
      statement - the query statement to be executed
      parameters - query parameters to set
      Returns:
      database query execution result which can contain multiple rows

    • createNamedGet

      DbStatementGet createNamedGet(String statementName, String statement)
      Create a database query returning a single row using a named statement passed as an argument.
      Parameters:
      statementName - the name of the statement
      statement - the statement text
      Returns:
      database statement that can process query returning a single row

    • createNamedGet

      DbStatementGet createNamedGet(String statementName)
      Create a database query returning a single row using a statement defined in the configuration file.
      Parameters:
      statementName - the name of the configuration node with statement
      Returns:
      database statement that can process query returning a single row

    • createGet

      DbStatementGet createGet(String statement)
      Create a database query returning a single row using a statement passed as an argument.
      Parameters:
      statement - the query statement to be executed
      Returns:
      database statement that can process query returning a single row

    • namedGet

      default Single<Optional<DbRow>> namedGet(String statementName, Object... parameters)
      Create and execute a database query using a statement defined in the configuration file.
      Parameters:
      statementName - the name of the configuration node with statement
      parameters - query parameters to set
      Returns:
      database query execution result which can contain single row

    • get

      default Single<Optional<DbRow>> get(String statement, Object... parameters)
      Create and execute a database query using a statement passed as an argument.
      Parameters:
      statement - the query statement to be executed
      parameters - query parameters to set
      Returns:
      database query execution result which can contain single row

    • createNamedInsert

      default DbStatementDml createNamedInsert(String statementName, String statement)
      Create an insert statement using a named statement passed as an argument.
      Parameters:
      statementName - the name of the statement
      statement - the statement text
      Returns:
      database statement that can insert data

    • createNamedInsert

      DbStatementDml createNamedInsert(String statementName)
      Create an insert statement using a named statement.
      Parameters:
      statementName - the name of the statement
      Returns:
      database statement that can insert data

    • createInsert

      DbStatementDml createInsert(String statement)
      Create an insert statement using a statement text.
      Parameters:
      statement - the statement text
      Returns:
      database statement that can insert data

    • namedInsert

      default Single<Long> namedInsert(String statementName, Object... parameters)
      Create and execute insert statement using a statement defined in the configuration file.
      Parameters:
      statementName - the name of the configuration node with statement
      parameters - query parameters to set
      Returns:
      number of rows inserted into the database

    • insert

      default Single<Long> insert(String statement, Object... parameters)
      Create and execute insert statement using a statement passed as an argument.
      Parameters:
      statement - the insert statement to be executed
      parameters - query parameters to set
      Returns:
      number of rows inserted into the database

    • createNamedUpdate

      default DbStatementDml createNamedUpdate(String statementName, String statement)
      Create an update statement using a named statement passed as an argument.
      Parameters:
      statementName - the name of the statement
      statement - the statement text
      Returns:
      database statement that can update data

    • createNamedUpdate

      DbStatementDml createNamedUpdate(String statementName)
      Create an update statement using a named statement.
      Parameters:
      statementName - the name of the statement
      Returns:
      database statement that can update data

    • createUpdate

      DbStatementDml createUpdate(String statement)
      Create an update statement using a statement text.
      Parameters:
      statement - the statement text
      Returns:
      database statement that can update data

    • namedUpdate

      default Single<Long> namedUpdate(String statementName, Object... parameters)
      Create and execute update statement using a statement defined in the configuration file.
      Parameters:
      statementName - the name of the configuration node with statement
      parameters - query parameters to set
      Returns:
      number of rows updateed into the database

    • update

      default Single<Long> update(String statement, Object... parameters)
      Create and execute update statement using a statement passed as an argument.
      Parameters:
      statement - the update statement to be executed
      parameters - query parameters to set
      Returns:
      number of rows updateed into the database

    • createNamedDelete

      default DbStatementDml createNamedDelete(String statementName, String statement)
      Create a delete statement using a named statement passed as an argument.
      Parameters:
      statementName - the name of the statement
      statement - the statement text
      Returns:
      database statement that can delete data

    • createNamedDelete

      DbStatementDml createNamedDelete(String statementName)
      Create andelete statement using a named statement.
      Parameters:
      statementName - the name of the statement
      Returns:
      database statement that can delete data

    • createDelete

      DbStatementDml createDelete(String statement)
      Create a delete statement using a statement text.
      Parameters:
      statement - the statement text
      Returns:
      database statement that can delete data

    • namedDelete

      default Single<Long> namedDelete(String statementName, Object... parameters)
      Create and execute delete statement using a statement defined in the configuration file.
      Parameters:
      statementName - the name of the configuration node with statement
      parameters - query parameters to set
      Returns:
      number of rows deleted from the database

    • delete

      default Single<Long> delete(String statement, Object... parameters)
      Create and execute delete statement using a statement passed as an argument.
      Parameters:
      statement - the delete statement to be executed
      parameters - query parameters to set
      Returns:
      number of rows deleted from the database

    • createNamedDmlStatement

      DbStatementDml createNamedDmlStatement(String statementName, String statement)
      Create a data modification statement using a named statement passed as an argument.
      Parameters:
      statementName - the name of the statement
      statement - the statement text
      Returns:
      data modification statement

    • createNamedDmlStatement

      DbStatementDml createNamedDmlStatement(String statementName)
      Create a data modification statement using a statement defined in the configuration file.
      Parameters:
      statementName - the name of the configuration node with statement
      Returns:
      data modification statement

    • createDmlStatement

      DbStatementDml createDmlStatement(String statement)
      Create a data modification statement using a statement passed as an argument.
      Parameters:
      statement - the data modification statement to be executed
      Returns:
      data modification statement

    • namedDml

      default Single<Long> namedDml(String statementName, Object... parameters)
      Create and execute a data modification statement using a statement defined in the configuration file.
      Parameters:
      statementName - the name of the configuration node with statement
      parameters - query parameters to set
      Returns:
      number of rows modified

    • dml

      default Single<Long> dml(String statement, Object... parameters)
      Create and execute data modification statement using a statement passed as an argument.
      Parameters:
      statement - the delete statement to be executed
      parameters - query parameters to set
      Returns:
      number of rows modified

    • unwrap

      <C> Single<C> unwrap(Class<C> cls)
      Unwrap database executor internals. Only database connection is supported. Any operations based on this connection are blocking. Reactive support must be implemented in user code. This connection instance is being used to execute all statements in current database executor context.
      Type Parameters:
      C - target class to be unwrapped
      Parameters:
      cls - target class to be unwrapped
      Returns:
      database executor internals future matching provided class
      Throws:
      UnsupportedOperationException - when provided class is not supported