com.github.pgasync.impl

Class PgConnection

java.lang.Object

com.github.pgasync.impl.PgConnection

All Implemented Interfaces:

Connection, Db, QueryExecutor, TransactionExecutor, java.lang.AutoCloseable

public class PgConnection
extends java.lang.Object
implements Connection

A connection to PostgreSQL backed. The postmaster forks a backend process for each connection. A connection can process only a single query at a time.

Author:

Antti Laisi

Constructor Summary

Constructors

Constructor and Description
PgConnection(PgProtocolStream stream, DataConverter dataConverter)

Method Summary

Modifier and Type	Method and Description
void	begin(java.util.function.Consumer<Transaction> handler, java.util.function.Consumer<java.lang.Throwable> onError) Begins a transaction.
void	close() Closes the connection.
void	query(java.lang.String sql, java.util.function.Consumer<ResultSet> onQuery, 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> onQuery, java.util.function.Consumer<java.lang.Throwable> onError) Executes an anonymous prepared statement.

Methods inherited from class java.lang.Object

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

Constructor Detail

PgConnection

public PgConnection(PgProtocolStream stream,
                    DataConverter dataConverter)

Method Detail

query

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

Description copied from interface: QueryExecutor

Executes a simple query.

Specified by:

query in interface QueryExecutor

Parameters:

sql - SQL to execute.

onQuery - Called when query is completed

onError - Called on exception thrown

query

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

Description copied from interface: QueryExecutor

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[].

Specified by:

query in interface QueryExecutor

Parameters:

sql - SQL to execute

params - List of parameters

onQuery - Called when query is completed

onError - Called on exception thrown

begin

public void begin(java.util.function.Consumer<Transaction> handler,
                  java.util.function.Consumer<java.lang.Throwable> onError)

Description copied from interface: TransactionExecutor

Begins a transaction.

Specified by:

begin in interface TransactionExecutor

Parameters:

handler - Called when transaction is successfully started.

onError - Called on exception thrown

close

public void close()

Description copied from interface: Connection

Closes the connection.

Specified by:

close in interface Connection

Specified by:

close in interface java.lang.AutoCloseable