go delete

Author: devpranoy

crud.go

@@ -32,8 +32,6 @@ func create(w http.ResponseWriter, r *http.Request) {
 	var createEvent event
 	reqBody, err := ioutil.ReadAll(r.Body)
 	json.Unmarshal(reqBody, &createEvent)
-
-	fmt.Println(createEvent.Name)
 	psqlInfo := fmt.Sprintf("host=%s port=%d user=%s "+"password=%s dbname=%s sslmode=disable",
 		host, port, user, password, dbname)
 	db, err := sql.Open("postgres", psqlInfo)
@@ -75,19 +73,54 @@ func read(w http.ResponseWriter, r *http.Request) {
 
 // UPDATE
 func update(w http.ResponseWriter, r *http.Request) {
-	fmt.Fprintf(w, "Welcome home!")
+	var createEvent event
+	reqBody, err := ioutil.ReadAll(r.Body)
+	json.Unmarshal(reqBody, &createEvent)
+	psqlInfo := fmt.Sprintf("host=%s port=%d user=%s "+"password=%s dbname=%s sslmode=disable",
+		host, port, user, password, dbname)
+	db, err := sql.Open("postgres", psqlInfo)
+	if err != nil {
+		panic(err)
+	}
+	sqlStatement := `UPDATE data SET name = ($1)`
+	_, err = db.Exec(sqlStatement, createEvent.Name)
+	if err != nil {
+		panic(err)
+	}
+	defer db.Close()
+	var response message
+	response.Message = "Success"
+	json.NewEncoder(w).Encode(response)
+
 }
 
 // DELETE
 func delete(w http.ResponseWriter, r *http.Request) {
-	fmt.Fprintf(w, "Welcome home!")
+	var createEvent event
+	reqBody, err := ioutil.ReadAll(r.Body)
+	json.Unmarshal(reqBody, &createEvent)
+	psqlInfo := fmt.Sprintf("host=%s port=%d user=%s "+"password=%s dbname=%s sslmode=disable",
+		host, port, user, password, dbname)
+	db, err := sql.Open("postgres", psqlInfo)
+	if err != nil {
+		panic(err)
+	}
+	sqlStatement := `DELETE FROM data WHERE name = ($1)`
+	_, err = db.Exec(sqlStatement, createEvent.Name)
+	if err != nil {
+		panic(err)
+	}
+	defer db.Close()
+	var response message
+	response.Message = "Success"
+	json.NewEncoder(w).Encode(response)
 }
 
 func main() {
 	router := mux.NewRouter().StrictSlash(true)
-	router.HandleFunc("/create", create)
-	router.HandleFunc("/read", read)
-	router.HandleFunc("/update", update)
-	router.HandleFunc("/delete", delete)
+	router.HandleFunc("/create", create).Methods("POST")
+	router.HandleFunc("/read", read).Methods("GET")
+	router.HandleFunc("/update", update).Methods("PUT")
+	router.HandleFunc("/delete", delete).Methods("DELETE")
 	log.Fatal(http.ListenAndServe(":8080", router))
 }

crud.py

@@ -13,7 +13,7 @@ def create():
     cur.execute(sql)
     conn.commit()
     conn.close()
-    response = {'message':'Success'}
+    response = {'Message':'Success'}
     return json.dumps(response)
 
 # READ
@@ -25,20 +25,20 @@ def read():
     cur.execute(sql)
     data = cur.fetchone()
     conn.close()
-    response = {'name':data[0]}
+    response = {'Name':data[0]}
     return json.dumps(response)
 
 # UPDATE
 @app.route('/update', methods=['PUT']) 
 def update():
-    name = request.json['name']
+    name = request.json['Name']
     conn = psycopg2.connect(database="postgres", user = "postgres", password = "password", host = "127.0.0.1", port = "5432")
     cur = conn.cursor()
     sql = "update data set name = '%s'"%name
     cur.execute(sql)
     conn.commit()
     conn.close()
-    response = {'message':'Success'}
+    response = {'Message':'Success'}
     return json.dumps(response)
 
 # DELETE
@@ -51,7 +51,7 @@ def delete():
     cur.execute(sql)
     conn.commit()
     conn.close()
-    response = {'message':'Success'}
+    response = {'Message':'Success'}
     return json.dumps(response)