(&self, table: Table)
| 502 | } |
| 503 | |
| 504 | fn all_entries(&self, table: Table) -> Result<Map<String, serde_json::Value>, DatabaseError> { |
| 505 | let conn = self.pool.get()?; |
| 506 | let mut stmt = conn.prepare(&format!("SELECT key, value FROM {table}"))?; |
| 507 | let rows = stmt.query_map([], |row| { |
| 508 | let key = row.get(0)?; |
| 509 | let value = Value::String(row.get(1)?); |
| 510 | Ok((key, value)) |
| 511 | })?; |
| 512 | |
| 513 | let mut map = Map::new(); |
| 514 | for row in rows { |
| 515 | let (key, value) = row?; |
| 516 | map.insert(key, value); |
| 517 | } |
| 518 | |
| 519 | Ok(map) |
| 520 | } |
| 521 | } |
| 522 | |
| 523 | fn max_migration_version<C: Deref<Target = Connection>>(conn: &C) -> Option<i64> { |
no test coverage detected