Skip to content

Commit 5c6571d

Browse files
authored
Prepared statement cache eviction (#562)
1 parent 4cae654 commit 5c6571d

File tree

5 files changed

+257
-77
lines changed

5 files changed

+257
-77
lines changed

integration/rust/tests/integration/prepared.rs

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,8 @@
1+
use std::time::Duration;
2+
13
use rust::setup::*;
24
use sqlx::{Executor, Row, postgres::PgPoolOptions, types::BigDecimal};
3-
use tokio::spawn;
5+
use tokio::{spawn, time::sleep};
46

57
#[tokio::test]
68
async fn test_prepared_cache() {
@@ -251,6 +253,9 @@ async fn test_prepard_cache_eviction() {
251253
conn.close().await;
252254
}
253255

256+
// Let maintenance clean up.
257+
sleep(Duration::from_secs(2)).await;
258+
254259
// Evicted only when clients disconnect or manually close the statement.
255260
let prepared = admin.fetch_all("SHOW PREPARED").await.unwrap();
256261
assert_eq!(prepared.len(), 2);

pgdog/src/frontend/client/mod.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -483,7 +483,6 @@ impl Client {
483483
let config = config::config();
484484
// Configure prepared statements cache.
485485
self.prepared_statements.level = config.prepared_statements();
486-
self.prepared_statements.capacity = config.config.general.prepared_statements_limit;
487486
self.timeouts = Timeouts::from_config(&config.config.general);
488487

489488
while !self.client_request.full() {

0 commit comments

Comments
 (0)