(resp: NativeResponse)
| 439 | } |
| 440 | |
| 441 | fn response_to_query_result(resp: NativeResponse) -> NodeDbResult<QueryResult> { |
| 442 | if resp.status == ResponseStatus::Error { |
| 443 | let msg = resp |
| 444 | .error |
| 445 | .map(|e| e.message) |
| 446 | .unwrap_or_else(|| "query failed".into()); |
| 447 | return Err(NodeDbError::internal(msg)); |
| 448 | } |
| 449 | Ok(QueryResult { |
| 450 | columns: resp.columns.unwrap_or_default(), |
| 451 | rows: resp.rows.unwrap_or_default(), |
| 452 | rows_affected: resp.rows_affected.unwrap_or(0), |
| 453 | }) |
| 454 | } |
| 455 | |
| 456 | #[cfg(test)] |
| 457 | mod tests { |