remove stream logic b/c underlying sqlx bug is fixed

Author: kurtbuilds

macro/src/codegen/insert.rs

@@ -55,12 +55,7 @@ pub fn impl_Model__insert(db: &dyn OrmliteCodegen, attr: &ModelMeta, metadata_ca
                         #(
                             #query_bindings
                         )*
-                        // using fetch instead of fetch_one because of https://github.com/launchbadge/sqlx/issues/1370
-                        let mut stream = q.fetch(&mut *conn);
-                        let mut model: Self = ::ormlite::StreamExt::try_next(&mut stream)
-                            .await?
-                            .ok_or_else(|| ::ormlite::Error::from(::ormlite::SqlxError::RowNotFound))?;
-                        ::ormlite::StreamExt::try_next(&mut stream).await?;
+                        let mut model = q.fetch_one(&mut *conn).await?;
                         #(
                             #late_bind
                         )*
@@ -100,12 +95,7 @@ pub fn impl_ModelBuilder__insert(db: &dyn OrmliteCodegen, attr: &TableMeta) -> T
                 );
                 let mut q = ::ormlite::query_as::<#db, Self::Model>(&query);
                 #(#bind_parameters)*
-                // using fetch instead of fetch_one because of https://github.com/launchbadge/sqlx/issues/1370
-                let mut stream = q.fetch(db);
-                let model = ::ormlite::StreamExt::try_next(&mut stream)
-                    .await?
-                    .ok_or_else(|| ::ormlite::Error::from(::ormlite::SqlxError::RowNotFound))?;
-                ::ormlite::StreamExt::try_next(&mut stream).await?;
+                let mut model = q.fetch_one(db).await?;
                 Ok(model)
             })
         }
@@ -172,11 +162,7 @@ pub fn impl_Insert(db: &dyn OrmliteCodegen, meta: &TableMeta, model: &Ident, ret
                     let mut model = self;
                     #(#insert_join)*
                     #(#query_bindings)*
-                    let mut stream = q.fetch(&mut *conn);
-                    let mut model = ::ormlite::StreamExt::try_next(&mut stream)
-                        .await?
-                        .ok_or_else(|| ::ormlite::Error::from(::ormlite::SqlxError::RowNotFound))?;
-                    ::ormlite::StreamExt::try_next(&mut stream).await?;
+                    let mut model = q.fetch_one(&mut *conn).await?;
                     #(#late_bind)*
                     Ok(model)
                 })