51 lines
1.3 KiB
Perl
51 lines
1.3 KiB
Perl
package App::Netdisco::DB::SetOperations;
|
||
|
||
use strict;
|
||
use warnings;
|
||
|
||
use parent 'DBIx::Class::Helper::ResultSet::SetOperations';
|
||
|
||
sub _set_operation {
|
||
my ( $self, $operation, $other ) = @_;
|
||
|
||
my @sql;
|
||
my @params;
|
||
|
||
my $as = $self->_resolved_attrs->{as};
|
||
|
||
my @operands = ( $self, ref $other eq 'ARRAY' ? @$other : $other );
|
||
|
||
for (@operands) {
|
||
$self->throw_exception("ResultClass of ResultSets do not match!")
|
||
unless $self->result_class eq $_->result_class;
|
||
|
||
my $attrs = $_->_resolved_attrs;
|
||
|
||
$self->throw_exception('ResultSets do not all have the same selected columns!')
|
||
unless $self->_compare_arrays($as, $attrs->{as});
|
||
|
||
my ($sql, @bind) = @{${$_->as_query}};
|
||
# $sql =~ s/^\s*\((.*)\)\s*$/$1/;
|
||
$sql = q<(> . $sql . q<)>;
|
||
|
||
push @sql, $sql;
|
||
push @params, @bind;
|
||
}
|
||
|
||
my $query = q<(> . join(" $operation ", @sql). q<)>;
|
||
|
||
my $attrs = $self->_resolved_attrs;
|
||
return $self->result_source->resultset->search(undef, {
|
||
alias => $self->current_source_alias,
|
||
from => [{
|
||
$self->current_source_alias => \[ $query, @params ],
|
||
-alias => $self->current_source_alias,
|
||
-source_handle => $self->result_source->handle,
|
||
}],
|
||
columns => $attrs->{as},
|
||
result_class => $self->result_class,
|
||
});
|
||
}
|
||
|
||
1;
|