daniel543x/artcraft
1
0 Fork 0
mirror of https://github.com/storytold/artcraft.git synced 2026-11-03 17:08:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

explore weights query builder offset

Browse Source
This commit is contained in:
Kasisnu committed 2023-12-26 20:02:39 +05:30
1 parent b505896864
commit ad093d3fa8
1 file changed
+8 -13
Download Patch File Download Diff File Expand all files Collapse all files
crates/lib/mysql_queries/src/queries/model_weights/list/list_weights_query_builder.rs
+8 -13
View File
@@ -162,13 +162,15 @@ impl ListWeightsQueryBuilder {
mysql_pool: &MySqlPool
) -> AnyhowResult<Vec<RawWeightJoinUser>> {
let query = self.build_query_string();
//println!("HERE! query: {}", query);
//panic!("query: {:?}", query);
let mut query = sqlx::query_as::<_, RawWeightJoinUser>(&query);
// NB: The following bindings must match the order of the query builder !!
if let Some(offset) = self.offset {
query = query.bind(offset);
}
if let Some(username) = self.scope_creator_username.as_deref() {
query = query.bind(username);
}
@@ -183,9 +185,6 @@ impl ListWeightsQueryBuilder {
query = query.bind(self.limit);
if let Some(offset) = self.offset {
query = query.bind(offset);
}
let mut results = query.fetch_all(mysql_pool).await?;
@@ -331,18 +330,18 @@ impl ListWeightsQueryBuilder {
if sort_ascending {
if self.cursor_is_reversed {
// NB: We're searching backwards.
query.push_str(" model_weights.id");
query.push_str(" model_weights.id < ? ");
sort_ascending = !sort_ascending;
} else {
query.push_str(" model_weights.id");
query.push_str(" model_weights.id > ? ");
}
} else {
if self.cursor_is_reversed {
// NB: We're searching backwards.
query.push_str(" model_weights.id");
query.push_str(" model_weights.id > ? ");
sort_ascending = !sort_ascending;
} else {
query.push_str(" model_weights.id");
query.push_str(" model_weights.id < ? ");
}
}
}
@@ -411,10 +410,6 @@ impl ListWeightsQueryBuilder {
query.push_str(" LIMIT ?");
}
if let Some(_) = self.offset {
query.push_str(" OFFSET ?");
}
query
}
}