separate func added

Author: mikebionic

do_db_query.go

@@ -0,0 +1,74 @@
+package main
+
+import (
+	"database/sql"
+	"fmt"
+	"log"
+)
+
+func do_db_query(query_string string) {
+	db_type := "postgres"
+	db_user := "postgres"
+	db_password := "123456"
+	db_host := "localhost"
+	db_database := "dbSapHasap"
+
+	connStr := fmt.Sprintf("%s://%s:%s@%s/%s?sslmode=disable", db_type, db_user, db_password, db_host, db_database)
+
+	db, err := sql.Open("postgres", connStr)
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	query_request := query_string
+
+	rows, err := db.Query(query_request)
+	if err != nil {
+		log.Fatal(err)
+	}
+	defer rows.Close()
+
+	cols, _ := rows.Columns()
+
+	var query_results []interface{}
+
+	for rows.Next() {
+
+		values := make([]interface{}, len(cols))
+		valuePointers := make([]interface{}, len(cols))
+
+		for i := range cols {
+			valuePointers[i] = &values[i]
+		}
+
+		if err := rows.Scan(valuePointers...); err != nil {
+			log.Fatal(err)
+		}
+
+		for i, col := range cols {
+			query_result_dict := map[interface{}]interface{}{}
+
+			val := values[i]
+			b, ok := val.([]byte)
+
+			var v interface{}
+
+			if ok {
+				v = string(b)
+			} else {
+				v = val
+			}
+			query_result_dict[col] = v
+
+			fmt.Println(query_result_dict)
+			query_results = append(query_results, query_result_dict)
+		}
+
+		fmt.Println("resutls---------")
+		fmt.Println(query_results)
+
+	}
+
+	defer db.Close()
+	// return nil
+}

go.mod

@@ -4,5 +4,6 @@ go 1.16
 
 require (
 	github.com/go-sql-driver/mysql v1.6.0 // indirect
+	github.com/gorilla/mux v1.8.0 // indirect
 	github.com/lib/pq v1.10.2 // indirect
 )

go.sum

@@ -1,4 +1,6 @@
 github.com/go-sql-driver/mysql v1.6.0 h1:BCTh4TKNUYmOmMUcQ3IipzF5prigylS7XXjEkfCHuOE=
 github.com/go-sql-driver/mysql v1.6.0/go.mod h1:DCzpHaOWr8IXmIStZouvnhqoel9Qv2LBy8hT2VhHyBg=
+github.com/gorilla/mux v1.8.0 h1:i40aqfkR1h2SlN9hojwV5ZA91wcXFOvkdNIeFDP5koI=
+github.com/gorilla/mux v1.8.0/go.mod h1:DVbg23sWSpFRCP0SfiEN6jmj59UnW/n46BH5rLB71So=
 github.com/lib/pq v1.10.2 h1:AqzbZs4ZoCBp+GtejcpCpcxM3zlSMx29dXbUSeVtJb8=
-github.com/lib/pq v1.10.2/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=
+github.com/lib/pq v1.10.2/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=

main.go

@@ -1,78 +1,15 @@
 package main
 
 import (
-	"database/sql"
-	"fmt"
-	"log"
-
 	_ "github.com/lib/pq"
 )
 
 func main() {
 
-	db_type := "postgres"
-	db_user := "postgres"
-	db_password := "123456"
-	db_host := "localhost"
-	db_database := "dbSapHasap"
-
-	connStr := fmt.Sprintf("%s://%s:%s@%s/%s?sslmode=disable", db_type, db_user, db_password, db_host, db_database)
-
-	db, err := sql.Open("postgres", connStr)
-	if err != nil {
-		log.Fatal(err)
-	}
-
-	query_request := "SELECT \"ResId\", \"ResName\" FROM tbl_dk_resource"
-
-	rows, err := db.Query(query_request)
-	if err != nil {
-		log.Fatal(err)
-	}
-
-	defer rows.Close()
-
-	cols, _ := rows.Columns()
-
-	for rows.Next() {
-
-		values := make([]interface{}, len(cols))
-		valuePointers := make([]interface{}, len(cols))
-
-		for i := range cols {
-			valuePointers[i] = &values[i]
-		}
-
-		if err := rows.Scan(valuePointers...); err != nil {
-			log.Fatal(err)
-		}
-
-		var query_results []interface{}
-
-		for i, col := range cols {
-
-			query_result_dict := map[interface{}]interface{}{}
-			val := values[i]
-			b, ok := val.([]byte)
-
-			var v interface{}
-
-			if ok {
-				v = string(b)
-			} else {
-				v = val
-			}
-			query_result_dict[col] = v
-
-			fmt.Println(query_result_dict)
-			query_results = append(query_results, query_result_dict)
-		}
-
-		fmt.Println("resutls---------")
-		fmt.Println(query_results)
-
-	}
+	query_string := "SELECT \"ResId\", \"ResName\" FROM tbl_dk_resource"
+	query_string = "SELECT * FROM tbl_dk_res_category"
+	do_db_query(query_string)
 
-	defer db.Close()
+	// fmt.Println(response)
 
 }