Skip to content

Commit a952381

Browse files
Merge pull request #15 from readysettech/issue-12
Add digest to cache name
2 parents 57ff6b0 + 64ec697 commit a952381

File tree

1 file changed

+8
-3
lines changed

1 file changed

+8
-3
lines changed

src/queries.rs

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -82,8 +82,12 @@ pub fn check_readyset_query_support(
8282
}
8383
}
8484

85-
pub fn cache_query(conn: &mut PooledConn, digest_text: &String) -> Result<bool, mysql::Error> {
86-
conn.query_drop(format!("CREATE CACHE FROM {}", digest_text))
85+
pub fn cache_query(
86+
conn: &mut PooledConn,
87+
digest_text: &String,
88+
digest: &String,
89+
) -> Result<bool, mysql::Error> {
90+
conn.query_drop(format!("CREATE CACHE d_{} FROM {}", digest, digest_text))
8791
.expect("Failed to create readyset cache");
8892
Ok(true)
8993
}
@@ -177,7 +181,8 @@ pub fn query_discovery(
177181
.as_str(),
178182
);
179183
queries_added_or_change = true;
180-
cache_query(readyset_conn, &digest_text).expect("Failed to create readyset cache");
184+
cache_query(readyset_conn, &digest_text, &digest)
185+
.expect("Failed to create readyset cache");
181186
add_query_rule(proxysql_conn, &digest, config).expect("Failed to add query rule");
182187
current_queries_digest.push(digest);
183188
}

0 commit comments

Comments
 (0)