old_contents: import logging
  
  from airflow.hooks import MySqlHook
  from airflow.models import BaseOperator
  from airflow.utils import apply_defaults
  
  
  class MySqlOperator(BaseOperator):
      """
      Executes sql code in a specific MySQL database
  
      :param mysql_conn_id: reference to a specific mysql database
      :type mysql_conn_id: string
      :param sql: the sql code to be executed
      :type sql: Can receive a str representing a sql statement,
          a list of str (sql statements), or reference to a template file.
          Template reference are recognized by str ending in '.sql'
      """
  
      template_fields = ('sql',)
      template_ext = ('.sql',)
      ui_color = '#ededed'
  
      @apply_defaults
      def __init__(
              self, sql, mysql_conn_id='mysql_default', parameters=None,
              *args, **kwargs):
          super(MySqlOperator, self).__init__(*args, **kwargs)
          self.mysql_conn_id = mysql_conn_id
          self.sql = sql
          self.parameters = parameters
  
      def execute(self, context):
          logging.info('Executing: ' + str(self.sql))
          hook = MySqlHook(mysql_conn_id=self.mysql_conn_id)
          hook.run(self.sql, parameters=self.parameters)
  
new_contents: import logging
  
  from airflow.hooks import MySqlHook
  from airflow.models import BaseOperator
  from airflow.utils import apply_defaults
  
  
  class MySqlOperator(BaseOperator):
      """
      Executes sql code in a specific MySQL database
  
      :param mysql_conn_id: reference to a specific mysql database
      :type mysql_conn_id: string
      :param sql: the sql code to be executed
      :type sql: Can receive a str representing a sql statement,
          a list of str (sql statements), or reference to a template file.
          Template reference are recognized by str ending in '.sql'
      """
  
      template_fields = ('sql',)
      template_ext = ('.sql',)
      ui_color = '#ededed'
  
      @apply_defaults
      def __init__(
              self, sql, mysql_conn_id='mysql_default', parameters=None,
              autocommit=False, *args, **kwargs):
          super(MySqlOperator, self).__init__(*args, **kwargs)
          self.mysql_conn_id = mysql_conn_id
          self.sql = sql
          self.autocommit = autocommit
          self.parameters = parameters
  
      def execute(self, context):
          logging.info('Executing: ' + str(self.sql))
          hook = MySqlHook(mysql_conn_id=self.mysql_conn_id)
          hook.run(
              self.sql,
              autocommit=self.autocommit,
              parameters=self.parameters)
  
subject: Allow auto-commit option for Mysql Operator