| 1038 | } |
| 1039 | |
| 1040 | func TestConnExecMultipleQueries(t *testing.T) { |
| 1041 | t.Parallel() |
| 1042 | |
| 1043 | ctx, cancel := context.WithTimeout(context.Background(), 120*time.Second) |
| 1044 | defer cancel() |
| 1045 | |
| 1046 | pgConn, err := pgconn.Connect(ctx, os.Getenv("PGX_TEST_DATABASE")) |
| 1047 | require.NoError(t, err) |
| 1048 | defer closeConn(t, pgConn) |
| 1049 | |
| 1050 | results, err := pgConn.Exec(ctx, "select 'Hello, world'; select 1").ReadAll() |
| 1051 | assert.NoError(t, err) |
| 1052 | |
| 1053 | assert.Len(t, results, 2) |
| 1054 | |
| 1055 | assert.Nil(t, results[0].Err) |
| 1056 | assert.Equal(t, "SELECT 1", results[0].CommandTag.String()) |
| 1057 | assert.Len(t, results[0].Rows, 1) |
| 1058 | assert.Equal(t, "Hello, world", string(results[0].Rows[0][0])) |
| 1059 | |
| 1060 | assert.Nil(t, results[1].Err) |
| 1061 | assert.Equal(t, "SELECT 1", results[1].CommandTag.String()) |
| 1062 | assert.Len(t, results[1].Rows, 1) |
| 1063 | assert.Equal(t, "1", string(results[1].Rows[0][0])) |
| 1064 | |
| 1065 | ensureConnValid(t, pgConn) |
| 1066 | } |
| 1067 | |
| 1068 | func TestConnExecMultipleQueriesEagerFieldDescriptions(t *testing.T) { |
| 1069 | t.Parallel() |