Fix Attean::Algebra::Update->blank_nodes (#70).

kasei · Feb 12, 2016 · 50a445f · 50a445f
1 parent 91a9293
commit 50a445f
Showing 1 changed file with 13 additions and 2 deletions.
diff --git a/lib/Attean/Algebra.pm b/lib/Attean/Algebra.pm
@@ -1403,6 +1403,19 @@ package Attean::Algebra::Update 0.012 {
 		}
 	}
 
+	around 'blank_nodes' => sub {
+		my $orig	= shift;
+		my $self	= shift;
+		my @blanks	= $orig->($self, @_);
+		my %seen	= map { $_->value => 1 } @blanks;
+		foreach my $data ($self->insert, $self->delete) {
+			my @triples	= @{ $data };
+			my @b	= grep { $_->does('Attean::API::Blank') } map { $_->values } @triples;
+			push(@blanks, grep { not $seen{$_->value}++ } @b);
+		}
+		return @blanks;
+	};
+
 	sub algebra_as_string {
 		my $self	= shift;
 		state $S	= {
@@ -1482,8 +1495,6 @@ package Attean::Algebra::Update 0.012 {
 	}
 }
 
-# DELETE WHERE
-
 1;
 
 __END__