text: # -*- coding: utf-8 -*-
  from __future__ import unicode_literals
  import unittest
  
  from infi.clickhouse_orm.models import BufferModel
  from infi.clickhouse_orm.engines import *
  from .base_test_with_data import *
  
  
  class BufferTestCase(TestCaseWithData):
  
      def _insert_and_check_buffer(self, data, count):
          self.database.insert(data)
          self.assertEqual(count, self.database.count(PersonBuffer))
  
      def _sample_buffer_data(self):
          for entry in data:
              yield PersonBuffer(**entry)
  
      def test_insert_buffer(self):
          self.database.create_table(PersonBuffer)
          self._insert_and_check_buffer(self._sample_buffer_data(), len(data))
  
  
  class PersonBuffer(BufferModel, Person):
  
      engine = Buffer(Person)
  