balki/pgweb
1
0
Fork 0
Code Pull Requests Activity

Move statements inline within Client

Browse Source
This commit is contained in:
Chris Bandy 2014-11-21 04:51:38 +00:00
parent b771465d99
commit e071532d35
2 changed files with 21 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
client.go
View File

@ -50,11 +50,15 @@ func (client *Client) recordQuery(query string) {
}
func (client *Client) Info() (*Result, error) {
return client.query(PG_INFO)
return client.query(`
SELECT version(), user, current_database(), inet_client_addr(), inet_client_port(), inet_server_addr(), inet_server_port()`,
)
}
func (client *Client) Databases() ([]string, error) {
res, err := client.query(PG_DATABASES)
res, err := client.query(`
SELECT datname FROM pg_database WHERE datistemplate = false ORDER BY datname ASC`,
)
if err != nil {
return nil, err
@ -70,7 +74,9 @@ func (client *Client) Databases() ([]string, error) {
}
func (client *Client) Tables() ([]string, error) {
res, err := client.query(PG_TABLES)
res, err := client.query(`
SELECT table_name FROM information_schema.tables WHERE table_schema = 'public' ORDER BY table_schema,table_name`,
)
if err != nil {
return nil, err
@ -86,15 +92,24 @@ 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(`
SELECT column_name, data_type, is_nullable, character_maximum_length, character_set_catalog, column_default FROM information_schema.columns where table_name = '%s'`,
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(`
SELECT pg_size_pretty(pg_table_size('%s')) AS data_size, pg_size_pretty(pg_indexes_size('%s')) AS index_size, pg_size_pretty(pg_total_relation_size('%s')) AS total_size, (SELECT COUNT(*) FROM %s) AS rows_count`,
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(`
SELECT indexname, indexdef FROM pg_indexes WHERE tablename = '%s'`,
table,
))
if err != nil {
return nil, err

10
statements.go
View File

@ -1,10 +0,0 @@
package main
const (
PG_INFO = "SELECT version(), user, current_database(), inet_client_addr(), inet_client_port(), inet_server_addr(), inet_server_port()"
PG_DATABASES = "SELECT datname FROM pg_database WHERE datistemplate = false ORDER BY datname ASC;"
PG_TABLES = "SELECT table_name FROM information_schema.tables WHERE table_schema = 'public' ORDER BY table_schema,table_name;"
PG_TABLE_SCHEMA = "SELECT column_name, data_type, is_nullable, character_maximum_length, character_set_catalog, column_default FROM information_schema.columns where table_name = '%s';"
PG_TABLE_INDEXES = "SELECT indexname, indexdef FROM pg_indexes WHERE tablename = '%s';"
PG_TABLE_INFO = "SELECT pg_size_pretty(pg_table_size('%s')) AS data_size, pg_size_pretty(pg_indexes_size('%s')) AS index_size, pg_size_pretty(pg_total_relation_size('%s')) AS total_size, (SELECT COUNT(*) FROM %s) AS rows_count"
)