import os

import re

    "Returns a list of the CREATE TABLE SQL statements for the given app."

        # This must be the "dummy" database backend, which means the user

        raise CommandError("Django doesn't know which syntax to use for your SQL statements,\n" +

    # Get installed models, so we generate REFERENCES right.

    # We trim models from the current app so that the sqlreset command does not

    # generate invalid SQL (leaving models out of known_models is harmless, so

    # we can be conservative).

    final_output = []

    tables = connection.introspection.table_names()

    known_models = set([model for model in connection.introspection.installed_models(tables) if model not in app_models])

    pending_references = {}

    for model in app_models:

        output, references = connection.creation.sql_create_model(model, style, known_models)

        final_output.extend(output)

        for refto, refs in references.items():

            pending_references.setdefault(refto, []).extend(refs)

            if refto in known_models:

                final_output.extend(connection.creation.sql_for_pending_references(refto, style, pending_references))

        final_output.extend(connection.creation.sql_for_pending_references(model, style, pending_references))

        # Keep track of the fact that we've created the table for this model.

        known_models.add(model)

    # Handle references to tables that are from other apps

    # but don't exist physically.

    not_installed_models = set(pending_references.keys())

    if not_installed_models:

        alter_sql = []

        for model in not_installed_models:

            alter_sql.extend(['-- ' + sql for sql in

                connection.creation.sql_for_pending_references(model, style, pending_references)])

        if alter_sql:

            final_output.append('-- The following references should be added but depend on non-existent tables:')

            final_output.extend(alter_sql)

    return final_output

    "Returns a list of the DROP TABLE SQL statements for the given app."

    # This should work even if a connection isn't available

    try:

        cursor = connection.cursor()

    except:

        cursor = None

    # Figure out which tables already exist

    if cursor:

        table_names = connection.introspection.get_table_list(cursor)

    else:

        table_names = []

    output = []

    # Output DROP TABLE statements for standard application tables.

    to_delete = set()

    references_to_delete = {}

    for model in app_models:

        if cursor and connection.introspection.table_name_converter(model._meta.db_table) in table_names:

            # The table exists, so it needs to be dropped

            opts = model._meta

            for f in opts.local_fields:

                if f.rel and f.rel.to not in to_delete:

                    references_to_delete.setdefault(f.rel.to, []).append( (model, f) )

            to_delete.add(model)

    for model in app_models:

        if connection.introspection.table_name_converter(model._meta.db_table) in table_names:

            output.extend(connection.creation.sql_destroy_model(model, references_to_delete, style))

    # Close database connection explicitly, in case this output is being piped

    # directly into a database client, to avoid locking issues.

    if cursor:

        cursor.close()

        connection.close()

    return output[::-1] # Reverse it, to deal with table dependencies.

    "Returns a list of the DROP TABLE SQL, then the CREATE TABLE SQL, for the given module."

    """

    Returns a list of the SQL statements used to flush the database.

    If only_django is True, then only table names that have associated Django

    models and are in INSTALLED_APPS will be included.

    """

    if only_django:

        tables = connection.introspection.django_table_names(only_existing=True)

    else:

        tables = connection.introspection.table_names()

    statements = connection.ops.sql_flush(style, tables, connection.introspection.sequence_list())

    return statements

    "Returns a list of the custom table modifying SQL statements for the given app."

    output = []

    app_models = get_models(app)

    app_dir = os.path.normpath(os.path.join(os.path.dirname(app.__file__), 'sql'))

    for model in app_models:

    return output

    "Returns a list of the CREATE INDEX SQL statements for all models in the given app."

    output = []

    for model in models.get_models(app):

        output.extend(connection.creation.sql_indexes_for_model(model, style))

    return output

    "Returns a list of CREATE TABLE SQL, initial-data inserts, and CREATE INDEX SQL for the given module."

    opts = model._meta

    app_dir = os.path.normpath(os.path.join(os.path.dirname(models.get_app(model._meta.app_label).__file__), 'sql'))

    output = []

    # Post-creation SQL should come before any initial SQL data is loaded.

    # Some backends can't execute more than one SQL statement at a time,

    # so split into separate statements.

    statements = re.compile(r";[ \t]*$", re.M)

    # Find custom SQL, if it's available.

                 os.path.join(app_dir, "%s.sql" % opts.object_name.lower())]

    for sql_file in sql_files:

        if os.path.exists(sql_file):

            fp = open(sql_file, 'U')

            for statement in statements.split(fp.read().decode(settings.FILE_CHARSET)):

                # Remove any comments from the file

                statement = re.sub(ur"--.*([\n\Z]|$)", "", statement)

                if statement.strip():

                    output.append(statement + u";")

            fp.close()

    return output

    # Emit the post_sync signal for every application.

    for app in models.get_apps():

        app_name = app.__name__.split('.')[-2]

        if verbosity >= 2:

            print "Running post-sync handlers for application", app_name

        models.signals.post_syncdb.send(sender=app, app=app,

            created_models=created_models, verbosity=verbosity,