package main

import (
	"database/sql"
	"fmt"
	"log"

	_ "github.com/lib/pq"
)

func main() {
	user := "worf"
	pass := "worf"
	host := "localhost"
	port := "5432"
	//dbName := "worf"
	connString := fmt.Sprintf("user=%s password=%s host=%s port=%s dbname=postgres sslmode=disable", user, pass, host, port)
	//connString := fmt.Sprintf("user=%s password=%s host=%s port=%s sslmode=disable", user, pass, host, port)
	db, err := sql.Open("postgres", connString)
	if err != nil {
		log.Fatal("connection error", err)
	}
	defer db.Close()
	rows, err := db.Query("select current_database()")
	if err != nil {
		log.Fatal(err)
	}
	defer rows.Close()
	var name string
	for rows.Next() {
		err := rows.Scan(&name)
		if err != nil {
			log.Fatal(err)
		}
		log.Println(name)
	}
	// _, err = db.Exec("CREATE DATABASE " + dbName)
	// if err != nil {
	// 	_, err = db.Query(`SELECT *, pg_terminate_backend(pid) FROM pg_stat_activity WHERE datname = $1`, dbName)
	// 	if err != nil {
	// 		log.Fatal("pid error", err)
	// 	}
	// 	_, err = db.Exec("DROP DATABASE " + dbName)
	// 	if err != nil {
	// 		log.Fatal("db drop error", err)
	// 	}
	// 	_, err = db.Exec("CREATE DATABASE " + dbName)
	// 	if err != nil {
	// 		log.Fatal("Create db error", err)
	// 	}
	// }
}