code: def execute(self, query, *multiparams, **params):
          
          coro = self._execute(query, *multiparams, **params)
          return _SAConnectionContextManager(coro)
docs: Executes a SQL query with optional parameters.
  
          query - a SQL query string or any sqlalchemy expression.
  
          *multiparams/**params - represent bound parameter values to be
          used in the execution.  Typically, the format is a dictionary
          passed to *multiparams:
  
              await conn.execute(
                  table.insert(),
                  {"id":1, "value":"v1"},
              )
  
          ...or individual key/values interpreted by **params::
  
              await conn.execute(
                  table.insert(), id=1, value="v1"
              )
  
          In the case that a plain SQL string is passed, a tuple or
          individual values in \*multiparams may be passed::
  
              await conn.execute(
                  "INSERT INTO table (id, value) VALUES (%d, %s)",
                  (1, "v1")
              )
  
              await conn.execute(
                  "INSERT INTO table (id, value) VALUES (%s, %s)",
                  1, "v1"
              )
  
          Returns ResultProxy instance with results of SQL query
          execution.