Revision 2db16f05 tools/migrate-data
b/tools/migrate-data | ||
---|---|---|
46 | 46 |
from lib.migrate import Migration |
47 | 47 |
|
48 | 48 |
class DataMigration(Migration): |
49 |
def __init__(self, db): |
|
50 |
Migration.__init__(self, db) |
|
49 |
def __init__(self, pithosdb, db):
|
|
50 |
Migration.__init__(self, pithosdb)
|
|
51 | 51 |
# XXX Need more columns for primary key - last modified timestamp... |
52 |
engine = create_engine(db) |
|
53 |
metadata = MetaData(engine) |
|
54 |
|
|
52 | 55 |
columns=[] |
53 | 56 |
columns.append(Column('path', String(2048), primary_key=True)) |
54 | 57 |
columns.append(Column('hash', String(255))) |
55 |
self.files = Table('files', self.metadata, *columns)
|
|
56 |
self.metadata.create_all(self.engine)
|
|
58 |
self.files = Table('files', metadata, *columns) |
|
59 |
metadata.create_all(engine)
|
|
57 | 60 |
|
58 | 61 |
def cache_put(self, path, hash): |
59 | 62 |
# Insert or replace. |
... | ... | |
108 | 111 |
print status |
109 | 112 |
|
110 | 113 |
if __name__ == "__main__": |
114 |
pithosdb = '' |
|
111 | 115 |
db = 'sqlite:///migrate.db' |
112 | 116 |
|
113 |
dt = DataMigration(db) |
|
117 |
dt = DataMigration(pithosdb, db)
|
|
114 | 118 |
dt.execute() |
Also available in: Unified diff