Modifier and Type | Method and Description |
---|---|
JsonArray |
AmqpMessage.bodyAsJsonArray() |
Modifier and Type | Method and Description |
---|---|
AmqpMessageBuilder |
AmqpMessageBuilder.withJsonArrayAsBody(JsonArray json) |
Modifier and Type | Method and Description |
---|---|
JsonArray |
Buffer.toJsonArray()
Returns a Json array representation of the Buffer.
|
Modifier and Type | Method and Description |
---|---|
JsonArray |
JsonArray.add(int pos,
Object value)
Add an Object to the JSON array at given position
pos . |
JsonArray |
JsonArray.add(Object value)
Add an Object to the JSON array.
|
JsonArray |
JsonArray.addAll(JsonArray array)
Appends all of the elements in the specified array to the end of this JSON array.
|
JsonArray |
JsonArray.addNull()
Add a null value to the JSON array.
|
JsonArray |
JsonArray.clear()
Remove all entries from the JSON array
|
JsonArray |
JsonArray.copy()
Deep copy of the JSON array.
|
JsonArray |
JsonArray.copy(java.util.function.Function<Object,?> cloner)
Deep copy of the JSON array.
|
JsonArray |
JsonArray.getJsonArray(int pos)
Get the JsonArray at position
pos in the array. |
JsonArray |
JsonObject.getJsonArray(String key)
Get the JsonArray value with the specified key
|
JsonArray |
JsonObject.getJsonArray(String key,
JsonArray def)
Like
JsonObject.getJsonArray(String) but specifying a default value to return if there is no entry. |
static JsonArray |
JsonArray.of(Object... values)
Create a JsonArray containing an arbitrary number of values.
|
JsonArray |
JsonArray.set(int pos,
Object value)
Set an Object to the JSON array at position
pos . |
JsonArray |
JsonArray.setNull(int pos)
Set a null value to the JSON array at position
pos . |
Modifier and Type | Method and Description |
---|---|
JsonArray |
JsonArray.addAll(JsonArray array)
Appends all of the elements in the specified array to the end of this JSON array.
|
JsonArray |
JsonObject.getJsonArray(String key,
JsonArray def)
Like
JsonObject.getJsonArray(String) but specifying a default value to return if there is no entry. |
Modifier and Type | Method and Description |
---|---|
JsonArray |
JsonEvent.arrayValue() |
Modifier and Type | Method and Description |
---|---|
String |
JDBCHashStrategy.getHashedStoredPwd(JsonArray row)
Deprecated.
Retrieve the hashed password from the result of the authentication query
|
String |
JDBCHashStrategy.getSalt(JsonArray row)
Deprecated.
Retrieve the salt from the result of the authentication query
|
void |
JDBCHashStrategy.setNonces(JsonArray nonces)
Deprecated.
Sets a ordered list of nonces where each position corresponds to a version.
|
JDBCAuth |
JDBCAuth.setNonces(JsonArray nonces)
Deprecated.
Provide a application configuration level on hash nonce's as a ordered list of
nonces where each position corresponds to a version.
|
Modifier and Type | Method and Description |
---|---|
AttestationCertificates |
AttestationCertificates.setX5c(JsonArray x5c) |
Modifier and Type | Method and Description |
---|---|
Object |
JDBCEncoder.encode(JsonArray input,
int pos,
JDBCColumnDescriptorProvider provider)
Convert Java input value to SQL value
|
Modifier and Type | Method and Description |
---|---|
JsonArray |
UpdateOptions.getArrayFilters()
Get the arrayFilters option.
|
Modifier and Type | Method and Description |
---|---|
Future<JsonArray> |
MongoClient.distinct(String collection,
String fieldName,
String resultClassname)
Like
MongoClient.distinct(String, String, String, Handler) but returns a Future of the asynchronous result |
Future<JsonArray> |
MongoClient.distinct(String collection,
String fieldName,
String resultClassname,
DistinctOptions distinctOptions)
Like
MongoClient.distinct(String, String, String, DistinctOptions, Handler) but returns a Future of the asynchronous result |
Future<JsonArray> |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Like
MongoClient.distinctWithQuery(String, String, String, JsonObject, Handler) but returns a Future of the asynchronous result |
Future<JsonArray> |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Like
MongoClient.distinctWithQuery(String, String, String, JsonObject, DistinctOptions, Handler) but returns a Future of the asynchronous result |
Future<JsonArray> |
MongoClient.listIndexes(String collection)
Like
MongoClient.listIndexes(String, Handler) but returns a Future of the asynchronous result |
Modifier and Type | Method and Description |
---|---|
ReadStream<JsonObject> |
MongoClient.aggregate(String collection,
JsonArray pipeline)
Run aggregate MongoDB command with default
AggregateOptions . |
ReadStream<JsonObject> |
MongoClient.aggregateWithOptions(String collection,
JsonArray pipeline,
AggregateOptions options)
Run aggregate MongoDB command.
|
UpdateOptions |
UpdateOptions.setArrayFilters(JsonArray arrayFilters)
Set the arrayFilters option
|
Future<MongoClientUpdateResult> |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonArray update)
Like
MongoClient.updateCollection(String, JsonObject, JsonArray, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonArray update,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Use an aggregation pipeline to update documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Future<MongoClientUpdateResult> |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options)
Like
MongoClient.updateCollectionWithOptions(String, JsonObject, JsonArray, UpdateOptions, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
ReadStream<com.mongodb.client.model.changestream.ChangeStreamDocument<JsonObject>> |
MongoClient.watch(String collection,
JsonArray pipeline,
boolean withUpdatedDoc,
int batchSize)
Watch the collection change.
|
Modifier and Type | Method and Description |
---|---|
MongoClient |
MongoClient.distinct(String collection,
String fieldName,
String resultClassname,
DistinctOptions distinctOptions,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name.
|
MongoClient |
MongoClient.distinct(String collection,
String fieldName,
String resultClassname,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name.
|
MongoClient |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
MongoClient.listIndexes(String collection,
Handler<AsyncResult<JsonArray>> resultHandler)
Get all the indexes in this collection.
|
Modifier and Type | Method and Description |
---|---|
JsonArray |
SQLOptions.getAutoGeneratedKeysIndexes() |
JsonArray |
UpdateResult.getKeys()
Get any generated keys
|
JsonArray |
ResultSet.getOutput()
Get the registered outputs
|
Modifier and Type | Method and Description |
---|---|
List<JsonArray> |
ResultSet.getResults()
Get the results
|
Modifier and Type | Method and Description |
---|---|
SQLConnection |
SQLConnection.callWithParams(String sql,
JsonArray params,
JsonArray outputs,
Handler<AsyncResult<ResultSet>> resultHandler)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
default SQLClient |
SQLClient.callWithParams(String sql,
JsonArray params,
JsonArray outputs,
Handler<AsyncResult<ResultSet>> handler)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
SQLOperations |
SQLOperations.callWithParams(String sql,
JsonArray params,
JsonArray outputs,
Handler<AsyncResult<ResultSet>> resultHandler)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
default SQLOperations |
SQLOperations.querySingleWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
SQLConnection |
SQLConnection.queryStreamWithParams(String sql,
JsonArray params,
Handler<AsyncResult<SQLRowStream>> handler)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
default SQLClient |
SQLClient.queryStreamWithParams(String sql,
JsonArray params,
Handler<AsyncResult<SQLRowStream>> handler)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
SQLOperations |
SQLOperations.queryStreamWithParams(String sql,
JsonArray params,
Handler<AsyncResult<SQLRowStream>> handler)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
SQLConnection |
SQLConnection.queryWithParams(String sql,
JsonArray params,
Handler<AsyncResult<ResultSet>> resultHandler)
Executes the given SQL
SELECT prepared statement which returns the results of the query. |
default SQLClient |
SQLClient.queryWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<ResultSet>> handler)
Execute a single SQL prepared statement, this method acquires a connection from the the pool and executes the SQL
prepared statement and returns it back after the execution.
|
SQLOperations |
SQLOperations.queryWithParams(String sql,
JsonArray params,
Handler<AsyncResult<ResultSet>> resultHandler)
Executes the given SQL
SELECT prepared statement which returns the results of the query. |
SQLOptions |
SQLOptions.setAutoGeneratedKeysIndexes(JsonArray autoGeneratedKeysIndexes) |
UpdateResult |
UpdateResult.setKeys(JsonArray keys) |
ResultSet |
ResultSet.setOutput(JsonArray output) |
SQLConnection |
SQLConnection.updateWithParams(String sql,
JsonArray params,
Handler<AsyncResult<UpdateResult>> resultHandler)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
default SQLClient |
SQLClient.updateWithParams(String sql,
JsonArray params,
Handler<AsyncResult<UpdateResult>> handler)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
SQLOperations |
SQLOperations.updateWithParams(String sql,
JsonArray params,
Handler<AsyncResult<UpdateResult>> resultHandler)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
Modifier and Type | Method and Description |
---|---|
SQLConnection |
SQLConnection.batchCallableWithParams(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs,
Handler<AsyncResult<List<Integer>>> handler)
Batch a callable statement with all entries from the args list.
|
SQLConnection |
SQLConnection.batchCallableWithParams(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs,
Handler<AsyncResult<List<Integer>>> handler)
Batch a callable statement with all entries from the args list.
|
SQLConnection |
SQLConnection.batchWithParams(String sqlStatement,
List<JsonArray> args,
Handler<AsyncResult<List<Integer>>> handler)
Batch a prepared statement with all entries from the args list.
|
SQLRowStream |
SQLRowStream.handler(Handler<JsonArray> handler) |
default SQLOperations |
SQLOperations.querySingle(String sql,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement that returns a single SQL row.
|
default SQLOperations |
SQLOperations.querySingleWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
ResultSet |
ResultSet.setResults(List<JsonArray> results) |
Constructor and Description |
---|
UpdateResult(int updated,
JsonArray keys)
Constructor
|
Constructor and Description |
---|
ResultSet(List<String> columnNames,
List<JsonArray> results,
ResultSet next)
Create a result-set
|
Modifier and Type | Method and Description |
---|---|
default JsonArray |
RequestBody.asJsonArray() |
JsonArray |
RequestBody.asJsonArray(int maxAllowedLength)
Gets the current body buffer as a
JsonArray . |
default JsonArray |
RoutingContext.getBodyAsJsonArray()
Deprecated.
Use
RoutingContext.body() instead. |
default JsonArray |
RoutingContext.getBodyAsJsonArray(int maxAllowedLength)
Deprecated.
Use
RoutingContext.body() instead.
Gets the current body buffer as a JsonArray . If a positive limit is provided the parsing will only happen
if the buffer length is smaller or equal to the limit. Otherwise an IllegalStateException is thrown.
When the application is only handling uploads in JSON format, it is recommended to set a limit on
BodyHandler.setBodyLimit(long) as this will avoid the upload to be parsed and
loaded into the application memory. |
Modifier and Type | Method and Description |
---|---|
JsonArray |
RequestParameter.getJsonArray()
Deprecated.
Returns null if value is not a JsonArray, otherwise it returns value
|
Modifier and Type | Method and Description |
---|---|
static OperationResponse |
OperationResponse.completedWithJson(JsonArray jsonArray)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static ServiceResponse |
ServiceResponse.completedWithJson(JsonArray jsonArray)
Creates a
ServiceResponse with status code 200, status message OK, content type application/json and jsonArray as body |
Modifier and Type | Method and Description |
---|---|
JsonArray |
HttpResponse.bodyAsJsonArray() |
Modifier and Type | Method and Description |
---|---|
static BodyCodec<JsonArray> |
BodyCodec.jsonArray() |
Modifier and Type | Method and Description |
---|---|
JsonArray |
RequestParameter.getJsonArray() |
Modifier and Type | Method and Description |
---|---|
JDBCConnectOptions |
JDBCConnectOptions.setAutoGeneratedKeysIndexes(JsonArray autoGeneratedKeysIndexes) |
Modifier and Type | Method and Description |
---|---|
JsonArray |
JsonArrayDeserializer.deserialize(String topic,
byte[] data) |
Modifier and Type | Method and Description |
---|---|
static org.apache.kafka.common.serialization.Serde<JsonArray> |
VertxSerdes.JsonArray() |
Modifier and Type | Method and Description |
---|---|
byte[] |
JsonArraySerializer.serialize(String topic,
JsonArray data) |
Modifier and Type | Method and Description |
---|---|
static Object |
VertxExtensionModule.getAt(JsonArray json,
int idx)
Subscript operator for
JsonArray , the read part. |
static void |
VertxExtensionModule.leftShift(JsonArray json,
Object value)
<< operator for JsonObject . |
Modifier and Type | Method and Description |
---|---|
static JsonArray |
MqttWill.propertiesToJson(MqttProperties properties) |
Modifier and Type | Method and Description |
---|---|
static MqttProperties |
MqttWill.propertiesFromJson(JsonArray array) |
Modifier and Type | Method and Description |
---|---|
JsonArray |
AmqpMessage.bodyAsJsonArray() |
Modifier and Type | Method and Description |
---|---|
AmqpMessageBuilder |
AmqpMessageBuilder.withJsonArrayAsBody(JsonArray json) |
Modifier and Type | Method and Description |
---|---|
JsonArray |
Buffer.toJsonArray()
Returns a Json array representation of the Buffer.
|
Modifier and Type | Method and Description |
---|---|
JsonArray |
JsonEvent.arrayValue() |
Modifier and Type | Method and Description |
---|---|
String |
JDBCHashStrategy.getHashedStoredPwd(JsonArray row)
Deprecated.
|
String |
JDBCHashStrategy.getSalt(JsonArray row)
Deprecated.
|
void |
JDBCHashStrategy.setNonces(JsonArray nonces)
Deprecated.
|
JDBCAuth |
JDBCAuth.setNonces(JsonArray nonces)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Maybe<JsonArray> |
JDBCClient.rxQuerySingle(String sql)
Execute a one shot SQL statement that returns a single SQL row.
|
Maybe<JsonArray> |
JDBCClient.rxQuerySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Modifier and Type | Method and Description |
---|---|
SQLOperations |
JDBCClient.querySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
SQLOperations |
JDBCClient.querySingleWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Maybe<JsonArray> |
JDBCClient.rxQuerySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Modifier and Type | Method and Description |
---|---|
SQLOperations |
JDBCClient.querySingle(String sql,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement that returns a single SQL row.
|
SQLOperations |
JDBCClient.querySingleWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Modifier and Type | Method and Description |
---|---|
Single<JsonArray> |
MongoClient.rxDistinct(String collection,
String fieldName,
String resultClassname)
Gets the distinct values of the specified field name.
|
Single<JsonArray> |
MongoClient.rxDistinct(String collection,
String fieldName,
String resultClassname,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name.
|
Single<JsonArray> |
MongoClient.rxDistinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Gets the distinct values of the specified field name filtered by specified query.
|
Single<JsonArray> |
MongoClient.rxDistinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
Single<JsonArray> |
MongoClient.rxListIndexes(String collection)
Get all the indexes in this collection.
|
Modifier and Type | Method and Description |
---|---|
ReadStream<JsonObject> |
MongoClient.aggregate(String collection,
JsonArray pipeline)
Run aggregate MongoDB command with default
AggregateOptions . |
ReadStream<JsonObject> |
MongoClient.aggregateWithOptions(String collection,
JsonArray pipeline,
AggregateOptions options)
Run aggregate MongoDB command.
|
Maybe<MongoClientUpdateResult> |
MongoClient.rxUpdateCollection(String collection,
JsonObject query,
JsonArray update)
Use an aggregation pipeline to update documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Maybe<MongoClientUpdateResult> |
MongoClient.rxUpdateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options)
Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonArray update)
Use an aggregation pipeline to update documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonArray update,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Use an aggregation pipeline to update documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options)
Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
ReadStream<com.mongodb.client.model.changestream.ChangeStreamDocument<JsonObject>> |
MongoClient.watch(String collection,
JsonArray pipeline,
boolean withUpdatedDoc,
int batchSize)
Watch the collection change.
|
Modifier and Type | Method and Description |
---|---|
MongoClient |
MongoClient.distinct(String collection,
String fieldName,
String resultClassname,
DistinctOptions distinctOptions,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name.
|
MongoClient |
MongoClient.distinct(String collection,
String fieldName,
String resultClassname,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name.
|
MongoClient |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
MongoClient.listIndexes(String collection,
Handler<AsyncResult<JsonArray>> resultHandler)
Get all the indexes in this collection.
|
Modifier and Type | Method and Description |
---|---|
ReadStream<JsonArray> |
SQLRowStream.fetch(long amount)
Fetch the specified
amount of elements. |
Pipe<JsonArray> |
SQLRowStream.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Maybe<JsonArray> |
SQLConnection.rxQuerySingle(String sql)
Execute a one shot SQL statement that returns a single SQL row.
|
Maybe<JsonArray> |
SQLClient.rxQuerySingle(String sql)
Execute a one shot SQL statement that returns a single SQL row.
|
Maybe<JsonArray> |
SQLOperations.rxQuerySingle(String sql)
Execute a one shot SQL statement that returns a single SQL row.
|
Maybe<JsonArray> |
SQLConnection.rxQuerySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Maybe<JsonArray> |
SQLClient.rxQuerySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Maybe<JsonArray> |
SQLOperations.rxQuerySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Flowable<JsonArray> |
SQLRowStream.toFlowable() |
Observable<JsonArray> |
SQLRowStream.toObservable() |
Modifier and Type | Method and Description |
---|---|
SQLConnection |
SQLConnection.callWithParams(String sql,
JsonArray params,
JsonArray outputs)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
SQLClient |
SQLClient.callWithParams(String sql,
JsonArray params,
JsonArray outputs)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
SQLOperations |
SQLOperations.callWithParams(String sql,
JsonArray params,
JsonArray outputs)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
SQLConnection |
SQLConnection.callWithParams(String sql,
JsonArray params,
JsonArray outputs,
Handler<AsyncResult<ResultSet>> resultHandler)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
SQLClient |
SQLClient.callWithParams(String sql,
JsonArray params,
JsonArray outputs,
Handler<AsyncResult<ResultSet>> handler)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
SQLOperations |
SQLOperations.callWithParams(String sql,
JsonArray params,
JsonArray outputs,
Handler<AsyncResult<ResultSet>> resultHandler)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
SQLOperations |
SQLConnection.querySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
SQLOperations |
SQLClient.querySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
SQLOperations |
SQLOperations.querySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
SQLOperations |
SQLConnection.querySingleWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
SQLOperations |
SQLClient.querySingleWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
SQLOperations |
SQLOperations.querySingleWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
SQLConnection |
SQLConnection.queryStreamWithParams(String sql,
JsonArray params)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
SQLClient |
SQLClient.queryStreamWithParams(String sql,
JsonArray params)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
SQLOperations |
SQLOperations.queryStreamWithParams(String sql,
JsonArray params)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
SQLConnection |
SQLConnection.queryStreamWithParams(String sql,
JsonArray params,
Handler<AsyncResult<SQLRowStream>> handler)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
SQLClient |
SQLClient.queryStreamWithParams(String sql,
JsonArray params,
Handler<AsyncResult<SQLRowStream>> handler)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
SQLOperations |
SQLOperations.queryStreamWithParams(String sql,
JsonArray params,
Handler<AsyncResult<SQLRowStream>> handler)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
SQLConnection |
SQLConnection.queryWithParams(String sql,
JsonArray params)
Executes the given SQL
SELECT prepared statement which returns the results of the query. |
SQLClient |
SQLClient.queryWithParams(String sql,
JsonArray arguments)
Execute a single SQL prepared statement, this method acquires a connection from the the pool and executes the SQL
prepared statement and returns it back after the execution.
|
SQLOperations |
SQLOperations.queryWithParams(String sql,
JsonArray params)
Executes the given SQL
SELECT prepared statement which returns the results of the query. |
SQLConnection |
SQLConnection.queryWithParams(String sql,
JsonArray params,
Handler<AsyncResult<ResultSet>> resultHandler)
Executes the given SQL
SELECT prepared statement which returns the results of the query. |
SQLClient |
SQLClient.queryWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<ResultSet>> handler)
Execute a single SQL prepared statement, this method acquires a connection from the the pool and executes the SQL
prepared statement and returns it back after the execution.
|
SQLOperations |
SQLOperations.queryWithParams(String sql,
JsonArray params,
Handler<AsyncResult<ResultSet>> resultHandler)
Executes the given SQL
SELECT prepared statement which returns the results of the query. |
Single<ResultSet> |
SQLConnection.rxCallWithParams(String sql,
JsonArray params,
JsonArray outputs)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
Single<ResultSet> |
SQLClient.rxCallWithParams(String sql,
JsonArray params,
JsonArray outputs)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
Single<ResultSet> |
SQLOperations.rxCallWithParams(String sql,
JsonArray params,
JsonArray outputs)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
Maybe<JsonArray> |
SQLConnection.rxQuerySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Maybe<JsonArray> |
SQLClient.rxQuerySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Maybe<JsonArray> |
SQLOperations.rxQuerySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Single<SQLRowStream> |
SQLConnection.rxQueryStreamWithParams(String sql,
JsonArray params)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
Single<SQLRowStream> |
SQLClient.rxQueryStreamWithParams(String sql,
JsonArray params)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
Single<SQLRowStream> |
SQLOperations.rxQueryStreamWithParams(String sql,
JsonArray params)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
Single<ResultSet> |
SQLConnection.rxQueryWithParams(String sql,
JsonArray params)
Executes the given SQL
SELECT prepared statement which returns the results of the query. |
Single<ResultSet> |
SQLClient.rxQueryWithParams(String sql,
JsonArray arguments)
Execute a single SQL prepared statement, this method acquires a connection from the the pool and executes the SQL
prepared statement and returns it back after the execution.
|
Single<ResultSet> |
SQLOperations.rxQueryWithParams(String sql,
JsonArray params)
Executes the given SQL
SELECT prepared statement which returns the results of the query. |
Single<UpdateResult> |
SQLConnection.rxUpdateWithParams(String sql,
JsonArray params)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
Single<UpdateResult> |
SQLClient.rxUpdateWithParams(String sql,
JsonArray params)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
Single<UpdateResult> |
SQLOperations.rxUpdateWithParams(String sql,
JsonArray params)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
SQLConnection |
SQLConnection.updateWithParams(String sql,
JsonArray params)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
SQLClient |
SQLClient.updateWithParams(String sql,
JsonArray params)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
SQLOperations |
SQLOperations.updateWithParams(String sql,
JsonArray params)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
SQLConnection |
SQLConnection.updateWithParams(String sql,
JsonArray params,
Handler<AsyncResult<UpdateResult>> resultHandler)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
SQLClient |
SQLClient.updateWithParams(String sql,
JsonArray params,
Handler<AsyncResult<UpdateResult>> handler)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
SQLOperations |
SQLOperations.updateWithParams(String sql,
JsonArray params,
Handler<AsyncResult<UpdateResult>> resultHandler)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
Modifier and Type | Method and Description |
---|---|
SQLConnection |
SQLConnection.batchCallableWithParams(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs)
Batch a callable statement with all entries from the args list.
|
SQLConnection |
SQLConnection.batchCallableWithParams(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs)
Batch a callable statement with all entries from the args list.
|
SQLConnection |
SQLConnection.batchCallableWithParams(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs,
Handler<AsyncResult<List<Integer>>> handler)
Batch a callable statement with all entries from the args list.
|
SQLConnection |
SQLConnection.batchCallableWithParams(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs,
Handler<AsyncResult<List<Integer>>> handler)
Batch a callable statement with all entries from the args list.
|
SQLConnection |
SQLConnection.batchWithParams(String sqlStatement,
List<JsonArray> args)
Batch a prepared statement with all entries from the args list.
|
SQLConnection |
SQLConnection.batchWithParams(String sqlStatement,
List<JsonArray> args,
Handler<AsyncResult<List<Integer>>> handler)
Batch a prepared statement with all entries from the args list.
|
SQLRowStream |
SQLRowStream.handler(Handler<JsonArray> handler) |
void |
SQLRowStream.pipeTo(WriteStream<JsonArray> dst)
Pipe this
ReadStream to the WriteStream . |
void |
SQLRowStream.pipeTo(WriteStream<JsonArray> dst,
Handler<AsyncResult<Void>> handler)
Pipe this
ReadStream to the WriteStream . |
SQLOperations |
SQLConnection.querySingle(String sql,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement that returns a single SQL row.
|
SQLOperations |
SQLClient.querySingle(String sql,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement that returns a single SQL row.
|
SQLOperations |
SQLOperations.querySingle(String sql,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement that returns a single SQL row.
|
SQLOperations |
SQLConnection.querySingleWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
SQLOperations |
SQLClient.querySingleWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
SQLOperations |
SQLOperations.querySingleWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Single<List<Integer>> |
SQLConnection.rxBatchCallableWithParams(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs)
Batch a callable statement with all entries from the args list.
|
Single<List<Integer>> |
SQLConnection.rxBatchCallableWithParams(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs)
Batch a callable statement with all entries from the args list.
|
Single<List<Integer>> |
SQLConnection.rxBatchWithParams(String sqlStatement,
List<JsonArray> args)
Batch a prepared statement with all entries from the args list.
|
Completable |
SQLRowStream.rxPipeTo(WriteStream<JsonArray> dst)
Pipe this
ReadStream to the WriteStream . |
Modifier and Type | Method and Description |
---|---|
JsonArray |
RequestBody.asJsonArray() |
JsonArray |
RequestBody.asJsonArray(int maxAllowedLength)
Gets the current body buffer as a .
|
JsonArray |
RoutingContext.getBodyAsJsonArray()
Deprecated.
|
JsonArray |
RoutingContext.getBodyAsJsonArray(int maxAllowedLength)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonArray |
RequestParameter.getJsonArray()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonArray |
HttpResponse.bodyAsJsonArray() |
Modifier and Type | Method and Description |
---|---|
static BodyCodec<JsonArray> |
BodyCodec.jsonArray() |
Modifier and Type | Method and Description |
---|---|
JsonArray |
RequestParameter.getJsonArray() |
Modifier and Type | Method and Description |
---|---|
Request |
Request.arg(JsonArray arg)
Adds a JsonArray argument, the encoding will serialize the json as value0, value1, ...
|
Modifier and Type | Method and Description |
---|---|
JsonArray[] |
Tuple.getArrayOfJsonArrays(int pos)
Get an array of value at
pos . |
JsonArray[] |
Row.getArrayOfJsonArrays(String column)
Get an array of value for the given
column . |
JsonArray |
Tuple.getJsonArray(int pos)
Get a value at
pos . |
JsonArray |
Row.getJsonArray(String column)
Get a value for the given
column . |
Modifier and Type | Method and Description |
---|---|
Tuple |
Tuple.addArrayOfJsonArray(JsonArray[] value)
Add an array of value at the end of the tuple.
|
Tuple |
Tuple.addJsonArray(JsonArray value)
Add a value at the end of the tuple.
|
Modifier and Type | Method and Description |
---|---|
default Request |
Request.arg(JsonArray arg)
Adds a JsonArray argument, the encoding will serialize the json as value0, value1, ...
|
Modifier and Type | Method and Description |
---|---|
JsonArray |
AmqpMessage.bodyAsJsonArray() |
Modifier and Type | Method and Description |
---|---|
AmqpMessageBuilder |
AmqpMessageBuilder.withJsonArrayAsBody(JsonArray json) |
Modifier and Type | Method and Description |
---|---|
JsonArray |
Buffer.toJsonArray()
Returns a Json array representation of the Buffer.
|
Modifier and Type | Method and Description |
---|---|
JsonArray |
JsonEvent.arrayValue() |
Modifier and Type | Method and Description |
---|---|
String |
JDBCHashStrategy.getHashedStoredPwd(JsonArray row)
Deprecated.
|
String |
JDBCHashStrategy.getSalt(JsonArray row)
Deprecated.
|
void |
JDBCHashStrategy.setNonces(JsonArray nonces)
Deprecated.
|
JDBCAuth |
JDBCAuth.setNonces(JsonArray nonces)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Single<JsonArray> |
JDBCClient.rxQuerySingle(String sql)
Execute a one shot SQL statement that returns a single SQL row.
|
Single<JsonArray> |
JDBCClient.rxQuerySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Modifier and Type | Method and Description |
---|---|
SQLOperations |
JDBCClient.querySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
SQLOperations |
JDBCClient.querySingleWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Single<JsonArray> |
JDBCClient.rxQuerySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Modifier and Type | Method and Description |
---|---|
SQLOperations |
JDBCClient.querySingle(String sql,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement that returns a single SQL row.
|
SQLOperations |
JDBCClient.querySingleWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Modifier and Type | Method and Description |
---|---|
Single<JsonArray> |
MongoClient.rxDistinct(String collection,
String fieldName,
String resultClassname)
Gets the distinct values of the specified field name.
|
Single<JsonArray> |
MongoClient.rxDistinct(String collection,
String fieldName,
String resultClassname,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name.
|
Single<JsonArray> |
MongoClient.rxDistinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Gets the distinct values of the specified field name filtered by specified query.
|
Single<JsonArray> |
MongoClient.rxDistinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
Single<JsonArray> |
MongoClient.rxListIndexes(String collection)
Get all the indexes in this collection.
|
Modifier and Type | Method and Description |
---|---|
ReadStream<JsonObject> |
MongoClient.aggregate(String collection,
JsonArray pipeline)
Run aggregate MongoDB command with default
AggregateOptions . |
ReadStream<JsonObject> |
MongoClient.aggregateWithOptions(String collection,
JsonArray pipeline,
AggregateOptions options)
Run aggregate MongoDB command.
|
Single<MongoClientUpdateResult> |
MongoClient.rxUpdateCollection(String collection,
JsonObject query,
JsonArray update)
Use an aggregation pipeline to update documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Single<MongoClientUpdateResult> |
MongoClient.rxUpdateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options)
Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonArray update)
Use an aggregation pipeline to update documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonArray update,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Use an aggregation pipeline to update documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options)
Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
ReadStream<com.mongodb.client.model.changestream.ChangeStreamDocument<JsonObject>> |
MongoClient.watch(String collection,
JsonArray pipeline,
boolean withUpdatedDoc,
int batchSize)
Watch the collection change.
|
Modifier and Type | Method and Description |
---|---|
MongoClient |
MongoClient.distinct(String collection,
String fieldName,
String resultClassname,
DistinctOptions distinctOptions,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name.
|
MongoClient |
MongoClient.distinct(String collection,
String fieldName,
String resultClassname,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name.
|
MongoClient |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
MongoClient.listIndexes(String collection,
Handler<AsyncResult<JsonArray>> resultHandler)
Get all the indexes in this collection.
|
Modifier and Type | Method and Description |
---|---|
ReadStream<JsonArray> |
SQLRowStream.fetch(long amount)
Fetch the specified
amount of elements. |
Pipe<JsonArray> |
SQLRowStream.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Single<JsonArray> |
SQLConnection.rxQuerySingle(String sql)
Execute a one shot SQL statement that returns a single SQL row.
|
Single<JsonArray> |
SQLClient.rxQuerySingle(String sql)
Execute a one shot SQL statement that returns a single SQL row.
|
Single<JsonArray> |
SQLOperations.rxQuerySingle(String sql)
Execute a one shot SQL statement that returns a single SQL row.
|
Single<JsonArray> |
SQLConnection.rxQuerySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Single<JsonArray> |
SQLClient.rxQuerySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Single<JsonArray> |
SQLOperations.rxQuerySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Observable<JsonArray> |
SQLRowStream.toObservable() |
Modifier and Type | Method and Description |
---|---|
SQLConnection |
SQLConnection.callWithParams(String sql,
JsonArray params,
JsonArray outputs)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
SQLClient |
SQLClient.callWithParams(String sql,
JsonArray params,
JsonArray outputs)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
SQLOperations |
SQLOperations.callWithParams(String sql,
JsonArray params,
JsonArray outputs)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
SQLConnection |
SQLConnection.callWithParams(String sql,
JsonArray params,
JsonArray outputs,
Handler<AsyncResult<ResultSet>> resultHandler)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
SQLClient |
SQLClient.callWithParams(String sql,
JsonArray params,
JsonArray outputs,
Handler<AsyncResult<ResultSet>> handler)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
SQLOperations |
SQLOperations.callWithParams(String sql,
JsonArray params,
JsonArray outputs,
Handler<AsyncResult<ResultSet>> resultHandler)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
SQLOperations |
SQLConnection.querySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
SQLOperations |
SQLClient.querySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
SQLOperations |
SQLOperations.querySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
SQLOperations |
SQLConnection.querySingleWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
SQLOperations |
SQLClient.querySingleWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
SQLOperations |
SQLOperations.querySingleWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
SQLConnection |
SQLConnection.queryStreamWithParams(String sql,
JsonArray params)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
SQLClient |
SQLClient.queryStreamWithParams(String sql,
JsonArray params)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
SQLOperations |
SQLOperations.queryStreamWithParams(String sql,
JsonArray params)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
SQLConnection |
SQLConnection.queryStreamWithParams(String sql,
JsonArray params,
Handler<AsyncResult<SQLRowStream>> handler)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
SQLClient |
SQLClient.queryStreamWithParams(String sql,
JsonArray params,
Handler<AsyncResult<SQLRowStream>> handler)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
SQLOperations |
SQLOperations.queryStreamWithParams(String sql,
JsonArray params,
Handler<AsyncResult<SQLRowStream>> handler)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
SQLConnection |
SQLConnection.queryWithParams(String sql,
JsonArray params)
Executes the given SQL
SELECT prepared statement which returns the results of the query. |
SQLClient |
SQLClient.queryWithParams(String sql,
JsonArray arguments)
Execute a single SQL prepared statement, this method acquires a connection from the the pool and executes the SQL
prepared statement and returns it back after the execution.
|
SQLOperations |
SQLOperations.queryWithParams(String sql,
JsonArray params)
Executes the given SQL
SELECT prepared statement which returns the results of the query. |
SQLConnection |
SQLConnection.queryWithParams(String sql,
JsonArray params,
Handler<AsyncResult<ResultSet>> resultHandler)
Executes the given SQL
SELECT prepared statement which returns the results of the query. |
SQLClient |
SQLClient.queryWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<ResultSet>> handler)
Execute a single SQL prepared statement, this method acquires a connection from the the pool and executes the SQL
prepared statement and returns it back after the execution.
|
SQLOperations |
SQLOperations.queryWithParams(String sql,
JsonArray params,
Handler<AsyncResult<ResultSet>> resultHandler)
Executes the given SQL
SELECT prepared statement which returns the results of the query. |
Single<ResultSet> |
SQLConnection.rxCallWithParams(String sql,
JsonArray params,
JsonArray outputs)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
Single<ResultSet> |
SQLClient.rxCallWithParams(String sql,
JsonArray params,
JsonArray outputs)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
Single<ResultSet> |
SQLOperations.rxCallWithParams(String sql,
JsonArray params,
JsonArray outputs)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
Single<JsonArray> |
SQLConnection.rxQuerySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Single<JsonArray> |
SQLClient.rxQuerySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Single<JsonArray> |
SQLOperations.rxQuerySingleWithParams(String sql,
JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Single<SQLRowStream> |
SQLConnection.rxQueryStreamWithParams(String sql,
JsonArray params)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
Single<SQLRowStream> |
SQLClient.rxQueryStreamWithParams(String sql,
JsonArray params)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
Single<SQLRowStream> |
SQLOperations.rxQueryStreamWithParams(String sql,
JsonArray params)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
Single<ResultSet> |
SQLConnection.rxQueryWithParams(String sql,
JsonArray params)
Executes the given SQL
SELECT prepared statement which returns the results of the query. |
Single<ResultSet> |
SQLClient.rxQueryWithParams(String sql,
JsonArray arguments)
Execute a single SQL prepared statement, this method acquires a connection from the the pool and executes the SQL
prepared statement and returns it back after the execution.
|
Single<ResultSet> |
SQLOperations.rxQueryWithParams(String sql,
JsonArray params)
Executes the given SQL
SELECT prepared statement which returns the results of the query. |
Single<UpdateResult> |
SQLConnection.rxUpdateWithParams(String sql,
JsonArray params)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
Single<UpdateResult> |
SQLClient.rxUpdateWithParams(String sql,
JsonArray params)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
Single<UpdateResult> |
SQLOperations.rxUpdateWithParams(String sql,
JsonArray params)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
SQLConnection |
SQLConnection.updateWithParams(String sql,
JsonArray params)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
SQLClient |
SQLClient.updateWithParams(String sql,
JsonArray params)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
SQLOperations |
SQLOperations.updateWithParams(String sql,
JsonArray params)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
SQLConnection |
SQLConnection.updateWithParams(String sql,
JsonArray params,
Handler<AsyncResult<UpdateResult>> resultHandler)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
SQLClient |
SQLClient.updateWithParams(String sql,
JsonArray params,
Handler<AsyncResult<UpdateResult>> handler)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
SQLOperations |
SQLOperations.updateWithParams(String sql,
JsonArray params,
Handler<AsyncResult<UpdateResult>> resultHandler)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
Modifier and Type | Method and Description |
---|---|
SQLConnection |
SQLConnection.batchCallableWithParams(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs)
Batch a callable statement with all entries from the args list.
|
SQLConnection |
SQLConnection.batchCallableWithParams(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs)
Batch a callable statement with all entries from the args list.
|
SQLConnection |
SQLConnection.batchCallableWithParams(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs,
Handler<AsyncResult<List<Integer>>> handler)
Batch a callable statement with all entries from the args list.
|
SQLConnection |
SQLConnection.batchCallableWithParams(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs,
Handler<AsyncResult<List<Integer>>> handler)
Batch a callable statement with all entries from the args list.
|
SQLConnection |
SQLConnection.batchWithParams(String sqlStatement,
List<JsonArray> args)
Batch a prepared statement with all entries from the args list.
|
SQLConnection |
SQLConnection.batchWithParams(String sqlStatement,
List<JsonArray> args,
Handler<AsyncResult<List<Integer>>> handler)
Batch a prepared statement with all entries from the args list.
|
SQLRowStream |
SQLRowStream.handler(Handler<JsonArray> handler) |
void |
SQLRowStream.pipeTo(WriteStream<JsonArray> dst)
Pipe this
ReadStream to the WriteStream . |
void |
SQLRowStream.pipeTo(WriteStream<JsonArray> dst,
Handler<AsyncResult<Void>> handler)
Pipe this
ReadStream to the WriteStream . |
SQLOperations |
SQLConnection.querySingle(String sql,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement that returns a single SQL row.
|
SQLOperations |
SQLClient.querySingle(String sql,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement that returns a single SQL row.
|
SQLOperations |
SQLOperations.querySingle(String sql,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement that returns a single SQL row.
|
SQLOperations |
SQLConnection.querySingleWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
SQLOperations |
SQLClient.querySingleWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
SQLOperations |
SQLOperations.querySingleWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
Single<List<Integer>> |
SQLConnection.rxBatchCallableWithParams(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs)
Batch a callable statement with all entries from the args list.
|
Single<List<Integer>> |
SQLConnection.rxBatchCallableWithParams(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs)
Batch a callable statement with all entries from the args list.
|
Single<List<Integer>> |
SQLConnection.rxBatchWithParams(String sqlStatement,
List<JsonArray> args)
Batch a prepared statement with all entries from the args list.
|
Single<Void> |
SQLRowStream.rxPipeTo(WriteStream<JsonArray> dst)
Pipe this
ReadStream to the WriteStream . |
Modifier and Type | Method and Description |
---|---|
JsonArray |
RequestBody.asJsonArray() |
JsonArray |
RequestBody.asJsonArray(int maxAllowedLength)
Gets the current body buffer as a .
|
JsonArray |
RoutingContext.getBodyAsJsonArray()
Deprecated.
|
JsonArray |
RoutingContext.getBodyAsJsonArray(int maxAllowedLength)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonArray |
RequestParameter.getJsonArray()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonArray |
HttpResponse.bodyAsJsonArray() |
Modifier and Type | Method and Description |
---|---|
static BodyCodec<JsonArray> |
BodyCodec.jsonArray() |
Modifier and Type | Method and Description |
---|---|
JsonArray |
RequestParameter.getJsonArray() |
Modifier and Type | Method and Description |
---|---|
Request |
Request.arg(JsonArray arg)
Adds a JsonArray argument, the encoding will serialize the json as value0, value1, ...
|
Modifier and Type | Method and Description |
---|---|
JsonArray[] |
Tuple.getArrayOfJsonArrays(int pos)
Get an array of value at
pos . |
JsonArray[] |
Row.getArrayOfJsonArrays(String column)
Get an array of value for the given
column . |
JsonArray |
Tuple.getJsonArray(int pos)
Get a value at
pos . |
JsonArray |
Row.getJsonArray(String column)
Get a value for the given
column . |
Modifier and Type | Method and Description |
---|---|
Tuple |
Tuple.addArrayOfJsonArray(JsonArray[] value)
Add an array of value at the end of the tuple.
|
Tuple |
Tuple.addJsonArray(JsonArray value)
Add a value at the end of the tuple.
|
Modifier and Type | Method and Description |
---|---|
JsonArray |
AmqpMessage.bodyAsJsonArray() |
Modifier and Type | Method and Description |
---|---|
AmqpMessageBuilder |
AmqpMessageBuilder.withJsonArrayAsBody(JsonArray json) |
Modifier and Type | Method and Description |
---|---|
JsonArray |
Buffer.toJsonArray()
Returns a Json array representation of the Buffer.
|
Modifier and Type | Method and Description |
---|---|
JsonArray |
JsonEvent.arrayValue() |
Modifier and Type | Method and Description |
---|---|
Single<JsonArray> |
MongoClient.distinct(String collection,
String fieldName,
String resultClassname)
Gets the distinct values of the specified field name.
|
Single<JsonArray> |
MongoClient.distinct(String collection,
String fieldName,
String resultClassname,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name.
|
Single<JsonArray> |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Gets the distinct values of the specified field name filtered by specified query.
|
Single<JsonArray> |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
Single<JsonArray> |
MongoClient.listIndexes(String collection)
Get all the indexes in this collection.
|
Single<JsonArray> |
MongoClient.rxDistinct(String collection,
String fieldName,
String resultClassname)
Gets the distinct values of the specified field name.
|
Single<JsonArray> |
MongoClient.rxDistinct(String collection,
String fieldName,
String resultClassname,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name.
|
Single<JsonArray> |
MongoClient.rxDistinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Gets the distinct values of the specified field name filtered by specified query.
|
Single<JsonArray> |
MongoClient.rxDistinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
Single<JsonArray> |
MongoClient.rxListIndexes(String collection)
Get all the indexes in this collection.
|
Modifier and Type | Method and Description |
---|---|
ReadStream<JsonObject> |
MongoClient.aggregate(String collection,
JsonArray pipeline)
Run aggregate MongoDB command with default
AggregateOptions . |
ReadStream<JsonObject> |
MongoClient.aggregateWithOptions(String collection,
JsonArray pipeline,
AggregateOptions options)
Run aggregate MongoDB command.
|
Maybe<MongoClientUpdateResult> |
MongoClient.rxUpdateCollection(String collection,
JsonObject query,
JsonArray update)
Use an aggregation pipeline to update documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Maybe<MongoClientUpdateResult> |
MongoClient.rxUpdateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options)
Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
Maybe<MongoClientUpdateResult> |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonArray update)
Use an aggregation pipeline to update documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Maybe<MongoClientUpdateResult> |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options)
Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
ReadStream<com.mongodb.client.model.changestream.ChangeStreamDocument<JsonObject>> |
MongoClient.watch(String collection,
JsonArray pipeline,
boolean withUpdatedDoc,
int batchSize)
Watch the collection change.
|
Modifier and Type | Method and Description |
---|---|
JsonArray |
RequestBody.asJsonArray() |
JsonArray |
RequestBody.asJsonArray(int maxAllowedLength)
Gets the current body buffer as a .
|
JsonArray |
RoutingContext.getBodyAsJsonArray()
Deprecated.
|
JsonArray |
RoutingContext.getBodyAsJsonArray(int maxAllowedLength)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonArray |
RequestParameter.getJsonArray()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonArray |
HttpResponse.bodyAsJsonArray() |
Modifier and Type | Method and Description |
---|---|
static BodyCodec<JsonArray> |
BodyCodec.jsonArray() |
Modifier and Type | Method and Description |
---|---|
JsonArray |
RequestParameter.getJsonArray() |
Modifier and Type | Method and Description |
---|---|
Request |
Request.arg(JsonArray arg)
Adds a JsonArray argument, the encoding will serialize the json as value0, value1, ...
|
Modifier and Type | Method and Description |
---|---|
JsonArray[] |
Tuple.getArrayOfJsonArrays(int pos)
Get an array of value at
pos . |
JsonArray[] |
Row.getArrayOfJsonArrays(String column)
Get an array of value for the given
column . |
JsonArray |
Tuple.getJsonArray(int pos)
Get a value at
pos . |
JsonArray |
Row.getJsonArray(String column)
Get a value for the given
column . |
Modifier and Type | Method and Description |
---|---|
Tuple |
Tuple.addArrayOfJsonArray(JsonArray[] value)
Add an array of value at the end of the tuple.
|
Tuple |
Tuple.addJsonArray(JsonArray value)
Add a value at the end of the tuple.
|
Modifier and Type | Method and Description |
---|---|
static JsonArray |
HelperUtils.convertStackTrace(Throwable cause) |
Modifier and Type | Method and Description |
---|---|
static List<Character> |
ProxyUtils.convertToListChar(JsonArray arr) |
static Set<Character> |
ProxyUtils.convertToSetChar(JsonArray arr) |
Modifier and Type | Method and Description |
---|---|
default JsonArray[] |
Tuple.getArrayOfJsonArrays(int pos)
Get an array of
JsonArray value at pos . |
default JsonArray[] |
Row.getArrayOfJsonArrays(String column)
Get an array of
JsonArray value for the given column . |
default JsonArray |
Tuple.getJsonArray(int pos)
Get a
JsonArray value at pos . |
default JsonArray |
Row.getJsonArray(String column)
Get a
JsonArray value for the given column . |
Modifier and Type | Method and Description |
---|---|
default Tuple |
Tuple.addArrayOfJsonArray(JsonArray[] value)
Add an array of
JsonArray value at the end of the tuple. |
default Tuple |
Tuple.addJsonArray(JsonArray value)
Add a
JsonArray value at the end of the tuple. |
Copyright © 2024 Eclipse. All rights reserved.