Run the sybase C subtest *after* the main test
[dbsrgits/DBIx-Class.git] / lib / DBIx / Class / Storage / DBI / SQLAnywhere.pm
CommitLineData
db8f81cf 1package DBIx::Class::Storage::DBI::SQLAnywhere;
f200d74b 2
3use strict;
4use warnings;
548d1627 5use base qw/DBIx::Class::Storage::DBI::UniqueIdentifier/;
f200d74b 6use mro 'c3';
6298a324 7use List::Util 'first';
52b420dd 8use Try::Tiny;
4b3515a6 9use DBIx::Class::Storage::DBI::SQLAnywhere::Cursor ();
fd323bf1 10use namespace::clean;
f200d74b 11
6a247f33 12__PACKAGE__->mk_group_accessors(simple => qw/_identity/);
13__PACKAGE__->sql_limit_dialect ('RowNumberOver');
2b8cc2f2 14__PACKAGE__->sql_quote_char ('"');
db8f81cf 15
40d8d018 16__PACKAGE__->new_guid('UUIDTOSTR(NEWID())');
17
4b3515a6 18# default to the UUID decoding cursor, overridable by the user
19__PACKAGE__->cursor_class('DBIx::Class::Storage::DBI::SQLAnywhere::Cursor');
20
db8f81cf 21=head1 NAME
22
4b3515a6 23DBIx::Class::Storage::DBI::SQLAnywhere - Driver for SQL Anywhere
db8f81cf 24
25=head1 DESCRIPTION
26
4b3515a6 27This class implements autoincrements for SQL Anywhere and provides
28L<DBIx::Class::InflateColumn::DateTime> support and support for the
29C<uniqueidentifier> type (via
30L<DBIx::Class::Storage::DBI::SQLAnywhere::Cursor>.)
db8f81cf 31
32You need the C<DBD::SQLAnywhere> driver that comes with the SQL Anywhere
33distribution, B<NOT> the one on CPAN. It is usually under a path such as:
34
2b0076be 35 /opt/sqlanywhere11/sdk/perl
36
7df295ec 37Recommended L<connect_info|DBIx::Class::Storage::DBI/connect_info> settings:
2b0076be 38
39 on_connect_call => 'datetime_setup'
40
41=head1 METHODS
db8f81cf 42
43=cut
44
45sub last_insert_id { shift->_identity }
46
e366f807 47sub _prefetch_autovalues {
f200d74b 48 my $self = shift;
db8f81cf 49 my ($source, $to_insert) = @_;
50
e366f807 51 my $values = $self->next::method(@_);
52
52416317 53 my $colinfo = $source->columns_info;
54
6298a324 55 my $identity_col =
e366f807 56 first { $colinfo->{$_}{is_auto_increment} } keys %$colinfo;
db8f81cf 57
cea43436 58# user might have an identity PK without is_auto_increment
59 if (not $identity_col) {
60 foreach my $pk_col ($source->primary_columns) {
52416317 61 if (
62 ! exists $to_insert->{$pk_col}
63 and
64 $colinfo->{$pk_col}{data_type}
65 and
66 $colinfo->{$pk_col}{data_type} !~ /^uniqueidentifier/i
67 ) {
cea43436 68 $identity_col = $pk_col;
69 last;
70 }
71 }
72 }
73
b0267fb7 74 if ($identity_col && (not exists $to_insert->{$identity_col})) {
db8f81cf 75 my $dbh = $self->_get_dbh;
76 my $table_name = $source->from;
77 $table_name = $$table_name if ref $table_name;
78
9780718f 79 my ($identity) = try {
80 $dbh->selectrow_array("SELECT GET_IDENTITY('$table_name')")
548d1627 81 };
82
83 if (defined $identity) {
e366f807 84 $values->{$identity_col} = $identity;
548d1627 85 $self->_identity($identity);
86 }
87 }
88
e366f807 89 return $values;
548d1627 90}
91
4b3515a6 92sub _uuid_to_str {
93 my ($self, $data) = @_;
94
95 $data = unpack 'H*', $data;
96
97 for my $pos (8, 13, 18, 23) {
98 substr($data, $pos, 0) = '-';
99 }
100
101 return $data;
102}
103
104# select_single does not invoke a cursor object at all, hence UUID decoding happens
105# here if the proper cursor class is set
106sub select_single {
548d1627 107 my $self = shift;
4b3515a6 108
109 my @row = $self->next::method(@_);
110
111 return @row
112 unless $self->cursor_class->isa('DBIx::Class::Storage::DBI::SQLAnywhere::Cursor');
113
548d1627 114 my ($ident, $select) = @_;
115
7e5fec1c 116 my $col_info = $self->_resolve_column_info($ident);
548d1627 117
118 for my $select_idx (0..$#$select) {
119 my $selected = $select->[$select_idx];
f200d74b 120
548d1627 121 next if ref $selected;
db8f81cf 122
4b3515a6 123 my $data_type = $col_info->{$selected}{data_type}
124 or next;
125
126 if ($self->_is_guid_type($data_type)) {
127 my $returned = $row[$select_idx];
548d1627 128
4b3515a6 129 if (length $returned == 16) {
130 $row[$select_idx] = $self->_uuid_to_str($returned);
131 }
548d1627 132 }
f200d74b 133 }
db8f81cf 134
4b3515a6 135 return @row;
db8f81cf 136}
137
2b0076be 138# this sub stolen from MSSQL
139
140sub build_datetime_parser {
141 my $self = shift;
142 my $type = "DateTime::Format::Strptime";
9780718f 143 try {
52b420dd 144 eval "require ${type}"
9780718f 145 }
146 catch {
147 $self->throw_exception("Couldn't load ${type}: $_");
148 };
149
2b0076be 150 return $type->new( pattern => '%Y-%m-%d %H:%M:%S.%6N' );
151}
152
153=head2 connect_call_datetime_setup
154
155Used as:
156
157 on_connect_call => 'datetime_setup'
158
7df295ec 159In L<connect_info|DBIx::Class::Storage::DBI/connect_info> to set the date and
160timestamp formats (as temporary options for the session) for use with
2b0076be 161L<DBIx::Class::InflateColumn::DateTime>.
162
163The C<TIMESTAMP> data type supports up to 6 digits after the decimal point for
164second precision. The full precision is used.
165
166The C<DATE> data type supposedly stores hours and minutes too, according to the
167documentation, but I could not get that to work. It seems to only store the
168date.
169
170You will need the L<DateTime::Format::Strptime> module for inflation to work.
171
172=cut
173
174sub connect_call_datetime_setup {
175 my $self = shift;
176
177 $self->_do_query(
178 "set temporary option timestamp_format = 'yyyy-mm-dd hh:mm:ss.ssssss'"
179 );
180 $self->_do_query(
181 "set temporary option date_format = 'yyyy-mm-dd hh:mm:ss.ssssss'"
182 );
183}
184
90d7422f 185sub _exec_svp_begin {
9cf3db6f 186 my ($self, $name) = @_;
187
90d7422f 188 $self->_dbh->do("SAVEPOINT $name");
9cf3db6f 189}
190
191# can't release savepoints that have been rolled back
90d7422f 192sub _exec_svp_release { 1 }
9cf3db6f 193
90d7422f 194sub _exec_svp_rollback {
9cf3db6f 195 my ($self, $name) = @_;
196
90d7422f 197 $self->_dbh->do("ROLLBACK TO SAVEPOINT $name")
9cf3db6f 198}
199
f200d74b 2001;
db8f81cf 201
270eecac 202=head1 MAXIMUM CURSORS
203
7df295ec 204A L<DBIx::Class> application can use a lot of cursors, due to the usage of
205L<prepare_cached|DBI/prepare_cached>.
270eecac 206
207The default cursor maximum is C<50>, which can be a bit too low. This limit can
208be turned off (or increased) by the DBA by executing:
209
210 set option max_statement_count = 0
211 set option max_cursor_count = 0
212
213Highly recommended.
214
db8f81cf 215=head1 AUTHOR
216
217See L<DBIx::Class/AUTHOR> and L<DBIx::Class/CONTRIBUTORS>.
218
219=head1 LICENSE
220
221You may distribute this code under the same terms as Perl itself.
222
223=cut