text: import sys
  from importlib import import_module
  from optparse import make_option
  
  from django.conf import settings
  from django.core.apps import app_cache
  from django.db import connections, router, transaction, DEFAULT_DB_ALIAS
  from django.core.management import call_command
  from django.core.management.base import NoArgsCommand, CommandError
  from django.core.management.color import no_style
  from django.core.management.sql import sql_flush, emit_post_migrate_signal
  from django.utils.six.moves import input
  from django.utils import six
  
  
  class Command(NoArgsCommand):
      option_list = NoArgsCommand.option_list + (
          make_option('--noinput', action='store_false', dest='interactive', default=True,
              help='Tells Django to NOT prompt the user for input of any kind.'),
          make_option('--database', action='store', dest='database',
              default=DEFAULT_DB_ALIAS, help='Nominates a database to flush. '
                  'Defaults to the "default" database.'),
          make_option('--no-initial-data', action='store_false', dest='load_initial_data', default=True,
              help='Tells Django not to load any initial data after database synchronization.'),
      )
      help = ('Returns the database to the state it was in immediately after '
             'migrate was first executed. This means that all data will be removed '
             'from the database, any post-migration handlers will be '
             're-executed, and the initial_data fixture will be re-installed.')
  
      def handle_noargs(self, **options):
          db = options.get('database')
          connection = connections[db]
          verbosity = int(options.get('verbosity'))
          interactive = options.get('interactive')
          # The following are stealth options used by Django's internals.
          reset_sequences = options.get('reset_sequences', True)
          allow_cascade = options.get('allow_cascade', False)
          inhibit_post_migrate = options.get('inhibit_post_migrate', False)
  
          self.style = no_style()
  
          # Import the 'management' module within each installed app, to register
          # dispatcher events.
          for app_name in settings.INSTALLED_APPS:
              try:
                  import_module('.management', app_name)
              except ImportError:
                  pass
  
          sql_list = sql_flush(self.style, connection, only_django=True,
                               reset_sequences=reset_sequences,
                               allow_cascade=allow_cascade)
  
          if interactive:
              confirm = input("""You have requested a flush of the database.
  This will IRREVERSIBLY DESTROY all data currently in the %r database,
  and return each table to a fresh state.
  Are you sure you want to do this?
  
      Type 'yes' to continue, or 'no' to cancel: """ % connection.settings_dict['NAME'])
          else:
              confirm = 'yes'
  
          if confirm == 'yes':
              try:
                  with transaction.commit_on_success_unless_managed():
                      cursor = connection.cursor()
                      for sql in sql_list:
                          cursor.execute(sql)
              except Exception as e:
                  new_msg = (
                      "Database %s couldn't be flushed. Possible reasons:\n"
                      "  * The database isn't running or isn't configured correctly.\n"
                      "  * At least one of the expected database tables doesn't exist.\n"
                      "  * The SQL was invalid.\n"
                      "Hint: Look at the output of 'django-admin.py sqlflush'. That's the SQL this command wasn't able to run.\n"
                      "The full error: %s") % (connection.settings_dict['NAME'], e)
                  six.reraise(CommandError, CommandError(new_msg), sys.exc_info()[2])
  
              if not inhibit_post_migrate:
                  self.emit_post_migrate(verbosity, interactive, db)
  
              # Reinstall the initial_data fixture.
              if options.get('load_initial_data'):
                  # Reinstall the initial_data fixture.
                  call_command('loaddata', 'initial_data', **options)
  
          else:
              self.stdout.write("Flush cancelled.\n")
  
      @staticmethod
      def emit_post_migrate(verbosity, interactive, database):
          # Emit the post migrate signal. This allows individual applications to
          # respond as if the database had been migrated from scratch.
          all_models = []
          for app_config in app_cache.get_app_configs(only_with_models_module=True):
              all_models.extend(router.get_migratable_models(app_config.models_module, database, include_auto_created=True))
          emit_post_migrate_signal(set(all_models), verbosity, interactive, database)
  