From fc5b186e8d688c62cdea2fd9ab9ce358d2b21d0a Mon Sep 17 00:00:00 2001 From: Stephen Buergler Date: Tue, 30 Apr 2019 23:32:05 -0500 Subject: [PATCH] Don't leak so many connections in the pg backend This change fixes an error I get: Error: pq: too many connections for role "asdf" because I can only have so many connections. --- backend/remote-state/pg/backend.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/backend/remote-state/pg/backend.go b/backend/remote-state/pg/backend.go index 711e6f4cc..34e0a46c3 100644 --- a/backend/remote-state/pg/backend.go +++ b/backend/remote-state/pg/backend.go @@ -65,7 +65,7 @@ func (b *Backend) configure(ctx context.Context) error { // Prepare database schema, tables, & indexes. var query string query = `CREATE SCHEMA IF NOT EXISTS %s` - if _, err := db.Query(fmt.Sprintf(query, b.schemaName)); err != nil { + if _, err := db.Exec(fmt.Sprintf(query, b.schemaName)); err != nil { return err } query = `CREATE TABLE IF NOT EXISTS %s.%s ( @@ -73,11 +73,11 @@ func (b *Backend) configure(ctx context.Context) error { name TEXT, data TEXT )` - if _, err := db.Query(fmt.Sprintf(query, b.schemaName, statesTableName)); err != nil { + if _, err := db.Exec(fmt.Sprintf(query, b.schemaName, statesTableName)); err != nil { return err } query = `CREATE UNIQUE INDEX IF NOT EXISTS %s ON %s.%s (name)` - if _, err := db.Query(fmt.Sprintf(query, statesIndexName, b.schemaName, statesTableName)); err != nil { + if _, err := db.Exec(fmt.Sprintf(query, statesIndexName, b.schemaName, statesTableName)); err != nil { return err }