def METHOD_NAME(connection, drop_all=False):
    if drop_all:
        if schema_exists(connection, "processing"):
            connection.execute("DROP SCHEMA processing CASCADE;")
        if schema_exists(connection, "datamart"):
            connection.execute("DROP SCHEMA datamart CASCADE;")
    if not schema_exists(connection, "datamart"):
        connection.execute("CREATE SCHEMA datamart;")
    if not schema_exists(connection, "processing"):
        connection.execute("CREATE SCHEMA processing;")
    Base.metadata.create_all(connection)
    dbsession = get_session_factory(connection)()
    populate_datamart(dbsession)
    dbsession.commit()