code: def query(query, use_sudo=True, **kwargs):
      
      func = use_sudo and run_as_root or run
  
      user = kwargs.get('mysql_user') or env.get('mysql_user')
      password = kwargs.get('mysql_password') or env.get('mysql_password')
  
      options = [
          '--batch',
          '--raw',
          '--skip-column-names',
      ]
      if user:
          options.append('--user=%s' % quote(user))
      if password:
          options.append('--password=%s' % quote(password))
      options = ' '.join(options)
  
      return func('mysql %(options)s --execute=%(query)s' % {
          'options': options,
          'query': quote(query),
      })
docs: Run a MySQL query.