update

Author: madasatya6

README.md

@@ -1,2 +1,2 @@
-# golang-mysql-graphql
-Contoh Graphql Golang + MySQL
+# Golang-mysql-graphql
+Example Golang graphql api with mysql db.

config/dbConfig.go

@@ -0,0 +1,19 @@
+package config
+
+import (
+	"database/sql"
+	_ "github.com/go-sql-driver/mysql"
+)
+
+
+func GetConnection() (*sql.DB,error){
+	db,err := sql.Open("mysql","user:pass@tcp(xxx.xxx.xxx.xxx:PORT)/namedb")
+	if err != nil {
+		panic(err.Error())
+	}
+	err = db.Ping()
+	if err != nil {
+		panic(err.Error())
+	}
+	return db,err
+}

main.go

@@ -0,0 +1,37 @@
+package main
+
+import (
+	"github.com/madasatya6/golang-mysql-graphql/schema/query"
+	"encoding/json"
+	"fmt"
+	"github.com/graphql-go/graphql"
+	"github.com/madasatya6/golang-mysql-graphql/schema/mutation"
+	"net/http"
+)
+
+func executeQuery(query string, schema graphql.Schema) *graphql.Result {
+	result := graphql.Do(graphql.Params{
+		Schema:   schema    ,
+		RequestString: query,
+	})
+	if len(result.Errors) > 0 {
+		fmt.Printf("wrong result, unexpected errors: %v", result.Errors)
+	}
+	return result
+}
+
+func main(){
+	var Schame,err = graphql.NewSchema(graphql.SchemaConfig{
+		Query:query.RootQuery,
+		Mutation: mutation.Mutation,
+	})
+	if err != nil{
+		panic(err.Error())
+	}
+	http.HandleFunc("/graphql", func(w http.ResponseWriter, r *http.Request) {
+		result := executeQuery(r.URL.Query().Get("Query"), Schame)
+		json.NewEncoder(w).Encode(result)
+	})
+	http.ListenAndServe(":8088", nil)
+
+}

schema/mutation/mutation.go

@@ -0,0 +1,33 @@
+package mutation
+
+import (
+	"github.com/madasatya6/golang-mysql-graphql/schema/types"
+	"github.com/graphql-go/graphql"
+)
+
+var Mutation = graphql.NewObject(graphql.ObjectConfig{
+	Name:"Mutation",
+	Fields:graphql.Fields{
+		"CreateProducts":&graphql.Field{
+			Type:graphql.NewList(types.ProductTypes),
+			//config param argument
+			Args:graphql.FieldConfigArgument{
+				"ID_PRO": &graphql.ArgumentConfig{
+					Type:graphql.NewNonNull(graphql.String),
+				},
+				"PRO_NAME": &graphql.ArgumentConfig{
+					Type:graphql.NewNonNull(graphql.String),
+				},
+				"QTE_IN_STOCK": &graphql.ArgumentConfig{
+					Type:graphql.NewNonNull(graphql.Int),
+				},
+				"PRO_IMAGE": &graphql.ArgumentConfig{
+					Type:graphql.NewNonNull(graphql.String),
+				},
+			},
+			Resolve: CreateProductMutation ,
+		},
+		// untuk membuat object lainya tinggal di ulang
+
+	},
+})

schema/mutation/resolverMutation.go

@@ -0,0 +1,23 @@
+package mutation
+
+import (
+	"github.com/madasatya6/golang-mysql-graphql/config"
+	"github.com/graphql-go/graphql"
+)
+
+func CreateProductMutation(param graphql.ResolveParams) (interface{},error) {
+	idpro := param.Args["ID_PRO"].(string)
+	nama := param.Args["PRO_NAME"].(string)
+	qty := param.Args["QTE_IN_STOCK"].(int)
+	img := param.Args["PRO_IMAGE"].(string)
+	db, err := config.GetConnection()
+	if err != nil {
+		panic(err.Error())
+	}
+	_ , err = db.Query("INSERT INTO Restaurant.Products values (?,?,?,?)",idpro,nama,qty,img)
+	if err != nil {
+		panic(err.Error())
+	}
+
+	return nil, err
+}

schema/query/query.go

@@ -0,0 +1,24 @@
+package query
+
+import (
+	"github.com/madasatya6/golang-mysql-graphql/schema/types"
+	"github.com/graphql-go/graphql"
+)
+
+var RootQuery = graphql.NewObject(graphql.ObjectConfig{
+	Name:"Query",
+	Fields:graphql.Fields{
+		"Products":&graphql.Field{
+			Type:graphql.NewList(types.ProductTypes),
+			//config param argument
+			Args:graphql.FieldConfigArgument{
+				"ID_PRO": &graphql.ArgumentConfig{
+					Type:graphql.NewNonNull(graphql.String),
+				},
+			},
+			Resolve: ProductResolve,
+		},
+		// untuk membuat object lainya tinggal di ulang
+
+	},
+})

schema/query/resolverQuery.go

@@ -0,0 +1,32 @@
+package query
+import (
+	"github.com/graphql-go/graphql"
+	"github.com/madasatya6/golang-mysql-graphql/schema/types"
+	"github.com/madasatya6/golang-mysql-graphql/config"
+)
+
+func ProductResolve(param graphql.ResolveParams) (interface{},error){
+	var a types.Product
+	var b []types.Product
+	db ,err:= config.GetConnection()
+	if err != nil {
+		panic(err.Error())
+	}
+	b = b[:0]
+	result,err := db.Query("select ID_PRO,PRO_NAME,QTE_IN_STOCK,ifnull(PRO_IMAGE,'') from Products")
+	if err != nil{
+		panic(err.Error())
+	}
+
+	for result.Next(){
+		err = result.Scan(&a.IdPro,&a.ProName,&a.QteStock,&a.ProImg)
+		if err != nil{
+			panic(err.Error())
+		}
+		b = append(b,a)
+
+	}
+
+
+	return b , nil
+}

schema/types/Model.go

@@ -0,0 +1,8 @@
+package types
+
+type Product struct {
+	IdPro string `json:"ID_PRO"`
+	ProName string `json:"PRO_NAME"`
+	QteStock int `json:"QTE_IN_STOCK"`
+	ProImg string `json:"PRO_IMAGE"`
+}

schema/types/types.go

@@ -0,0 +1,27 @@
+package types
+import (
+
+"github.com/graphql-go/graphql"
+
+)
+
+var ProductTypes = graphql.NewObject(graphql.ObjectConfig{
+	Name:"Products",
+	Fields:graphql.Fields{
+		"ID_PRO":&graphql.Field{
+			Type:graphql.Int,
+		},
+		"PRO_NAME":&graphql.Field{
+			Type:graphql.String,
+		},
+		"QTE_IN_STOCK":&graphql.Field{
+			Type:graphql.Int,
+		},
+		"PRICE":&graphql.Field{
+			Type:graphql.Float,
+		},
+		"PRO_IMAGE":&graphql.Field{
+			Type:graphql.String,
+		},
+	},
+})