log_debug('Trying to insert new rows')

        if is_function:

            log_debug('Calling function on input rows')

            args = dict(((k.name, v) for k, v in mapping.iteritems()))

            func_call = sql_gen.NamedCol(out_pkey,

                sql_gen.FunctionCall(out_table, **args))

            if not is_literals:

                # Create empty pkeys table so its row type can be used

                insert_into_pkeys(input_joins, [in_pkey_col, func_call],

                    limit=0, recover=True)

                result_type = db.col_info(sql_gen.Col(out_pkey, into)).type

                ## Create error handling wrapper function

                wrapper = db.TempFunction(sql_gen.concat(into.name, '_wrap'))

                select_cols = [in_pkey_col]+args.values()

                row_var = copy.copy(sql_gen.row_var)

                row_var.set_srcs([in_table])

                in_pkey_var = sql_gen.Col(in_pkey, row_var)

                args = dict(((k, sql_gen.with_table(v, row_var))

                    for k, v in args.iteritems()))

                func_call = sql_gen.FunctionCall(out_table, **args)

                def mk_return(result):

                    return sql_gen.ReturnQuery(sql.mk_select(db,

                        fields=[in_pkey_var, result], explain=False))

                exc_handler = func_wrapper_exception_handler(db,

                    mk_return(sql_gen.Cast(result_type, None)), args.values(),

                    errors_table_)

                sql.define_func(db, sql_gen.FunctionDef(wrapper,

                    sql_gen.SetOf(into),

                    sql_gen.RowExcIgnore(sql_gen.RowType(in_table),

                        sql.mk_select(db, input_joins, order_by=None),

                        mk_return(func_call), exc_handler=exc_handler)

                    ))

                wrapper_table = sql_gen.FunctionCall(wrapper)