Skip to content

Commit b5150ca

Browse files
committed
fix format
Signed-off-by: Yuchen Liang <[email protected]>
1 parent 983fef1 commit b5150ca

File tree

1 file changed

+9
-12
lines changed

1 file changed

+9
-12
lines changed

optd-core/src/storage/memo.rs

Lines changed: 9 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -80,9 +80,7 @@ impl Memoize for SqliteMemo {
8080
}
8181

8282
let mut txn = self.begin().await?;
83-
let representative_group_id = self
84-
.get_representative_group_id(&mut txn, group_id)
85-
.await?;
83+
let representative_group_id = self.get_representative_group_id(&mut txn, group_id).await?;
8684
let logical_exprs: Vec<LogicalExprRecord> =
8785
sqlx::query_as(&self.get_all_logical_exprs_in_group_query)
8886
.bind(representative_group_id)
@@ -168,8 +166,7 @@ impl Memoize for SqliteMemo {
168166
to: RelationalGroupId,
169167
) -> Result<RelationalGroupId> {
170168
let mut txn = self.begin().await?;
171-
self.set_representative_group_id(&mut txn, from, to)
172-
.await?;
169+
self.set_representative_group_id(&mut txn, from, to).await?;
173170
txn.commit().await?;
174171
Ok(to)
175172
}
@@ -275,7 +272,7 @@ impl SqliteMemo {
275272
ScalarOperatorKind::Constant,
276273
)
277274
.await?;
278-
275+
279276
sqlx::query_scalar("INSERT INTO scalar_constants (scalar_expression_id, group_id, value) VALUES ($1, $2, $3) ON CONFLICT DO UPDATE SET group_id = group_id RETURNING group_id")
280277
.bind(scalar_expr_id)
281278
.bind(group_id)
@@ -291,7 +288,7 @@ impl SqliteMemo {
291288
ScalarOperatorKind::ColumnRef,
292289
)
293290
.await?;
294-
291+
295292
sqlx::query_scalar("INSERT INTO scalar_column_refs (scalar_expression_id, group_id, column_index) VALUES ($1, $2, $3) ON CONFLICT DO UPDATE SET group_id = group_id RETURNING group_id")
296293
.bind(scalar_expr_id)
297294
.bind(group_id)
@@ -310,7 +307,7 @@ impl SqliteMemo {
310307
println!("add: {:?}", add);
311308
println!("scalar_expr_id: {:?}", scalar_expr_id);
312309
println!("group_id: {:?}", group_id);
313-
310+
314311
sqlx::query_scalar("INSERT INTO scalar_adds (scalar_expression_id, group_id, left_group_id, right_group_id) VALUES ($1, $2, $3, $4) ON CONFLICT DO UPDATE SET group_id = group_id RETURNING group_id")
315312
.bind(scalar_expr_id)
316313
.bind(group_id)
@@ -327,7 +324,7 @@ impl SqliteMemo {
327324
ScalarOperatorKind::Equal,
328325
)
329326
.await?;
330-
327+
331328
sqlx::query_scalar("INSERT INTO scalar_equals (scalar_expression_id, group_id, left_group_id, right_group_id) VALUES ($1, $2, $3, $4) ON CONFLICT DO UPDATE SET group_id = group_id RETURNING group_id")
332329
.bind(scalar_expr_id)
333330
.bind(group_id)
@@ -417,7 +414,7 @@ impl SqliteMemo {
417414
LogicalOperatorKind::Scan,
418415
)
419416
.await?;
420-
417+
421418
sqlx::query_scalar("INSERT INTO scans (logical_expression_id, group_id, table_name, predicate_group_id) VALUES ($1, $2, $3, $4) ON CONFLICT DO UPDATE SET group_id = group_id RETURNING group_id")
422419
.bind(logical_expr_id)
423420
.bind(group_id)
@@ -434,7 +431,7 @@ impl SqliteMemo {
434431
LogicalOperatorKind::Filter,
435432
)
436433
.await?;
437-
434+
438435
sqlx::query_scalar("INSERT INTO filters (logical_expression_id, group_id, child_group_id, predicate_group_id) VALUES ($1, $2, $3, $4) ON CONFLICT DO UPDATE SET group_id = group_id RETURNING group_id")
439436
.bind(logical_expr_id)
440437
.bind(group_id)
@@ -451,7 +448,7 @@ impl SqliteMemo {
451448
LogicalOperatorKind::Join,
452449
)
453450
.await?;
454-
451+
455452
sqlx::query_scalar("INSERT INTO joins (logical_expression_id, group_id, join_type, left_group_id, right_group_id, condition_group_id) VALUES ($1, $2, $3, $4, $5, $6) ON CONFLICT DO UPDATE SET group_id = group_id RETURNING group_id")
456453
.bind(logical_expr_id)
457454
.bind(group_id)

0 commit comments

Comments
 (0)