Skip to content

Commit fbb1efb

Browse files
committed
libsql: Reset statement in Rows::next()
1 parent ca1a70c commit fbb1efb

File tree

1 file changed

+8
-7
lines changed

1 file changed

+8
-7
lines changed

libsql/src/local/rows.rs

Lines changed: 8 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -46,8 +46,14 @@ impl Rows {
4646
err_msg = errors::error_from_handle(self.stmt.conn.raw);
4747
}
4848
match err {
49-
libsql_sys::ffi::SQLITE_OK => Ok(None),
50-
libsql_sys::ffi::SQLITE_DONE => Ok(None),
49+
libsql_sys::ffi::SQLITE_OK => {
50+
self.stmt.reset();
51+
Ok(None)
52+
}
53+
libsql_sys::ffi::SQLITE_DONE => {
54+
self.stmt.reset();
55+
Ok(None)
56+
}
5157
libsql_sys::ffi::SQLITE_ROW => Ok(Some(Row {
5258
stmt: self.stmt.clone(),
5359
})),
@@ -82,11 +88,6 @@ impl AsRef<Statement> for Rows {
8288
}
8389
}
8490

85-
impl Drop for Rows {
86-
fn drop(&mut self) {
87-
self.stmt.reset();
88-
}
89-
}
9091

9192
pub struct RowsFuture {
9293
pub(crate) conn: Connection,

0 commit comments

Comments
 (0)