14 title = "%i entites to fix" % len(rset) |
14 title = "%i entites to fix" % len(rset) |
15 nbops = rset.rowcount |
15 nbops = rset.rowcount |
16 enabled = interactive_mode |
16 enabled = interactive_mode |
17 with progress(title=title, nbops=nbops, size=30, enabled=enabled) as pb: |
17 with progress(title=title, nbops=nbops, size=30, enabled=enabled) as pb: |
18 with hooks_control(session, session.HOOKS_DENY_ALL, 'integrity'): |
18 with hooks_control(session, session.HOOKS_DENY_ALL, 'integrity'): |
19 for i, e in enumerate(rset.entities()): |
19 for i, row in enumerate(rset): |
20 e.set_attributes(cwuri=e.cwuri.replace('/eid', '')) |
20 data = {'eid': row[0], 'cwuri': row[1].replace(u'/eid', u'')} |
21 if i % 100: # commit every 100 entities to limit memory consumption |
21 rql('SET X cwuri %(cwuri)s WHERE X eid %(eid)s', data) |
|
22 if not i % 100: # commit every 100 entities to limit memory consumption |
22 pb.text = "%i committed" % i |
23 pb.text = "%i committed" % i |
23 commit(ask_confirm=False) |
24 commit(ask_confirm=False) |
24 pb.update() |
25 pb.update() |
25 commit(ask_confirm=False) |
26 commit(ask_confirm=False) |
26 |
27 |