X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FStorage%2FDBI%2FInterBase.pm;h=7b6ef6cbc058de5d0ee721f94dd73d910de4ee89;hb=12a184d0a0c1868708e43aaabefe08f9e7ac9ec4;hp=2ba25424278b551cce2b8706b6a69016d01fdf52;hpb=c58270743fa0bebf1410d02136b3f82ec8838feb;p=dbsrgits%2FDBIx-Class-Historic.git diff --git a/lib/DBIx/Class/Storage/DBI/InterBase.pm b/lib/DBIx/Class/Storage/DBI/InterBase.pm index 2ba2542..7b6ef6c 100644 --- a/lib/DBIx/Class/Storage/DBI/InterBase.pm +++ b/lib/DBIx/Class/Storage/DBI/InterBase.pm @@ -1,140 +1,50 @@ package DBIx::Class::Storage::DBI::InterBase; -# partly stolen from DBIx::Class::Storage::DBI::MSSQL - use strict; use warnings; -use base qw/DBIx::Class::Storage::DBI/; +use base qw/DBIx::Class::Storage::DBI::Firebird::Common/; use mro 'c3'; -use List::Util(); - -__PACKAGE__->mk_group_accessors(simple => qw/ - _auto_incs -/); +use DBIx::Class::_Util 'dbic_internal_try'; +use namespace::clean; =head1 NAME -DBIx::Class::Storage::DBI::InterBase - Driver for the Firebird RDBMS +DBIx::Class::Storage::DBI::InterBase - Driver for the Firebird RDBMS via +L =head1 DESCRIPTION -This class implements autoincrements for Firebird using C, sets the -limit dialect to C and provides preliminary -L support. +This driver is a subclass of L for +use with L, see that driver for general details. -For ODBC support, see L. +You need to use either the +L option or +L (see L) for your code to function +correctly with this driver. Otherwise you will likely get bizarre error messages +such as C. The alternative is to use the +L driver, which is more suitable +for long running processes such as under L. To turn on L support, see L. =cut -sub _prep_for_execute { - my $self = shift; - my ($op, $extra_bind, $ident, $args) = @_; - - if ($op eq 'insert') { - my @pk = $ident->primary_columns; - my %pk; - @pk{@pk} = (); - - my @auto_inc_cols = grep { - my $inserting = $args->[0]{$_}; - - ($ident->column_info($_)->{is_auto_increment} - || exists $pk{$_}) - && ( - (not defined $inserting) - || - (ref $inserting eq 'SCALAR' && $$inserting =~ /^null\z/i) - ) - } $ident->columns; - - if (@auto_inc_cols) { - $args->[1]{returning} = \@auto_inc_cols; - - $self->_auto_incs([]); - $self->_auto_incs->[0] = \@auto_inc_cols; - } - } - - return $self->next::method(@_); -} - -sub _execute { - my $self = shift; - my ($op) = @_; - - my ($rv, $sth, @bind) = $self->dbh_do($self->can('_dbh_execute'), @_); - - if ($op eq 'insert' && $self->_auto_incs) { - local $@; - my (@auto_incs) = eval { - local $SIG{__WARN__} = sub {}; - $sth->fetchrow_array - }; - $self->_auto_incs->[1] = \@auto_incs; - $sth->finish; - } - - return wantarray ? ($rv, $sth, @bind) : $rv; -} - -sub last_insert_id { - my ($self, $source, @cols) = @_; - my @result; - - my %auto_incs; - @auto_incs{ @{ $self->_auto_incs->[0] } } = - @{ $self->_auto_incs->[1] }; - - push @result, $auto_incs{$_} for @cols; - - return @result; -} - -# this sub stolen from DB2 - -sub _sql_maker_opts { - my ( $self, $opts ) = @_; - - if ( $opts ) { - $self->{_sql_maker_opts} = { %$opts }; - } - - return { limit_dialect => 'FirstSkip', %{$self->{_sql_maker_opts}||{}} }; -} - -sub _svp_begin { - my ($self, $name) = @_; - - $self->_get_dbh->do("SAVEPOINT $name"); -} - -sub _svp_release { - my ($self, $name) = @_; - - $self->_get_dbh->do("RELEASE SAVEPOINT $name"); -} - -sub _svp_rollback { - my ($self, $name) = @_; - - $self->_get_dbh->do("ROLLBACK TO SAVEPOINT $name") -} - sub _ping { my $self = shift; my $dbh = $self->_dbh or return 0; local $dbh->{RaiseError} = 1; + local $dbh->{PrintError} = 0; - eval { + (dbic_internal_try { $dbh->do('select 1 from rdb$database'); - }; - - return $@ ? 0 : 1; + 1; + }) + ? 1 + : 0 + ; } # We want dialect 3 for new features and quoting to work, DBD::InterBase uses @@ -160,13 +70,29 @@ sub _set_sql_dialect { } } -# softcommit makes savepoints work -sub _run_connection_actions { +=head2 connect_call_use_softcommit + +Used as: + + on_connect_call => 'use_softcommit' + +In L to set the +L C option. + +You need either this option or C<< disable_sth_caching => 1 >> for +L code to function correctly (otherwise you may get C errors.) Or use the L +driver. + +The downside of using this option is that your process will B see UPDATEs, +INSERTs and DELETEs from other processes for already open statements. + +=cut + +sub connect_call_use_softcommit { my $self = shift; $self->_dbh->{ib_softcommit} = 1; - - $self->next::method(@_); } =head2 connect_call_datetime_setup @@ -175,8 +101,8 @@ Used as: on_connect_call => 'datetime_setup' -In L to set the date and timestamp -formats using: +In L to set the date and +timestamp formats using: $dbh->{ib_time_all} = 'ISO'; @@ -196,8 +122,7 @@ Timestamp columns can be declared with either C or C. You will need the L module for inflation to work. -For L, this is a noop and sub-second -precision is not currently available. +For L, this is a noop. =cut @@ -207,78 +132,35 @@ sub connect_call_datetime_setup { $self->_get_dbh->{ib_time_all} = 'ISO'; } -sub datetime_parser_type { - 'DBIx::Class::Storage::DBI::InterBase::DateTime::Format' -} - -package # hide from PAUSE - DBIx::Class::Storage::DBI::InterBase::DateTime::Format; - -my $timestamp_format = '%Y-%m-%d %H:%M:%S.%4N'; # %F %T -my $date_format = '%Y-%m-%d'; - -my ($timestamp_parser, $date_parser); - -sub parse_datetime { - shift; - require DateTime::Format::Strptime; - $timestamp_parser ||= DateTime::Format::Strptime->new( - pattern => $timestamp_format, - on_error => 'croak', - ); - return $timestamp_parser->parse_datetime(shift); -} - -sub format_datetime { - shift; - require DateTime::Format::Strptime; - $timestamp_parser ||= DateTime::Format::Strptime->new( - pattern => $timestamp_format, - on_error => 'croak', - ); - return $timestamp_parser->format_datetime(shift); -} - -sub parse_date { - shift; - require DateTime::Format::Strptime; - $date_parser ||= DateTime::Format::Strptime->new( - pattern => $date_format, - on_error => 'croak', - ); - return $date_parser->parse_datetime(shift); -} - -sub format_date { - shift; - require DateTime::Format::Strptime; - $date_parser ||= DateTime::Format::Strptime->new( - pattern => $date_format, - on_error => 'croak', - ); - return $date_parser->format_datetime(shift); -} - -1; - =head1 CAVEATS =over 4 =item * -C support only works for Firebird versions 2 or greater. To -work with earlier versions, we'll need to figure out how to retrieve the bodies -of C triggers and parse them for the C name. +with L, you will not be able to see changes made +to data in other processes. If this is an issue, use +L as a +workaround for the C errors, this of course adversely +affects performance. + +Alternately, use the L driver. =back -=head1 AUTHOR +=head1 FURTHER QUESTIONS? -See L and L. +Check the list of L. -=head1 LICENSE +=head1 COPYRIGHT AND LICENSE -You may distribute this code under the same terms as Perl itself. +This module is free software L +by the L. You can +redistribute it and/or modify it under the same terms as the +L. =cut + +1; + +# vim:sts=2 sw=2: