Refactor/improve support of DBD::Sybase compiled against FreeTDS (mainly MSSQL)
[dbsrgits/DBIx-Class-Historic.git] / lib / DBIx / Class / Storage / DBI / Sybase / FreeTDS.pm
CommitLineData
c1e5a9ac 1package DBIx::Class::Storage::DBI::Sybase::FreeTDS;
2
3use strict;
4use warnings;
5use base qw/DBIx::Class::Storage::DBI::Sybase/;
6use mro 'c3';
7use Try::Tiny;
8use namespace::clean;
9
10=head1 NAME
11
12DBIx::Class::Storage::DBI::Sybase - Base class for drivers using L<DBD::Sybase>
13over FreeTDS.
14
15=head1 DESCRIPTION
16
17This is the base class for Storages designed to work with L<DBD::Sybase> over
18FreeTDS.
19
20It is a subclass of L<DBIx::Class::Storage::DBI::Sybase>.
21
22=head1 METHODS
23
24=cut
25
26# The subclass storage driver defines _set_autocommit_stmt
27# for MsSQL it is SET IMPLICIT_TRANSACTIONS ON/OFF
28# for proper Sybase it's SET CHAINED ON/OFF
29sub _set_autocommit {
30 my $self = shift;
31
32 if ($self->_dbh_autocommit) {
33 $self->_dbh->do($self->_set_autocommit_stmt(1));
34 } else {
35 $self->_dbh->do($self->_set_autocommit_stmt(0));
36 }
37}
38
39# Handle AutoCommit and SET TEXTSIZE because LongReadLen doesn't work.
40#
41sub _run_connection_actions {
42 my $self = shift;
43
44 # based on LongReadLen in connect_info
45 $self->set_textsize;
46
47 $self->_set_autocommit;
48
49 $self->next::method(@_);
50}
51
52=head2 set_textsize
53
54When using DBD::Sybase with FreeTDS, C<< $dbh->{LongReadLen} >> is not available,
55use this function instead. It does:
56
57 $dbh->do("SET TEXTSIZE $bytes");
58
59Takes the number of bytes, or uses the C<LongReadLen> value from your
60L<connect_info|DBIx::Class::Storage::DBI/connect_info> if omitted, lastly falls
61back to the C<32768> which is the L<DBD::Sybase> default.
62
63=cut
64
65sub set_textsize {
66 my $self = shift;
67 my $text_size =
68 shift
69 ||
70 try { $self->_dbic_cinnect_attributes->{LongReadLen} }
71 ||
72 32768; # the DBD::Sybase default
73
74 $self->_dbh->do("SET TEXTSIZE $text_size");
75}
76
77sub _dbh_begin_work {
78 my $self = shift;
79
80 if ($self->{_in_dbh_do}) {
81 $self->_dbh->do('BEGIN TRAN');
82 }
83 else {
84 $self->dbh_do(sub { $_[1]->do('BEGIN TRAN') });
85 }
86}
87
88sub _dbh_commit {
89 my $self = shift;
90
91 my $dbh = $self->_dbh
92 or $self->throw_exception('cannot COMMIT on a disconnected handle');
93
94 $dbh->do('COMMIT');
95}
96
97sub _dbh_rollback {
98 my $self = shift;
99
100 my $dbh = $self->_dbh
101 or $self->throw_exception('cannot ROLLBACK on a disconnected handle');
102
103 $dbh->do('ROLLBACK');
104}
105
1061;
107
108=head1 AUTHORS
109
110See L<DBIx::Class/CONTRIBUTORS>.
111
112=head1 LICENSE
113
114You may distribute this code under the same terms as Perl itself.
115
116=cut