X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FDeploymentHandler%2FDad.pm;h=db9eaec477d54fbcfa814b7888049f6183a91837;hb=c75b871a6f82b51175a60d98e18f4b9876850510;hp=fe8656bed5e8dc8ffcd2e75eb3f69a87c4d49309;hpb=f7e215c9d2af2471f4586336fb7ed1ae3725be07;p=dbsrgits%2FDBIx-Class-DeploymentHandler.git diff --git a/lib/DBIx/Class/DeploymentHandler/Dad.pm b/lib/DBIx/Class/DeploymentHandler/Dad.pm index fe8656b..db9eaec 100644 --- a/lib/DBIx/Class/DeploymentHandler/Dad.pm +++ b/lib/DBIx/Class/DeploymentHandler/Dad.pm @@ -3,9 +3,14 @@ package DBIx::Class::DeploymentHandler::Dad; # ABSTRACT: Parent class for DeploymentHandlers use Moose; -use Method::Signatures::Simple; require DBIx::Class::Schema; # loaded for type constraint use Carp::Clan '^DBIx::Class::DeploymentHandler'; +use DBIx::Class::DeploymentHandler::Logger; +use DBIx::Class::DeploymentHandler::Types; +use Log::Contextual ':log', -package_logger => + DBIx::Class::DeploymentHandler::Logger->new({ + env_prefix => 'DBICDH' + }); has schema => ( isa => 'DBIx::Class::Schema', @@ -21,19 +26,23 @@ has backup_directory => ( has to_version => ( is => 'ro', + isa => 'Str', lazy_build => 1, ); -sub _build_to_version { $_[0]->schema->schema_version } +sub _build_to_version { $_[0]->schema_version } has schema_version => ( is => 'ro', + isa => 'StrSchemaVersion', lazy_build => 1, ); sub _build_schema_version { $_[0]->schema->schema_version } -method install { +sub install { + my $self = shift; + log_info { 'installing version ' . $self->to_version }; croak 'Install not possible as versions table already exists in database' if $self->version_storage_is_installed; @@ -46,9 +55,14 @@ method install { } sub upgrade { + log_info { 'upgrading' }; my $self = shift; + my $ran_once = 0; while ( my $version_list = $self->next_version_set ) { - my ($ddl, $upgrade_sql) = @{$self->upgrade_single_step($version_list)||[]}; + $ran_once = 1; + my ($ddl, $upgrade_sql) = @{ + $self->upgrade_single_step({ version_set => $version_list }) + ||[]}; $self->add_database_version({ version => $version_list->[-1], @@ -56,19 +70,29 @@ sub upgrade { upgrade_sql => $upgrade_sql, }); } + + log_warn { 'no need to run upgrade' } unless $ran_once; } sub downgrade { + log_info { 'downgrading' }; my $self = shift; + my $ran_once = 0; while ( my $version_list = $self->previous_version_set ) { - $self->downgrade_single_step($version_list); + $ran_once = 1; + $self->downgrade_single_step({ version_set => $version_list }); # do we just delete a row here? I think so but not sure - $self->delete_database_version({ version => $version_list->[-1] }); + $self->delete_database_version({ version => $version_list->[0] }); } + log_warn { 'no version to run downgrade' } unless $ran_once; } -method backup { $self->storage->backup($self->backup_directory) } +sub backup { + my $self = shift; + log_info { 'backing up' }; + $self->schema->storage->backup($self->backup_directory) +} __PACKAGE__->meta->make_immutable;