dnim/rust-postgres
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

More protocol updates

Browse Source
This commit is contained in:
Steven Fackler 2016-09-20 09:47:16 -04:00
parent 1062b2a4d6
commit 63790cf565
2 changed files with 3 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/lib.rs
View File

@ -410,10 +410,7 @@ impl InnerConnection {
query: query,
param_types: &[],
}));
try!(self.stream.write_message(&frontend::Describe {
variant: b'S',
name: stmt_name,
}));
try!(self.stream.write_message2(|buf| frontend::describe(b'S', stmt_name, buf)));
try!(self.stream.write_message(&frontend::Sync));
try!(self.stream.flush());
@ -536,10 +533,7 @@ impl InnerConnection {
}
}
try!(self.stream.write_message(&frontend::Execute {
portal: portal_name,
max_rows: row_limit,
}));
try!(self.stream.write_message2(|buf| frontend::execute(portal_name, row_limit, buf)));
try!(self.stream.write_message(&frontend::Sync));
try!(self.stream.flush());

5
src/rows.rs
View File

@ -351,10 +351,7 @@ impl<'trans, 'stmt> LazyRows<'trans, 'stmt> {
fn execute(&mut self) -> Result<()> {
let mut conn = self.stmt.conn().conn.borrow_mut();
try!(conn.stream.write_message(&frontend::Execute {
portal: &self.name,
max_rows: self.row_limit,
}));
try!(conn.stream.write_message2(|buf| frontend::execute(&self.name, self.row_limit, buf)));
try!(conn.stream.write_message(&frontend::Sync));
try!(conn.stream.flush());
conn.read_rows(&mut self.data).map(|more_rows| self.more_rows = more_rows)