Changeset 21765 for lang/perl/App-Hachero

Timestamp:

10/21/08 11:09:09 (5 years ago)

Author:

lopnor

Message:

lang/perl/App-Hachero: support count_up mode in Output::DBIC

Location:

lang/perl/App-Hachero/trunk

Files:

• lib/App/Hachero/Plugin/Output/DBIC.pm (modified) (3 diffs)
• t/plugin/output/02_dbic_countup.t (added)

lang/perl/App-Hachero/trunk/lib/App/Hachero/Plugin/Output/DBIC.pm

@@ -8 +8 @@
     my $schema = App::Hachero::Plugin::Output::DBIC::Schema
         ->connect(@{$self->config->{config}->{connect_info}});
+    my $update_mode = $self->config->{config}->{update_mode};
     unless ($schema) {
         $context->log(error => "connection error");
@@ -23 +24 @@
             for my $data ($result->values) {
                 eval {
-                    $rs->update_or_create($data->hashref)
+                    my $hashref = $data->hashref;
+                    if ( $update_mode eq 'count_up' ) {
+                        my $count = delete $hashref->{count};
+                        my $rec = $rs->find_or_create($hashref);
+                        $rec->update({count => ($rec->count || 0) + $count});
+                    } else {
+                        $rs->update_or_create($hashref)
+                    }
                 };
                 if ($@) {
@@ -56 +64 @@
     - module: Output::DBIC
       config:
+        update_mode: [count_up|overwrite]
         connect_info:
             - dbi:mysql:dbhost=db.local;dbname=logdb
             - your_name
             - your_password
+        
 
 =head1 DESCRIPTION