BUG23622215: Fix missing arguments in transaction methods

The following error is thrown on using any of the transaction methods:
TypeError: execute_nonquery() takes at least 3 arguments (2 given)

Adding the required arguments in the call to `execute_nonquery` from
each of the transaction methods.

Test cases were added for regression.

Author: amitab

lib/mysqlx/connection.py

@@ -182,19 +182,19 @@ def create_schema(self, name):
     def start_transaction(self):
         """Starts a transaction context on the server.
         """
-        self._connection.execute_nonquery("START TRANSACTION")
+        self._connection.execute_nonquery("sql", "START TRANSACTION", True)
 
     def commit(self):
         """Commits all the operations executed after a call to
         startTransaction().
         """
-        self._connection.execute_nonquery("COMMIT")
+        self._connection.execute_nonquery("sql", "COMMIT", True)
 
     def rollback(self):
         """Discards all the operations executed after a call to
         startTransaction().
         """
-        self._connection.execute_nonquery("ROLLBACK")
+        self._connection.execute_nonquery("sql", "ROLLBACK", True)
 
 
 class XSession(BaseSession):

tests/test_mysqlx_connection.py

@@ -106,3 +106,45 @@ def test_create_schema(self):
     def test_sql(self):
         statement = self.session.sql("SELECT VERSION()")
         self.assertTrue(isinstance(statement, mysqlx.statement.Statement))
+
+    def test_rollback(self):
+        table_name = "t2"
+        schema = self.session.get_schema(self.schema_name)
+
+        if not schema.exists_in_database():
+            self.session.create_schema(self.schema_name)
+
+        stmt = "CREATE TABLE {0}.{1}(_id INT)"
+        self.session.sql(stmt.format(self.schema_name, table_name)).execute()
+        table = schema.get_table(table_name)
+
+        self.session.start_transaction()
+
+        table.insert("_id").values(1).execute()
+        self.assertEqual(table.count(), 1)
+
+        self.session.rollback()
+        self.assertEqual(table.count(), 0)
+
+        schema.drop_table(table_name)
+
+    def test_commit(self):
+        table_name = "t2"
+        schema = self.session.get_schema(self.schema_name)
+
+        if not schema.exists_in_database():
+            self.session.create_schema(self.schema_name)
+
+        stmt = "CREATE TABLE {0}.{1}(_id INT)"
+        self.session.sql(stmt.format(self.schema_name, table_name)).execute()
+        table = schema.get_table(table_name)
+
+        self.session.start_transaction()
+
+        table.insert("_id").values(1).execute()
+        self.assertEqual(table.count(), 1)
+
+        self.session.commit()
+        self.assertEqual(table.count(), 1)
+
+        schema.drop_table(table_name)