log_debug('Exception already seen, handler broken')

            on_error(e)

            remove_all_rows()

        else: exc_strs.add(e_str)

    ignore_all_ref = [False]

    def remove_all_rows():

                    main_select, **insert_args)

            break # insert successful

        except sql.MissingCastException, e:

            type_ = e.type

            if e.col == None: out_cols = mapping.keys()

                            errors_table_)

                        break # cast successful

                    except sql.InvalidValueException, e:

                        ignore(in_col, e.value, e)

        except sql.DuplicateKeyException, e:

            # Different rows violating different unique constraints not

            # supported

                join_cols.values())

            insert_in_tables.append(insert_in_table)

        except sql.NullValueException, e:

            out_col, = e.cols

            try: in_col = mapping[out_col]

                    remove_all_rows()

            else: ignore(in_col, None, e)

        except sql.CheckException, e:

            ensure_cond(e.cond, e, failed=True)

        except sql.InvalidValueException, e:

            for in_col in mapping.values(): ignore(in_col, e.value, e)

        except psycopg2.extensions.TransactionRollbackError, e:

            # retry

        except sql.DatabaseErrors, e:

            log_debug('No handler for exception')

            on_error(e)