Added startup checks to warn loudly if we appear to be running on RedHat systems...
[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
d2f3e87b 71=head2 Arbitrary SQL through a custom ResultSource
321d9634 72
73Sometimes you have to run arbitrary SQL because your query is too complex
74(e.g. it contains Unions, Sub-Selects, Stored Procedures, etc.) or has to
75be optimized for your database in a special way, but you still want to
76get the results as a L<DBIx::Class::ResultSet>.
77The recommended way to accomplish this is by defining a separate ResultSource
78for your query. You can then inject complete SQL statements using a scalar
79reference (this is a feature of L<SQL::Abstract>).
80
81Say you want to run a complex custom query on your user data, here's what
82you have to add to your User class:
83
84 package My::Schema::User;
85
86 use base qw/DBIx::Class/;
87
88 # ->load_components, ->table, ->add_columns, etc.
89
90 # Make a new ResultSource based on the User class
91 my $source = __PACKAGE__->result_source_instance();
92 my $new_source = $source->new( $source );
93 $new_source->source_name( 'UserFriendsComplex' );
94
95 # Hand in your query as a scalar reference
96 # It will be added as a sub-select after FROM,
97 # so pay attention to the surrounding brackets!
98 $new_source->name( \<<SQL );
99 ( SELECT u.* FROM user u
100 INNER JOIN user_friends f ON u.id = f.user_id
101 WHERE f.friend_user_id = ?
102 UNION
103 SELECT u.* FROM user u
104 INNER JOIN user_friends f ON u.id = f.friend_user_id
105 WHERE f.user_id = ? )
106 SQL
107
108 # Finally, register your new ResultSource with your Schema
109 My::Schema->register_source( 'UserFriendsComplex' => $new_source );
110
111Next, you can execute your complex query using bind parameters like this:
112
113 my $friends = [ $schema->resultset( 'UserFriendsComplex' )->search( {},
114 {
115 bind => [ 12345, 12345 ]
116 }
117 ) ];
118
119... and you'll get back a perfect L<DBIx::Class::ResultSet>.
120
d2f3e87b 121=head2 Using specific columns
faf62551 122
324572ca 123When you only want specific columns from a table, you can use
124C<columns> to specify which ones you need. This is useful to avoid
125loading columns with large amounts of data that you aren't about to
126use anyway:
faf62551 127
bade79c4 128 my $rs = $schema->resultset('Artist')->search(
5e8b1b2a 129 undef,
bade79c4 130 {
5e8b1b2a 131 columns => [qw/ name /]
bade79c4 132 }
133 );
faf62551 134
bade79c4 135 # Equivalent SQL:
136 # SELECT artist.name FROM artist
faf62551 137
324572ca 138This is a shortcut for C<select> and C<as>, see below. C<columns>
139cannot be used together with C<select> and C<as>.
140
d2f3e87b 141=head2 Using database functions or stored procedures
faf62551 142
bade79c4 143The combination of C<select> and C<as> can be used to return the result of a
144database function or stored procedure as a column value. You use C<select> to
145specify the source for your column value (e.g. a column name, function, or
146stored procedure name). You then use C<as> to set the column name you will use
147to access the returned value:
faf62551 148
bade79c4 149 my $rs = $schema->resultset('Artist')->search(
324572ca 150 {},
bade79c4 151 {
152 select => [ 'name', { LENGTH => 'name' } ],
153 as => [qw/ name name_length /],
154 }
155 );
faf62551 156
bade79c4 157 # Equivalent SQL:
98b65433 158 # SELECT name name, LENGTH( name )
bade79c4 159 # FROM artist
faf62551 160
d676881f 161Note that the C< as > attribute has absolutely nothing to with the sql
162syntax C< SELECT foo AS bar > (see the documentation in
163L<DBIx::Class::ResultSet/ATTRIBUTES>). If your alias exists as a
164column in your base class (i.e. it was added with C<add_columns>), you
165just access it as normal. Our C<Artist> class has a C<name> column, so
166we just use the C<name> accessor:
faf62551 167
bade79c4 168 my $artist = $rs->first();
169 my $name = $artist->name();
faf62551 170
171If on the other hand the alias does not correspond to an existing column, you
324572ca 172have to fetch the value using the C<get_column> accessor:
faf62551 173
bade79c4 174 my $name_length = $artist->get_column('name_length');
faf62551 175
bade79c4 176If you don't like using C<get_column>, you can always create an accessor for
faf62551 177any of your aliases using either of these:
178
bade79c4 179 # Define accessor manually:
180 sub name_length { shift->get_column('name_length'); }
faf62551 181
bade79c4 182 # Or use DBIx::Class::AccessorGroup:
183 __PACKAGE__->mk_group_accessors('column' => 'name_length');
faf62551 184
d2f3e87b 185=head2 SELECT DISTINCT with multiple columns
faf62551 186
bade79c4 187 my $rs = $schema->resultset('Foo')->search(
324572ca 188 {},
bade79c4 189 {
190 select => [
191 { distinct => [ $source->columns ] }
192 ],
d676881f 193 as => [ $source->columns ] # remember 'as' is not the same as SQL AS :-)
bade79c4 194 }
195 );
faf62551 196
286f32b3 197 my $count = $rs->next->get_column('count');
198
d2f3e87b 199=head2 SELECT COUNT(DISTINCT colname)
6607ee1b 200
bade79c4 201 my $rs = $schema->resultset('Foo')->search(
324572ca 202 {},
bade79c4 203 {
204 select => [
205 { count => { distinct => 'colname' } }
206 ],
207 as => [ 'count' ]
208 }
209 );
6607ee1b 210
d2f3e87b 211=head2 Grouping results
bade79c4 212
213L<DBIx::Class> supports C<GROUP BY> as follows:
214
215 my $rs = $schema->resultset('Artist')->search(
324572ca 216 {},
bade79c4 217 {
218 join => [qw/ cds /],
219 select => [ 'name', { count => 'cds.cdid' } ],
220 as => [qw/ name cd_count /],
221 group_by => [qw/ name /]
222 }
223 );
6607ee1b 224
bade79c4 225 # Equivalent SQL:
226 # SELECT name, COUNT( cds.cdid ) FROM artist me
227 # LEFT JOIN cd cds ON ( cds.artist = me.artistid )
228 # GROUP BY name
6607ee1b 229
d676881f 230Please see L<DBIx::Class::ResultSet/ATTRIBUTES> documentation if you
231are in any way unsure about the use of the attributes above (C< join
232>, C< select >, C< as > and C< group_by >).
233
d2f3e87b 234=head2 Predefined searches
74dc2edc 235
324572ca 236You can write your own L<DBIx::Class::ResultSet> class by inheriting from it
74dc2edc 237and define often used searches as methods:
238
239 package My::DBIC::ResultSet::CD;
240 use strict;
241 use warnings;
242 use base 'DBIx::Class::ResultSet';
243
244 sub search_cds_ordered {
245 my ($self) = @_;
246
247 return $self->search(
248 {},
249 { order_by => 'name DESC' },
250 );
251 }
252
253 1;
254
255To use your resultset, first tell DBIx::Class to create an instance of it
256for you, in your My::DBIC::Schema::CD class:
257
258 __PACKAGE__->resultset_class('My::DBIC::ResultSet::CD');
259
260Then call your new method in your code:
261
262 my $ordered_cds = $schema->resultset('CD')->search_cds_ordered();
263
d2f3e87b 264=head2 Using SQL functions on the left hand side of a comparison
1c133e22 265
266Using SQL functions on the left hand side of a comparison is generally
267not a good idea since it requires a scan of the entire table. However,
268it can be accomplished with C<DBIx::Class> when necessary.
269
270If you do not have quoting on, simply include the function in your search
271specification as you would any column:
272
273 $rs->search({ 'YEAR(date_of_birth)' => 1979 });
274
275With quoting on, or for a more portable solution, use the C<where>
276attribute:
277
278 $rs->search({}, { where => \'YEAR(date_of_birth) = 1979' });
279
280=begin hidden
281
282(When the bind args ordering bug is fixed, this technique will be better
283and can replace the one above.)
284
285With quoting on, or for a more portable solution, use the C<where> and
286C<bind> attributes:
287
288 $rs->search({}, {
289 where => \'YEAR(date_of_birth) = ?',
290 bind => [ 1979 ]
291 });
292
293=end hidden
294
d2f3e87b 295=head1 JOINS AND PREFETCHING
296
87980de7 297=head2 Using joins and prefetch
298
bade79c4 299You can use the C<join> attribute to allow searching on, or sorting your
300results by, one or more columns in a related table. To return all CDs matching
301a particular artist name:
ea6309e2 302
bade79c4 303 my $rs = $schema->resultset('CD')->search(
304 {
305 'artist.name' => 'Bob Marley'
306 },
307 {
308 join => [qw/artist/], # join the artist table
309 }
310 );
311
312 # Equivalent SQL:
313 # SELECT cd.* FROM cd
314 # JOIN artist ON cd.artist = artist.id
315 # WHERE artist.name = 'Bob Marley'
316
317If required, you can now sort on any column in the related tables by including
318it in your C<order_by> attribute:
319
320 my $rs = $schema->resultset('CD')->search(
321 {
322 'artist.name' => 'Bob Marley'
323 },
324 {
325 join => [qw/ artist /],
326 order_by => [qw/ artist.name /]
327 }
2f81ed0f 328 );
ea6309e2 329
bade79c4 330 # Equivalent SQL:
331 # SELECT cd.* FROM cd
332 # JOIN artist ON cd.artist = artist.id
333 # WHERE artist.name = 'Bob Marley'
334 # ORDER BY artist.name
ea6309e2 335
bade79c4 336Note that the C<join> attribute should only be used when you need to search or
337sort using columns in a related table. Joining related tables when you only
338need columns from the main table will make performance worse!
ea6309e2 339
bade79c4 340Now let's say you want to display a list of CDs, each with the name of the
341artist. The following will work fine:
ea6309e2 342
bade79c4 343 while (my $cd = $rs->next) {
344 print "CD: " . $cd->title . ", Artist: " . $cd->artist->name;
345 }
ea6309e2 346
bade79c4 347There is a problem however. We have searched both the C<cd> and C<artist> tables
348in our main query, but we have only returned data from the C<cd> table. To get
349the artist name for any of the CD objects returned, L<DBIx::Class> will go back
350to the database:
ea6309e2 351
bade79c4 352 SELECT artist.* FROM artist WHERE artist.id = ?
ea6309e2 353
354A statement like the one above will run for each and every CD returned by our
355main query. Five CDs, five extra queries. A hundred CDs, one hundred extra
356queries!
357
bade79c4 358Thankfully, L<DBIx::Class> has a C<prefetch> attribute to solve this problem.
897342e4 359This allows you to fetch results from related tables in advance:
ea6309e2 360
bade79c4 361 my $rs = $schema->resultset('CD')->search(
362 {
363 'artist.name' => 'Bob Marley'
364 },
365 {
366 join => [qw/ artist /],
367 order_by => [qw/ artist.name /],
368 prefetch => [qw/ artist /] # return artist data too!
369 }
370 );
ea6309e2 371
bade79c4 372 # Equivalent SQL (note SELECT from both "cd" and "artist"):
373 # SELECT cd.*, artist.* FROM cd
374 # JOIN artist ON cd.artist = artist.id
375 # WHERE artist.name = 'Bob Marley'
376 # ORDER BY artist.name
ea6309e2 377
378The code to print the CD list remains the same:
379
bade79c4 380 while (my $cd = $rs->next) {
381 print "CD: " . $cd->title . ", Artist: " . $cd->artist->name;
382 }
ea6309e2 383
bade79c4 384L<DBIx::Class> has now prefetched all matching data from the C<artist> table,
ea6309e2 385so no additional SQL statements are executed. You now have a much more
386efficient query.
387
77d6b403 388Note that as of L<DBIx::Class> 0.05999_01, C<prefetch> I<can> be used with
389C<has_many> relationships.
ea6309e2 390
bade79c4 391Also note that C<prefetch> should only be used when you know you will
ea6309e2 392definitely use data from a related table. Pre-fetching related tables when you
393only need columns from the main table will make performance worse!
394
d2f3e87b 395=head2 Multi-step joins
ea6309e2 396
397Sometimes you want to join more than one relationship deep. In this example,
bade79c4 398we want to find all C<Artist> objects who have C<CD>s whose C<LinerNotes>
399contain a specific string:
400
401 # Relationships defined elsewhere:
402 # Artist->has_many('cds' => 'CD', 'artist');
403 # CD->has_one('liner_notes' => 'LinerNotes', 'cd');
404
405 my $rs = $schema->resultset('Artist')->search(
406 {
407 'liner_notes.notes' => { 'like', '%some text%' },
408 },
409 {
410 join => {
411 'cds' => 'liner_notes'
412 }
413 }
414 );
ea6309e2 415
bade79c4 416 # Equivalent SQL:
417 # SELECT artist.* FROM artist
418 # JOIN ( cd ON artist.id = cd.artist )
419 # JOIN ( liner_notes ON cd.id = liner_notes.cd )
420 # WHERE liner_notes.notes LIKE '%some text%'
ea6309e2 421
422Joins can be nested to an arbitrary level. So if we decide later that we
423want to reduce the number of Artists returned based on who wrote the liner
424notes:
425
bade79c4 426 # Relationship defined elsewhere:
427 # LinerNotes->belongs_to('author' => 'Person');
428
429 my $rs = $schema->resultset('Artist')->search(
430 {
431 'liner_notes.notes' => { 'like', '%some text%' },
432 'author.name' => 'A. Writer'
433 },
434 {
435 join => {
436 'cds' => {
437 'liner_notes' => 'author'
ea6309e2 438 }
bade79c4 439 }
440 }
441 );
ea6309e2 442
bade79c4 443 # Equivalent SQL:
444 # SELECT artist.* FROM artist
445 # JOIN ( cd ON artist.id = cd.artist )
446 # JOIN ( liner_notes ON cd.id = liner_notes.cd )
447 # JOIN ( author ON author.id = liner_notes.author )
448 # WHERE liner_notes.notes LIKE '%some text%'
449 # AND author.name = 'A. Writer'
87980de7 450
897342e4 451=head2 Multi-step prefetch
452
453From 0.04999_05 onwards, C<prefetch> can be nested more than one relationship
454deep using the same syntax as a multi-step join:
455
456 my $rs = $schema->resultset('Tag')->search(
ac2803ef 457 {},
897342e4 458 {
459 prefetch => {
460 cd => 'artist'
461 }
462 }
463 );
464
465 # Equivalent SQL:
466 # SELECT tag.*, cd.*, artist.* FROM tag
467 # JOIN cd ON tag.cd = cd.cdid
468 # JOIN artist ON cd.artist = artist.artistid
469
470Now accessing our C<cd> and C<artist> relationships does not need additional
471SQL statements:
472
473 my $tag = $rs->first;
474 print $tag->cd->artist->name;
475
d2f3e87b 476=head1 ROW-LEVEL OPERATIONS
477
478=head2 Retrieving a row object's Schema
479
480It is possible to get a Schema object from a row object like so:
481
482 my $schema = $cd->result_source->schema;
483 # use the schema as normal:
484 my $artist_rs = $schema->resultset('Artist');
485
486This can be useful when you don't want to pass around a Schema object to every
487method.
488
489=head2 Getting the value of the primary key for the last database insert
490
491AKA getting last_insert_id
492
493If you are using PK::Auto (which is a core component as of 0.07), this is
494straightforward:
495
496 my $foo = $rs->create(\%blah);
497 # do more stuff
498 my $id = $foo->id; # foo->my_primary_key_field will also work.
499
500If you are not using autoincrementing primary keys, this will probably
501not work, but then you already know the value of the last primary key anyway.
502
503=head2 Stringification
504
505Employ the standard stringification technique by using the C<overload>
506module.
507
508To make an object stringify itself as a single column, use something
509like this (replace C<foo> with the column/method of your choice):
510
511 use overload '""' => sub { shift->name}, fallback => 1;
512
513For more complex stringification, you can use an anonymous subroutine:
514
515 use overload '""' => sub { $_[0]->name . ", " .
516 $_[0]->address }, fallback => 1;
517
518=head3 Stringification Example
519
520Suppose we have two tables: C<Product> and C<Category>. The table
521specifications are:
522
523 Product(id, Description, category)
524 Category(id, Description)
525
526C<category> is a foreign key into the Category table.
527
528If you have a Product object C<$obj> and write something like
529
530 print $obj->category
531
532things will not work as expected.
533
534To obtain, for example, the category description, you should add this
535method to the class defining the Category table:
536
537 use overload "" => sub {
538 my $self = shift;
539
540 return $self->Description;
541 }, fallback => 1;
542
543=head2 Want to know if find_or_create found or created a row?
544
545Just use C<find_or_new> instead, then check C<in_storage>:
546
547 my $obj = $rs->find_or_new({ blah => 'blarg' });
548 unless ($obj->in_storage) {
549 $obj->insert;
550 # do whatever else you wanted if it was a new row
551 }
552
553=head2 Dynamic Sub-classing DBIx::Class proxy classes
554
555AKA multi-class object inflation from one table
556
557L<DBIx::Class> classes are proxy classes, therefore some different
558techniques need to be employed for more than basic subclassing. In
559this example we have a single user table that carries a boolean bit
560for admin. We would like like to give the admin users
561objects(L<DBIx::Class::Row>) the same methods as a regular user but
562also special admin only methods. It doesn't make sense to create two
563seperate proxy-class files for this. We would be copying all the user
564methods into the Admin class. There is a cleaner way to accomplish
565this.
566
567Overriding the C<inflate_result> method within the User proxy-class
568gives us the effect we want. This method is called by
569L<DBIx::Class::ResultSet> when inflating a result from storage. So we
570grab the object being returned, inspect the values we are looking for,
571bless it if it's an admin object, and then return it. See the example
572below:
573
574B<Schema Definition>
575
576 package DB::Schema;
577
578 use base qw/DBIx::Class::Schema/;
579
580 __PACKAGE__->load_classes(qw/User/);
581
582
583B<Proxy-Class definitions>
584
585 package DB::Schema::User;
586
587 use strict;
588 use warnings;
589 use base qw/DBIx::Class/;
590
591 ### Defined what our admin class is for ensure_class_loaded
592 my $admin_class = __PACKAGE__ . '::Admin';
593
594 __PACKAGE__->load_components(qw/Core/);
595
596 __PACKAGE__->table('users');
597
598 __PACKAGE__->add_columns(qw/user_id email password
599 firstname lastname active
600 admin/);
601
602 __PACKAGE__->set_primary_key('user_id');
603
604 sub inflate_result {
605 my $self = shift;
606 my $ret = $self->next::method(@_);
607 if( $ret->admin ) {### If this is an admin rebless for extra functions
608 $self->ensure_class_loaded( $admin_class );
609 bless $ret, $admin_class;
610 }
611 return $ret;
612 }
613
614 sub hello {
615 print "I am a regular user.\n";
616 return ;
617 }
618
619
620 package DB::Schema::User::Admin;
621
622 use strict;
623 use warnings;
624 use base qw/DB::Schema::User/;
625
626 sub hello
627 {
628 print "I am an admin.\n";
629 return;
630 }
631
632 sub do_admin_stuff
633 {
634 print "I am doing admin stuff\n";
635 return ;
636 }
637
638B<Test File> test.pl
639
640 use warnings;
641 use strict;
642 use DB::Schema;
643
644 my $user_data = { email => 'someguy@place.com',
645 password => 'pass1',
646 admin => 0 };
647
648 my $admin_data = { email => 'someadmin@adminplace.com',
649 password => 'pass2',
650 admin => 1 };
651
652 my $schema = DB::Schema->connection('dbi:Pg:dbname=test');
653
654 $schema->resultset('User')->create( $user_data );
655 $schema->resultset('User')->create( $admin_data );
656
657 ### Now we search for them
658 my $user = $schema->resultset('User')->single( $user_data );
659 my $admin = $schema->resultset('User')->single( $admin_data );
660
661 print ref $user, "\n";
662 print ref $admin, "\n";
663
664 print $user->password , "\n"; # pass1
665 print $admin->password , "\n";# pass2; inherited from User
666 print $user->hello , "\n";# I am a regular user.
667 print $admin->hello, "\n";# I am an admin.
668
669 ### The statement below will NOT print
670 print "I can do admin stuff\n" if $user->can('do_admin_stuff');
671 ### The statement below will print
672 print "I can do admin stuff\n" if $admin->can('do_admin_stuff');
673
674=head2 Skip object creation for faster results
675
676DBIx::Class is not built for speed, it's built for convenience and
677ease of use, but sometimes you just need to get the data, and skip the
678fancy objects.
679
680To do this simply use L<DBIx::Class::ResultClass::HashRefInflator>.
681
682 my $rs = $schema->resultset('CD');
683
684 $rs->result_class('DBIx::Class::ResultClass::HashRefInflator');
685
686 my $hash_ref = $rs->find(1);
687
688Wasn't that easy?
689
690=head2 Get raw data for blindingly fast results
691
692If the L<HashRefInflator|DBIx::Class::ResultClass::HashRefInflator> solution
693above is not fast enough for you, you can use a DBIx::Class to return values
694exactly as they come out of the data base with none of the convenience methods
695wrapped round them.
696
697This is used like so:-
698
699 my $cursor = $rs->cursor
700 while (my @vals = $cursor->next) {
701 # use $val[0..n] here
702 }
703
704You will need to map the array offsets to particular columns (you can
705use the I<select> attribute of C<search()> to force ordering).
706
707=head1 RESULTSET OPERATIONS
708
709=head2 Getting Schema from a ResultSet
710
711To get the schema object from a result set, do the following:
712
713 $rs->result_source->schema
714
715=head2 Getting Columns Of Data
716
717AKA Aggregating Data
ac2803ef 718
719If you want to find the sum of a particular column there are several
720ways, the obvious one is to use search:
721
722 my $rs = $schema->resultset('Items')->search(
723 {},
724 {
725 select => [ { sum => 'Cost' } ],
d676881f 726 as => [ 'total_cost' ], # remember this 'as' is for DBIx::Class::ResultSet not SQL
ac2803ef 727 }
728 );
729 my $tc = $rs->first->get_column('total_cost');
730
731Or, you can use the L<DBIx::Class::ResultSetColumn>, which gets
732returned when you ask the C<ResultSet> for a column using
733C<get_column>:
734
735 my $cost = $schema->resultset('Items')->get_column('Cost');
736 my $tc = $cost->sum;
737
738With this you can also do:
739
740 my $minvalue = $cost->min;
741 my $maxvalue = $cost->max;
742
743Or just iterate through the values of this column only:
744
745 while ( my $c = $cost->next ) {
746 print $c;
747 }
748
749 foreach my $c ($cost->all) {
750 print $c;
751 }
752
709353af 753C<ResultSetColumn> only has a limited number of built-in functions, if
754you need one that it doesn't have, then you can use the C<func> method
755instead:
756
757 my $avg = $cost->func('AVERAGE');
758
759This will cause the following SQL statement to be run:
760
761 SELECT AVERAGE(Cost) FROM Items me
762
763Which will of course only work if your database supports this function.
ac2803ef 764See L<DBIx::Class::ResultSetColumn> for more documentation.
765
d2f3e87b 766=head1 USING RELATIONSHIPS
acee4e4d 767
d2f3e87b 768=head2 Create a new row in a related table
acee4e4d 769
770 my $book->create_related('author', { name => 'Fred'});
771
d2f3e87b 772=head2 Search in a related table
acee4e4d 773
774Only searches for books named 'Titanic' by the author in $author.
775
776 my $author->search_related('books', { name => 'Titanic' });
777
d2f3e87b 778=head2 Delete data in a related table
acee4e4d 779
780Deletes only the book named Titanic by the author in $author.
781
782 my $author->delete_related('books', { name => 'Titanic' });
783
d2f3e87b 784=head2 Ordering a relationship result set
f8bad769 785
786If you always want a relation to be ordered, you can specify this when you
787create the relationship.
788
789To order C<< $book->pages >> by descending page_number.
790
791 Book->has_many('pages' => 'Page', 'book', { order_by => \'page_number DESC'} );
792
d2f3e87b 793=head2 Many-to-many relationships
f8bad769 794
d2f3e87b 795This is straightforward using L<ManyToMany|DBIx::Class::Relationship/many_to_many>:
f8bad769 796
d2f3e87b 797 package My::DB;
798 # ... set up connection ...
87980de7 799
d2f3e87b 800 package My::User;
801 use base 'My::DB';
802 __PACKAGE__->table('user');
803 __PACKAGE__->add_columns(qw/id name/);
804 __PACKAGE__->set_primary_key('id');
805 __PACKAGE__->has_many('user_address' => 'My::UserAddress', 'user');
806 __PACKAGE__->many_to_many('addresses' => 'user_address', 'address');
87980de7 807
d2f3e87b 808 package My::UserAddress;
809 use base 'My::DB';
810 __PACKAGE__->table('user_address');
811 __PACKAGE__->add_columns(qw/user address/);
812 __PACKAGE__->set_primary_key(qw/user address/);
813 __PACKAGE__->belongs_to('user' => 'My::User');
814 __PACKAGE__->belongs_to('address' => 'My::Address');
181a28f4 815
d2f3e87b 816 package My::Address;
817 use base 'My::DB';
818 __PACKAGE__->table('address');
819 __PACKAGE__->add_columns(qw/id street town area_code country/);
820 __PACKAGE__->set_primary_key('id');
821 __PACKAGE__->has_many('user_address' => 'My::UserAddress', 'address');
822 __PACKAGE__->many_to_many('users' => 'user_address', 'user');
823
824 $rs = $user->addresses(); # get all addresses for a user
825 $rs = $address->users(); # get all users for an address
826
827=head1 TRANSACTIONS
828
829As of version 0.04001, there is improved transaction support in
830L<DBIx::Class::Storage> and L<DBIx::Class::Schema>. Here is an
831example of the recommended way to use it:
832
833 my $genus = $schema->resultset('Genus')->find(12);
834
835 my $coderef2 = sub {
836 $genus->extinct(1);
837 $genus->update;
838 };
70634260 839
181a28f4 840 my $coderef1 = sub {
35d4fe78 841 $genus->add_to_species({ name => 'troglodyte' });
842 $genus->wings(2);
843 $genus->update;
70634260 844 $schema->txn_do($coderef2); # Can have a nested transaction
181a28f4 845 return $genus->species;
846 };
847
181a28f4 848 my $rs;
849 eval {
70634260 850 $rs = $schema->txn_do($coderef1);
181a28f4 851 };
852
853 if ($@) { # Transaction failed
854 die "the sky is falling!" #
855 if ($@ =~ /Rollback failed/); # Rollback failed
856
857 deal_with_failed_transaction();
35d4fe78 858 }
87980de7 859
181a28f4 860Nested transactions will work as expected. That is, only the outermost
861transaction will actually issue a commit to the $dbh, and a rollback
862at any level of any transaction will cause the entire nested
863transaction to fail. Support for savepoints and for true nested
40dbc108 864transactions (for databases that support them) will hopefully be added
865in the future.
ee38fa40 866
d2f3e87b 867=head1 SQL
ee38fa40 868
d2f3e87b 869=head2 Creating Schemas From An Existing Database
ea6309e2 870
d2f3e87b 871L<DBIx::Class::Schema::Loader> will connect to a database and create a
872L<DBIx::Class::Schema> and associated sources by examining the database.
bade79c4 873
d2f3e87b 874The recommend way of achieving this is to use the
875L<make_schema_at|DBIx::Class::Schema::Loader/make_schema_at> method:
bade79c4 876
d2f3e87b 877 perl -MDBIx::Class::Schema::Loader=make_schema_at,dump_to_dir:./lib -e 'make_schema_at("My::Schema", { debug => 1 }, [ "dbi:Pg:dbname=foo","postgres" ])'
362500af 878
d2f3e87b 879This will create a tree of files rooted at C<./lib/My/Schema/> containing
880source definitions for all the tables found in the C<foo> database.
362500af 881
d2f3e87b 882=head2 Creating DDL SQL
362500af 883
264f1571 884The following functionality requires you to have L<SQL::Translator>
885(also known as "SQL Fairy") installed.
362500af 886
264f1571 887To create a set of database-specific .sql files for the above schema:
362500af 888
264f1571 889 my $schema = My::Schema->connect($dsn);
890 $schema->create_ddl_dir(['MySQL', 'SQLite', 'PostgreSQL'],
891 '0.1',
d2f3e87b 892 './dbscriptdir/'
264f1571 893 );
894
895By default this will create schema files in the current directory, for
896MySQL, SQLite and PostgreSQL, using the $VERSION from your Schema.pm.
897
898To create a new database using the schema:
899
900 my $schema = My::Schema->connect($dsn);
901 $schema->deploy({ add_drop_tables => 1});
902
903To import created .sql files using the mysql client:
904
905 mysql -h "host" -D "database" -u "user" -p < My_Schema_1.0_MySQL.sql
906
907To create C<ALTER TABLE> conversion scripts to update a database to a
908newer version of your schema at a later point, first set a new
d2f3e87b 909C<$VERSION> in your Schema file, then:
264f1571 910
911 my $schema = My::Schema->connect($dsn);
912 $schema->create_ddl_dir(['MySQL', 'SQLite', 'PostgreSQL'],
913 '0.2',
914 '/dbscriptdir/',
915 '0.1'
916 );
917
918This will produce new database-specific .sql files for the new version
919of the schema, plus scripts to convert from version 0.1 to 0.2. This
920requires that the files for 0.1 as created above are available in the
921given directory to diff against.
362500af 922
d2f3e87b 923=head2 Adding Indexes And Functions To Your SQL
362500af 924
d2f3e87b 925Often you will want indexes on columns on your table to speed up searching. To
926do this, create a method called C<sqlt_deploy_hook> in the relevant source
927class:
b0a20454 928
d2f3e87b 929 package My::Schema::Artist;
b0a20454 930
d2f3e87b 931 __PACKAGE__->table('artist');
932 __PACKAGE__->add_columns(id => { ... }, name => { ... })
b0a20454 933
d2f3e87b 934 sub sqlt_deploy_hook {
935 my ($self, $sqlt_table) = @_;
936
937 $sqlt_table->add_index(name => 'idx_name', fields => ['name']);
938 }
939
940 1;
941
942Sometimes you might want to change the index depending on the type of the
943database for which SQL is being generated:
944
945 my ($db_type = $sqlt_table->schema->translator->producer_type)
946 =~ s/^SQL::Translator::Producer:://;
947
948You can also add hooks to the schema level to stop certain tables being
949created:
950
951 package My::Schema;
952
953 ...
954
955 sub sqlt_deploy_hook {
956 my ($self, $sqlt_schema) = @_;
957
958 $sqlt_schema->drop_table('table_name');
959 }
960
961You could also add views or procedures to the output using
962L<SQL::Translator::Schema/add_view> or
963L<SQL::Translator::Schema/add_procedure>.
b0a20454 964
362500af 965=head2 Schema versioning
966
967The following example shows simplistically how you might use DBIx::Class to
968deploy versioned schemas to your customers. The basic process is as follows:
969
da4779ad 970=over 4
971
972=item 1.
973
974Create a DBIx::Class schema
975
976=item 2.
977
978Save the schema
979
980=item 3.
981
982Deploy to customers
983
984=item 4.
985
986Modify schema to change functionality
987
988=item 5.
989
990Deploy update to customers
991
992=back
362500af 993
d2f3e87b 994B<Create a DBIx::Class schema>
362500af 995
996This can either be done manually, or generated from an existing database as
d2f3e87b 997described under L</Creating Schemas From An Existing Database>
362500af 998
d2f3e87b 999B<Save the schema>
362500af 1000
d2f3e87b 1001Call L<DBIx::Class::Schema/create_ddl_dir> as above under L</Creating DDL SQL>.
362500af 1002
d2f3e87b 1003B<Deploy to customers>
362500af 1004
1005There are several ways you could deploy your schema. These are probably
1006beyond the scope of this recipe, but might include:
1007
da4779ad 1008=over 4
1009
1010=item 1.
1011
1012Require customer to apply manually using their RDBMS.
1013
1014=item 2.
1015
1016Package along with your app, making database dump/schema update/tests
362500af 1017all part of your install.
1018
da4779ad 1019=back
1020
d2f3e87b 1021B<Modify the schema to change functionality>
362500af 1022
264f1571 1023As your application evolves, it may be necessary to modify your schema
1024to change functionality. Once the changes are made to your schema in
1025DBIx::Class, export the modified schema and the conversion scripts as
d2f3e87b 1026in L</Creating DDL SQL>.
362500af 1027
d2f3e87b 1028B<Deploy update to customers>
362500af 1029
264f1571 1030Add the L<DBIx::Class::Schema::Versioned> schema component to your
1031Schema class. This will add a new table to your database called
1032C<SchemaVersions> which will keep track of which version is installed
1033and warn if the user trys to run a newer schema version than the
1034database thinks it has.
1035
1036Alternatively, you can send the conversion sql scripts to your
1037customers as above.
362500af 1038
d2f3e87b 1039=head2 Setting quoting for the generated SQL.
1040
1041If the database contains column names with spaces and/or reserved words, they
1042need to be quoted in the SQL queries. This is done using:
1043
1044 __PACKAGE__->storage->sql_maker->quote_char([ qw/[ ]/] );
1045 __PACKAGE__->storage->sql_maker->name_sep('.');
1046
1047The first sets the quote characters. Either a pair of matching
1048brackets, or a C<"> or C<'>:
1049
1050 __PACKAGE__->storage->sql_maker->quote_char('"');
1051
1052Check the documentation of your database for the correct quote
1053characters to use. C<name_sep> needs to be set to allow the SQL
1054generator to put the quotes the correct place.
1055
1056In most cases you should set these as part of the arguments passed to
1057L<DBIx::Class::Schema/conect>:
1058
1059 my $schema = My::Schema->connect(
1060 'dbi:mysql:my_db',
1061 'db_user',
1062 'db_password',
1063 {
1064 quote_char => '"',
1065 name_sep => '.'
1066 }
1067 )
1068
7be93b07 1069=head2 Setting limit dialect for SQL::Abstract::Limit
1070
324572ca 1071In some cases, SQL::Abstract::Limit cannot determine the dialect of
1072the remote SQL server by looking at the database handle. This is a
1073common problem when using the DBD::JDBC, since the DBD-driver only
1074know that in has a Java-driver available, not which JDBC driver the
1075Java component has loaded. This specifically sets the limit_dialect
1076to Microsoft SQL-server (See more names in SQL::Abstract::Limit
1077-documentation.
7be93b07 1078
1079 __PACKAGE__->storage->sql_maker->limit_dialect('mssql');
1080
324572ca 1081The JDBC bridge is one way of getting access to a MSSQL server from a platform
7be93b07 1082that Microsoft doesn't deliver native client libraries for. (e.g. Linux)
1083
d2f3e87b 1084The limit dialect can also be set at connect time by specifying a
1085C<limit_dialect> key in the final hash as shown above.
2437a1e3 1086
d2f3e87b 1087=head1 BOOTSTRAPPING/MIGRATING
2437a1e3 1088
d2f3e87b 1089=head2 Easy migration from class-based to schema-based setup
2437a1e3 1090
d2f3e87b 1091You want to start using the schema-based approach to L<DBIx::Class>
1092(see L<SchemaIntro.pod>), but have an established class-based setup with lots
1093of existing classes that you don't want to move by hand. Try this nifty script
1094instead:
1095
1096 use MyDB;
1097 use SQL::Translator;
1098
1099 my $schema = MyDB->schema_instance;
2437a1e3 1100
d2f3e87b 1101 my $translator = SQL::Translator->new(
1102 debug => $debug || 0,
1103 trace => $trace || 0,
1104 no_comments => $no_comments || 0,
1105 show_warnings => $show_warnings || 0,
1106 add_drop_table => $add_drop_table || 0,
1107 validate => $validate || 0,
1108 parser_args => {
1109 'DBIx::Schema' => $schema,
1110 },
1111 producer_args => {
1112 'prefix' => 'My::Schema',
1113 },
1114 );
1115
1116 $translator->parser('SQL::Translator::Parser::DBIx::Class');
1117 $translator->producer('SQL::Translator::Producer::DBIx::Class::File');
1118
1119 my $output = $translator->translate(@args) or die
1120 "Error: " . $translator->error;
1121
1122 print $output;
2437a1e3 1123
d2f3e87b 1124You could use L<Module::Find> to search for all subclasses in the MyDB::*
1125namespace, which is currently left as an exercise for the reader.
2437a1e3 1126
d2f3e87b 1127=head1 OVERLOADING METHODS
086b93a2 1128
ab872312 1129L<DBIx::Class> uses the L<Class::C3> package, which provides for redispatch of
1130method calls, useful for things like default values and triggers. You have to
1131use calls to C<next::method> to overload methods. More information on using
1132L<Class::C3> with L<DBIx::Class> can be found in
086b93a2 1133L<DBIx::Class::Manual::Component>.
1134
d2f3e87b 1135=head2 Setting default values for a row
1136
1137It's as simple as overriding the C<new> method. Note the use of
1138C<next::method>.
1139
1140 sub new {
1141 my ( $class, $attrs ) = @_;
1142
1143 $attrs->{foo} = 'bar' unless defined $attrs->{foo};
1144
1145 my $new = $class->next::method($attrs);
1146
1147 return $new;
1148 }
1149
1150For more information about C<next::method>, look in the L<Class::C3>
1151documentation. See also L<DBIx::Class::Manual::Component> for more
1152ways to write your own base classes to do this.
1153
1154People looking for ways to do "triggers" with DBIx::Class are probably
1155just looking for this.
1156
1157=head2 Changing one field whenever another changes
086b93a2 1158
1159For example, say that you have three columns, C<id>, C<number>, and
1160C<squared>. You would like to make changes to C<number> and have
1161C<squared> be automagically set to the value of C<number> squared.
1162You can accomplish this by overriding C<store_column>:
1163
1164 sub store_column {
1165 my ( $self, $name, $value ) = @_;
1166 if ($name eq 'number') {
1167 $self->squared($value * $value);
1168 }
1169 $self->next::method($name, $value);
1170 }
1171
1172Note that the hard work is done by the call to C<next::method>, which
324572ca 1173redispatches your call to store_column in the superclass(es).
086b93a2 1174
d2f3e87b 1175=head2 Automatically creating related objects
086b93a2 1176
324572ca 1177You might have a class C<Artist> which has many C<CD>s. Further, if you
086b93a2 1178want to create a C<CD> object every time you insert an C<Artist> object.
ccbebdbc 1179You can accomplish this by overriding C<insert> on your objects:
086b93a2 1180
1181 sub insert {
ccbebdbc 1182 my ( $self, @args ) = @_;
1183 $self->next::method(@args);
086b93a2 1184 $self->cds->new({})->fill_from_artist($self)->insert;
1185 return $self;
1186 }
1187
1188where C<fill_from_artist> is a method you specify in C<CD> which sets
1189values in C<CD> based on the data in the C<Artist> object you pass in.
1190
d2f3e87b 1191=head2 Wrapping/overloading a column accessor
1192
1193B<Problem:>
1194
1195Say you have a table "Camera" and want to associate a description
1196with each camera. For most cameras, you'll be able to generate the description from
1197the other columns. However, in a few special cases you may want to associate a
1198custom description with a camera.
1199
1200B<Solution:>
1201
1202In your database schema, define a description field in the "Camera" table that
1203can contain text and null values.
1204
1205In DBIC, we'll overload the column accessor to provide a sane default if no
1206custom description is defined. The accessor will either return or generate the
1207description, depending on whether the field is null or not.
1208
1209First, in your "Camera" schema class, define the description field as follows:
1210
1211 __PACKAGE__->add_columns(description => { accessor => '_description' });
1212
1213Next, we'll define the accessor-wrapper subroutine:
1214
1215 sub description {
1216 my $self = shift;
1217
1218 # If there is an update to the column, we'll let the original accessor
1219 # deal with it.
1220 return $self->_description(@_) if @_;
1221
1222 # Fetch the column value.
1223 my $description = $self->_description;
1224
1225 # If there's something in the description field, then just return that.
1226 return $description if defined $description && length $descripton;
1227
1228 # Otherwise, generate a description.
1229 return $self->generate_description;
1230 }
1231
1232=head1 DEBUGGING AND PROFILING
1233
1234=head2 DBIx::Class objects with Data::Dumper
1def3451 1235
1236L<Data::Dumper> can be a very useful tool for debugging, but sometimes it can
1237be hard to find the pertinent data in all the data it can generate.
1238Specifically, if one naively tries to use it like so,
1239
1240 use Data::Dumper;
1241
1242 my $cd = $schema->resultset('CD')->find(1);
1243 print Dumper($cd);
1244
1245several pages worth of data from the CD object's schema and result source will
1246be dumped to the screen. Since usually one is only interested in a few column
1247values of the object, this is not very helpful.
1248
1249Luckily, it is possible to modify the data before L<Data::Dumper> outputs
1250it. Simply define a hook that L<Data::Dumper> will call on the object before
1251dumping it. For example,
1252
1253 package My::DB::CD;
1254
1255 sub _dumper_hook {
99fb1058 1256 $_[0] = bless {
1257 %{ $_[0] },
1def3451 1258 result_source => undef,
99fb1058 1259 }, ref($_[0]);
1def3451 1260 }
1261
1262 [...]
1263
1264 use Data::Dumper;
1265
22139027 1266 local $Data::Dumper::Freezer = '_dumper_hook';
1def3451 1267
1268 my $cd = $schema->resultset('CD')->find(1);
1269 print Dumper($cd);
1270 # dumps $cd without its ResultSource
1271
1272If the structure of your schema is such that there is a common base class for
1273all your table classes, simply put a method similar to C<_dumper_hook> in the
1274base class and set C<$Data::Dumper::Freezer> to its name and L<Data::Dumper>
1275will automagically clean up your data before printing it. See
1276L<Data::Dumper/EXAMPLES> for more information.
1277
4c248161 1278=head2 Profiling
1279
85f78622 1280When you enable L<DBIx::Class::Storage>'s debugging it prints the SQL
4c248161 1281executed as well as notifications of query completion and transaction
1282begin/commit. If you'd like to profile the SQL you can subclass the
1283L<DBIx::Class::Storage::Statistics> class and write your own profiling
1284mechanism:
1285
1286 package My::Profiler;
1287 use strict;
1288
1289 use base 'DBIx::Class::Storage::Statistics';
1290
1291 use Time::HiRes qw(time);
1292
1293 my $start;
1294
1295 sub query_start {
1296 my $self = shift();
1297 my $sql = shift();
1298 my $params = @_;
1299
70f39278 1300 $self->print("Executing $sql: ".join(', ', @params)."\n");
4c248161 1301 $start = time();
1302 }
1303
1304 sub query_end {
1305 my $self = shift();
1306 my $sql = shift();
1307 my @params = @_;
1308
70f39278 1309 my $elapsed = sprintf("%0.4f", time() - $start);
1310 $self->print("Execution took $elapsed seconds.\n");
4c248161 1311 $start = undef;
1312 }
1313
1314 1;
1315
1316You can then install that class as the debugging object:
1317
70f39278 1318 __PACKAGE__->storage->debugobj(new My::Profiler());
1319 __PACKAGE__->storage->debug(1);
4c248161 1320
1321A more complicated example might involve storing each execution of SQL in an
1322array:
1323
1324 sub query_end {
1325 my $self = shift();
1326 my $sql = shift();
1327 my @params = @_;
1328
1329 my $elapsed = time() - $start;
1330 push(@{ $calls{$sql} }, {
1331 params => \@params,
1332 elapsed => $elapsed
1333 });
1334 }
1335
1336You could then create average, high and low execution times for an SQL
1337statement and dig down to see if certain parameters cause aberrant behavior.
70f39278 1338You might want to check out L<DBIx::Class::QueryLog> as well.
4c248161 1339
7aaec96c 1340
40dbc108 1341=cut