old_contents: from asyncpgsa import compile_query
  from asyncpgsa.pool import SAPool
  
  from .mockconnection import MockConnection
  from .mocktransactionmanager import MockTransactionManager
  
  
  class MockSAPool(SAPool):
      def __init__(self, connection=None):
          super().__init__(min_size=1,
                           max_size=1,
                           max_queries=1,
                           setup=None,
                           loop=None)
          self.connection = connection
          if not self.connection:
              self.connection = MockConnection()
  
      def __getattr__(self, item):
          raise Exception('Sorry, {} doesnt exist yet. '
                          'Consider making a PR.'.format(item))
  
      async def _new_connection(self, timeout=None):
          return self.connection
  
      async def acquire(self, *, timeout=None):
          return self.connection
  
      async def release(self, connection):
          pass
  
      async def general_query(self, query, *args, **kwargs):
          q, a = compile_query(query)
          return self.connection.general_query(q, *args, **kwargs)
  
      def transaction(self, **kwargs):
          return MockTransactionManager(self, self.connection)
  
new_contents: from asyncpgsa import compile_query
  from asyncpgsa.pool import SAPool
  
  from .mockconnection import MockConnection
  from .mocktransactionmanager import MockTransactionManager
  
  
  class MockSAPool(SAPool):
      def __init__(self, connection=None):
          super().__init__(min_size=1,
                           max_size=1,
                           max_queries=1,
                           setup=None,
                           loop=None,
                           init=None)
          self.connection = connection
          if not self.connection:
              self.connection = MockConnection()
  
      def __getattr__(self, item):
          raise Exception('Sorry, {} doesnt exist yet. '
                          'Consider making a PR.'.format(item))
  
      async def _new_connection(self, timeout=None):
          return self.connection
  
      async def acquire(self, *, timeout=None):
          return self.connection
  
      async def release(self, connection):
          pass
  
      async def general_query(self, query, *args, **kwargs):
          q, a = compile_query(query)
          return self.connection.general_query(q, *args, **kwargs)
  
      def transaction(self, **kwargs):
          return MockTransactionManager(self, self.connection)
  
subject: Update mockpool.py (#27)