Skip to main content

sea_schema/
connection.rs

1use crate::sqlx_types::{SqlxError, SqlxRow};
2use sea_query::SelectStatement;
3
4#[async_trait::async_trait(?Send)]
5pub trait Connection: Sized + Sync {
6    async fn query_all(&self, select: SelectStatement) -> Result<Vec<SqlxRow>, SqlxError>;
7
8    async fn query_all_raw(&self, sql: String) -> Result<Vec<SqlxRow>, SqlxError>;
9}