Class MongoDbExecute

java.lang.Object

io.helidon.dbclient.DbExecuteBase

io.helidon.dbclient.mongodb.MongoDbExecute

All Implemented Interfaces:

DbExecute

public class MongoDbExecute
extends DbExecuteBase

Execute implementation for MongoDB.

Method Summary

Modifier and Type	Method	Description
DbStatementDml	createNamedDelete(String name, String stmt)	Create a delete statement using a named statement passed as an argument.
DbStatementDml	createNamedDmlStatement(String name, String stmt)	Create a data modification statement using a named statement passed as an argument.
DbStatementGet	createNamedGet(String name, String stmt)	Create a database query returning a single row using a named statement passed as an argument.
DbStatementDml	createNamedInsert(String name, String stmt)	Create an insert statement using a named statement passed as an argument.
DbStatementQuery	createNamedQuery(String name, String stmt)	Create a database query using a named statement passed as argument.
DbStatementDml	createNamedUpdate(String name, String stmt)	Create an update statement using a named statement passed as an argument.
<C> C	unwrap(Class<C> cls)	Unwrap database executor internals.

Methods inherited from class DbExecuteBase

context, context, createDelete, createDmlStatement, createGet, createInsert, createNamedDelete, createNamedDmlStatement, createNamedGet, createNamedInsert, createNamedQuery, createNamedUpdate, createQuery, createUpdate, generateName, statementText

Modifier and Type	Method	Description
protected DbClientContext	context()	Return database client context.
protected <C extends DbClientContext> C	context(Class<C> cls)	Return database client context cast to it's extending class.
DbStatementDml	createDelete(String statement)	Create a delete statement using a statement text.
DbStatementDml	createDmlStatement(String statement)	Create a data modification statement using a statement passed as an argument.
DbStatementGet	createGet(String statement)	Create a database query returning a single row using a statement passed as an argument.
DbStatementDml	createInsert(String statement)	Create an insert statement using a statement text.
DbStatementDml	createNamedDelete(String statementName)	Create a delete statement using a named statement.
DbStatementDml	createNamedDmlStatement(String statementName)	Create a data modification statement using a statement defined in the configuration file.
DbStatementGet	createNamedGet(String statementName)	Create a database query returning a single row using a statement defined in the configuration file.
DbStatementDml	createNamedInsert(String statementName)	Create an insert statement using a named statement.
DbStatementQuery	createNamedQuery(String statementName)	Create a database query using a statement defined in the configuration file.
DbStatementDml	createNamedUpdate(String statementName)	Create an update statement using a named statement.
DbStatementQuery	createQuery(String statement)	Create a database query using a statement passed as an argument.
DbStatementDml	createUpdate(String statement)	Create an update statement using a statement text.
protected String	generateName(DbStatementType type, String statement)	Generate a name for a statement.
protected String	statementText(String name)	Return a statement text based on the statement name.

Methods inherited from class Object

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

Methods inherited from interface DbExecute

delete, dml, get, insert, namedDelete, namedDml, namedGet, namedInsert, namedQuery, namedUpdate, query, update

Modifier and Type	Method	Description
default long	delete(String statement, Object... parameters)	Create and execute delete statement using a statement passed as an argument.
default long	dml(String statement, Object... parameters)	Create and execute data modification statement using a statement passed as an argument.
default Optional<DbRow>	get(String statement, Object... parameters)	Create and execute a database query using a statement passed as an argument.
default long	insert(String statement, Object... parameters)	Create and execute insert statement using a statement passed as an argument.
default long	namedDelete(String statementName, Object... parameters)	Create and execute delete statement using a statement defined in the configuration file.
default long	namedDml(String statementName, Object... parameters)	Create and execute a data modification statement using a statement defined in the configuration file.
default Optional<DbRow>	namedGet(String statementName, Object... parameters)	Create and execute a database query using a statement defined in the configuration file.
default long	namedInsert(String statementName, Object... parameters)	Create and execute insert statement using a statement defined in the configuration file.
default Stream<DbRow>	namedQuery(String statementName, Object... parameters)	Create and execute a database query using a statement defined in the configuration file.
default long	namedUpdate(String statementName, Object... parameters)	Create and execute update statement using a statement defined in the configuration file.
default Stream<DbRow>	query(String statement, Object... parameters)	Create and execute a database query using a statement passed as an argument.
default long	update(String statement, Object... parameters)	Create and execute update statement using a statement passed as an argument.

Method Details

createNamedQuery

public DbStatementQuery createNamedQuery(String name,
 String stmt)

Description copied from interface: DbExecute

Create a database query using a named statement passed as argument.

Parameters:

name - the name of the statement

stmt - the query statement

Returns:

database statement that can process query returning multiple rows

createNamedGet

public DbStatementGet createNamedGet(String name,
 String stmt)

Description copied from interface: DbExecute

Create a database query returning a single row using a named statement passed as an argument.

Parameters:

name - the name of the statement

stmt - the statement text

Returns:

database statement that can process query returning a single row

createNamedDmlStatement

public DbStatementDml createNamedDmlStatement(String name,
 String stmt)

Description copied from interface: DbExecute

Create a data modification statement using a named statement passed as an argument.

Parameters:

name - the name of the statement

stmt - the statement text

Returns:

data modification statement

createNamedInsert

public DbStatementDml createNamedInsert(String name,
 String stmt)

Description copied from interface: DbExecute

Create an insert statement using a named statement passed as an argument.

Parameters:

name - the name of the statement

stmt - the statement text

Returns:

database statement that can insert data

createNamedUpdate

public DbStatementDml createNamedUpdate(String name,
 String stmt)

Description copied from interface: DbExecute

Create an update statement using a named statement passed as an argument.

Parameters:

name - the name of the statement

stmt - the statement text

Returns:

database statement that can update data

createNamedDelete

public DbStatementDml createNamedDelete(String name,
 String stmt)

Description copied from interface: DbExecute

Create a delete statement using a named statement passed as an argument.

Parameters:

name - the name of the statement

stmt - the statement text

Returns:

database statement that can delete data

unwrap

public <C> C unwrap(Class<C> cls)

Description copied from interface: DbExecute

Unwrap database executor internals. Only database connection is supported. This connection instance is being used to execute all statements in current database executor context.

When java.sql.Connection is requested for JDBC provider, this connection must be closed by user code using close() method on returned Connection instance.

Type Parameters:

C - target class to be unwrapped

Parameters:

cls - target class to be unwrapped

Returns:

database executor internals matching provided class