| 996 | } |
| 997 | |
| 998 | func TestConnExec(t *testing.T) { |
| 999 | t.Parallel() |
| 1000 | |
| 1001 | ctx, cancel := context.WithTimeout(context.Background(), 120*time.Second) |
| 1002 | defer cancel() |
| 1003 | |
| 1004 | pgConn, err := pgconn.Connect(ctx, os.Getenv("PGX_TEST_DATABASE")) |
| 1005 | require.NoError(t, err) |
| 1006 | defer closeConn(t, pgConn) |
| 1007 | |
| 1008 | results, err := pgConn.Exec(ctx, "select 'Hello, world'").ReadAll() |
| 1009 | assert.NoError(t, err) |
| 1010 | |
| 1011 | assert.Len(t, results, 1) |
| 1012 | assert.Nil(t, results[0].Err) |
| 1013 | assert.Equal(t, "SELECT 1", results[0].CommandTag.String()) |
| 1014 | assert.Len(t, results[0].Rows, 1) |
| 1015 | assert.Equal(t, "Hello, world", string(results[0].Rows[0][0])) |
| 1016 | |
| 1017 | ensureConnValid(t, pgConn) |
| 1018 | } |
| 1019 | |
| 1020 | func TestConnExecEmpty(t *testing.T) { |
| 1021 | t.Parallel() |