diff --git a/src/connection.rs b/src/connection.rs index a140938e..274739d5 100644 --- a/src/connection.rs +++ b/src/connection.rs @@ -1,4 +1,4 @@ -use crate::{backend::Backend, executor::Executor, query::RawQuery, row::FromRow}; +use crate::{backend::Backend, executor::Executor, query::RawQuery, row::FromSqlRow}; use crossbeam_queue::SegQueue; use crossbeam_utils::atomic::AtomicCell; use futures_channel::oneshot::{channel, Sender}; @@ -98,7 +98,7 @@ where fn fetch<'c, 'q, T: 'c, Q: 'q + 'c>(&'c self, query: Q) -> BoxStream<'c, io::Result> where Q: RawQuery<'q, Backend = Self::Backend>, - T: FromRow + Send + Unpin, + T: FromSqlRow + Send + Unpin, { Box::pin(async_stream::try_stream! { let mut conn = self.get().await; @@ -116,7 +116,7 @@ where ) -> BoxFuture<'c, io::Result>> where Q: RawQuery<'q, Backend = Self::Backend>, - T: FromRow, + T: FromSqlRow, { Box::pin(async move { let mut conn = self.get().await; diff --git a/src/executor.rs b/src/executor.rs index 60b1f22a..ab8534dd 100644 --- a/src/executor.rs +++ b/src/executor.rs @@ -1,4 +1,4 @@ -use crate::{backend::Backend, query::RawQuery, row::FromRow}; +use crate::{backend::Backend, query::RawQuery, row::FromSqlRow}; use futures_core::{future::BoxFuture, stream::BoxStream}; use std::io; @@ -12,7 +12,7 @@ pub trait Executor: Send { fn fetch<'c, 'q, T: 'c, Q: 'q + 'c>(&'c self, query: Q) -> BoxStream<'c, io::Result> where Q: RawQuery<'q, Backend = Self::Backend>, - T: FromRow + Send + Unpin; + T: FromSqlRow + Send + Unpin; fn fetch_optional<'c, 'q, T: 'c, Q: 'q + 'c>( &'c self, @@ -20,7 +20,7 @@ pub trait Executor: Send { ) -> BoxFuture<'c, io::Result>> where Q: RawQuery<'q, Backend = Self::Backend>, - T: FromRow; + T: FromSqlRow; } impl<'e, E> Executor for &'e E @@ -40,7 +40,7 @@ where fn fetch<'c, 'q, T: 'c, Q: 'q + 'c>(&'c self, query: Q) -> BoxStream<'c, io::Result> where Q: RawQuery<'q, Backend = Self::Backend>, - T: FromRow + Send + Unpin, + T: FromSqlRow + Send + Unpin, { (*self).fetch(query) } @@ -51,7 +51,7 @@ where ) -> BoxFuture<'c, io::Result>> where Q: RawQuery<'q, Backend = Self::Backend>, - T: FromRow, + T: FromSqlRow, { (*self).fetch_optional(query) } diff --git a/src/pg/backend.rs b/src/pg/backend.rs index 13280bae..aca8def7 100644 --- a/src/pg/backend.rs +++ b/src/pg/backend.rs @@ -11,5 +11,5 @@ impl Backend for Pg { type Row = super::PgRow; } -// Generates tuple FromRow impls for this backend -impl_from_row_tuples_for_backend!(Pg); +// Generates tuple FromSqlRow impls for this backend +impl_from_sql_row_tuples_for_backend!(Pg); diff --git a/src/pool.rs b/src/pool.rs index 3ea31526..7e287231 100644 --- a/src/pool.rs +++ b/src/pool.rs @@ -1,5 +1,5 @@ use crate::{ - backend::Backend, connection::RawConnection, executor::Executor, query::RawQuery, row::FromRow, + backend::Backend, connection::RawConnection, executor::Executor, query::RawQuery, row::FromSqlRow, }; use crossbeam_queue::{ArrayQueue, SegQueue}; use futures_channel::oneshot; @@ -143,7 +143,7 @@ where fn fetch<'c, 'q, T: 'c, Q: 'q + 'c>(&'c self, query: Q) -> BoxStream<'c, io::Result> where Q: RawQuery<'q, Backend = Self::Backend>, - T: FromRow + Send + Unpin, + T: FromSqlRow + Send + Unpin, { Box::pin(async_stream::try_stream! { let live = self.0.acquire().await?; @@ -162,7 +162,7 @@ where ) -> BoxFuture<'c, io::Result>> where Q: RawQuery<'q, Backend = Self::Backend>, - T: FromRow, + T: FromSqlRow, { Box::pin(async move { let live = self.0.acquire().await?; diff --git a/src/query.rs b/src/query.rs index 0e6d8bbe..3a831c66 100644 --- a/src/query.rs +++ b/src/query.rs @@ -1,7 +1,7 @@ use crate::{ backend::{Backend, BackendAssocRawQuery}, executor::Executor, - row::FromRow, + row::FromSqlRow, serialize::ToSql, types::HasSqlType, }; @@ -64,7 +64,7 @@ where pub fn fetch(self, executor: &'q E) -> BoxStream<'q, io::Result> where E: Executor, - T: FromRow + Send + Unpin, + T: FromSqlRow + Send + Unpin, >::RawQuery: 'q, { executor.fetch(self.inner) @@ -74,7 +74,7 @@ where pub fn fetch_optional(self, executor: &'q E) -> BoxFuture<'q, io::Result>> where E: Executor, - T: FromRow, + T: FromSqlRow, >::RawQuery: 'q, { executor.fetch_optional(self.inner) diff --git a/src/row.rs b/src/row.rs index 0c59adbf..1ebfe283 100644 --- a/src/row.rs +++ b/src/row.rs @@ -19,11 +19,11 @@ pub trait Row: Send { } } -pub trait FromRow { +pub trait FromSqlRow { fn from_row>(row: R) -> Self; } -impl FromRow for T +impl FromSqlRow for T where DB: Backend + HasSqlType, T: FromSql, @@ -35,9 +35,9 @@ where } #[allow(unused)] -macro_rules! impl_from_row_tuple { +macro_rules! impl_from_sql_row_tuple { ($B:ident: $( ($idx:tt) -> $T:ident );+;) => { - impl<$($T,)+> crate::row::FromRow<$B> for ($($T,)+) + impl<$($T,)+> crate::row::FromSqlRow<$B> for ($($T,)+) where $($B: crate::types::HasSqlType<$T>,)+ $($T: crate::deserialize::FromSql<$B>,)+ @@ -51,31 +51,31 @@ macro_rules! impl_from_row_tuple { } #[allow(unused)] -macro_rules! impl_from_row_tuples_for_backend { +macro_rules! impl_from_sql_row_tuples_for_backend { ($B:ident) => { - impl_from_row_tuple!($B: + impl_from_sql_row_tuple!($B: (0) -> T1; ); - impl_from_row_tuple!($B: + impl_from_sql_row_tuple!($B: (0) -> T1; (1) -> T2; ); - impl_from_row_tuple!($B: + impl_from_sql_row_tuple!($B: (0) -> T1; (1) -> T2; (2) -> T3; ); - impl_from_row_tuple!($B: + impl_from_sql_row_tuple!($B: (0) -> T1; (1) -> T2; (2) -> T3; (3) -> T4; ); - impl_from_row_tuple!($B: + impl_from_sql_row_tuple!($B: (0) -> T1; (1) -> T2; (2) -> T3; @@ -83,7 +83,7 @@ macro_rules! impl_from_row_tuples_for_backend { (4) -> T5; ); - impl_from_row_tuple!($B: + impl_from_sql_row_tuple!($B: (0) -> T1; (1) -> T2; (2) -> T3; @@ -92,7 +92,7 @@ macro_rules! impl_from_row_tuples_for_backend { (5) -> T6; ); - impl_from_row_tuple!($B: + impl_from_sql_row_tuple!($B: (0) -> T1; (1) -> T2; (2) -> T3; @@ -102,7 +102,7 @@ macro_rules! impl_from_row_tuples_for_backend { (6) -> T7; ); - impl_from_row_tuple!($B: + impl_from_sql_row_tuple!($B: (0) -> T1; (1) -> T2; (2) -> T3; @@ -113,7 +113,7 @@ macro_rules! impl_from_row_tuples_for_backend { (7) -> T8; ); - impl_from_row_tuple!($B: + impl_from_sql_row_tuple!($B: (0) -> T1; (1) -> T2; (2) -> T3;