Skip to content

Commit 4d5eed8

Browse files
committed
Add query to Transaction and GenericConnection
1 parent a3e967a commit 4d5eed8

1 file changed

Lines changed: 16 additions & 0 deletions

File tree

src/lib.rs

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1209,6 +1209,11 @@ impl<'conn> Transaction<'conn> {
12091209
self.conn.execute(query, params)
12101210
}
12111211

1212+
/// Like `Connection::query`.
1213+
pub fn query<'a>(&'a self, query: &str, params: &[&ToSql]) -> Result<Rows<'a>> {
1214+
self.conn.query(query, params)
1215+
}
1216+
12121217
/// Like `Connection::batch_execute`.
12131218
pub fn batch_execute(&self, query: &str) -> Result<()> {
12141219
self.conn.batch_execute(query)
@@ -1330,6 +1335,9 @@ pub trait GenericConnection {
13301335
/// Like `Connection::execute`.
13311336
fn execute(&self, query: &str, params: &[&ToSql]) -> Result<u64>;
13321337

1338+
/// Like `Connection::query`.
1339+
fn query<'a>(&'a self, query: &str, params: &[&ToSql]) -> Result<Rows<'a>>;
1340+
13331341
/// Like `Connection::transaction`.
13341342
fn transaction<'a>(&'a self) -> Result<Transaction<'a>>;
13351343

@@ -1353,6 +1361,10 @@ impl GenericConnection for Connection {
13531361
self.execute(query, params)
13541362
}
13551363

1364+
fn query<'a>(&'a self, query: &str, params: &[&ToSql]) -> Result<Rows<'a>> {
1365+
self.query(query, params)
1366+
}
1367+
13561368
fn transaction<'a>(&'a self) -> Result<Transaction<'a>> {
13571369
self.transaction()
13581370
}
@@ -1379,6 +1391,10 @@ impl<'a> GenericConnection for Transaction<'a> {
13791391
self.execute(query, params)
13801392
}
13811393

1394+
fn query<'b>(&'b self, query: &str, params: &[&ToSql]) -> Result<Rows<'b>> {
1395+
self.query(query, params)
1396+
}
1397+
13821398
fn transaction<'b>(&'b self) -> Result<Transaction<'b>> {
13831399
self.transaction()
13841400
}

0 commit comments

Comments
 (0)