equal
deleted
inserted
replaced
141 else: |
141 else: |
142 schemasql = sqlschema(schema, driver) |
142 schemasql = sqlschema(schema, driver) |
143 #skip_entities=[str(e) for e in schema.entities() |
143 #skip_entities=[str(e) for e in schema.entities() |
144 # if not repo.system_source.support_entity(str(e))]) |
144 # if not repo.system_source.support_entity(str(e))]) |
145 sqlexec(schemasql, execute, pbtitle=_title) |
145 sqlexec(schemasql, execute, pbtitle=_title) |
146 # install additional driver specific sql files |
|
147 for fpath in glob(join(CW_SOFTWARE_ROOT, 'schemas', '*.sql.%s' % driver)): |
|
148 print '-> installing', fpath |
|
149 sqlexec(open(fpath).read(), execute, False, delimiter=';;') |
|
150 for directory in reversed(config.cubes_path()): |
|
151 for fpath in glob(join(directory, 'schema', '*.sql.%s' % driver)): |
|
152 print '-> installing', fpath |
|
153 sqlexec(open(fpath).read(), execute, False, delimiter=';;') |
|
154 sqlcursor.close() |
146 sqlcursor.close() |
155 sqlcnx.commit() |
147 sqlcnx.commit() |
156 sqlcnx.close() |
148 sqlcnx.close() |
157 session = repo.internal_session() |
149 session = repo.internal_session() |
158 try: |
150 try: |
181 config.cube_appobject_path = set(('entities',)) |
173 config.cube_appobject_path = set(('entities',)) |
182 repo.vreg.set_schema(repo.schema) |
174 repo.vreg.set_schema(repo.schema) |
183 assert len(repo.sources) == 1, repo.sources |
175 assert len(repo.sources) == 1, repo.sources |
184 handler = config.migration_handler(schema, interactive=False, |
176 handler = config.migration_handler(schema, interactive=False, |
185 cnx=cnx, repo=repo) |
177 cnx=cnx, repo=repo) |
|
178 # install additional driver specific sql files |
|
179 handler.install_custom_sql_scripts(join(CW_SOFTWARE_ROOT, 'schemas'), driver) |
|
180 for directory in reversed(config.cubes_path()): |
|
181 handler.install_custom_sql_scripts(join(directory, 'schema'), driver) |
186 initialize_schema(config, schema, handler) |
182 initialize_schema(config, schema, handler) |
187 # yoo ! |
183 # yoo ! |
188 cnx.commit() |
184 cnx.commit() |
189 config.enabled_sources = None |
185 config.enabled_sources = None |
190 for uri, source_config in config.sources().items(): |
186 for uri, source_config in config.sources().items(): |