/*
 * Copyright (c) 2011-2020 Contributors to the Eclipse Foundation
 *
 * This program and the accompanying materials are made available under the
 * terms of the Eclipse Public License 2.0 which is available at
 * http://www.eclipse.org/legal/epl-2.0, or the Apache License, Version 2.0
 * which is available at https://www.apache.org/licenses/LICENSE-2.0.
 *
 * SPDX-License-Identifier: EPL-2.0 OR Apache-2.0
 */

package io.vertx.sqlclient.impl.cache;

import io.vertx.sqlclient.impl.PreparedStatement;

import java.util.List;

Cache which manages the lifecycle of all cached prepared statements .
/** * Cache which manages the lifecycle of all cached prepared statements . */
public class PreparedStatementCache { private final int capacity; private final LruCache<String, PreparedStatement> cache; public PreparedStatementCache(int cacheCapacity) { this.capacity = cacheCapacity; this.cache = new LruCache<>(cacheCapacity); } public PreparedStatement get(String sql) { return cache.get(sql); }
Put a statement in the cache.
Params:
  • preparedStatement – the prepared statement to cache
Returns:the list of prepared statement to evict and close
/** * Put a statement in the cache. * * @param preparedStatement the prepared statement to cache * @return the list of prepared statement to evict and close */
public List<PreparedStatement> put(PreparedStatement preparedStatement) { return cache.cache(preparedStatement.sql(), preparedStatement); }
Remove the cached entry when the cached statement is closing so that pending requests will not use a closed prepared statement.
Params:
  • sql – the identified sql of the cached statement
/** * Remove the cached entry when the cached statement is closing so that pending requests will not use a closed prepared statement. * * @param sql the identified sql of the cached statement */
public void remove(String sql) { this.cache.remove(sql); } public PreparedStatement evict() { return cache.evict(); } public boolean isFull() { return cache.size() == capacity; }
Returns:the cache size
/** * @return the cache size */
public int size() { return cache.size(); } }