/
germanubis
/
sqlx
Обзор
Документация
Войти
/
germanubis
/
sqlx
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
main
sqlx-sqlite/src/query_result.rs
40 строк
1 KB
Pmarquez
Implement AnyQueryResult for Sqlite and MySQL (#3608)
26 ноя 2024, 21:59
Не верифицирован
26 ноя 2024, 21:59
d4ae6ff
Код
Авторство
О чём код?
use std::iter::{Extend, IntoIterator}; #[derive(Debug, Default)] pub struct SqliteQueryResult { pub(super) changes: u64, pub(super) last_insert_rowid: i64, } impl SqliteQueryResult { pub fn rows_affected(&self) -> u64 { self.changes } pub fn last_insert_rowid(&self) -> i64 { self.last_insert_rowid } } impl Extend<SqliteQueryResult> for SqliteQueryResult { fn extend<T: IntoIterator<Item = SqliteQueryResult>>(&mut self, iter: T) { for elem in iter { self.changes += elem.changes; self.last_insert_rowid = elem.last_insert_rowid; } } } #[cfg(feature = "any")] impl From<SqliteQueryResult> for sqlx_core::any::AnyQueryResult { fn from(done: SqliteQueryResult) -> Self { let last_insert_id = match done.last_insert_rowid() { 0 => None, n => Some(n), }; sqlx_core::any::AnyQueryResult { rows_affected: done.rows_affected(), last_insert_id, } } }