sync_schema_props_perms('defaultval')

def convert_defaultval(cwattr, default):

    from decimal import Decimal

    import yams

    from cubicweb import Binary

    if default is None:

        return

    atype = cwattr.to_entity[0].name

    if atype == 'Boolean':

        # boolean attributes with default=False were stored as ''

        assert default in ('True', 'False', ''), repr(default)

        default = default == 'True'

    elif atype in ('Int', 'BigInt'):

        default = int(default)

    elif atype == 'Float':

        default = float(default)

    elif atype == 'Decimal':

        default = Decimal(default)

    elif atype in ('Date', 'Datetime', 'TZDatetime', 'Time'):

        try:

            # handle NOW and TODAY, keep them stored as strings

            yams.KEYWORD_MAP[atype][default.upper()]

            default = default.upper()

        except KeyError:

            # otherwise get an actual date or datetime

            default = yams.DATE_FACTORY_MAP[atype](default)

    else:

        assert atype == 'String', atype

        default = unicode(default)

    return Binary.zpickle(default)

dbh = repo.system_source.dbhelper

        sql(req, args, ask_confirm=False)

# Set object type to "Bytes" for CWAttribute's "defaultval" attribute

rql('SET X to_entity B WHERE X is CWAttribute, X from_entity Y, Y name "CWAttribute", '

    'X relation_type Z, Z name "defaultval", B name "Bytes"')

from yams import buildobjs as ybo

schema.add_relation_def(ybo.RelationDefinition('CWAttribute', 'defaultval', 'Bytes'))

schema.del_relation_def('CWAttribute', 'defaultval', 'String')

commit()

for rschema in schema.relations():

    if rschema.symmetric:

        subjects = set(repr(e.type) for e in rschema.subjects())

        objects = set(repr(e.type) for e in rschema.objects())

        assert subjects == objects

        martians = set(str(eid) for eid, in sql('SELECT eid_to FROM %s_relation, entities WHERE eid_to = eid AND type NOT IN (%s)' %

                                           (rschema.type, ','.join(subjects))))

        martians |= set(str(eid) for eid, in sql('SELECT eid_from FROM %s_relation, entities WHERE eid_from = eid AND type NOT IN (%s)' %

                                            (rschema.type, ','.join(subjects))))

        if martians:

            martians = ','.join(martians)

            print 'deleting broken relations %s for eids %s' % (rschema.type, martians)

            sql('DELETE FROM %s_relation WHERE eid_from IN (%s) OR eid_to IN (%s)' % (rschema.type, martians, martians))

        with session.deny_all_hooks_but():

            rql('SET X %(r)s Y WHERE Y %(r)s X, NOT X %(r)s Y' % {'r': rschema.type})

    commit()