/*
 * Copyright 2014 Red Hat, Inc.
 *
 * Red Hat licenses this file to you under the Apache License, version 2.0
 * (the "License"); you may not use this file except in compliance with the
 * License.  You may obtain a copy of the License at:
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.  See the
 * License for the specific language governing permissions and limitations
 * under the License.
 */

package io.reactiverse.reactivex.pgclient;

import java.util.Map;
import io.reactivex.Observable;
import io.reactivex.Flowable;
import io.reactivex.Single;
import io.reactivex.Completable;
import io.reactivex.Maybe;
import java.util.List;
import io.vertx.core.AsyncResult;
import io.vertx.core.Handler;

A pool of connection.

NOTE: This class has been automatically generated from the original non RX-ified interface using Vert.x codegen.
/** * A pool of connection. * * <p/> * NOTE: This class has been automatically generated from the {@link io.reactiverse.pgclient.PgPool original} non RX-ified interface using Vert.x codegen. */
@io.vertx.lang.rx.RxGen(io.reactiverse.pgclient.PgPool.class) public class PgPool extends io.reactiverse.reactivex.pgclient.PgClient { @Override public String toString() { return delegate.toString(); } @Override public boolean equals(Object o) { if (this == o) return true; if (o == null || getClass() != o.getClass()) return false; PgPool that = (PgPool) o; return delegate.equals(that.delegate); } @Override public int hashCode() { return delegate.hashCode(); } public static final io.vertx.lang.rx.TypeArg<PgPool> __TYPE_ARG = new io.vertx.lang.rx.TypeArg<>( obj -> new PgPool((io.reactiverse.pgclient.PgPool) obj), PgPool::getDelegate ); private final io.reactiverse.pgclient.PgPool delegate; public PgPool(io.reactiverse.pgclient.PgPool delegate) { super(delegate); this.delegate = delegate; } public io.reactiverse.pgclient.PgPool getDelegate() { return delegate; } public io.reactiverse.reactivex.pgclient.PgPool preparedQuery(String sql, Handler<AsyncResult<io.reactiverse.reactivex.pgclient.PgRowSet>> handler) { delegate.preparedQuery(sql, new Handler<AsyncResult<io.reactiverse.pgclient.PgRowSet>>() { public void handle(AsyncResult<io.reactiverse.pgclient.PgRowSet> ar) { if (ar.succeeded()) { handler.handle(io.vertx.core.Future.succeededFuture(io.reactiverse.reactivex.pgclient.PgRowSet.newInstance(ar.result()))); } else { handler.handle(io.vertx.core.Future.failedFuture(ar.cause())); } } }); return this; } public Single<io.reactiverse.reactivex.pgclient.PgRowSet> rxPreparedQuery(String sql) { return io.vertx.reactivex.impl.AsyncResultSingle.toSingle(handler -> { preparedQuery(sql, handler); }); } public io.reactiverse.reactivex.pgclient.PgPool query(String sql, Handler<AsyncResult<io.reactiverse.reactivex.pgclient.PgRowSet>> handler) { delegate.query(sql, new Handler<AsyncResult<io.reactiverse.pgclient.PgRowSet>>() { public void handle(AsyncResult<io.reactiverse.pgclient.PgRowSet> ar) { if (ar.succeeded()) { handler.handle(io.vertx.core.Future.succeededFuture(io.reactiverse.reactivex.pgclient.PgRowSet.newInstance(ar.result()))); } else { handler.handle(io.vertx.core.Future.failedFuture(ar.cause())); } } }); return this; } public Single<io.reactiverse.reactivex.pgclient.PgRowSet> rxQuery(String sql) { return io.vertx.reactivex.impl.AsyncResultSingle.toSingle(handler -> { query(sql, handler); }); } public io.reactiverse.reactivex.pgclient.PgPool preparedQuery(String sql, io.reactiverse.reactivex.pgclient.Tuple arguments, Handler<AsyncResult<io.reactiverse.reactivex.pgclient.PgRowSet>> handler) { delegate.preparedQuery(sql, arguments.getDelegate(), new Handler<AsyncResult<io.reactiverse.pgclient.PgRowSet>>() { public void handle(AsyncResult<io.reactiverse.pgclient.PgRowSet> ar) { if (ar.succeeded()) { handler.handle(io.vertx.core.Future.succeededFuture(io.reactiverse.reactivex.pgclient.PgRowSet.newInstance(ar.result()))); } else { handler.handle(io.vertx.core.Future.failedFuture(ar.cause())); } } }); return this; } public Single<io.reactiverse.reactivex.pgclient.PgRowSet> rxPreparedQuery(String sql, io.reactiverse.reactivex.pgclient.Tuple arguments) { return io.vertx.reactivex.impl.AsyncResultSingle.toSingle(handler -> { preparedQuery(sql, arguments, handler); }); } public io.reactiverse.reactivex.pgclient.PgPool preparedBatch(String sql, List<io.reactiverse.reactivex.pgclient.Tuple> batch, Handler<AsyncResult<io.reactiverse.reactivex.pgclient.PgRowSet>> handler) { delegate.preparedBatch(sql, batch.stream().map(elt -> elt.getDelegate()).collect(java.util.stream.Collectors.toList()), new Handler<AsyncResult<io.reactiverse.pgclient.PgRowSet>>() { public void handle(AsyncResult<io.reactiverse.pgclient.PgRowSet> ar) { if (ar.succeeded()) { handler.handle(io.vertx.core.Future.succeededFuture(io.reactiverse.reactivex.pgclient.PgRowSet.newInstance(ar.result()))); } else { handler.handle(io.vertx.core.Future.failedFuture(ar.cause())); } } }); return this; } public Single<io.reactiverse.reactivex.pgclient.PgRowSet> rxPreparedBatch(String sql, List<io.reactiverse.reactivex.pgclient.Tuple> batch) { return io.vertx.reactivex.impl.AsyncResultSingle.toSingle(handler -> { preparedBatch(sql, batch, handler); }); }
Get a connection from the pool.
Params:
  • handler – the handler that will get the connection result
/** * Get a connection from the pool. * @param handler the handler that will get the connection result */
public void getConnection(Handler<AsyncResult<io.reactiverse.reactivex.pgclient.PgConnection>> handler) { delegate.getConnection(new Handler<AsyncResult<io.reactiverse.pgclient.PgConnection>>() { public void handle(AsyncResult<io.reactiverse.pgclient.PgConnection> ar) { if (ar.succeeded()) { handler.handle(io.vertx.core.Future.succeededFuture(io.reactiverse.reactivex.pgclient.PgConnection.newInstance(ar.result()))); } else { handler.handle(io.vertx.core.Future.failedFuture(ar.cause())); } } }); }
Get a connection from the pool.
Returns:
/** * Get a connection from the pool. * @return */
public Single<io.reactiverse.reactivex.pgclient.PgConnection> rxGetConnection() { return io.vertx.reactivex.impl.AsyncResultSingle.toSingle(handler -> { getConnection(handler); }); }
Borrow a connection from the pool and begin a transaction, the underlying connection will be returned to the pool when the transaction ends.
Params:
  • handler –
/** * Borrow a connection from the pool and begin a transaction, the underlying connection will be returned * to the pool when the transaction ends. * @param handler */
public void begin(Handler<AsyncResult<io.reactiverse.reactivex.pgclient.PgTransaction>> handler) { delegate.begin(new Handler<AsyncResult<io.reactiverse.pgclient.PgTransaction>>() { public void handle(AsyncResult<io.reactiverse.pgclient.PgTransaction> ar) { if (ar.succeeded()) { handler.handle(io.vertx.core.Future.succeededFuture(io.reactiverse.reactivex.pgclient.PgTransaction.newInstance(ar.result()))); } else { handler.handle(io.vertx.core.Future.failedFuture(ar.cause())); } } }); }
Borrow a connection from the pool and begin a transaction, the underlying connection will be returned to the pool when the transaction ends.
Returns:the transaction
/** * Borrow a connection from the pool and begin a transaction, the underlying connection will be returned * to the pool when the transaction ends. * @return the transaction */
public Single<io.reactiverse.reactivex.pgclient.PgTransaction> rxBegin() { return io.vertx.reactivex.impl.AsyncResultSingle.toSingle(handler -> { begin(handler); }); }
Close the pool and release the associated resources.
/** * Close the pool and release the associated resources. */
public void close() { delegate.close(); } public static PgPool newInstance(io.reactiverse.pgclient.PgPool arg) { return arg != null ? new PgPool(arg) : null; } }