def execute(self, query: str) -> None:
    self._ensure_transaction()
    self._connection_impl._protocol.sync_simple_query(query, enums.Capability.EXECUTE)
def execute(self, query: str) -> None:
    self._ensure_transaction()
    self._connection_impl._protocol.sync_simple_query(query, enums.Capability.EXECUTE)