File Coverage

blib/lib/SQL/Translator/Parser/xSV.pm

Criterion	Covered	Total	%
statement	67	68	98.5
branch	22	28	78.5
condition	15	25	60.0
subroutine	9	9	100.0
pod	0	1	0.0
total	113	131	86.2

package SQL::Translator::Parser::xSV;

=head1 NAME

SQL::Translator::Parser::xSV - parser for arbitrarily delimited text files

=head1 SYNOPSIS

  use SQL::Translator;
  use SQL::Translator::Parser::xSV;

  my $translator  =  SQL::Translator->new(
      parser      => 'xSV',
      parser_args => { field_separator => "\t" },
  );

=head1 DESCRIPTION

Parses arbitrarily delimited text files.  See the
Text::RecordParser manpage for arguments on how to parse the file
(e.g., C, C).  Other arguments
include:

=head1 OPTIONS

=over

=item * scan_fields

Indicates that the columns should be scanned to determine data types
and field sizes.  True by default.

=item * trim_fields

A shortcut to sending filters to Text::RecordParser, will create
callbacks that trim leading and trailing spaces from fields and headers.
True by default.

=back

Field names will automatically be normalized by
C.

=cut

use strict;
use warnings;
our @EXPORT;
our $VERSION = '1.63';

use Exporter;
use Text::ParseWords qw(quotewords);
use Text::RecordParser;
use SQL::Translator::Utils qw(debug normalize_name);

use base qw(Exporter);
@EXPORT = qw(parse);

#
# Passed a SQL::Translator instance and a string containing the data
#
sub parse {
    my ( $tr, $data )    = @_;
    my $args             = $tr->parser_args;
    my $parser           = Text::RecordParser->new(
        field_separator  => $args->{'field_separator'}  || ',',
        record_separator => $args->{'record_separator'} || "\n",
        data             => $data,
        header_filter    => \&normalize_name,
    );

    $parser->field_filter( sub { $_ = shift || ''; s/^\s+|\s+$//g; $_ } )
        unless defined $args->{'trim_fields'} && $args->{'trim_fields'} == 0;

    my $schema = $tr->schema;
    my $table = $schema->add_table( name => 'table1' );

    #
    # Get the field names from the first row.
    #
    $parser->bind_header;
    my @field_names = $parser->field_list;

    for ( my $i = 0; $i < @field_names; $i++ ) {
        my $field = $table->add_field(
            name              => $field_names[$i],
            data_type         => 'char',
            default_value     => '',
            size              => 255,
            is_nullable       => 1,
            is_auto_increment => undef,
        ) or die $table->error;

        if ( $i == 0 ) {
            $table->primary_key( $field->name );
            $field->is_primary_key(1);
        }
    }

    #
    # If directed, look at every field's values to guess size and type.
    #
    unless (
        defined $args->{'scan_fields'} &&
        $args->{'scan_fields'} == 0
    ) {
        my %field_info = map { $_, {} } @field_names;
        while ( my $rec = $parser->fetchrow_hashref ) {
            for my $field ( @field_names ) {
                my $data = defined $rec->{ $field } ? $rec->{ $field } : '';
                my $size = [ length $data ];
                my $type;

                if ( $data =~ /^-?\d+$/ ) {
                    $type = 'integer';
                }
                elsif (
                    $data =~ /^-?[,\d]+\.[\d+]?$/
                    ||
                    $data =~ /^-?[,\d]+?\.\d+$/
                    ||
                    $data =~ /^-?\.\d+$/
                ) {
                    $type = 'float';
                    my ( $w, $d ) =
                        map { s/,//g; length $_ || 1 } split( /\./, $data );
                    $size = [ $w + $d, $d ];
                }
                else {
                    $type = 'char';
                }

                for my $i ( 0, 1 ) {
                    next unless defined $size->[ $i ];
                    my $fsize = $field_info{ $field }{'size'}[ $i ] || 0;
                    if ( $size->[ $i ] > $fsize ) {
                        $field_info{ $field }{'size'}[ $i ] = $size->[ $i ];
                    }
                }

                $field_info{ $field }{ $type }++;
            }
        }

        for my $field ( keys %field_info ) {
            my $size      = $field_info{ $field }{'size'} || [ 1 ];
            my $data_type =
                $field_info{ $field }{'char'}    ? 'char'  :
                $field_info{ $field }{'float'}   ? 'float' :
                $field_info{ $field }{'integer'} ? 'integer' : 'char';

            if ( $data_type eq 'char' && scalar @$size == 2 ) {
                $size = [ $size->[0] + $size->[1] ];
            }

            my $field = $table->get_field( $field );
            $field->size( $size );
            $field->data_type( $data_type );
        }
    }

    return 1;
}

1;

=pod

=head1 AUTHORS

Darren Chamberlain [e-mail],
Ken Y. Clark [e-mail].

=head1 SEE ALSO

Text::RecordParser, SQL::Translator.

=cut