|
21 | 21 | I: IntoIterator<Item = &'a dyn ToSql>,
|
22 | 22 | I::IntoIter: ExactSizeIterator,
|
23 | 23 | {
|
24 |
| - let buf = encode(client, &statement, params)?; |
| 24 | + let buf = if log::log_enabled!(log::Level::Debug) { |
| 25 | + let params = params.into_iter().collect::<Vec<_>>(); |
| 26 | + log::debug!( |
| 27 | + "executing statement {} with parameters: {:?}", |
| 28 | + statement.name(), |
| 29 | + params, |
| 30 | + ); |
| 31 | + encode(client, &statement, params)? |
| 32 | + } else { |
| 33 | + encode(client, &statement, params)? |
| 34 | + }; |
25 | 35 | let responses = start(client, buf).await?;
|
26 | 36 | Ok(RowStream {
|
27 | 37 | statement,
|
|
59 | 69 | I: IntoIterator<Item = &'a dyn ToSql>,
|
60 | 70 | I::IntoIter: ExactSizeIterator,
|
61 | 71 | {
|
62 |
| - let buf = encode(client, &statement, params)?; |
| 72 | + let buf = if log::log_enabled!(log::Level::Debug) { |
| 73 | + let params = params.into_iter().collect::<Vec<_>>(); |
| 74 | + log::debug!( |
| 75 | + "executing statement {} with parameters: {:?}", |
| 76 | + statement.name(), |
| 77 | + params, |
| 78 | + ); |
| 79 | + encode(client, &statement, params)? |
| 80 | + } else { |
| 81 | + encode(client, &statement, params)? |
| 82 | + }; |
63 | 83 | let mut responses = start(client, buf).await?;
|
64 | 84 |
|
65 | 85 | loop {
|
|
0 commit comments