@@ -60,10 +60,10 @@ public void testPool(TestContext ctx) {
60
60
PgPool pool = createPool (options , 4 );
61
61
for (int i = 0 ;i < num ;i ++) {
62
62
pool .getConnection (ctx .asyncAssertSuccess (conn -> {
63
- conn .query ("SELECT id, randomnumber from WORLD" ).execute (ar -> {
63
+ conn .query ("SELECT id, randomnumber from WORLD WHERE id = 1 " ).execute (ar -> {
64
64
if (ar .succeeded ()) {
65
65
SqlResult result = ar .result ();
66
- ctx .assertEquals (10000 , result .size ());
66
+ ctx .assertEquals (1 , result .size ());
67
67
} else {
68
68
ctx .assertEquals ("closed" , ar .cause ().getMessage ());
69
69
}
@@ -80,10 +80,10 @@ public void testQuery(TestContext ctx) {
80
80
Async async = ctx .async (num );
81
81
PgPool pool = createPool (options , 4 );
82
82
for (int i = 0 ;i < num ;i ++) {
83
- pool .query ("SELECT id, randomnumber from WORLD" ).execute (ar -> {
83
+ pool .query ("SELECT id, randomnumber from WORLD WHERE id = 1 " ).execute (ar -> {
84
84
if (ar .succeeded ()) {
85
85
SqlResult result = ar .result ();
86
- ctx .assertEquals (10000 , result .size ());
86
+ ctx .assertEquals (1 , result .size ());
87
87
} else {
88
88
ctx .assertEquals ("closed" , ar .cause ().getMessage ());
89
89
}
0 commit comments