Add cookbook entry for dealing with runaway prepared statement cache
[dbsrgits/DBIx-Class.git] / lib / DBIx / Class / Manual / Cookbook.pod
CommitLineData
3b44ccc6 1=head1 NAME
9c82c181 2
40dbc108 3DBIx::Class::Manual::Cookbook - Miscellaneous recipes
ee38fa40 4
d2f3e87b 5=head1 SEARCHING
2913b2d3 6
d2f3e87b 7=head2 Paged results
faf62551 8
bade79c4 9When you expect a large number of results, you can ask L<DBIx::Class> for a
264f1571 10paged resultset, which will fetch only a defined number of records at a time:
faf62551 11
bade79c4 12 my $rs = $schema->resultset('Artist')->search(
5e8b1b2a 13 undef,
bade79c4 14 {
15 page => 1, # page to return (defaults to 1)
16 rows => 10, # number of results per page
17 },
18 );
faf62551 19
bade79c4 20 return $rs->all(); # all records for page 1
faf62551 21
bade79c4 22The C<page> attribute does not have to be specified in your search:
23
24 my $rs = $schema->resultset('Artist')->search(
5e8b1b2a 25 undef,
bade79c4 26 {
27 rows => 10,
28 }
29 );
faf62551 30
bade79c4 31 return $rs->page(1); # DBIx::Class::ResultSet containing first 10 records
faf62551 32
264f1571 33In either of the above cases, you can get a L<Data::Page> object for the
bade79c4 34resultset (suitable for use in e.g. a template) using the C<pager> method:
faf62551 35
bade79c4 36 return $rs->pager();
faf62551 37
d2f3e87b 38=head2 Complex WHERE clauses
2913b2d3 39
40dbc108 40Sometimes you need to formulate a query using specific operators:
41
ea6309e2 42 my @albums = $schema->resultset('Album')->search({
35d4fe78 43 artist => { 'like', '%Lamb%' },
44 title => { 'like', '%Fear of Fours%' },
45 });
40dbc108 46
47This results in something like the following C<WHERE> clause:
48
35d4fe78 49 WHERE artist LIKE '%Lamb%' AND title LIKE '%Fear of Fours%'
40dbc108 50
51Other queries might require slightly more complex logic:
52
ea6309e2 53 my @albums = $schema->resultset('Album')->search({
35d4fe78 54 -or => [
55 -and => [
56 artist => { 'like', '%Smashing Pumpkins%' },
57 title => 'Siamese Dream',
58 ],
59 artist => 'Starchildren',
60 ],
61 });
40dbc108 62
63This results in the following C<WHERE> clause:
64
35d4fe78 65 WHERE ( artist LIKE '%Smashing Pumpkins%' AND title = 'Siamese Dream' )
66 OR artist = 'Starchildren'
40dbc108 67
68For more information on generating complex queries, see
69L<SQL::Abstract/WHERE CLAUSES>.
ee38fa40 70
b9823354 71=head2 Retrieve one and only one row from a resultset
72
73Sometimes you need only the first "top" row of a resultset. While this can be
74easily done with L<< $rs->first|DBIx::Class::ResultSet/first >>, it is suboptimal,
75as a full blown cursor for the resultset will be created and then immediately
76destroyed after fetching the first row object.
77L<< $rs->single|DBIx::Class::ResultSet/single >> is
78designed specifically for this case - it will grab the first returned result
79without even instantiating a cursor.
80
81Before replacing all your calls to C<first()> with C<single()> please observe the
82following CAVEATS:
83
84=over
85
86=item *
87While single() takes a search condition just like search() does, it does
88_not_ accept search attributes. However one can always chain a single() to
89a search():
90
91 my $top_cd = $cd_rs -> search({}, { order_by => 'rating' }) -> single;
92
93
94=item *
95Since single() is the engine behind find(), it is designed to fetch a
96single row per database query. Thus a warning will be issued when the
97underlying SELECT returns more than one row. Sometimes however this usage
98is valid: i.e. we have an arbitrary number of cd's but only one of them is
99at the top of the charts at any given time. If you know what you are doing,
100you can silence the warning by explicitly limiting the resultset size:
101
102 my $top_cd = $cd_rs -> search ({}, { order_by => 'rating', rows => 1 }) -> single;
103
104=back
105
d2f3e87b 106=head2 Arbitrary SQL through a custom ResultSource
321d9634 107
108Sometimes you have to run arbitrary SQL because your query is too complex
109(e.g. it contains Unions, Sub-Selects, Stored Procedures, etc.) or has to
110be optimized for your database in a special way, but you still want to
111get the results as a L<DBIx::Class::ResultSet>.
112The recommended way to accomplish this is by defining a separate ResultSource
113for your query. You can then inject complete SQL statements using a scalar
114reference (this is a feature of L<SQL::Abstract>).
115
116Say you want to run a complex custom query on your user data, here's what
117you have to add to your User class:
118
119 package My::Schema::User;
120
121 use base qw/DBIx::Class/;
122
123 # ->load_components, ->table, ->add_columns, etc.
124
125 # Make a new ResultSource based on the User class
126 my $source = __PACKAGE__->result_source_instance();
127 my $new_source = $source->new( $source );
128 $new_source->source_name( 'UserFriendsComplex' );
129
130 # Hand in your query as a scalar reference
131 # It will be added as a sub-select after FROM,
132 # so pay attention to the surrounding brackets!
133 $new_source->name( \<<SQL );
134 ( SELECT u.* FROM user u
135 INNER JOIN user_friends f ON u.id = f.user_id
136 WHERE f.friend_user_id = ?
137 UNION
138 SELECT u.* FROM user u
139 INNER JOIN user_friends f ON u.id = f.friend_user_id
140 WHERE f.user_id = ? )
141 SQL
142
143 # Finally, register your new ResultSource with your Schema
dbe79da9 144 My::Schema->register_extra_source( 'UserFriendsComplex' => $new_source );
321d9634 145
146Next, you can execute your complex query using bind parameters like this:
147
148 my $friends = [ $schema->resultset( 'UserFriendsComplex' )->search( {},
149 {
150 bind => [ 12345, 12345 ]
151 }
152 ) ];
153
d00a5c68 154... and you'll get back a perfect L<DBIx::Class::ResultSet> (except, of course,
155that you cannot modify the rows it contains, ie. cannot call L</update>,
156L</delete>, ... on it).
157
158If you prefer to have the definitions of these custom ResultSources in separate
159files (instead of stuffing all of them into the same resultset class), you can
160achieve the same with subclassing the resultset class and defining the
161ResultSource there:
162
163 package My::Schema::UserFriendsComplex;
164
165 use My::Schema::User;
166 use base qw/My::Schema::User/;
167
168 __PACKAGE__->table('dummy'); # currently must be called before anything else
169
170 # Hand in your query as a scalar reference
171 # It will be added as a sub-select after FROM,
172 # so pay attention to the surrounding brackets!
173 __PACKAGE__->name( \<<SQL );
174 ( SELECT u.* FROM user u
175 INNER JOIN user_friends f ON u.id = f.user_id
176 WHERE f.friend_user_id = ?
177 UNION
178 SELECT u.* FROM user u
179 INNER JOIN user_friends f ON u.id = f.friend_user_id
180 WHERE f.user_id = ? )
181 SQL
182
183TIMTOWDI.
321d9634 184
d2f3e87b 185=head2 Using specific columns
faf62551 186
324572ca 187When you only want specific columns from a table, you can use
188C<columns> to specify which ones you need. This is useful to avoid
189loading columns with large amounts of data that you aren't about to
190use anyway:
faf62551 191
bade79c4 192 my $rs = $schema->resultset('Artist')->search(
5e8b1b2a 193 undef,
bade79c4 194 {
5e8b1b2a 195 columns => [qw/ name /]
bade79c4 196 }
197 );
faf62551 198
bade79c4 199 # Equivalent SQL:
200 # SELECT artist.name FROM artist
faf62551 201
324572ca 202This is a shortcut for C<select> and C<as>, see below. C<columns>
203cannot be used together with C<select> and C<as>.
204
d2f3e87b 205=head2 Using database functions or stored procedures
faf62551 206
bade79c4 207The combination of C<select> and C<as> can be used to return the result of a
208database function or stored procedure as a column value. You use C<select> to
209specify the source for your column value (e.g. a column name, function, or
210stored procedure name). You then use C<as> to set the column name you will use
211to access the returned value:
faf62551 212
bade79c4 213 my $rs = $schema->resultset('Artist')->search(
324572ca 214 {},
bade79c4 215 {
216 select => [ 'name', { LENGTH => 'name' } ],
217 as => [qw/ name name_length /],
218 }
219 );
faf62551 220
bade79c4 221 # Equivalent SQL:
98b65433 222 # SELECT name name, LENGTH( name )
bade79c4 223 # FROM artist
faf62551 224
d676881f 225Note that the C< as > attribute has absolutely nothing to with the sql
226syntax C< SELECT foo AS bar > (see the documentation in
227L<DBIx::Class::ResultSet/ATTRIBUTES>). If your alias exists as a
228column in your base class (i.e. it was added with C<add_columns>), you
229just access it as normal. Our C<Artist> class has a C<name> column, so
230we just use the C<name> accessor:
faf62551 231
bade79c4 232 my $artist = $rs->first();
233 my $name = $artist->name();
faf62551 234
235If on the other hand the alias does not correspond to an existing column, you
324572ca 236have to fetch the value using the C<get_column> accessor:
faf62551 237
bade79c4 238 my $name_length = $artist->get_column('name_length');
faf62551 239
bade79c4 240If you don't like using C<get_column>, you can always create an accessor for
faf62551 241any of your aliases using either of these:
242
bade79c4 243 # Define accessor manually:
244 sub name_length { shift->get_column('name_length'); }
faf62551 245
bade79c4 246 # Or use DBIx::Class::AccessorGroup:
247 __PACKAGE__->mk_group_accessors('column' => 'name_length');
faf62551 248
d2f3e87b 249=head2 SELECT DISTINCT with multiple columns
faf62551 250
bade79c4 251 my $rs = $schema->resultset('Foo')->search(
324572ca 252 {},
bade79c4 253 {
254 select => [
255 { distinct => [ $source->columns ] }
256 ],
d676881f 257 as => [ $source->columns ] # remember 'as' is not the same as SQL AS :-)
bade79c4 258 }
259 );
faf62551 260
d2f3e87b 261=head2 SELECT COUNT(DISTINCT colname)
6607ee1b 262
bade79c4 263 my $rs = $schema->resultset('Foo')->search(
324572ca 264 {},
bade79c4 265 {
266 select => [
267 { count => { distinct => 'colname' } }
268 ],
269 as => [ 'count' ]
270 }
271 );
6607ee1b 272
3d565896 273 my $count = $rs->next->get_column('count');
274
d2f3e87b 275=head2 Grouping results
bade79c4 276
277L<DBIx::Class> supports C<GROUP BY> as follows:
278
279 my $rs = $schema->resultset('Artist')->search(
324572ca 280 {},
bade79c4 281 {
282 join => [qw/ cds /],
51458a6a 283 select => [ 'name', { count => 'cds.id' } ],
bade79c4 284 as => [qw/ name cd_count /],
285 group_by => [qw/ name /]
286 }
287 );
6607ee1b 288
bade79c4 289 # Equivalent SQL:
51458a6a 290 # SELECT name, COUNT( cd.id ) FROM artist
291 # LEFT JOIN cd ON artist.id = cd.artist
bade79c4 292 # GROUP BY name
6607ee1b 293
d676881f 294Please see L<DBIx::Class::ResultSet/ATTRIBUTES> documentation if you
295are in any way unsure about the use of the attributes above (C< join
296>, C< select >, C< as > and C< group_by >).
297
70bb942d 298=head2 Subqueries (EXPERIMENTAL)
03834f77 299
300You can write subqueries relatively easily in DBIC.
301
302 my $inside_rs = $schema->resultset('Artist')->search({
303 name => [ 'Billy Joel', 'Brittany Spears' ],
304 });
305
68a797c1 306 my $rs = $schema->resultset('CD')->search({
03834f77 307 artist_id => { 'IN' => $inside_rs->get_column('id')->as_query },
308 });
309
310The usual operators ( =, !=, IN, NOT IN, etc) are supported.
311
312B<NOTE>: You have to explicitly use '=' when doing an equality comparison.
313The following will B<not> work:
314
68a797c1 315 my $rs = $schema->resultset('CD')->search({
03834f77 316 artist_id => $inside_rs->get_column('id')->as_query,
317 });
318
0a62f675 319=head3 Support
320
321Subqueries are supported in the where clause (first hashref), and in the
322from, select, and +select attributes.
323
68a797c1 324=head3 Correlated subqueries
325
326 my $cdrs = $schema->resultset('CD');
327 my $rs = $cdrs->search({
328 year => {
329 '=' => $cdrs->search(
330 { artistid => { '=' => \'me.artistid' } },
331 { alias => 'inner' }
332 )->get_column('year')->max_rs->as_query,
333 },
334 });
335
336That creates the following SQL:
337
338 SELECT me.cdid, me.artist, me.title, me.year, me.genreid, me.single_track
339 FROM cd me
340 WHERE year = (
341 SELECT MAX(inner.year)
342 FROM cd inner
343 WHERE artistid = me.artistid
344 )
345
6a9530d1 346=head3 EXPERIMENTAL
347
348Please note that subqueries are considered an experimental feature.
349
d2f3e87b 350=head2 Predefined searches
74dc2edc 351
324572ca 352You can write your own L<DBIx::Class::ResultSet> class by inheriting from it
74dc2edc 353and define often used searches as methods:
354
355 package My::DBIC::ResultSet::CD;
356 use strict;
357 use warnings;
358 use base 'DBIx::Class::ResultSet';
359
360 sub search_cds_ordered {
361 my ($self) = @_;
362
363 return $self->search(
364 {},
365 { order_by => 'name DESC' },
366 );
367 }
368
369 1;
370
371To use your resultset, first tell DBIx::Class to create an instance of it
372for you, in your My::DBIC::Schema::CD class:
373
9dc1bfce 374 # class definition as normal
375 __PACKAGE__->load_components(qw/ Core /);
376 __PACKAGE__->table('cd');
377
378 # tell DBIC to use the custom ResultSet class
74dc2edc 379 __PACKAGE__->resultset_class('My::DBIC::ResultSet::CD');
380
9dc1bfce 381Note that C<resultset_class> must be called after C<load_components> and C<table>, or you will get errors about missing methods.
382
74dc2edc 383Then call your new method in your code:
384
385 my $ordered_cds = $schema->resultset('CD')->search_cds_ordered();
386
d2f3e87b 387=head2 Using SQL functions on the left hand side of a comparison
1c133e22 388
389Using SQL functions on the left hand side of a comparison is generally
390not a good idea since it requires a scan of the entire table. However,
391it can be accomplished with C<DBIx::Class> when necessary.
392
393If you do not have quoting on, simply include the function in your search
394specification as you would any column:
395
396 $rs->search({ 'YEAR(date_of_birth)' => 1979 });
397
398With quoting on, or for a more portable solution, use the C<where>
399attribute:
400
401 $rs->search({}, { where => \'YEAR(date_of_birth) = 1979' });
402
403=begin hidden
404
405(When the bind args ordering bug is fixed, this technique will be better
406and can replace the one above.)
407
408With quoting on, or for a more portable solution, use the C<where> and
409C<bind> attributes:
410
411 $rs->search({}, {
412 where => \'YEAR(date_of_birth) = ?',
413 bind => [ 1979 ]
414 });
415
416=end hidden
417
d2f3e87b 418=head1 JOINS AND PREFETCHING
419
87980de7 420=head2 Using joins and prefetch
421
bade79c4 422You can use the C<join> attribute to allow searching on, or sorting your
423results by, one or more columns in a related table. To return all CDs matching
424a particular artist name:
ea6309e2 425
bade79c4 426 my $rs = $schema->resultset('CD')->search(
427 {
428 'artist.name' => 'Bob Marley'
429 },
430 {
51458a6a 431 join => 'artist', # join the artist table
bade79c4 432 }
433 );
434
435 # Equivalent SQL:
436 # SELECT cd.* FROM cd
437 # JOIN artist ON cd.artist = artist.id
438 # WHERE artist.name = 'Bob Marley'
439
440If required, you can now sort on any column in the related tables by including
441it in your C<order_by> attribute:
442
443 my $rs = $schema->resultset('CD')->search(
444 {
445 'artist.name' => 'Bob Marley'
446 },
447 {
51458a6a 448 join => 'artist',
bade79c4 449 order_by => [qw/ artist.name /]
450 }
2f81ed0f 451 );
ea6309e2 452
bade79c4 453 # Equivalent SQL:
454 # SELECT cd.* FROM cd
455 # JOIN artist ON cd.artist = artist.id
456 # WHERE artist.name = 'Bob Marley'
457 # ORDER BY artist.name
ea6309e2 458
bade79c4 459Note that the C<join> attribute should only be used when you need to search or
460sort using columns in a related table. Joining related tables when you only
461need columns from the main table will make performance worse!
ea6309e2 462
bade79c4 463Now let's say you want to display a list of CDs, each with the name of the
464artist. The following will work fine:
ea6309e2 465
bade79c4 466 while (my $cd = $rs->next) {
467 print "CD: " . $cd->title . ", Artist: " . $cd->artist->name;
468 }
ea6309e2 469
bade79c4 470There is a problem however. We have searched both the C<cd> and C<artist> tables
471in our main query, but we have only returned data from the C<cd> table. To get
472the artist name for any of the CD objects returned, L<DBIx::Class> will go back
473to the database:
ea6309e2 474
bade79c4 475 SELECT artist.* FROM artist WHERE artist.id = ?
ea6309e2 476
477A statement like the one above will run for each and every CD returned by our
478main query. Five CDs, five extra queries. A hundred CDs, one hundred extra
479queries!
480
bade79c4 481Thankfully, L<DBIx::Class> has a C<prefetch> attribute to solve this problem.
897342e4 482This allows you to fetch results from related tables in advance:
ea6309e2 483
bade79c4 484 my $rs = $schema->resultset('CD')->search(
485 {
486 'artist.name' => 'Bob Marley'
487 },
488 {
51458a6a 489 join => 'artist',
bade79c4 490 order_by => [qw/ artist.name /],
51458a6a 491 prefetch => 'artist' # return artist data too!
bade79c4 492 }
493 );
ea6309e2 494
bade79c4 495 # Equivalent SQL (note SELECT from both "cd" and "artist"):
496 # SELECT cd.*, artist.* FROM cd
497 # JOIN artist ON cd.artist = artist.id
498 # WHERE artist.name = 'Bob Marley'
499 # ORDER BY artist.name
ea6309e2 500
501The code to print the CD list remains the same:
502
bade79c4 503 while (my $cd = $rs->next) {
504 print "CD: " . $cd->title . ", Artist: " . $cd->artist->name;
505 }
ea6309e2 506
bade79c4 507L<DBIx::Class> has now prefetched all matching data from the C<artist> table,
ea6309e2 508so no additional SQL statements are executed. You now have a much more
509efficient query.
510
77d6b403 511Note that as of L<DBIx::Class> 0.05999_01, C<prefetch> I<can> be used with
512C<has_many> relationships.
ea6309e2 513
bade79c4 514Also note that C<prefetch> should only be used when you know you will
ea6309e2 515definitely use data from a related table. Pre-fetching related tables when you
516only need columns from the main table will make performance worse!
517
51458a6a 518=head2 Multiple joins
519
520In the examples above, the C<join> attribute was a scalar. If you
521pass an array reference instead, you can join to multiple tables. In
522this example, we want to limit the search further, using
523C<LinerNotes>:
524
525 # Relationships defined elsewhere:
526 # CD->belongs_to('artist' => 'Artist');
527 # CD->has_one('liner_notes' => 'LinerNotes', 'cd');
528 my $rs = $schema->resultset('CD')->search(
529 {
530 'artist.name' => 'Bob Marley'
531 'liner_notes.notes' => { 'like', '%some text%' },
532 },
533 {
534 join => [qw/ artist liner_notes /],
535 order_by => [qw/ artist.name /],
536 }
537 );
538
539 # Equivalent SQL:
540 # SELECT cd.*, artist.*, liner_notes.* FROM cd
541 # JOIN artist ON cd.artist = artist.id
542 # JOIN liner_notes ON cd.id = liner_notes.cd
543 # WHERE artist.name = 'Bob Marley'
544 # ORDER BY artist.name
545
d2f3e87b 546=head2 Multi-step joins
ea6309e2 547
548Sometimes you want to join more than one relationship deep. In this example,
bade79c4 549we want to find all C<Artist> objects who have C<CD>s whose C<LinerNotes>
550contain a specific string:
551
552 # Relationships defined elsewhere:
553 # Artist->has_many('cds' => 'CD', 'artist');
554 # CD->has_one('liner_notes' => 'LinerNotes', 'cd');
555
556 my $rs = $schema->resultset('Artist')->search(
557 {
558 'liner_notes.notes' => { 'like', '%some text%' },
559 },
560 {
561 join => {
562 'cds' => 'liner_notes'
563 }
564 }
565 );
ea6309e2 566
bade79c4 567 # Equivalent SQL:
568 # SELECT artist.* FROM artist
51458a6a 569 # LEFT JOIN cd ON artist.id = cd.artist
570 # LEFT JOIN liner_notes ON cd.id = liner_notes.cd
bade79c4 571 # WHERE liner_notes.notes LIKE '%some text%'
ea6309e2 572
573Joins can be nested to an arbitrary level. So if we decide later that we
574want to reduce the number of Artists returned based on who wrote the liner
575notes:
576
bade79c4 577 # Relationship defined elsewhere:
578 # LinerNotes->belongs_to('author' => 'Person');
579
580 my $rs = $schema->resultset('Artist')->search(
581 {
582 'liner_notes.notes' => { 'like', '%some text%' },
583 'author.name' => 'A. Writer'
584 },
585 {
586 join => {
587 'cds' => {
588 'liner_notes' => 'author'
ea6309e2 589 }
bade79c4 590 }
591 }
592 );
ea6309e2 593
bade79c4 594 # Equivalent SQL:
595 # SELECT artist.* FROM artist
51458a6a 596 # LEFT JOIN cd ON artist.id = cd.artist
597 # LEFT JOIN liner_notes ON cd.id = liner_notes.cd
598 # LEFT JOIN author ON author.id = liner_notes.author
bade79c4 599 # WHERE liner_notes.notes LIKE '%some text%'
600 # AND author.name = 'A. Writer'
87980de7 601
51458a6a 602=head2 Multi-step and multiple joins
603
604With various combinations of array and hash references, you can join
605tables in any combination you desire. For example, to join Artist to
606CD and Concert, and join CD to LinerNotes:
607
608 # Relationships defined elsewhere:
609 # Artist->has_many('concerts' => 'Concert', 'artist');
610
611 my $rs = $schema->resultset('Artist')->search(
612 { },
613 {
614 join => [
615 {
616 cds => 'liner_notes'
617 },
618 'concerts'
619 ],
620 }
621 );
622
623 # Equivalent SQL:
624 # SELECT artist.* FROM artist
625 # LEFT JOIN cd ON artist.id = cd.artist
626 # LEFT JOIN liner_notes ON cd.id = liner_notes.cd
627 # LEFT JOIN concert ON artist.id = concert.artist
628
897342e4 629=head2 Multi-step prefetch
630
631From 0.04999_05 onwards, C<prefetch> can be nested more than one relationship
632deep using the same syntax as a multi-step join:
633
634 my $rs = $schema->resultset('Tag')->search(
ac2803ef 635 {},
897342e4 636 {
637 prefetch => {
638 cd => 'artist'
639 }
640 }
641 );
642
643 # Equivalent SQL:
644 # SELECT tag.*, cd.*, artist.* FROM tag
51458a6a 645 # JOIN cd ON tag.cd = cd.id
646 # JOIN artist ON cd.artist = artist.id
897342e4 647
648Now accessing our C<cd> and C<artist> relationships does not need additional
649SQL statements:
650
651 my $tag = $rs->first;
652 print $tag->cd->artist->name;
653
d2f3e87b 654=head1 ROW-LEVEL OPERATIONS
655
656=head2 Retrieving a row object's Schema
657
658It is possible to get a Schema object from a row object like so:
659
660 my $schema = $cd->result_source->schema;
661 # use the schema as normal:
662 my $artist_rs = $schema->resultset('Artist');
663
664This can be useful when you don't want to pass around a Schema object to every
665method.
666
667=head2 Getting the value of the primary key for the last database insert
668
669AKA getting last_insert_id
670
671If you are using PK::Auto (which is a core component as of 0.07), this is
672straightforward:
673
674 my $foo = $rs->create(\%blah);
675 # do more stuff
676 my $id = $foo->id; # foo->my_primary_key_field will also work.
677
678If you are not using autoincrementing primary keys, this will probably
679not work, but then you already know the value of the last primary key anyway.
680
681=head2 Stringification
682
683Employ the standard stringification technique by using the C<overload>
684module.
685
686To make an object stringify itself as a single column, use something
687like this (replace C<foo> with the column/method of your choice):
688
689 use overload '""' => sub { shift->name}, fallback => 1;
690
691For more complex stringification, you can use an anonymous subroutine:
692
693 use overload '""' => sub { $_[0]->name . ", " .
694 $_[0]->address }, fallback => 1;
695
696=head3 Stringification Example
697
698Suppose we have two tables: C<Product> and C<Category>. The table
699specifications are:
700
701 Product(id, Description, category)
702 Category(id, Description)
703
704C<category> is a foreign key into the Category table.
705
706If you have a Product object C<$obj> and write something like
707
708 print $obj->category
709
710things will not work as expected.
711
712To obtain, for example, the category description, you should add this
713method to the class defining the Category table:
714
715 use overload "" => sub {
716 my $self = shift;
717
718 return $self->Description;
719 }, fallback => 1;
720
721=head2 Want to know if find_or_create found or created a row?
722
723Just use C<find_or_new> instead, then check C<in_storage>:
724
725 my $obj = $rs->find_or_new({ blah => 'blarg' });
726 unless ($obj->in_storage) {
727 $obj->insert;
728 # do whatever else you wanted if it was a new row
729 }
730
731=head2 Dynamic Sub-classing DBIx::Class proxy classes
732
733AKA multi-class object inflation from one table
734
735L<DBIx::Class> classes are proxy classes, therefore some different
736techniques need to be employed for more than basic subclassing. In
737this example we have a single user table that carries a boolean bit
738for admin. We would like like to give the admin users
739objects(L<DBIx::Class::Row>) the same methods as a regular user but
740also special admin only methods. It doesn't make sense to create two
741seperate proxy-class files for this. We would be copying all the user
742methods into the Admin class. There is a cleaner way to accomplish
743this.
744
745Overriding the C<inflate_result> method within the User proxy-class
746gives us the effect we want. This method is called by
747L<DBIx::Class::ResultSet> when inflating a result from storage. So we
748grab the object being returned, inspect the values we are looking for,
749bless it if it's an admin object, and then return it. See the example
750below:
751
752B<Schema Definition>
753
754 package DB::Schema;
755
756 use base qw/DBIx::Class::Schema/;
757
758 __PACKAGE__->load_classes(qw/User/);
759
760
761B<Proxy-Class definitions>
762
763 package DB::Schema::User;
764
765 use strict;
766 use warnings;
767 use base qw/DBIx::Class/;
768
769 ### Defined what our admin class is for ensure_class_loaded
770 my $admin_class = __PACKAGE__ . '::Admin';
771
772 __PACKAGE__->load_components(qw/Core/);
773
774 __PACKAGE__->table('users');
775
776 __PACKAGE__->add_columns(qw/user_id email password
777 firstname lastname active
778 admin/);
779
780 __PACKAGE__->set_primary_key('user_id');
781
782 sub inflate_result {
783 my $self = shift;
784 my $ret = $self->next::method(@_);
785 if( $ret->admin ) {### If this is an admin rebless for extra functions
786 $self->ensure_class_loaded( $admin_class );
787 bless $ret, $admin_class;
788 }
789 return $ret;
790 }
791
792 sub hello {
793 print "I am a regular user.\n";
794 return ;
795 }
796
797
798 package DB::Schema::User::Admin;
799
800 use strict;
801 use warnings;
802 use base qw/DB::Schema::User/;
803
804 sub hello
805 {
806 print "I am an admin.\n";
807 return;
808 }
809
810 sub do_admin_stuff
811 {
812 print "I am doing admin stuff\n";
813 return ;
814 }
815
816B<Test File> test.pl
817
818 use warnings;
819 use strict;
820 use DB::Schema;
821
822 my $user_data = { email => 'someguy@place.com',
823 password => 'pass1',
824 admin => 0 };
825
826 my $admin_data = { email => 'someadmin@adminplace.com',
827 password => 'pass2',
828 admin => 1 };
829
830 my $schema = DB::Schema->connection('dbi:Pg:dbname=test');
831
832 $schema->resultset('User')->create( $user_data );
833 $schema->resultset('User')->create( $admin_data );
834
835 ### Now we search for them
836 my $user = $schema->resultset('User')->single( $user_data );
837 my $admin = $schema->resultset('User')->single( $admin_data );
838
839 print ref $user, "\n";
840 print ref $admin, "\n";
841
842 print $user->password , "\n"; # pass1
843 print $admin->password , "\n";# pass2; inherited from User
844 print $user->hello , "\n";# I am a regular user.
845 print $admin->hello, "\n";# I am an admin.
846
847 ### The statement below will NOT print
848 print "I can do admin stuff\n" if $user->can('do_admin_stuff');
849 ### The statement below will print
850 print "I can do admin stuff\n" if $admin->can('do_admin_stuff');
851
a5b29361 852=head2 Skip row object creation for faster results
d2f3e87b 853
854DBIx::Class is not built for speed, it's built for convenience and
855ease of use, but sometimes you just need to get the data, and skip the
856fancy objects.
857
858To do this simply use L<DBIx::Class::ResultClass::HashRefInflator>.
859
860 my $rs = $schema->resultset('CD');
861
862 $rs->result_class('DBIx::Class::ResultClass::HashRefInflator');
863
864 my $hash_ref = $rs->find(1);
a5b29361 865
d2f3e87b 866Wasn't that easy?
bc96f260 867
d2f3e87b 868=head2 Get raw data for blindingly fast results
869
870If the L<HashRefInflator|DBIx::Class::ResultClass::HashRefInflator> solution
871above is not fast enough for you, you can use a DBIx::Class to return values
872exactly as they come out of the data base with none of the convenience methods
873wrapped round them.
874
2d7d8459 875This is used like so:
d2f3e87b 876
877 my $cursor = $rs->cursor
878 while (my @vals = $cursor->next) {
879 # use $val[0..n] here
880 }
881
882You will need to map the array offsets to particular columns (you can
883use the I<select> attribute of C<search()> to force ordering).
884
885=head1 RESULTSET OPERATIONS
886
887=head2 Getting Schema from a ResultSet
888
889To get the schema object from a result set, do the following:
890
891 $rs->result_source->schema
892
893=head2 Getting Columns Of Data
894
895AKA Aggregating Data
ac2803ef 896
897If you want to find the sum of a particular column there are several
898ways, the obvious one is to use search:
899
900 my $rs = $schema->resultset('Items')->search(
901 {},
902 {
903 select => [ { sum => 'Cost' } ],
d676881f 904 as => [ 'total_cost' ], # remember this 'as' is for DBIx::Class::ResultSet not SQL
ac2803ef 905 }
906 );
907 my $tc = $rs->first->get_column('total_cost');
908
909Or, you can use the L<DBIx::Class::ResultSetColumn>, which gets
910returned when you ask the C<ResultSet> for a column using
911C<get_column>:
912
913 my $cost = $schema->resultset('Items')->get_column('Cost');
914 my $tc = $cost->sum;
915
916With this you can also do:
917
918 my $minvalue = $cost->min;
919 my $maxvalue = $cost->max;
920
921Or just iterate through the values of this column only:
922
923 while ( my $c = $cost->next ) {
924 print $c;
925 }
926
927 foreach my $c ($cost->all) {
928 print $c;
929 }
930
709353af 931C<ResultSetColumn> only has a limited number of built-in functions, if
932you need one that it doesn't have, then you can use the C<func> method
933instead:
934
935 my $avg = $cost->func('AVERAGE');
936
937This will cause the following SQL statement to be run:
938
939 SELECT AVERAGE(Cost) FROM Items me
940
941Which will of course only work if your database supports this function.
ac2803ef 942See L<DBIx::Class::ResultSetColumn> for more documentation.
943
204e5c03 944=head2 Creating a result set from a set of rows
945
946Sometimes you have a (set of) row objects that you want to put into a
947resultset without the need to hit the DB again. You can do that by using the
948L<set_cache|DBIx::Class::Resultset/set_cache> method:
949
2d7a4e46 950 my @uploadable_groups;
204e5c03 951 while (my $group = $groups->next) {
952 if ($group->can_upload($self)) {
953 push @uploadable_groups, $group;
954 }
955 }
956 my $new_rs = $self->result_source->resultset;
957 $new_rs->set_cache(\@uploadable_groups);
958 return $new_rs;
959
960
d2f3e87b 961=head1 USING RELATIONSHIPS
acee4e4d 962
d2f3e87b 963=head2 Create a new row in a related table
acee4e4d 964
6f1434fd 965 my $author = $book->create_related('author', { name => 'Fred'});
acee4e4d 966
d2f3e87b 967=head2 Search in a related table
acee4e4d 968
969Only searches for books named 'Titanic' by the author in $author.
970
6f1434fd 971 my $books_rs = $author->search_related('books', { name => 'Titanic' });
acee4e4d 972
d2f3e87b 973=head2 Delete data in a related table
acee4e4d 974
975Deletes only the book named Titanic by the author in $author.
976
6f1434fd 977 $author->delete_related('books', { name => 'Titanic' });
acee4e4d 978
d2f3e87b 979=head2 Ordering a relationship result set
f8bad769 980
981If you always want a relation to be ordered, you can specify this when you
982create the relationship.
983
6f1434fd 984To order C<< $book->pages >> by descending page_number, create the relation
985as follows:
f8bad769 986
6f1434fd 987 __PACKAGE__->has_many('pages' => 'Page', 'book', { order_by => \'page_number DESC'} );
f8bad769 988
7c0825ab 989=head2 Filtering a relationship result set
990
991If you want to get a filtered result set, you can just add add to $attr as follows:
992
993 __PACKAGE__->has_many('pages' => 'Page', 'book', { where => { scrap => 0 } } );
994
d2f3e87b 995=head2 Many-to-many relationships
f8bad769 996
d2f3e87b 997This is straightforward using L<ManyToMany|DBIx::Class::Relationship/many_to_many>:
f8bad769 998
d2f3e87b 999 package My::User;
6f1434fd 1000 use base 'DBIx::Class';
1001 __PACKAGE__->load_components('Core');
d2f3e87b 1002 __PACKAGE__->table('user');
1003 __PACKAGE__->add_columns(qw/id name/);
1004 __PACKAGE__->set_primary_key('id');
1005 __PACKAGE__->has_many('user_address' => 'My::UserAddress', 'user');
1006 __PACKAGE__->many_to_many('addresses' => 'user_address', 'address');
87980de7 1007
d2f3e87b 1008 package My::UserAddress;
6f1434fd 1009 use base 'DBIx::Class';
1010 __PACKAGE__->load_components('Core');
d2f3e87b 1011 __PACKAGE__->table('user_address');
1012 __PACKAGE__->add_columns(qw/user address/);
1013 __PACKAGE__->set_primary_key(qw/user address/);
1014 __PACKAGE__->belongs_to('user' => 'My::User');
1015 __PACKAGE__->belongs_to('address' => 'My::Address');
181a28f4 1016
d2f3e87b 1017 package My::Address;
6f1434fd 1018 use base 'DBIx::Class';
1019 __PACKAGE__->load_components('Core');
d2f3e87b 1020 __PACKAGE__->table('address');
1021 __PACKAGE__->add_columns(qw/id street town area_code country/);
1022 __PACKAGE__->set_primary_key('id');
1023 __PACKAGE__->has_many('user_address' => 'My::UserAddress', 'address');
1024 __PACKAGE__->many_to_many('users' => 'user_address', 'user');
1025
1026 $rs = $user->addresses(); # get all addresses for a user
1027 $rs = $address->users(); # get all users for an address
1028
1029=head1 TRANSACTIONS
1030
1031As of version 0.04001, there is improved transaction support in
1032L<DBIx::Class::Storage> and L<DBIx::Class::Schema>. Here is an
1033example of the recommended way to use it:
1034
1035 my $genus = $schema->resultset('Genus')->find(12);
1036
1037 my $coderef2 = sub {
1038 $genus->extinct(1);
1039 $genus->update;
1040 };
70634260 1041
181a28f4 1042 my $coderef1 = sub {
35d4fe78 1043 $genus->add_to_species({ name => 'troglodyte' });
1044 $genus->wings(2);
1045 $genus->update;
6f1434fd 1046 $schema->txn_do($coderef2); # Can have a nested transaction. Only the outer will actualy commit
181a28f4 1047 return $genus->species;
1048 };
1049
181a28f4 1050 my $rs;
1051 eval {
70634260 1052 $rs = $schema->txn_do($coderef1);
181a28f4 1053 };
1054
1055 if ($@) { # Transaction failed
1056 die "the sky is falling!" #
1057 if ($@ =~ /Rollback failed/); # Rollback failed
1058
1059 deal_with_failed_transaction();
35d4fe78 1060 }
87980de7 1061
181a28f4 1062Nested transactions will work as expected. That is, only the outermost
1063transaction will actually issue a commit to the $dbh, and a rollback
1064at any level of any transaction will cause the entire nested
1065transaction to fail. Support for savepoints and for true nested
40dbc108 1066transactions (for databases that support them) will hopefully be added
1067in the future.
ee38fa40 1068
d2f3e87b 1069=head1 SQL
ee38fa40 1070
d2f3e87b 1071=head2 Creating Schemas From An Existing Database
ea6309e2 1072
d2f3e87b 1073L<DBIx::Class::Schema::Loader> will connect to a database and create a
1074L<DBIx::Class::Schema> and associated sources by examining the database.
bade79c4 1075
d2f3e87b 1076The recommend way of achieving this is to use the
1077L<make_schema_at|DBIx::Class::Schema::Loader/make_schema_at> method:
bade79c4 1078
6f1434fd 1079 perl -MDBIx::Class::Schema::Loader=make_schema_at,dump_to_dir:./lib \
1080 -e 'make_schema_at("My::Schema", { debug => 1 }, [ "dbi:Pg:dbname=foo","postgres" ])'
362500af 1081
d2f3e87b 1082This will create a tree of files rooted at C<./lib/My/Schema/> containing
1083source definitions for all the tables found in the C<foo> database.
362500af 1084
d2f3e87b 1085=head2 Creating DDL SQL
362500af 1086
264f1571 1087The following functionality requires you to have L<SQL::Translator>
1088(also known as "SQL Fairy") installed.
362500af 1089
264f1571 1090To create a set of database-specific .sql files for the above schema:
362500af 1091
264f1571 1092 my $schema = My::Schema->connect($dsn);
1093 $schema->create_ddl_dir(['MySQL', 'SQLite', 'PostgreSQL'],
1094 '0.1',
d2f3e87b 1095 './dbscriptdir/'
264f1571 1096 );
1097
1098By default this will create schema files in the current directory, for
1099MySQL, SQLite and PostgreSQL, using the $VERSION from your Schema.pm.
1100
1101To create a new database using the schema:
1102
1103 my $schema = My::Schema->connect($dsn);
1104 $schema->deploy({ add_drop_tables => 1});
1105
1106To import created .sql files using the mysql client:
1107
1108 mysql -h "host" -D "database" -u "user" -p < My_Schema_1.0_MySQL.sql
1109
1110To create C<ALTER TABLE> conversion scripts to update a database to a
1111newer version of your schema at a later point, first set a new
d2f3e87b 1112C<$VERSION> in your Schema file, then:
264f1571 1113
1114 my $schema = My::Schema->connect($dsn);
1115 $schema->create_ddl_dir(['MySQL', 'SQLite', 'PostgreSQL'],
1116 '0.2',
1117 '/dbscriptdir/',
1118 '0.1'
1119 );
1120
1121This will produce new database-specific .sql files for the new version
1122of the schema, plus scripts to convert from version 0.1 to 0.2. This
1123requires that the files for 0.1 as created above are available in the
1124given directory to diff against.
362500af 1125
6f1434fd 1126=head2 Select from dual
16cd5b28 1127
1128Dummy tables are needed by some databases to allow calling functions
1129or expressions that aren't based on table content, for examples of how
1130this applies to various database types, see:
1131L<http://troels.arvin.dk/db/rdbms/#other-dummy_table>.
1132
1133Note: If you're using Oracles dual table don't B<ever> do anything
1134other than a select, if you CRUD on your dual table you *will* break
1135your database.
1136
1137Make a table class as you would for any other table
1138
1139 package MyAppDB::Dual;
1140 use strict;
1141 use warnings;
1142 use base 'DBIx::Class';
1143 __PACKAGE__->load_components("Core");
1144 __PACKAGE__->table("Dual");
1145 __PACKAGE__->add_columns(
1146 "dummy",
1147 { data_type => "VARCHAR2", is_nullable => 0, size => 1 },
1148 );
1149
1150Once you've loaded your table class select from it using C<select>
1151and C<as> instead of C<columns>
1152
1153 my $rs = $schema->resultset('Dual')->search(undef,
1154 { select => [ 'sydate' ],
1155 as => [ 'now' ]
1156 },
1157 );
1158
1159All you have to do now is be careful how you access your resultset, the below
1160will not work because there is no column called 'now' in the Dual table class
1161
1162 while (my $dual = $rs->next) {
1163 print $dual->now."\n";
1164 }
6f1434fd 1165 # Can't locate object method "now" via package "MyAppDB::Dual" at headshot.pl line 23.
16cd5b28 1166
1167You could of course use 'dummy' in C<as> instead of 'now', or C<add_columns> to
1168your Dual class for whatever you wanted to select from dual, but that's just
1169silly, instead use C<get_column>
1170
1171 while (my $dual = $rs->next) {
1172 print $dual->get_column('now')."\n";
1173 }
1174
1175Or use C<cursor>
1176
1177 my $cursor = $rs->cursor;
1178 while (my @vals = $cursor->next) {
1179 print $vals[0]."\n";
1180 }
1181
1182Or use L<DBIx::Class::ResultClass::HashRefInflator>
1183
1184 $rs->result_class('DBIx::Class::ResultClass::HashRefInflator');
1185 while ( my $dual = $rs->next ) {
1186 print $dual->{now}."\n";
1187 }
1188
1189Here are some example C<select> conditions to illustrate the different syntax
1190you could use for doing stuff like
1191C<oracles.heavily(nested(functions_can('take', 'lots'), OF), 'args')>
1192
1193 # get a sequence value
1194 select => [ 'A_SEQ.nextval' ],
1195
1196 # get create table sql
1197 select => [ { 'dbms_metadata.get_ddl' => [ "'TABLE'", "'ARTIST'" ]} ],
1198
1199 # get a random num between 0 and 100
1200 select => [ { "trunc" => [ { "dbms_random.value" => [0,100] } ]} ],
1201
1202 # what year is it?
1203 select => [ { 'extract' => [ \'year from sysdate' ] } ],
1204
1205 # do some math
1206 select => [ {'round' => [{'cos' => [ \'180 * 3.14159265359/180' ]}]}],
1207
1208 # which day of the week were you born on?
6f1434fd 1209 select => [{'to_char' => [{'to_date' => [ "'25-DEC-1980'", "'dd-mon-yyyy'" ]}, "'day'"]}],
16cd5b28 1210
1211 # select 16 rows from dual
1212 select => [ "'hello'" ],
1213 as => [ 'world' ],
1214 group_by => [ 'cube( 1, 2, 3, 4 )' ],
1215
1216
1217
d2f3e87b 1218=head2 Adding Indexes And Functions To Your SQL
362500af 1219
d2f3e87b 1220Often you will want indexes on columns on your table to speed up searching. To
1221do this, create a method called C<sqlt_deploy_hook> in the relevant source
2d7d8459 1222class (refer to the advanced
1223L<callback system|DBIx::Class::ResultSource/sqlt_deploy_callback> if you wish
1224to share a hook between multiple sources):
b0a20454 1225
d2f3e87b 1226 package My::Schema::Artist;
b0a20454 1227
d2f3e87b 1228 __PACKAGE__->table('artist');
1229 __PACKAGE__->add_columns(id => { ... }, name => { ... })
b0a20454 1230
d2f3e87b 1231 sub sqlt_deploy_hook {
1232 my ($self, $sqlt_table) = @_;
1233
1234 $sqlt_table->add_index(name => 'idx_name', fields => ['name']);
1235 }
1236
1237 1;
1238
1239Sometimes you might want to change the index depending on the type of the
1240database for which SQL is being generated:
1241
1242 my ($db_type = $sqlt_table->schema->translator->producer_type)
1243 =~ s/^SQL::Translator::Producer:://;
1244
1245You can also add hooks to the schema level to stop certain tables being
1246created:
1247
1248 package My::Schema;
1249
1250 ...
1251
1252 sub sqlt_deploy_hook {
1253 my ($self, $sqlt_schema) = @_;
1254
1255 $sqlt_schema->drop_table('table_name');
1256 }
1257
2d7d8459 1258You could also add views, procedures or triggers to the output using
1259L<SQL::Translator::Schema/add_view>,
1260L<SQL::Translator::Schema/add_procedure> or
1261L<SQL::Translator::Schema/add_trigger>.
1262
b0a20454 1263
362500af 1264=head2 Schema versioning
1265
1266The following example shows simplistically how you might use DBIx::Class to
1267deploy versioned schemas to your customers. The basic process is as follows:
1268
da4779ad 1269=over 4
1270
1271=item 1.
1272
1273Create a DBIx::Class schema
1274
1275=item 2.
1276
1277Save the schema
1278
1279=item 3.
1280
1281Deploy to customers
1282
1283=item 4.
1284
1285Modify schema to change functionality
1286
1287=item 5.
1288
1289Deploy update to customers
1290
1291=back
362500af 1292
d2f3e87b 1293B<Create a DBIx::Class schema>
362500af 1294
1295This can either be done manually, or generated from an existing database as
d2f3e87b 1296described under L</Creating Schemas From An Existing Database>
362500af 1297
d2f3e87b 1298B<Save the schema>
362500af 1299
d2f3e87b 1300Call L<DBIx::Class::Schema/create_ddl_dir> as above under L</Creating DDL SQL>.
362500af 1301
d2f3e87b 1302B<Deploy to customers>
362500af 1303
1304There are several ways you could deploy your schema. These are probably
1305beyond the scope of this recipe, but might include:
1306
da4779ad 1307=over 4
1308
1309=item 1.
1310
1311Require customer to apply manually using their RDBMS.
1312
1313=item 2.
1314
1315Package along with your app, making database dump/schema update/tests
362500af 1316all part of your install.
1317
da4779ad 1318=back
1319
d2f3e87b 1320B<Modify the schema to change functionality>
362500af 1321
264f1571 1322As your application evolves, it may be necessary to modify your schema
1323to change functionality. Once the changes are made to your schema in
1324DBIx::Class, export the modified schema and the conversion scripts as
d2f3e87b 1325in L</Creating DDL SQL>.
362500af 1326
d2f3e87b 1327B<Deploy update to customers>
362500af 1328
264f1571 1329Add the L<DBIx::Class::Schema::Versioned> schema component to your
1330Schema class. This will add a new table to your database called
ecea7937 1331C<dbix_class_schema_vesion> which will keep track of which version is installed
264f1571 1332and warn if the user trys to run a newer schema version than the
1333database thinks it has.
1334
1335Alternatively, you can send the conversion sql scripts to your
1336customers as above.
362500af 1337
d2f3e87b 1338=head2 Setting quoting for the generated SQL.
1339
1340If the database contains column names with spaces and/or reserved words, they
1341need to be quoted in the SQL queries. This is done using:
1342
1343 __PACKAGE__->storage->sql_maker->quote_char([ qw/[ ]/] );
1344 __PACKAGE__->storage->sql_maker->name_sep('.');
1345
1346The first sets the quote characters. Either a pair of matching
1347brackets, or a C<"> or C<'>:
1348
1349 __PACKAGE__->storage->sql_maker->quote_char('"');
1350
1351Check the documentation of your database for the correct quote
1352characters to use. C<name_sep> needs to be set to allow the SQL
1353generator to put the quotes the correct place.
1354
1355In most cases you should set these as part of the arguments passed to
d68b0c69 1356L<DBIx::Class::Schema/connect>:
d2f3e87b 1357
1358 my $schema = My::Schema->connect(
1359 'dbi:mysql:my_db',
1360 'db_user',
1361 'db_password',
1362 {
1363 quote_char => '"',
1364 name_sep => '.'
1365 }
1366 )
1367
7be93b07 1368=head2 Setting limit dialect for SQL::Abstract::Limit
1369
324572ca 1370In some cases, SQL::Abstract::Limit cannot determine the dialect of
1371the remote SQL server by looking at the database handle. This is a
1372common problem when using the DBD::JDBC, since the DBD-driver only
1373know that in has a Java-driver available, not which JDBC driver the
1374Java component has loaded. This specifically sets the limit_dialect
1375to Microsoft SQL-server (See more names in SQL::Abstract::Limit
1376-documentation.
7be93b07 1377
1378 __PACKAGE__->storage->sql_maker->limit_dialect('mssql');
1379
324572ca 1380The JDBC bridge is one way of getting access to a MSSQL server from a platform
7be93b07 1381that Microsoft doesn't deliver native client libraries for. (e.g. Linux)
1382
d2f3e87b 1383The limit dialect can also be set at connect time by specifying a
1384C<limit_dialect> key in the final hash as shown above.
2437a1e3 1385
05697a49 1386=head2 Working with PostgreSQL array types
1387
20ea616f 1388You can also assign values to PostgreSQL array columns by passing array
1389references in the C<\%columns> (C<\%vals>) hashref of the
1390L<DBIx::Class::ResultSet/create> and L<DBIx::Class::Row/update> family of
1391methods:
05697a49 1392
1393 $resultset->create({
1394 numbers => [1, 2, 3]
1395 });
1396
1397 $row->update(
1398 {
1399 numbers => [1, 2, 3]
1400 },
1401 {
1402 day => '2008-11-24'
1403 }
1404 );
1405
1406In conditions (eg. C<\%cond> in the L<DBIx::Class::ResultSet/search> family of
1407methods) you cannot directly use array references (since this is interpreted as
1408a list of values to be C<OR>ed), but you can use the following syntax to force
1409passing them as bind values:
1410
1411 $resultset->search(
1412 {
31eb3263 1413 numbers => \[ '= ?', [numbers => [1, 2, 3]] ]
05697a49 1414 }
1415 );
1416
1417See L<SQL::Abstract/array_datatypes> and L<SQL::Abstract/Literal SQL with
31eb3263 1418placeholders and bind values (subqueries)> for more explanation. Note that
1419L<DBIx::Class> sets L<SQL::Abstract/bindtype> to C<columns>, so you must pass
1420the bind values (the C<[1, 2, 3]> arrayref in the above example) wrapped in
1421arrayrefs together with the column name, like this: C<< [column_name => value]
1422>>.
05697a49 1423
d2f3e87b 1424=head1 BOOTSTRAPPING/MIGRATING
2437a1e3 1425
d2f3e87b 1426=head2 Easy migration from class-based to schema-based setup
2437a1e3 1427
d2f3e87b 1428You want to start using the schema-based approach to L<DBIx::Class>
1429(see L<SchemaIntro.pod>), but have an established class-based setup with lots
1430of existing classes that you don't want to move by hand. Try this nifty script
1431instead:
1432
1433 use MyDB;
1434 use SQL::Translator;
1435
1436 my $schema = MyDB->schema_instance;
2437a1e3 1437
d2f3e87b 1438 my $translator = SQL::Translator->new(
1439 debug => $debug || 0,
1440 trace => $trace || 0,
1441 no_comments => $no_comments || 0,
1442 show_warnings => $show_warnings || 0,
1443 add_drop_table => $add_drop_table || 0,
1444 validate => $validate || 0,
1445 parser_args => {
1446 'DBIx::Schema' => $schema,
1447 },
1448 producer_args => {
1449 'prefix' => 'My::Schema',
1450 },
1451 );
1452
1453 $translator->parser('SQL::Translator::Parser::DBIx::Class');
1454 $translator->producer('SQL::Translator::Producer::DBIx::Class::File');
1455
1456 my $output = $translator->translate(@args) or die
1457 "Error: " . $translator->error;
1458
1459 print $output;
2437a1e3 1460
d2f3e87b 1461You could use L<Module::Find> to search for all subclasses in the MyDB::*
1462namespace, which is currently left as an exercise for the reader.
2437a1e3 1463
d2f3e87b 1464=head1 OVERLOADING METHODS
086b93a2 1465
ab872312 1466L<DBIx::Class> uses the L<Class::C3> package, which provides for redispatch of
1467method calls, useful for things like default values and triggers. You have to
1468use calls to C<next::method> to overload methods. More information on using
1469L<Class::C3> with L<DBIx::Class> can be found in
086b93a2 1470L<DBIx::Class::Manual::Component>.
1471
d2f3e87b 1472=head2 Setting default values for a row
1473
1474It's as simple as overriding the C<new> method. Note the use of
1475C<next::method>.
1476
1477 sub new {
1478 my ( $class, $attrs ) = @_;
1479
1480 $attrs->{foo} = 'bar' unless defined $attrs->{foo};
1481
1482 my $new = $class->next::method($attrs);
1483
1484 return $new;
1485 }
1486
1487For more information about C<next::method>, look in the L<Class::C3>
1488documentation. See also L<DBIx::Class::Manual::Component> for more
1489ways to write your own base classes to do this.
1490
1491People looking for ways to do "triggers" with DBIx::Class are probably
1492just looking for this.
1493
1494=head2 Changing one field whenever another changes
086b93a2 1495
1496For example, say that you have three columns, C<id>, C<number>, and
1497C<squared>. You would like to make changes to C<number> and have
1498C<squared> be automagically set to the value of C<number> squared.
1499You can accomplish this by overriding C<store_column>:
1500
1501 sub store_column {
1502 my ( $self, $name, $value ) = @_;
1503 if ($name eq 'number') {
1504 $self->squared($value * $value);
1505 }
1506 $self->next::method($name, $value);
1507 }
1508
1509Note that the hard work is done by the call to C<next::method>, which
324572ca 1510redispatches your call to store_column in the superclass(es).
086b93a2 1511
d2f3e87b 1512=head2 Automatically creating related objects
086b93a2 1513
324572ca 1514You might have a class C<Artist> which has many C<CD>s. Further, if you
086b93a2 1515want to create a C<CD> object every time you insert an C<Artist> object.
ccbebdbc 1516You can accomplish this by overriding C<insert> on your objects:
086b93a2 1517
1518 sub insert {
ccbebdbc 1519 my ( $self, @args ) = @_;
1520 $self->next::method(@args);
086b93a2 1521 $self->cds->new({})->fill_from_artist($self)->insert;
1522 return $self;
1523 }
1524
1525where C<fill_from_artist> is a method you specify in C<CD> which sets
1526values in C<CD> based on the data in the C<Artist> object you pass in.
1527
d2f3e87b 1528=head2 Wrapping/overloading a column accessor
1529
1530B<Problem:>
1531
1532Say you have a table "Camera" and want to associate a description
1533with each camera. For most cameras, you'll be able to generate the description from
1534the other columns. However, in a few special cases you may want to associate a
1535custom description with a camera.
1536
1537B<Solution:>
1538
1539In your database schema, define a description field in the "Camera" table that
1540can contain text and null values.
1541
1542In DBIC, we'll overload the column accessor to provide a sane default if no
1543custom description is defined. The accessor will either return or generate the
1544description, depending on whether the field is null or not.
1545
1546First, in your "Camera" schema class, define the description field as follows:
1547
1548 __PACKAGE__->add_columns(description => { accessor => '_description' });
1549
1550Next, we'll define the accessor-wrapper subroutine:
1551
1552 sub description {
1553 my $self = shift;
1554
1555 # If there is an update to the column, we'll let the original accessor
1556 # deal with it.
1557 return $self->_description(@_) if @_;
1558
1559 # Fetch the column value.
1560 my $description = $self->_description;
1561
1562 # If there's something in the description field, then just return that.
1563 return $description if defined $description && length $descripton;
1564
1565 # Otherwise, generate a description.
1566 return $self->generate_description;
1567 }
1568
1569=head1 DEBUGGING AND PROFILING
1570
1571=head2 DBIx::Class objects with Data::Dumper
1def3451 1572
1573L<Data::Dumper> can be a very useful tool for debugging, but sometimes it can
1574be hard to find the pertinent data in all the data it can generate.
1575Specifically, if one naively tries to use it like so,
1576
1577 use Data::Dumper;
1578
1579 my $cd = $schema->resultset('CD')->find(1);
1580 print Dumper($cd);
1581
1582several pages worth of data from the CD object's schema and result source will
1583be dumped to the screen. Since usually one is only interested in a few column
1584values of the object, this is not very helpful.
1585
1586Luckily, it is possible to modify the data before L<Data::Dumper> outputs
1587it. Simply define a hook that L<Data::Dumper> will call on the object before
1588dumping it. For example,
1589
1590 package My::DB::CD;
1591
1592 sub _dumper_hook {
99fb1058 1593 $_[0] = bless {
1594 %{ $_[0] },
1def3451 1595 result_source => undef,
99fb1058 1596 }, ref($_[0]);
1def3451 1597 }
1598
1599 [...]
1600
1601 use Data::Dumper;
1602
22139027 1603 local $Data::Dumper::Freezer = '_dumper_hook';
1def3451 1604
1605 my $cd = $schema->resultset('CD')->find(1);
1606 print Dumper($cd);
1607 # dumps $cd without its ResultSource
1608
1609If the structure of your schema is such that there is a common base class for
1610all your table classes, simply put a method similar to C<_dumper_hook> in the
1611base class and set C<$Data::Dumper::Freezer> to its name and L<Data::Dumper>
1612will automagically clean up your data before printing it. See
1613L<Data::Dumper/EXAMPLES> for more information.
1614
4c248161 1615=head2 Profiling
1616
85f78622 1617When you enable L<DBIx::Class::Storage>'s debugging it prints the SQL
4c248161 1618executed as well as notifications of query completion and transaction
1619begin/commit. If you'd like to profile the SQL you can subclass the
1620L<DBIx::Class::Storage::Statistics> class and write your own profiling
1621mechanism:
1622
1623 package My::Profiler;
1624 use strict;
1625
1626 use base 'DBIx::Class::Storage::Statistics';
1627
1628 use Time::HiRes qw(time);
1629
1630 my $start;
1631
1632 sub query_start {
1633 my $self = shift();
1634 my $sql = shift();
1635 my $params = @_;
1636
70f39278 1637 $self->print("Executing $sql: ".join(', ', @params)."\n");
4c248161 1638 $start = time();
1639 }
1640
1641 sub query_end {
1642 my $self = shift();
1643 my $sql = shift();
1644 my @params = @_;
1645
70f39278 1646 my $elapsed = sprintf("%0.4f", time() - $start);
1647 $self->print("Execution took $elapsed seconds.\n");
4c248161 1648 $start = undef;
1649 }
1650
1651 1;
1652
1653You can then install that class as the debugging object:
1654
70f39278 1655 __PACKAGE__->storage->debugobj(new My::Profiler());
1656 __PACKAGE__->storage->debug(1);
4c248161 1657
1658A more complicated example might involve storing each execution of SQL in an
1659array:
1660
1661 sub query_end {
1662 my $self = shift();
1663 my $sql = shift();
1664 my @params = @_;
1665
1666 my $elapsed = time() - $start;
1667 push(@{ $calls{$sql} }, {
1668 params => \@params,
1669 elapsed => $elapsed
1670 });
1671 }
1672
1673You could then create average, high and low execution times for an SQL
1674statement and dig down to see if certain parameters cause aberrant behavior.
70f39278 1675You might want to check out L<DBIx::Class::QueryLog> as well.
4c248161 1676
bc96f260 1677=head1 STARTUP SPEED
1678
1679L<DBIx::Class|DBIx::Class> programs can have a significant startup delay
1680as the ORM loads all the relevant classes. This section examines
1681techniques for reducing the startup delay.
1682
1683These tips are are listed in order of decreasing effectiveness - so the
1684first tip, if applicable, should have the greatest effect on your
1685application.
1686
1687=head2 Statically Define Your Schema
1688
1689If you are using
1690L<DBIx::Class::Schema::Loader|DBIx::Class::Schema::Loader> to build the
1691classes dynamically based on the database schema then there will be a
1692significant startup delay.
1693
1694For production use a statically defined schema (which can be generated
1695using L<DBIx::Class::Schema::Loader|DBIx::Class::Schema::Loader> to dump
1696the database schema once - see
1697L<make_schema_at|DBIx::Class::Schema::Loader/make_schema_at> and
1698L<dump_directory|DBIx::Class::Schema::Loader/dump_directory> for more
1699details on creating static schemas from a database).
1700
1701=head2 Move Common Startup into a Base Class
1702
1703Typically L<DBIx::Class> result classes start off with
1704
1705 use base qw/DBIx::Class/;
1706 __PACKAGE__->load_components(qw/InflateColumn::DateTime Core/);
1707
1708If this preamble is moved into a common base class:-
1709
1710 package MyDBICbase;
1711
1712 use base qw/DBIx::Class/;
1713 __PACKAGE__->load_components(qw/InflateColumn::DateTime Core/);
1714 1;
1715
1716and each result class then uses this as a base:-
1717
1718 use base qw/MyDBICbase/;
1719
1720then the load_components is only performed once, which can result in a
1721considerable startup speedup for schemas with many classes.
1722
1723=head2 Explicitly List Schema Result Classes
1724
1725The schema class will normally contain
1726
1727 __PACKAGE__->load_classes();
1728
1729to load the result classes. This will use L<Module::Find|Module::Find>
1730to find and load the appropriate modules. Explicitly defining the
1731classes you wish to load will remove the overhead of
1732L<Module::Find|Module::Find> and the related directory operations:-
1733
1734 __PACKAGE__->load_classes(qw/ CD Artist Track /);
1735
1736If you are instead using the L<load_namespaces|DBIx::Class::Schema/load_namespaces>
1737syntax to load the appropriate classes there is not a direct alternative
1738avoiding L<Module::Find|Module::Find>.
7aaec96c 1739
f4db5947 1740=head1 MEMORY USAGE
1741
1742=head2 Cached statements
1743
1744L<DBIx::Class> normally caches all statements with L<< prepare_cached()|DBI/prepare_cached >>.
1745This is normally a good idea, but if too many statements are cached, the database may use too much
1746memory and may eventually run out and fail entirely. If you suspect this may be the case, you may want
1747to examine DBI's L<< CachedKids|DBI/CachedKidsCachedKids_(hash_ref) >> hash:
1748
1749 # print all currently cached prepared statements
1750 print for keys %{$schema->storage->dbh->{CachedKids}};
1751 # get a count of currently cached prepared statements
1752 my $count = scalar keys %{$schema->storage->dbh->{CachedKids}};
1753
1754If it's appropriate, you can simply clear these statements, automatically deallocating them in the
1755database:
1756
1757 my $kids = $schema->storage->dbh->{CachedKids};
1758 delete @{$kids}{keys %$kids} if scalar keys %$kids > 100;
1759
1760But what you probably want is to expire unused statements and not those that are used frequently.
1761You can accomplish this with L<Tie::Cache> or L<Tie::Cache::LRU>:
1762
1763 use Tie::Cache;
1764 use DB::Main;
1765 my $schema = DB::Main->connect($dbi_dsn, $user, $pass, {
1766 on_connect_do => sub { tie %{shift->_dbh->{CachedKids}}, 'Tie::Cache', 100 },
1767 });
1768
40dbc108 1769=cut