14 |
schema |
schema |
15 |
|
|
16 |
table |
table |
17 |
|
|
18 |
|
no_transaction |
19 |
)); |
)); |
20 |
|
|
21 |
use Data::Dump qw/dump/; |
use Data::Dump qw/dump/; |
44 |
|
|
45 |
$self->{_dbh} = DBI->connect( $self->dsn, $self->user, $self->passwd, { RaiseError => 1 } ); |
$self->{_dbh} = DBI->connect( $self->dsn, $self->user, $self->passwd, { RaiseError => 1 } ); |
46 |
|
|
47 |
$self->{_dbh}->begin_work; |
$self->{_dbh}->begin_work unless $self->no_transaction; |
48 |
|
|
49 |
if ( -e $self->schema ) { |
if ( -e $self->schema ) { |
50 |
foreach my $sql ( split(/;/, scalar read_file( $self->schema )) ) { |
foreach my $sql ( split(/;/, scalar read_file( $self->schema )) ) { |
130 |
|
|
131 |
$log->info('finish'); |
$log->info('finish'); |
132 |
|
|
133 |
$self->{_dbh}->commit; |
unless ( $self->no_transaction ) { |
134 |
|
$self->{_dbh}->commit; |
135 |
$log->info('commit done'); |
$log->info('commit done'); |
136 |
|
} |
137 |
|
|
138 |
return 1; |
return 1; |
139 |
} |
} |