--- trunk/lib/WebPAC/Input.pm 2006/08/25 12:31:06 619 +++ trunk/lib/WebPAC/Input.pm 2006/09/06 18:08:30 634 @@ -7,8 +7,8 @@ use WebPAC::Common; use base qw/WebPAC::Common/; -use Text::Iconv; use Data::Dumper; +use Encode qw/from_to/; =head1 NAME @@ -159,7 +159,7 @@ $input->open( path => '/path/to/database/file', - code_page => '852', + code_page => 'cp852', limit => 500, offset => 6000, lookup => $lookup_obj, @@ -174,7 +174,7 @@ }, ); -By default, C is assumed to be C<852>. +By default, C is assumed to be C. C is optional parametar to position at some offset before reading from database. @@ -205,7 +205,7 @@ if ($arg->{lookup_coderef} && ref($arg->{lookup_coderef}) ne 'CODE'); $log->logcroak("need path") if (! $arg->{'path'}); - my $code_page = $arg->{'code_page'} || '852'; + my $code_page = $arg->{'code_page'} || 'cp852'; # store data in object $self->{'input_code_page'} = $code_page; @@ -213,9 +213,6 @@ $self->{$v} = $arg->{$v} if ($arg->{$v}); } - # create Text::Iconv object - $self->{iconv} = Text::Iconv->new($code_page,$self->{'encoding'}); ## FIXME remove! - my $filter_ref; my $recode_regex; my $recode_map; @@ -243,21 +240,13 @@ my ($db, $size) = $self->{open_db}->( $self, path => $arg->{path}, - filter => sub { - my ($l,$f_nr) = @_; - return unless defined($l); - - ## FIXME remove iconv! - $l = $self->{iconv}->convert($l) if ($self->{iconv}); - - $l =~ s/($recode_regex)/$recode_map->{$1}/g if ($recode_regex && $recode_map); - - ## FIXME remove this warning when we are sure that none of API is calling - ## this wrongly - warn "filter called without field number" unless ($f_nr); - - return $l; - }, +# filter => sub { +# my ($l,$f_nr) = @_; +# return unless defined($l); +# from_to($l, $code_page, $self->{'encoding'}); +# $l =~ s/($recode_regex)/$recode_map->{$1}/g if ($recode_regex && $recode_map); +# return $l; +# }, %{ $arg }, ); @@ -299,20 +288,30 @@ my $rec = $self->{fetch_rec}->($self, $db, $pos, sub { my ($l,$f_nr) = @_; - return unless defined($l); - return $l unless ($rec_regex && $f_nr); +# return unless defined($l); +# return $l unless ($rec_regex && $f_nr); + + $log->debug("-=> $f_nr ## $l"); + + # codepage conversion and recode_regex + from_to($l, $code_page, $self->{'encoding'}); + $l =~ s/($recode_regex)/$recode_map->{$1}/g if ($recode_regex && $recode_map); # apply regexps if ($rec_regex && defined($rec_regex->{$f_nr})) { $log->logconfess("regexps->{$f_nr} must be ARRAY") if (ref($rec_regex->{$f_nr}) ne 'ARRAY'); my $c = 0; foreach my $r (@{ $rec_regex->{$f_nr} }) { - #$log->debug("\$l = $l\neval \$l =~ $r"); + my $old_l = $l; eval '$l =~ ' . $r; + if ($old_l ne $l) { + $log->debug("REGEX on $f_nr eval \$l =~ $r\n## old l: [$old_l]\n## new l: [$l]"); + } $log->error("error applying regex: $r") if ($@); } } + $log->debug("<=- $f_nr ## $l"); return $l; }); @@ -552,25 +551,29 @@ my $regexpes; + my $log = $self->_get_logger(); + foreach my $f (keys %$modify_record) { -warn "--- f: $f\n"; + $log->debug("field: $f"); + foreach my $sf (keys %{ $modify_record->{$f} }) { -warn "---- sf: $sf\n"; + $log->debug("subfield: $sf"); + foreach my $from (keys %{ $modify_record->{$f}->{$sf} }) { my $to = $modify_record->{$f}->{$sf}->{$from}; #die "no field?" unless defined($to); -warn "----- transform: |$from| -> |$to|\n"; + $log->debug("transform: |$from| -> |$to|"); if ($sf =~ /^\^/) { my $regex = - 's/\Q'. $sf .'\E([^\^]+)\Q'. $from .'\E([^\^]+)/'. $sf .'$1'. $to .'$2/g'; + 's/\Q'. $sf .'\E(.*?)\Q'. $from .'\E(.*?)/'. $sf .'$1'. $to .'$2/g'; push @{ $regexpes->{$f} }, $regex; -warn ">>>>> $regex [sf]\n"; + $log->debug(">>>>> $regex [sf]"); } else { my $regex = 's/\Q'. $from .'\E/'. $to .'/g'; push @{ $regexpes->{$f} }, $regex; -warn ">>>>> $regex [global]\n"; + $log->debug(">>>>> $regex [global]"); } }