From 56d0518e04cb32dbf6c2c33bb1305764791f0a10 Mon Sep 17 00:00:00 2001 From: Jack Christensen Date: Tue, 29 Jul 2014 17:49:13 -0500 Subject: [PATCH] Add test for ConnPool.Exec --- conn_pool_test.go | 31 +++++++++++++++++++++++++++++++ 1 file changed, 31 insertions(+) diff --git a/conn_pool_test.go b/conn_pool_test.go index 9284a09f..a5362e5c 100644 --- a/conn_pool_test.go +++ b/conn_pool_test.go @@ -431,3 +431,34 @@ func TestConnPoolQueryRow(t *testing.T) { t.Fatalf("Unexpected connection pool stats: %v", stats) } } + +func TestConnPoolExec(t *testing.T) { + t.Parallel() + + pool := createConnPool(t, 2) + defer pool.Close() + + results, err := pool.Exec("create temporary table foo(id integer primary key);") + if err != nil { + t.Fatalf("Unexpected error from pool.Exec: %v", err) + } + if results != "CREATE TABLE" { + t.Errorf("Unexpected results from Exec: %v", results) + } + + results, err = pool.Exec("insert into foo(id) values($1)", 1) + if err != nil { + t.Fatalf("Unexpected error from pool.Exec: %v", err) + } + if results != "INSERT 0 1" { + t.Errorf("Unexpected results from Exec: %v", results) + } + + results, err = pool.Exec("drop table foo;") + if err != nil { + t.Fatalf("Unexpected error from pool.Exec: %v", err) + } + if results != "DROP TABLE" { + t.Errorf("Unexpected results from Exec: %v", results) + } +}