package handler

import (
    "automation-data-testing-kafka-demo/driver"
    "fmt"
    "net/http"
    "time"
)

func getUser(w http.ResponseWriter, r *http.Request)  {
    /*accountID := r.FormValue("accountID")
    name        := r.FormValue("name")
    createdAt   := time.Now()
    modifiedAt  := ""*/

    db,err := driver.ConnectDB()
    if err != nil {
        panic(err.Error())
    }
	defer db.Close()

    dt := time.Now()
    fmt.Println(dt.Format("02-01-2006 15:04:05"))
    rows,err := db.Query("select account_id,name,created_at,modified_at from BWXUSER.account")
    if err != nil {
        fmt.Println("Error running query")
        fmt.Println(err)
        return
    }
    defer rows.Close()

    var a,b,c,d string
    for rows.Next() {
        rows.Scan(&a,&b,&c,&d)
    }

    fmt.Println("column 1 : " + a)
    fmt.Println("column 2 : " + b)
    fmt.Println("column 3 : " + c)
    fmt.Println("column 4 : " + d)
    fmt.Println(rows)

}