From Code to Community: Sponsoring The Perl and Raku Conference 2025 Learn more

RIBASUSHI / DBIx-Class-0.082899_06 / lib / DBIx / Class / Storage / DBI / Sybase.pm 

            

              
1
2
3
4
5
6
7
8
—
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
—
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147

              
package DBIx::Class::Storage::DBI::Sybase;
use strict;
use warnings;
use Try::Tiny;
use namespace::clean;
use base qw/DBIx::Class::Storage::DBI/;
=head1 NAME
DBIx::Class::Storage::DBI::Sybase - Base class for drivers using
L<DBD::Sybase>
=head1 DESCRIPTION
This is the base class/dispatcher for Storage's designed to work with
L<DBD::Sybase>
=head1 METHODS
=cut
sub _rebless {
  my $self = shift;
  my $dbtype;
  try {
    $dbtype = @{$self->_get_dbh->selectrow_arrayref(qq{sp_server_info \@attribute_id=1})}[2]
  } catch {
    $self->throw_exception("Unable to establish connection to determine database type: $_")
  };
  if ($dbtype) {
    $dbtype =~ s/\W/_/gi;
    # saner class name
    $dbtype = 'ASE' if $dbtype eq 'SQL_Server';
    my $subclass = __PACKAGE__ . "::$dbtype";
    if ($self->load_optional_class($subclass)) {
      bless $self, $subclass;
      $self->_rebless;
    }
  }
}
sub _init {
  # once the driver is determined see if we need to insert the DBD::Sybase w/ FreeTDS fixups
  # this is a dirty version of "instance role application", \o/ DO WANT Moo \o/
  my $self = shift;
  if (! $self->isa('DBIx::Class::Storage::DBI::Sybase::FreeTDS') and $self->_using_freetds) {
    require DBIx::Class::Storage::DBI::Sybase::FreeTDS;
    my @isa = @{mro::get_linear_isa(ref $self)};
    my $class = shift @isa; # this is our current ref
    my $trait_class = $class . '::FreeTDS';
    mro::set_mro ($trait_class, 'c3');
    no strict 'refs';
    @{"${trait_class}::ISA"} = ($class, 'DBIx::Class::Storage::DBI::Sybase::FreeTDS', @isa);
    bless ($self, $trait_class);
    Class::C3->reinitialize() if DBIx::Class::_ENV_::OLD_MRO;
    $self->_init(@_);
  }
  $self->next::method(@_);
}
sub _ping {
  my $self = shift;
  my $dbh = $self->_dbh or return 0;
  local $dbh->{RaiseError} = 1;
  local $dbh->{PrintError} = 0;
# FIXME if the main connection goes stale, does opening another for this statement
# really determine anything?
  if ($dbh->{syb_no_child_con}) {
    return try {
      $self->_connect->do('select 1');
      1;
    }
    catch {
      0;
    };
  }
  return try {
    $dbh->do('select 1');
    1;
  }
  catch {
    0;
  };
}
sub _set_max_connect {
  my $self = shift;
  my $val  = shift || 256;
  my $dsn = $self->_dbi_connect_info->[0];
  return if ref($dsn) eq 'CODE';
  if ($dsn !~ /maxConnect=/) {
    $self->_dbi_connect_info->[0] = "$dsn;maxConnect=$val";
    my $connected = defined $self->_dbh;
    $self->disconnect;
    $self->ensure_connected if $connected;
  }
}
# Whether or not DBD::Sybase was compiled against FreeTDS. If false, it means
# the Sybase OpenClient libraries were used.
sub _using_freetds {
  my $self = shift;
  return ($self->_get_dbh->{syb_oc_version}||'') =~ /freetds/i;
}
# Either returns the FreeTDS version against which DBD::Sybase was compiled,
# 0 if can't be determined, or undef otherwise
sub _using_freetds_version {
  my $inf = shift->_get_dbh->{syb_oc_version};
  return undef unless ($inf||'') =~ /freetds/i;
  return $inf =~ /v([0-9\.]+)/ ? $1 : 0;
}
=head1 FURTHER QUESTIONS?
Check the list of L<additional DBIC resources|DBIx::Class/GETTING HELP/SUPPORT>.
=head1 COPYRIGHT AND LICENSE
This module is free software L<copyright|DBIx::Class/COPYRIGHT AND LICENSE>
by the L<DBIx::Class (DBIC) authors|DBIx::Class/AUTHORS>. You can
redistribute it and/or modify it under the same terms as the
L<DBIx::Class library|DBIx::Class/COPYRIGHT AND LICENSE>.
=cut
1;