io.vertx.sqlclient.impl.cache

Class PreparedStatementCache

java.lang.Object

io.vertx.sqlclient.impl.cache.PreparedStatementCache

public class PreparedStatementCache
extends Object

Cache which manages the lifecycle of all cached prepared statements .

Constructor Summary

Constructors

Constructor and Description
PreparedStatementCache(SocketConnectionBase conn, int cacheCapacity)

Method Summary

Modifier and Type	Method and Description
Handler<AsyncResult<PreparedStatement>>	appendStmtReq(String sql, Handler<AsyncResult<PreparedStatement>> originalHandler) Append a new prepared statement request to this cache.
void	remove(String sql) Remove the cached entry when the cached statement is closing so that pending requests will not use a closed prepared statement.

Methods inherited from class java.lang.Object

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

Constructor Detail

PreparedStatementCache

public PreparedStatementCache(SocketConnectionBase conn,
                              int cacheCapacity)

Method Detail

appendStmtReq

public Handler<AsyncResult<PreparedStatement>> appendStmtReq(String sql,
                                                             Handler<AsyncResult<PreparedStatement>> originalHandler)

Append a new prepared statement request to this cache.

Parameters:

sql - the sql string to be prepare

originalHandler - the original prepare command handler

Returns:

null if the result has been cached or the network request is inflight, or a new Handler which represents the handler of all appending req waiters so it can be called when the command response is ready.

remove

public void remove(String sql)

Remove the cached entry when the cached statement is closing so that pending requests will not use a closed prepared statement.

Parameters:

sql - the identified sql of the cached statement