diff --git a/lib/SQL/Abstract.pm b/lib/SQL/Abstract.pm index 7e12187b..2e2c7b7e 100644 --- a/lib/SQL/Abstract.pm +++ b/lib/SQL/Abstract.pm @@ -454,6 +454,17 @@ sub select { return wantarray ? ($sql, @bind) : $sql; } +#====================================================================== +# SELECT FOR UPDATE +#====================================================================== + +sub select_for_update { + my $self = shift; + my($sql, @bind) = $self->select(@_); + $sql .= $self->_sqlcase(' for update'); + return wantarray ? ($sql, @bind) : $sql; +} + #====================================================================== # DELETE #====================================================================== @@ -2145,6 +2156,12 @@ for details. =back +=head2 select_for_update($source, $fields, $where, $order) + +This is a wrapper around L