def query_single(self, query: str, *args, **kwargs) -> typing.Any:
    self._ensure_transaction()
    con = self._connection_inner
    return self._connection_impl._protocol.sync_execute_anonymous(query=query, args=args, kwargs=kwargs, reg=con._codecs_registry, qc=con._query_cache, expect_one=True, io_format=protocol.IoFormat.BINARY)
def query_single(self, query: str, *args, **kwargs) -> typing.Any:
    self._ensure_transaction()
    con = self._connection_inner
    return self._connection_impl._protocol.sync_execute_anonymous(query=query, args=args, kwargs=kwargs, reg=con._codecs_registry, qc=con._query_cache, expect_one=True, io_format=protocol.IoFormat.BINARY)