From b771465d99f5722ec08850626eb533632aa0eefe Mon Sep 17 00:00:00 2001 From: Chris Bandy Date: Thu, 20 Nov 2014 12:32:53 +0000 Subject: [PATCH] Do not record history of internal queries --- client.go | 19 +++++++++++-------- 1 file changed, 11 insertions(+), 8 deletions(-) diff --git a/client.go b/client.go index 5d51167..e286f8e 100644 --- a/client.go +++ b/client.go @@ -50,11 +50,11 @@ func (client *Client) recordQuery(query string) { } func (client *Client) Info() (*Result, error) { - return client.Query(PG_INFO) + return client.query(PG_INFO) } func (client *Client) Databases() ([]string, error) { - res, err := client.Query(PG_DATABASES) + res, err := client.query(PG_DATABASES) if err != nil { return nil, err @@ -70,7 +70,7 @@ func (client *Client) Databases() ([]string, error) { } func (client *Client) Tables() ([]string, error) { - res, err := client.Query(PG_TABLES) + res, err := client.query(PG_TABLES) if err != nil { return nil, err @@ -86,15 +86,15 @@ func (client *Client) Tables() ([]string, error) { } func (client *Client) Table(table string) (*Result, error) { - return client.Query(fmt.Sprintf(PG_TABLE_SCHEMA, table)) + return client.query(fmt.Sprintf(PG_TABLE_SCHEMA, table)) } func (client *Client) TableInfo(table string) (*Result, error) { - return client.Query(fmt.Sprintf(PG_TABLE_INFO, table, table, table, table)) + return client.query(fmt.Sprintf(PG_TABLE_INFO, table, table, table, table)) } func (client *Client) TableIndexes(table string) (*Result, error) { - res, err := client.Query(fmt.Sprintf(PG_TABLE_INDEXES, table)) + res, err := client.query(fmt.Sprintf(PG_TABLE_INDEXES, table)) if err != nil { return nil, err @@ -104,9 +104,12 @@ func (client *Client) TableIndexes(table string) (*Result, error) { } func (client *Client) Query(query string) (*Result, error) { - rows, err := client.db.Queryx(query) - client.recordQuery(query) + return client.query(query) +} + +func (client *Client) query(query string) (*Result, error) { + rows, err := client.db.Queryx(query) if err != nil { return nil, err