equal
deleted
inserted
replaced
65 pass |
65 pass |
66 for rschema in etype.subject_relations(): |
66 for rschema in etype.subject_relations(): |
67 if rschema == 'has_text': |
67 if rschema == 'has_text': |
68 continue |
68 continue |
69 if rschema.is_final() or rschema.inlined: |
69 if rschema.is_final() or rschema.inlined: |
70 if isinstance(source, SQLiteAbstractSource): |
70 sqlcu.execute('ALTER TABLE cw_%s RENAME %s TO cw_%s' |
71 sqlcu.execute('ALTER TABLE cw_%s ADD COLUMN cw_%s' |
71 % (etype, rschema, rschema)) |
72 % (etype, rschema)) |
72 print 'renamed %s.%s column for source %s' % ( |
73 sqlcu.execute('UPDATE cw_%s SET %s=cw_%s' |
73 etype, rschema, uri) |
74 % (etype, rschema, rschema)) |
|
75 print 'added %s.cw_%s column for source %s' % ( |
|
76 etype, rschema, uri) |
|
77 else: |
|
78 sqlcu.execute('ALTER TABLE cw_%s RENAME %s TO cw_%s' |
|
79 % (etype, rschema, rschema)) |
|
80 print 'renamed %s.%s column for source %s' % ( |
|
81 etype, rschema, uri) |
|
82 pool.commit() |
74 pool.commit() |
83 repo._free_pool(pool) |
75 repo._free_pool(pool) |
84 |
76 |
85 |
77 |
86 class ServerMigrationHelper(MigrationHelper): |
78 class ServerMigrationHelper(MigrationHelper): |