43 |
|
|
44 |
$self->{_dbh} = DBI->connect( $self->dsn, $self->user, $self->passwd, { RaiseError => 1 } ); |
$self->{_dbh} = DBI->connect( $self->dsn, $self->user, $self->passwd, { RaiseError => 1 } ); |
45 |
|
|
46 |
eval { |
if ( -e $self->schema ) { |
47 |
$self->{_dbh}->do( scalar read_file( $self->schema ) ) if -e $self->schema; |
foreach my $sql ( split(/;/, scalar read_file( $self->schema )) ) { |
48 |
}; |
$log->debug( $sql ); |
49 |
|
eval { $self->{_dbh}->do( $sql ); }; |
50 |
|
} |
51 |
|
} |
52 |
|
|
53 |
return 1; |
return 1; |
54 |
} |
} |
127 |
|
|
128 |
my $log = $self->_get_logger(); |
my $log = $self->_get_logger(); |
129 |
|
|
130 |
$log->info('finish and dump data into database'); |
$log->info('finish'); |
131 |
|
|
132 |
warn dump( $self->{_rows} ); |
# warn dump( $self->{_rows} ); |
133 |
|
|
134 |
return 1; |
return 1; |
135 |
} |
} |