Module io.helidon.dbclient.mongodb

Package io.helidon.dbclient.mongodb

Class MongoDbExecute

java.lang.Object

io.helidon.dbclient.common.AbstractDbExecute

io.helidon.dbclient.mongodb.MongoDbExecute

All Implemented Interfaces:

DbExecute

Direct Known Subclasses:

MongoDbTransaction

public class MongoDbExecute
extends AbstractDbExecute
implements DbExecute

Execute implementation for MongoDB.

Method Summary

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

Methods inherited from class io.helidon.dbclient.common.AbstractDbExecute

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.helidon.dbclient.DbExecute

createDelete, createDmlStatement, createGet, createInsert, createNamedDelete, createNamedDmlStatement, createNamedGet, createNamedInsert, createNamedQuery, createNamedUpdate, createQuery, createUpdate, delete, dml, get, insert, namedDelete, namedDml, namedGet, namedInsert, namedQuery, namedUpdate, query, update

Method Detail

createNamedQuery

public DbStatementQuery createNamedQuery(String statementName,
                                         String statement)

Description copied from interface: DbExecute

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

Specified by:

createNamedQuery in interface DbExecute

Parameters:

statementName - the name of the statement

statement - the query statement

Returns:

database statement that can process query returning multiple rows

createNamedGet

public DbStatementGet createNamedGet(String statementName,
                                     String statement)

Description copied from interface: DbExecute

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

Specified by:

createNamedGet in interface DbExecute

Parameters:

statementName - the name of the statement

statement - the statement text

Returns:

database statement that can process query returning a single row

createNamedDmlStatement

public DbStatementDml createNamedDmlStatement(String statementName,
                                              String statement)

Description copied from interface: DbExecute

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

Specified by:

createNamedDmlStatement in interface DbExecute

Parameters:

statementName - the name of the statement

statement - the statement text

Returns:

data modification statement

createNamedInsert

public DbStatementDml createNamedInsert(String statementName,
                                        String statement)

Description copied from interface: DbExecute

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

Specified by:

createNamedInsert in interface DbExecute

Parameters:

statementName - the name of the statement

statement - the statement text

Returns:

database statement that can insert data

createNamedUpdate

public DbStatementDml createNamedUpdate(String statementName,
                                        String statement)

Description copied from interface: DbExecute

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

Specified by:

createNamedUpdate in interface DbExecute

Parameters:

statementName - the name of the statement

statement - the statement text

Returns:

database statement that can update data

createNamedDelete

public DbStatementDml createNamedDelete(String statementName,
                                        String statement)

Description copied from interface: DbExecute

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

Specified by:

createNamedDelete in interface DbExecute

Parameters:

statementName - the name of the statement

statement - the statement text

Returns:

database statement that can delete data

unwrap

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

Description copied from interface: DbExecute

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.

Specified by:

unwrap in interface DbExecute

Type Parameters:

C - target class to be unwrapped

Parameters:

cls - target class to be unwrapped

Returns:

database executor internals future matching provided class