File Coverage

blib/lib/Yancy/Command/backend/copy.pm

Criterion	Covered	Total	%
statement	17	18	94.4
branch	1	2	50.0
condition	2	5	40.0
subroutine	3	3	100.0
pod	1	1	100.0
total	24	29	82.7

package Yancy::Command::backend::copy;
our $VERSION = '1.088';
# ABSTRACT: Copy data between backends

#pod =head1 SYNOPSIS
#pod
#pod     Usage: APPLICATION backend copy DEST_BACKEND SRC_SCHEMA [DEST_SCHEMA]
#pod
#pod         ./myapp.pl backend copy sqlite:prod.db users
#pod         ./myapp.pl backend copy sqlite:prod.db users new_users
#pod
#pod =head1 DESCRIPTION
#pod
#pod This command copies data from the application's backend to another backend.
#pod Use this to set up a new application from an existing application's data,
#pod copy data between environments, or migrate data to a different backend.
#pod
#pod =head1 SEE ALSO
#pod
#pod L
#pod
#pod =cut

use Mojo::Base 'Mojolicious::Command';
use Yancy::Util qw( load_backend );

has description => 'Copy data between backends';
has usage => sub { shift->extract_usage };

sub run {
    my ( $self, @argv ) = @_;

    my ( $dest_url, $source_schema, $dest_schema ) = @argv;
    $dest_schema ||= $source_schema;
    my $source_backend = $self->app->yancy->backend;
    my $schema = $self->app->yancy->schema( $source_schema );
    my $id_field = $schema->{'x-id-field'} || 'id';
    my $dest_backend = load_backend( $dest_url, { $dest_schema => $schema } );
    for my $item ( @{ $source_backend->list( $source_schema )->{items} } ) {
        # XXX This is two round-trip requests to the database for every
        # item. We could fetch the entire list to have known IDs, but
        # that could be potentially thousands of rows. Either the
        # backend list() method needs some kind of iterator version so
        # as to not load the entire table before returning, or we need
        # a way for list() to return a single column instead of the
        # entire data set.
        if ( $dest_backend->get( $dest_schema, $item->{ $id_field } ) ) {
            $dest_backend->set( $dest_schema, $item->{ $id_field }, $item );
        }
        else {
            $dest_backend->create( $dest_schema, $item );
        }
    }
}

1;

__END__