Function queryPgStatActivity

tests/integration/pg_stat_activity_test.go:70–86

queryPgStatActivity returns all rows from pg_stat_activity as maps.

(db *sql.DB)

// queryPgStatActivity returns all rows from pg_stat_activity as maps.
func queryPgStatActivity(db *sql.DB) ([]map[string]interface{}, error) {
	rows, err := db.Query("SELECT * FROM pg_stat_activity")
	if err != nil {
		return nil, err
	}
	defer func() { _ = rows.Close() }()

	var result []map[string]interface{}
	for rows.Next() {
		row, err := scanPgStatActivityRow(rows)
		if err != nil {
			return nil, err
		}
		result = append(result, row)
	}
	return result, rows.Err()
}

// TestPgStatActivity tests the pg_stat_activity virtual table.
func TestPgStatActivity(t *testing.T) {