Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package main
- import (
- "fmt"
- "github.com/jackc/pgx"
- )
- var db *pgx.Conn
- func setup() {
- cc := pgx.ConnConfig{
- Host: "127.0.0.1",
- User: "mongodb",
- Password: "",
- Port: 27032,
- Database: "biuser",
- }
- var err error
- db, err = pgx.Connect(cc)
- if err != nil {
- panic(fmt.Sprintf("conn open error: %v", err.Error()))
- }
- }
- func runQuery(query string) error {
- rows, err := db.Query(query)
- if err != nil {
- return err
- }
- for rows.Next() {
- }
- rows.Close()
- return rows.Err()
- }
- func main() {
- setup()
- query := "SELECT AVG(\"Employee Salary\") AS \"avg_Employee_Salary_ok\", \"Employee Name\" AS \"none_Employee_Name_nk\" from \"Staples\" WHERE ((NOT (\"Employee Dept\" IS NULL)) AND (\"Employee Name\" = 'Suzanne Lafrenière')) GROUP BY \"Employee Name\" ORDER BY 1, 2"
- fmt.Println(runQuery(query))
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement