caisin/sea-orm
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Mutability

Browse Source
This commit is contained in:
Chris Tsang 2021-06-06 23:20:54 +08:00
parent 06d755513e
commit 2e512334a9
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/connector/paginator.rs
View File

@ -23,8 +23,9 @@ where
S: SelectorTrait + 'db, S: SelectorTrait + 'db,
{ {
/// Fetch a specific page /// Fetch a specific page
pub async fn fetch_page(&mut self, page: usize) -> Result<Vec<S::Item>, QueryErr> { pub async fn fetch_page(&self, page: usize) -> Result<Vec<S::Item>, QueryErr> {
self.query self.query
.clone()
.limit(self.page_size as u64) .limit(self.page_size as u64)
.offset((self.page_size * page) as u64); .offset((self.page_size * page) as u64);
let builder = self.db.get_query_builder_backend(); let builder = self.db.get_query_builder_backend();
@ -39,12 +40,12 @@ where
} }
/// Fetch the current page /// Fetch the current page
pub async fn fetch(&mut self) -> Result<Vec<S::Item>, QueryErr> { pub async fn fetch(&self) -> Result<Vec<S::Item>, QueryErr> {
self.fetch_page(self.page).await self.fetch_page(self.page).await
} }
/// Get the total number of pages /// Get the total number of pages
pub async fn num_pages(&mut self) -> Result<usize, QueryErr> { pub async fn num_pages(&self) -> Result<usize, QueryErr> {
let builder = self.db.get_query_builder_backend(); let builder = self.db.get_query_builder_backend();
let stmt = SelectStatement::new() let stmt = SelectStatement::new()
.expr(Expr::cust("COUNT(*) AS num_rows")) .expr(Expr::cust("COUNT(*) AS num_rows"))