itsscb/sqlx
1
0
Fork 0
mirror of https://github.com/launchbadge/sqlx.git synced 2025-12-29 21:00:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove the WIP statement caching (to add back properly later)

Browse Source
This commit is contained in:
Ryan Leckey 2019-09-03 06:54:37 -07:00
parent e903884451
commit 0c945cbbe2
1 changed files with 1 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/postgres/connection.rs
View File

@ -29,12 +29,6 @@ pub struct PostgresRawConnection {
// Backend-unique key to use to send a cancel query message to the server
secret_key: u32,
// Statement ID counter
next_statement_id: AtomicU64,
// Portal ID counter
next_portal_id: AtomicU64,
}
impl PostgresRawConnection {
@ -47,8 +41,6 @@ impl PostgresRawConnection {
stream: BufStream::new(stream),
process_id: 0,
secret_key: 0,
next_statement_id: AtomicU64::new(0),
next_portal_id: AtomicU64::new(0),
};
let user = url.username();
@ -221,7 +213,7 @@ impl PostgresRawConnection {
fn execute(&mut self, query: &str, params: PostgresQueryParameters, limit: i32) {
self.write(protocol::Parse {
portal: "",
statement: "",
query,
param_types: &*params.types,
});
@ -276,22 +268,6 @@ impl PostgresRawConnection {
// Connection was (unexpectedly) closed
Err(io::Error::from(io::ErrorKind::UnexpectedEof).into())
}
// TODO: Remove usage of fmt!
fn next_portal_id(&self) -> String {
format!(
"__sqlx_portal_{}",
self.next_portal_id.fetch_add(1, Ordering::AcqRel)
)
}
// TODO: Remove usage of fmt!
fn next_statement_id(&self) -> String {
format!(
"__sqlx_statement_{}",
self.next_statement_id.fetch_add(1, Ordering::AcqRel)
)
}
}
enum Step {