X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FStorage%2FDBI%2FInterBase.pm;h=cb6d8f9d67765c0ec7facea17f68e8bbcd1c93dc;hb=e5a62c46f;hp=2e5d7065503a73b9e66009e03720cd8180283662;hpb=c7f46488fb414b0bad12f2f164d81485b290f8cb;p=dbsrgits%2FDBIx-Class.git diff --git a/lib/DBIx/Class/Storage/DBI/InterBase.pm b/lib/DBIx/Class/Storage/DBI/InterBase.pm index 2e5d706..cb6d8f9 100644 --- a/lib/DBIx/Class/Storage/DBI/InterBase.pm +++ b/lib/DBIx/Class/Storage/DBI/InterBase.pm @@ -1,218 +1,49 @@ 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 Try::Tiny; +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 as well as -L sets the limit dialect to -C and provides L support. +This driver is a subclass of L for +use with L, see that driver for general details. 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. - -For ODBC support, see L. +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') { - $self->_auto_incs([]); - - my @pk = eval { local $@; $ident->_pri_cols }; - 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->[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 _sequence_fetch { - my ($self, $nextval, $sequence) = @_; - - if ($nextval ne 'nextval') { - $self->throw_exception("Can only fetch 'nextval' for a sequence"); - } - - $self->throw_exception('No sequence to fetch') unless $sequence; - - my ($val) = $self->_get_dbh->selectrow_array( -'SELECT GEN_ID(' . $self->sql_maker->_quote($sequence) . -', 1) FROM rdb$database'); - - return $val; -} - -sub _dbh_get_autoinc_seq { - my ($self, $dbh, $source, $col) = @_; - - my $table_name = $source->from; - $table_name = $$table_name if ref $table_name; - $table_name = $self->sql_maker->quote_char ? $table_name : uc($table_name); - - local $dbh->{LongReadLen} = 100000; - local $dbh->{LongTruncOk} = 1; - - my $sth = $dbh->prepare(<<'EOF'); -SELECT t.rdb$trigger_source -FROM rdb$triggers t -WHERE t.rdb$relation_name = ? -AND t.rdb$system_flag = 0 -- user defined -AND t.rdb$trigger_type = 1 -- BEFORE INSERT -EOF - $sth->execute($table_name); - - while (my ($trigger) = $sth->fetchrow_array) { - my @trig_cols = map { - /^"([^"]+)/ ? $1 : uc($1) - } $trigger =~ /new\.("?\w+"?)/ig; - - my ($quoted, $generator) = $trigger =~ -/(?:gen_id\s* \( \s* |next \s* value \s* for \s*)(")?(\w+)/ix; - - if ($generator) { - $generator = uc $generator unless $quoted; - - return $generator - if List::Util::first { - $self->sql_maker->quote_char ? ($_ eq $col) : (uc($_) eq uc($col)) - } @trig_cols; - } - } - - return undef; -} - -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; -} - -sub insert { - my $self = shift; - - my $updated_cols = $self->next::method(@_); - - if ($self->_auto_incs->[0]) { - my %auto_incs; - @auto_incs{ @{ $self->_auto_incs->[0] } } = @{ $self->_auto_incs->[1] }; - - $updated_cols = { %$updated_cols, %auto_incs }; - } - - return $updated_cols; -} - -# 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 { + return try { $dbh->do('select 1 from rdb$database'); + 1; + } catch { + 0; }; - - return $@ ? 0 : 1; } # We want dialect 3 for new features and quoting to work, DBD::InterBase uses @@ -249,7 +80,8 @@ 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.) +executing> 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. @@ -289,8 +121,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 @@ -300,58 +131,6 @@ 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 @@ -366,15 +145,7 @@ L as a workaround for the C errors, this of course adversely affects performance. -=item * - -C support by default only works for Firebird versions 2 or -greater, L however should -work with earlier versions. - -=item * - -Sub-second precision for TIMESTAMPs is not currently available with ODBC. +Alternately, use the L driver. =back @@ -387,3 +158,4 @@ See L and L. You may distribute this code under the same terms as Perl itself. =cut +# vim:sts=2 sw=2: