Recount-Server/recount-server.go

package main

import (
    //"database/sql"
    "fmt"
    "log"
    "time"
    "net/http"

    "github.com/shopspring/decimal"
    _ "github.com/lib/pq"
    "github.com/jmoiron/sqlx"
)

type Transaction struct {
    id int 
    amount decimal.Decimal
    description string
    account int
    bucket int
    date time.Time
}

func hello(w http.ResponseWriter, req *http.Request) {
    fmt.Fprintf(w, "hello\n")
}

func headers(w http.ResponseWriter, req *http.Request) {
    for name, headers := range req.Header {
        for _, h := range headers {
            fmt.Fprintf(w, "%v: %v\n", name, h)
        }
    }
}

func main() {
    log.SetPrefix("RecountServer: ")
    log.SetFlags(0)

    // 
    db, err := sqlx.Connect("postgres", "user=rcntuser password=Devel@pmentPa$$w0rd host=10.0.0.183 dbname=Borealis sslmode=disable")
    if err != nil {
        log.Fatal(err)
    }
    log.Print("Database connected")

    // Confirm a successful connection.
    if err := db.Ping(); err != nil {
        log.Fatal(err)
    }
    log.Print("Database successfully pinged")

    transactions := []Transaction{}
    err = db.Select(&transactions, "SELECT * FROM rcnt.transactions ORDER BY trns_id DESC")
    if err != nil {
        log.Fatal(err)
    }
    fmt.Print(fmt.Sprintf("%+v\n", transactions))
    log.Print("Select has been run")

    for _, trns := range transactions {
        log.Print(fmt.Sprintf("%#v : %#v", trns.amount, trns.id))
    }

    log.Print("select all run is done")

    http.HandleFunc("/hello", hello)
    http.HandleFunc("/headers", headers)

    http.ListenAndServe(":8090", nil)

    //fmt.Println("Hello World")
}