[source storage] refactor source sql generation and results handling to allow repository side callbacks for instance with the BytesFileSystemStorage, before this change: * fspath, _fsopen function were stored procedures executed on the database -> files had to be available both on the repository *and* the database host * we needed implementation for each handled database Now, those function are python callbacks executed when necessary on the repository side, on data comming from the database. The litle cons are: * you can't do anymore restriction on mapped attributes * you can't write queries which will return in the same rset column some mapped attributes (or not mapped the same way) / some not This seems much acceptable since: * it's much more easy to handle when you start having the db on another host than the repo * BFSS works seemlessly on any backend now * you don't bother that much about the cons (at least in the bfss case): you usually don't do any restriction on Bytes... Bonus points: BFSS is more efficient (no queries under the cover as it was done in the registered procedure) and we have a much nicer/efficient fspath implementation. IMO, that rocks :D

     1

"""pytest configuration file: we need this to properly remove ressources

     2

cached on test classes, at least until we've proper support for teardown_class

     3

"""

     4

import sys

     5

from os.path import split, splitext

     6

from logilab.common.pytest import PyTester

     7

     8

from cubicweb.etwist.server import _gc_debug

     9

    10

class CustomPyTester(PyTester):

    11

    def testfile(self, filename, batchmode=False):

    12

        try:

    13

            return super(CustomPyTester, self).testfile(filename, batchmode)

    14

        finally:

    15

            modname = splitext(split(filename)[1])[0]

    16

            try:

    17

                module = sys.modules[modname]

    18

            except KeyError:

    19

                # error during test module import

    20

                return

    21

            for cls in vars(module).values():

    22

                if getattr(cls, '__module__', None) != modname:

    23

                    continue

    24

                clean_repo_test_cls(cls)

    25

            #_gc_debug()

    26

    27

def clean_repo_test_cls(cls):

    28

    if 'repo' in cls.__dict__:

    29

        if not cls.repo._shutting_down:

    30

            cls.repo.shutdown()

    31

        del cls.repo

    32

    for clsattr in ('cnx', '_orig_cnx', 'config', '_config', 'vreg', 'schema'):

    33

        if clsattr in cls.__dict__:

    34

            delattr(cls, clsattr)