my $guard = $self->txn_scope_guard;
my $subrs_cur = $rs->cursor;
+ my $row_cnt = '0E0';
while (my @pks = $subrs_cur->next) {
my $cond;
$op eq 'update' ? $values : (),
$cond,
);
+
+ $row_cnt++;
}
$guard->commit;
- return 1;
+ return $row_cnt;
}
sub _select {