Skip to content

Commit 4a5a277

Browse files
committed
query_opt test
1 parent bf8b335 commit 4a5a277

File tree

1 file changed

+38
-5
lines changed

1 file changed

+38
-5
lines changed

tokio-postgres/tests/test/main.rs

Lines changed: 38 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -667,11 +667,11 @@ async fn query_one() {
667667
client
668668
.batch_execute(
669669
"
670-
CREATE TEMPORARY TABLE foo (
671-
name TEXT
672-
);
673-
INSERT INTO foo (name) VALUES ('alice'), ('bob'), ('carol');
674-
",
670+
CREATE TEMPORARY TABLE foo (
671+
name TEXT
672+
);
673+
INSERT INTO foo (name) VALUES ('alice'), ('bob'), ('carol');
674+
",
675675
)
676676
.await
677677
.unwrap();
@@ -691,3 +691,36 @@ async fn query_one() {
691691
.err()
692692
.unwrap();
693693
}
694+
695+
#[tokio::test]
696+
async fn query_opt() {
697+
let client = connect("user=postgres").await;
698+
699+
client
700+
.batch_execute(
701+
"
702+
CREATE TEMPORARY TABLE foo (
703+
name TEXT
704+
);
705+
INSERT INTO foo (name) VALUES ('alice'), ('bob'), ('carol');
706+
",
707+
)
708+
.await
709+
.unwrap();
710+
711+
assert!(client
712+
.query_opt("SELECT * FROM foo WHERE name = 'dave'", &[])
713+
.await
714+
.unwrap()
715+
.is_none());
716+
client
717+
.query_opt("SELECT * FROM foo WHERE name = 'alice'", &[])
718+
.await
719+
.unwrap()
720+
.unwrap();
721+
client
722+
.query_one("SELECT * FROM foo", &[])
723+
.await
724+
.err()
725+
.unwrap();
726+
}

0 commit comments

Comments
 (0)