migrations for comments

Author: reddy-s

src/migrations/customer/00004_ratings_ddl.sql

@@ -4,11 +4,12 @@ CREATE TABLE IF NOT EXISTS ratings.feedback (
     id BIGINT AUTO_INCREMENT,
     customer_id BINARY(16),
     product_id MEDIUMINT,
+    title VARCHAR(100),
     rating TINYINT,
     summary TEXT,
     helpful MEDIUMINT,
     active BOOLEAN DEFAULT TRUE,
     created_on     DATETIME DEFAULT CURRENT_TIMESTAMP,
     updated_on DATETIME ON UPDATE CURRENT_TIMESTAMP,
-    PRIMARY KEY (id)
+    PRIMARY KEY (id, customer_id, product_id)
 );

src/migrations/procedures/ratings/create_rating.sql

@@ -0,0 +1,43 @@
+DROP PROCEDURE IF EXISTS ratings.create_rating;
+
+DELIMITER $$
+
+CREATE PROCEDURE ratings.create_rating ( IN in_customer_id BINARY(16) , IN in_product_id MEDIUMINT,  IN in_title VARCHAR(100), IN in_rating TINYINT, IN in_summary TEXT )
+BEGIN
+
+	DECLARE var_order_total_price DECIMAL(13,2);
+
+	DECLARE EXIT HANDLER FOR SQLEXCEPTION
+    BEGIN
+          ROLLBACK;
+    END;
+
+    START TRANSACTION;
+
+        -- Creating a feedback
+		INSERT INTO ratings.feedback (
+                customer_id,
+                product_id,
+                title,
+                rating,
+                summary,
+                helpful
+        ) VALUES (
+            in_customer_id,
+            in_product_id,
+            in_title,
+            in_rating,
+            in_summary,
+            0
+        );
+
+        -- Setting feedback id
+        SET @var_feedback_id = LAST_INSERT_ID();
+
+	COMMIT;
+
+    SELECT @var_feedback_id;
+
+END $$
+
+DELIMITER ;

src/migrations/procedures/ratings/update_rating.sql

@@ -0,0 +1,31 @@
+DROP PROCEDURE IF EXISTS ratings.update_rating;
+
+DELIMITER $$
+
+CREATE PROCEDURE ratings.update_rating ( IN in_customer_id BINARY(16) , IN in_feedback_id BIGINT,  IN in_title VARCHAR(100), IN in_rating TINYINT, IN in_summary TEXT )
+BEGIN
+
+	DECLARE var_order_total_price DECIMAL(13,2);
+
+	DECLARE EXIT HANDLER FOR SQLEXCEPTION
+    BEGIN
+          ROLLBACK;
+    END;
+
+    START TRANSACTION;
+
+        -- Update a feedback
+		UPDATE ratings.feedback
+        SET title = in_title,
+            rating = in_rating,
+            summary = in_summary
+        WHERE id = in_feedback_id
+        AND   customer_id = in_customer_id;
+
+	COMMIT;
+
+    SELECT in_feedback_id;
+
+END $$
+
+DELIMITER ;