com.github.pgasync

Interface QueryExecutor

All Known Subinterfaces:

Connection, ConnectionPool, Db, Transaction

All Known Implementing Classes:

NettyPgConnectionPool, PgConnection, PgConnectionPool

public interface QueryExecutor

QueryExecutor submits SQL for execution.

Author:

Antti Laisi

Method Summary

Modifier and Type	Method and Description
void	query(java.lang.String sql, java.util.function.Consumer<ResultSet> onResult, java.util.function.Consumer<java.lang.Throwable> onError) Executes a simple query.
void	query(java.lang.String sql, java.util.List params, java.util.function.Consumer<ResultSet> onResult, java.util.function.Consumer<java.lang.Throwable> onError) Executes an anonymous prepared statement.

Method Detail

query

void query(java.lang.String sql,
           java.util.function.Consumer<ResultSet> onResult,
           java.util.function.Consumer<java.lang.Throwable> onError)

Executes a simple query.

Parameters:

sql - SQL to execute.

onResult - Called when query is completed

onError - Called on exception thrown

query

void query(java.lang.String sql,
           java.util.List params,
           java.util.function.Consumer<ResultSet> onResult,
           java.util.function.Consumer<java.lang.Throwable> onError)

Executes an anonymous prepared statement. Uses native PostgreSQL syntax with $arg instead of ? to mark parameters. Supported parameter types are String, Character, Number, Time, Date, Timestamp and byte[].

Parameters:

sql - SQL to execute

params - List of parameters

onResult - Called when query is completed

onError - Called on exception thrown