|
a/pyforge/flyway/command.py |
|
b/pyforge/flyway/command.py |
|
... |
|
... |
| 37 |
connection = Connection(
|
37 |
connection = Connection(
|
| 38 |
parsed_connection_url['host'],
|
38 |
parsed_connection_url['host'],
|
| 39 |
parsed_connection_url['port'])
|
39 |
parsed_connection_url['port'])
|
| 40 |
databases = connection.database_names()
|
40 |
databases = connection.database_names()
|
| 41 |
datastores = [ DataStore(self.options.connection_url + db)
|
41 |
datastores = [ DataStore(self.options.connection_url + db)
|
| 42 |
for db in connection.database_names() ]
|
42 |
for db in connection.database_names()
|
|
|
43 |
if db not in ('admin', 'local')]
|
| 43 |
else:
|
44 |
else:
|
| 44 |
datastores = [ DataStore(self.options.connection_url) ]
|
45 |
datastores = [ DataStore(self.options.connection_url) ]
|
| 45 |
self.log.info('Migrate server: %s:%s',
|
46 |
self.log.info('Migrate server: %s:%s',
|
| 46 |
parsed_connection_url['host'],
|
47 |
parsed_connection_url['host'],
|
| 47 |
parsed_connection_url['port'])
|
48 |
parsed_connection_url['port'])
|