Skip to content

Commit e098c31

Browse files
committed
Fixed mysql related tests
1 parent 26a02df commit e098c31

2 files changed

Lines changed: 4 additions & 4 deletions

File tree

crates/sources/src/providers/mysql.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -908,7 +908,7 @@ mod tests {
908908
let mut ctx = SessionContext::new();
909909
register_ci_table(&mut ctx, "users").await;
910910

911-
let before = query_all(&ctx, "SELECT email FROM users WHERE id = 1").await;
911+
let before = query_all(&ctx, "SELECT email FROM users WHERE id = 3").await;
912912
assert_eq!(total_rows(&before), 1);
913913
let before_email = before[0]
914914
.column(0)
@@ -925,7 +925,7 @@ mod tests {
925925
.await
926926
.expect("execute update");
927927

928-
let after = query_all(&ctx, "SELECT email FROM users WHERE id = 1").await;
928+
let after = query_all(&ctx, "SELECT email FROM users WHERE id = 3").await;
929929
assert_eq!(total_rows(&after), 1);
930930
let after_email = after[0]
931931
.column(0)

crates/sources/src/providers/sqlx/postgres.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1435,7 +1435,7 @@ mod tests {
14351435
let mut ctx = SessionContext::new();
14361436
register_ci_table(&mut ctx, "users").await;
14371437

1438-
let before = query_all(&ctx, "SELECT email FROM users WHERE id = 1").await;
1438+
let before = query_all(&ctx, "SELECT email FROM users WHERE id = 3").await;
14391439
assert_eq!(total_rows(&before), 1);
14401440
let before_email = before[0]
14411441
.column(0)
@@ -1452,7 +1452,7 @@ mod tests {
14521452
.await
14531453
.expect("execute update");
14541454

1455-
let after = query_all(&ctx, "SELECT email FROM users WHERE id = 1").await;
1455+
let after = query_all(&ctx, "SELECT email FROM users WHERE id = 3").await;
14561456
assert_eq!(total_rows(&after), 1);
14571457
let after_email = after[0]
14581458
.column(0)

0 commit comments

Comments
 (0)