Added sql queries execution in database and returing json

Author: romanoff

main.go

@@ -45,11 +45,35 @@ func handler(route *Route) func(http.ResponseWriter, *http.Request, httprouter.P
 		}
 		params, err := getRequestParams(r, urlParams)
 		sql, err := route.Sql(params)
+		if err != nil && sql != "" {
+			w.WriteHeader(http.StatusBadRequest)
+			fmt.Fprint(w, sql)
+			return
+		}
+		if err != nil {
+			w.WriteHeader(http.StatusInternalServerError)
+			log.Println(err)
+			return
+		}
+		log.Println(sql)
+		rows, err := db.Query(sql)
 		if err != nil {
 			w.WriteHeader(http.StatusInternalServerError)
+			log.Println(err)
 			return
 		}
-		fmt.Fprint(w, sql)
+		defer rows.Close()
+		var jsonValue string
+		for rows.Next() {
+			err := rows.Scan(&jsonValue)
+			if err != nil {
+				w.WriteHeader(http.StatusInternalServerError)
+				log.Println(err)
+				return
+			}
+			fmt.Fprint(w, jsonValue)
+		}
+
 	}
 }
 
@@ -64,6 +88,7 @@ func main() {
 	if err != nil {
 		log.Fatal(err)
 	}
+	defer db.Close()
 	router := httprouter.New()
 	for _, route := range routes {
 		if route.Method == "GET" {

route.go

@@ -3,6 +3,7 @@ package main
 import (
 	"bytes"
 	"encoding/json"
+	"errors"
 	"fmt"
 	"github.com/xeipuuv/gojsonschema"
 	"strings"
@@ -49,7 +50,7 @@ func (self *Route) Sql(params map[string]interface{}) (string, error) {
 		return "", err
 	}
 	if response != "" {
-		return response, nil
+		return response, errors.New("schema validation failed")
 	}
 	if !self.Custom {
 		out.Write([]byte("with response_table as ("))