db/changes/235201/00-util_tx_commit.sql

@@ -0,0 +1,12 @@
+DROP PROCEDURE IF EXISTS util.tx_commit;
+
+DELIMITER $$
+$$
+CREATE DEFINER=`root`@`localhost` PROCEDURE `util`.`tx_commit`(IN tx BOOL)
+BEGIN
+    IF tx THEN
+        COMMIT;
+    END IF;
+END
+$$
+DELIMITER ;

db/changes/235201/00-util_tx_rollback.sql

@@ -0,0 +1,12 @@
+DROP PROCEDURE IF EXISTS util.tx_rollback;
+
+DELIMITER $$
+$$
+CREATE DEFINER=`root`@`localhost` PROCEDURE `util`.`tx_rollback`(tx BOOL)
+BEGIN
+    IF tx THEN
+        ROLLBACK;
+    END IF;
+END
+$$
+DELIMITER ;

db/changes/235201/00-util_tx_start.sql

@@ -0,0 +1,12 @@
+DROP PROCEDURE IF EXISTS util.tx_start;
+
+DELIMITER $$
+$$
+CREATE DEFINER=`root`@`localhost` PROCEDURE `util`.`tx_start`(tx BOOL)
+BEGIN
+    IF tx THEN
+        START TRANSACTION;
+    END IF;
+END
+$$
+DELIMITER ;