diesel_derives/
queryable.rs1use proc_macro2::{Span, TokenStream};
2use quote::quote;
3use syn::{parse_quote, DeriveInput, Ident, Index, Result};
4
5use crate::field::Field;
6use crate::model::Model;
7use crate::util::wrap_in_dummy_mod;
8
9pub fn derive(item: DeriveInput) -> Result<TokenStream> {
10 let model = Model::from_item(&item, false, true)?;
11
12 let struct_name = &item.ident;
13 let field_ty = &model
14 .fields()
15 .iter()
16 .map(Field::ty_for_deserialize)
17 .collect::<Vec<_>>();
18 let build_expr = model.fields().iter().enumerate().map(|(i, f)| {
19 let field_name = &f.name;
20 let i = Index::from(i);
21 quote!(#field_name: row.#i.try_into()?)
26 });
27 let sql_type = &(0..model.fields().len())
28 .map(|i| {
29 let i = Ident::new(&format!("__ST{i}"), Span::mixed_site());
30 quote!(#i)
31 })
32 .collect::<Vec<_>>();
33
34 let (_, ty_generics, _) = item.generics.split_for_impl();
35 let mut generics = item.generics.clone();
36 generics
37 .params
38 .push(parse_quote!(__DB: diesel::backend::Backend));
39 for id in 0..model.fields().len() {
40 let ident = Ident::new(&format!("__ST{id}"), Span::mixed_site());
41 generics.params.push(parse_quote!(#ident));
42 }
43 {
44 let where_clause = generics.where_clause.get_or_insert(parse_quote!(where));
45 where_clause
46 .predicates
47 .push(parse_quote!((#(#field_ty,)*): diesel::deserialize::FromStaticSqlRow<(#(#sql_type,)*), __DB>));
48 }
49 let (impl_generics, _, where_clause) = generics.split_for_impl();
50
51 Ok(wrap_in_dummy_mod(quote! {
52 use diesel::row::{Row as _, Field as _};
53
54 impl #impl_generics diesel::deserialize::Queryable<(#(#sql_type,)*), __DB> for #struct_name #ty_generics
55 #where_clause
56 {
57 type Row = (#(#field_ty,)*);
58
59 fn build(row: (#(#field_ty,)*)) -> diesel::deserialize::Result<Self> {
60 use std::convert::TryInto;
61 Ok(Self {
62 #(#build_expr,)*
63 })
64 }
65 }
66 }))
67}