232     sqlcnx = repo.system_source.get_connection()

   232     with repo.internal_cnx() as cnx:

   233     sqlcursor = sqlcnx.cursor()

   233         sqlcnx = cnx.cnxset.cnx

   234     execute = sqlcursor.execute

   234         sqlcursor = cnx.cnxset.cu

   235     if drop:

   235         execute = sqlcursor.execute

   236         helper = database.get_db_helper(driver)

   236         if drop:

   237         dropsql = sql_drop_all_user_tables(helper, sqlcursor)

   237             helper = database.get_db_helper(driver)

   238         # We may fail dropping some tables because of table dependencies, in a first pass.

   238             dropsql = sql_drop_all_user_tables(helper, sqlcursor)

   239         # So, we try a second drop sequence to drop remaining tables if needed.

   239             # We may fail dropping some tables because of table dependencies, in a first pass.

   240         # Note that 2 passes is an arbitrary choice as it seems enougth for our usecases.

   240             # So, we try a second drop sequence to drop remaining tables if needed.

   241         # (looping may induce infinite recursion when user have no right for example)

   241             # Note that 2 passes is an arbitrary choice as it seems enough for our usecases

   242         # Here we try to keep code simple and backend independant. That why we don't try to

   242             # (looping may induce infinite recursion when user have no rights for example).

   243         # distinguish remaining tables (wrong right, dependencies, ...).

   243             # Here we try to keep code simple and backend independent. That's why we don't try to

   244         failed = sqlexec(dropsql, execute, cnx=sqlcnx,

   244             # distinguish remaining tables (missing privileges, dependencies, ...).

   245                          pbtitle='-> dropping tables (first pass)')

   245             failed = sqlexec(dropsql, execute, cnx=sqlcnx,

   246                              pbtitle='-> dropping tables (first pass)')

   247             if failed:

   248                 failed = sqlexec(failed, execute, cnx=sqlcnx,

   249                                  pbtitle='-> dropping tables (second pass)')

   250                 remainings = list(filter(drop_filter, helper.list_tables(sqlcursor)))

   251                 assert not remainings, 'Remaining tables: %s' % ', '.join(remainings)

   252         handler = config.migration_handler(schema, interactive=False, repo=repo, cnx=cnx)

   253         # install additional driver specific sql files

   254         handler.cmd_install_custom_sql_scripts()

   255         for cube in reversed(config.cubes()):

   256             handler.cmd_install_custom_sql_scripts(cube)

   257         _title = '-> creating tables '

   258         print(_title, end=' ')

   259         # schema entities and relations tables

   260         # can't skip entities table even if system source doesn't support them,

   261         # they are used sometimes by generated sql. Keeping them empty is much

   262         # simpler than fixing this...

   263         schemasql = sqlschema(schema, driver)

   264         #skip_entities=[str(e) for e in schema.entities()

   265         #               if not repo.system_source.support_entity(str(e))])

   266         failed = sqlexec(schemasql, execute, pbtitle=_title, delimiter=';;')

   247             failed = sqlexec(failed, execute, cnx=sqlcnx,

   268             print('The following SQL statements failed. You should check your schema.')

   248                              pbtitle='-> dropping tables (second pass)')

   269             print(failed)

   249             remainings = list(filter(drop_filter, helper.list_tables(sqlcursor)))

   270             raise Exception('execution of the sql schema failed, you should check your schema')

   250             assert not remainings, 'Remaining tables: %s' % ', '.join(remainings)

   271         sqlcursor.close()

   251     _title = '-> creating tables '

   272         sqlcnx.commit()

   252     print(_title, end=' ')

   253     # schema entities and relations tables

   254     # can't skip entities table even if system source doesn't support them,

   255     # they are used sometimes by generated sql. Keeping them empty is much

   256     # simpler than fixing this...

   257     schemasql = sqlschema(schema, driver)

   258     #skip_entities=[str(e) for e in schema.entities()

   259     #               if not repo.system_source.support_entity(str(e))])

   260     failed = sqlexec(schemasql, execute, pbtitle=_title, delimiter=';;')

   261     if failed:

   262         print('The following SQL statements failed. You should check your schema.')

   263         print(failed)

   264         raise Exception('execution of the sql schema failed, you should check your schema')

   265     sqlcursor.close()

   266     sqlcnx.commit()

   267     sqlcnx.close()

   292     # reloging using the admin user

   297     # re-login using the admin user