try:

                create_query = 'CREATE'

                if temp: create_query += ' TEMP'

                return run_query(db, create_query, params, *args, **kw_args)

                    # CREATE TABLE AS sets rowcount to # rows in query

    # DISTINCT ON columns

    if distinct_on != []:

        if distinct_on is not distinct_on_all:

            query += ' ON ('+(', '.join(map(parse_col, distinct_on)))+')'

    # Columns

    if fields == None: query += '*'

    else: query += ', '.join(map(parse_col, fields))

    # Main table

    # Add joins

    left_table = table0

            conds.append((sql_gen.Col(table_not_null_col(db, table), table),

                None))

        left_table = table

    missing = True

    if conds != []:

            .to_str(db)+')' for l, r in conds)))

        missing = False

    if order_by != None:

    if start != None:

        missing = False

    if missing: warnings.warn(DbWarning(

        'SELECT statement missing a WHERE, LIMIT, or OFFSET clause: '+query))

    # Build query

    query = 'INSERT INTO '+table.to_str(db)

    if returning != None:

        returning_name = copy.copy(returning)

        returning_name.table = None

        returning_name = returning_name.to_str(db)

    if embeddable:

        assert returning != None

                function = sql_gen.Table(function_name, func_schema).to_str(db)

                function_query = '''\

'''

                run_query(db, function_query, recover=True, cacheable=True,

                    log_ignore_excs=(DuplicateFunctionException,))

            values.append(value)

    # Build query

    else: query = None

    return insert_select(db, table, cols, query, values, *args, **kw_args)

    query = 'UPDATE '+sql_gen.as_Table(table).to_str(db)+'\nSET\n'

    query += ',\n'.join((sql_gen.to_name_only_col(col, table).to_str(db)+' = '

        +sql_gen.as_Value(new_value).to_str(db) for col, new_value in changes))

    return query