X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FStorage%2FDBI%2FSQLAnywhere.pm;h=16adca42430130ff4467a03f3c2e65fe76c21a6e;hb=7da56142c171e61e6bec750e80dbb26f595f777e;hp=936edb19e8b60f272f6e0ac938fb22734bba38d4;hpb=b0267fb70f1374d43e4512d8d1006d9f6fd3500b;p=dbsrgits%2FDBIx-Class.git diff --git a/lib/DBIx/Class/Storage/DBI/SQLAnywhere.pm b/lib/DBIx/Class/Storage/DBI/SQLAnywhere.pm index 936edb1..16adca4 100644 --- a/lib/DBIx/Class/Storage/DBI/SQLAnywhere.pm +++ b/lib/DBIx/Class/Storage/DBI/SQLAnywhere.pm @@ -2,7 +2,7 @@ package DBIx::Class::Storage::DBI::SQLAnywhere; use strict; use warnings; -use base qw/DBIx::Class::Storage::DBI/; +use base qw/DBIx::Class::Storage::DBI::UniqueIdentifier/; use mro 'c3'; use List::Util (); @@ -25,7 +25,7 @@ distribution, B the one on CPAN. It is usually under a path such as: /opt/sqlanywhere11/sdk/perl -Recommended L settings: +Recommended L settings: on_connect_call => 'datetime_setup' @@ -35,6 +35,8 @@ Recommended L settings: sub last_insert_id { shift->_identity } +sub _new_uuid { 'UUIDTOSTR(NEWID())' } + sub insert { my $self = shift; my ($source, $to_insert) = @_; @@ -43,16 +45,53 @@ sub insert { $source->column_info($_)->{is_auto_increment} } $source->columns; +# user might have an identity PK without is_auto_increment + if (not $identity_col) { + foreach my $pk_col ($source->primary_columns) { + if (not exists $to_insert->{$pk_col} && + $source->column_info($pk_col)->{data_type} !~ /^uniqueidentifier/i) + { + $identity_col = $pk_col; + last; + } + } + } + if ($identity_col && (not exists $to_insert->{$identity_col})) { my $dbh = $self->_get_dbh; my $table_name = $source->from; $table_name = $$table_name if ref $table_name; - my ($identity) = $dbh->selectrow_array("SELECT GET_IDENTITY('$table_name')"); + my ($identity) = eval { + local $@; $dbh->selectrow_array("SELECT GET_IDENTITY('$table_name')") + }; + + if (defined $identity) { + $to_insert->{$identity_col} = $identity; + $self->_identity($identity); + } + } + + return $self->next::method(@_); +} + +# convert UUIDs to strings in selects +sub _select_args { + my $self = shift; + my ($ident, $select) = @_; + + my $col_info = $self->_resolve_column_info($ident); + + for my $select_idx (0..$#$select) { + my $selected = $select->[$select_idx]; + + next if ref $selected; - $to_insert->{$identity_col} = $identity; + my $data_type = $col_info->{$selected}{data_type}; - $self->_identity($identity); + if ($data_type && lc($data_type) eq 'uniqueidentifier') { + $select->[$select_idx] = { UUIDTOSTR => $selected }; + } } return $self->next::method(@_); @@ -86,8 +125,8 @@ Used as: on_connect_call => 'datetime_setup' -In L to set the date and timestamp -formats (as temporary options for the session) for use with +In L to set the date and +timestamp formats (as temporary options for the session) for use with L. The C data type supports up to 6 digits after the decimal point for @@ -112,8 +151,36 @@ sub connect_call_datetime_setup { ); } +sub _svp_begin { + my ($self, $name) = @_; + + $self->_get_dbh->do("SAVEPOINT $name"); +} + +# can't release savepoints that have been rolled back +sub _svp_release { 1 } + +sub _svp_rollback { + my ($self, $name) = @_; + + $self->_get_dbh->do("ROLLBACK TO SAVEPOINT $name") +} + 1; +=head1 MAXIMUM CURSORS + +A L application can use a lot of cursors, due to the usage of +L. + +The default cursor maximum is C<50>, which can be a bit too low. This limit can +be turned off (or increased) by the DBA by executing: + + set option max_statement_count = 0 + set option max_cursor_count = 0 + +Highly recommended. + =head1 AUTHOR See L and L.