Skip to content

Instantly share code, notes, and snippets.

@mrenvoize

mrenvoize/Controller-Priority.pm

Created January 5, 2018 08:57
Show Gist options
  • Save mrenvoize/debbcfacc5c4e3dc75e813410b3f868b to your computer and use it in GitHub Desktop.
Save mrenvoize/debbcfacc5c4e3dc75e813410b3f868b to your computer and use it in GitHub Desktop.
Download ZIP
Multi-create Fun
Raw
Controller-Priority.pm
my $list_changeResult = $c->db->resultset('ListChange')->create(
{
list_id => $list_id,
request => [{requester_id => $requester_id, assignee_id => $assignee_id, status => 'new'}],
message => {
buffer_id => $list_id,
user_id => $requester_id,
text => "Priority tag '$tag' was removed from the system.",
important => 1
}
}
);
Raw
Result-ListChange.pm
use utf8;
package Rebus::Schema::Result::ListChange;
=head1 NAME
Rebus::Schema::Result::ListChange
=cut
use strict;
use warnings;
use base 'DBIx::Class::Core';
=head1 COMPONENTS LOADED
=over 4
=item * L<Helper::Row::NumifyGet>
=back
=cut
__PACKAGE__->load_components(qw( Helper::Row::NumifyGet ));
=head1 TABLE: C<list_changes>
=cut
__PACKAGE__->table("list_changes");
=head1 ACCESSORS
=head2 id
data_type: 'integer'
is_auto_increment: 1
is_nullable: 0
is_numeric: 1
=head2 list_id
data_type: 'integer'
is_foreign_key: 1
is_nullable: 1
is_numeric: 1
=head2 message_id
data_type: 'integer'
is_foreign_key: 1
is_nullable: 1
is_numeric: 1
=cut
__PACKAGE__->add_columns(
"id", {data_type => "integer", is_auto_increment => 1, is_nullable => 0, is_numeric => 1},
"list_id", {data_type => "integer", is_foreign_key => 1, is_nullable => 0, is_numeric => 1},
"message_id", {data_type => "integer", is_foreign_key => 1, is_nullable => 1, is_numeric => 1},
);
=head1 PRIMARY KEY
=over 4
=item * L </id>
=back
=cut
__PACKAGE__->set_primary_key("id");
=head1 RELATIONS
=head2 request
Type: has_one
Related object: L<Rebus::Schema::Result::Request>
=cut
__PACKAGE__->has_one(
"request",
"Rebus::Schema::Result::Request",
{"foreign.list_change_id" => "self.id"},
{is_foreign_key_constraint => 1, is_deferrable => 1, on_delete => "CASCADE", on_update => "CASCADE"},
);
=head2 list
Type: belongs_to
Related object: L<Rebus::Schema::Result::List>
=cut
__PACKAGE__->belongs_to(
"list", 'Rebus::Schema::Result::List',
{"foreign.id" => "self.list_id"},
{on_delete => "CASCADE", on_update => "CASCADE", "is_foreign_key_constraint" => 1},
);
=head2 buffer
Type: might_have
Related object: L<Rebus::Schema::Result::Buffer>
=cut
__PACKAGE__->might_have(
"buffer",
'Rebus::Schema::Result::Buffer',
{"foreign.list_id" => "self.list_id"},
{join_type => "left", is_foreign_key_constraint => 0, cascade_delete => 0},
);
=head2 message
Type: belongs_to
Related object: L<Rebus::Schema::Result::Buffermessage>
=cut
__PACKAGE__->belongs_to(
"message",
'Rebus::Schema::Result::Buffermessage',
{'foreign.id' => 'self.message_id'},
{'join_type' => 'left', 'on_delete' => 'SET NULL'},
);
1;
Raw
Result-Request.pm
use utf8; [258/9963]
package Rebus::Schema::Result::Request;
=head1 NAME
Rebus::Schema::Result::Request
=cut
use strict;
use warnings;
use base 'DBIx::Class::Core';
=head1 COMPONENTS LOADED
=over 4
=item * L<DBIx::Class::InflateColumn::DateTime>
=item * L<Helper::Row::NumifyGet>
=back
=cut
__PACKAGE__->load_components(qw(InflateColumn::DateTime Helper::Row::NumifyGet));
=head1 TABLE: C<request>
=cut
__PACKAGE__->table("requests");
=head1 ACCESSORS
=head2 id
data_type: 'integer'
is_auto_increment: 1
is_nullable: 0
is_numeric: 1
=head2 requester_id
data_type: 'integer'
is_foreign_key: 1
is_nullable: 0
is_numeric: 1
=head2 assignee_id
data_type: 'integer'
is_foreign_key: 1
is_nullable: 1
is_numeric: 1
=head2 status
data_type: 'text'
is_foreign_key: 1
is_nullable: 0
=head2 updated
data_type: 'timestamp'
datetime_undef_if_invalid: 1
default_value: current_timestamp
is_nullable: 0
retrieve_on_insert: 1
=head2 created
data_type: 'timestamp'
datetime_undef_if_invalid: 1
default_value: current_timestamp
is_nullable: 0
retrieve_on_insert: 1
[179/9963]
=head2 material_change_id
data_type: 'integer'
is_foreign_key: 1
is_nullable: 1
is_numeric: 1
=head2 material_copy_id
data_type: 'integer'
is_foreign_key: 1
is_nullable: 1
is_numeric: 1
=head2 list_change_id
data_type: 'integer'
is_foreign_key: 1
is_nullable: 1
is_numeric: 1
=head2 buffer_submission_id
data_type: 'integer'
is_foreign_key: 1
is_nullable: 1
is_numeric: 1
=cut
__PACKAGE__->add_columns(
"id",
{data_type => "integer", is_auto_increment => 1, is_nullable => 0, is_numeric => 1},
"requester_id",
{data_type => "integer", is_foreign_key => 1, is_nullable => 0, is_numeric => 1},
"assignee_id",
{data_type => "integer", is_foreign_key => 1, is_nullable => 1, is_numeric => 1},
"status",
{data_type => "text", is_nullable => 0,},
"updated",
{
data_type => "timestamp",
datetime_undef_if_invalid => 1,
default_value => \"current_timestamp",
is_nullable => 0,
retrieve_on_insert => 1
},
"created",
{
data_type => "timestamp",
datetime_undef_if_invalid => 1,
default_value => \"current_timestamp",
is_nullable => 0,
retrieve_on_insert => 1
},
'material_change_id',
{data_type => "integer", is_foreign_key => 1, is_nullable => 1, is_numeric => 1, default_value => \"null"},
'material_copy_id',
{data_type => "integer", is_foreign_key => 1, is_nullable => 1, is_numeric => 1, default_value => \"null"},
'list_change_id',
{data_type => "integer", is_foreign_key => 1, is_nullable => 1, is_numeric => 1, default_value => \"null"},
'buffer_submission_id',
{data_type => "integer", is_foreign_key => 1, is_nullable => 1, is_numeric => 1, default_value => \"null"},
);
=head1 PRIMARY KEY
=over 4
=item * L</id>
=back
=cut
__PACKAGE__->set_primary_key("id");
=head1 CONSTRAINTS
=head2 material_change
Type: Unique
=cut
__PACKAGE__->add_unique_constraint(material_change => [qw/material_change_id/]);
=head2 material_copy
Type: Unique
=cut
__PACKAGE__->add_unique_constraint(material_copy => [qw/material_copy_id/]);
=head2 list_change
Type: Unique
=cut
__PACKAGE__->add_unique_constraint(list_change => [qw/list_change_id/]);
=head2 buffer_submission
Type: Unique
=cut
__PACKAGE__->add_unique_constraint(buffer_submission => [qw/buffer_submission_id/]);
=head2 Multiple Table Inheritance - XOR
=over 4
=item * material_change
=item * material_copy
=item * list_change
=item * buffer_submission
=back
=cut
sub sqlt_deploy_hook {
my ($self, $sqlt_table) = @_;
return $sqlt_table->add_constraint(
type => 'CHECK',
name => 'requests_xor',
expression =>
"(material_copy_id IS NOT NULL)::integer + (buffer_submission_id IS NOT NULL)::integer + (list_change_id IS NOT NULL)::integer + (material_change_id IS NOT NULL)::integer = 1"
);
}
=head1 SPECIAL ACCESSORS
=head2 type
Name: type
=cut
sub type {
my $self = shift;
return 'change' if defined($self->material_change_id);
return 'copy' if defined($self->material_copy_id);
return 'buffer_submission' if defined($self->buffer_submission_id);
return 'list_change' if defined($self->list_change_id);
return;
}
=head1 RELATIONS
=head2 assignee
Type: belongs_to
Related object: L<Rebus::Schema::Result::User>
=cut
__PACKAGE__->belongs_to(
"assignee" => "Rebus::Schema::Result::User",
{id => "assignee_id"}, {is_deferrable => 1, on_delete => "RESTRICT", on_update => "RESTRICT", join_type => "left"},
);
=head2 requester
Type: belongs_to
Related object: L<Rebus::Schema::Result::User>
=cut
__PACKAGE__->belongs_to(
"requester" => "Rebus::Schema::Result::User",
{id => "requester_id"}, {is_deferrable => 1, on_delete => "RESTRICT", on_update => "RESTRICT"},
);
=head2 request_actions
Type: has_many
Related object: L<Rebus::Schema::Result::RequestAction>
=cut
__PACKAGE__->has_many(
"request_actions" => "Rebus::Schema::Result::RequestAction",
{"foreign.request_id" => "self.id"}, {cascade_copy => 0, cascade_delete => 1},
);
=head2 material_copy
Type: belongs_to
Related object: L<Rebus::Schema::Result::MaterialCopy>
=cut
__PACKAGE__->belongs_to(
'material_copy',
'Rebus::Schema::Result::MaterialCopy',
{'foreign.id' => 'self.material_copy_id'},
{join_type => 'left', is_deferrable => 1, on_delete => "RESTRICT", on_update => "RESTRICT"},
);
=head2 material_change
Type: belongs_to
Related object: L<Rebus::Schema::Result::MaterialChange>
=cut
__PACKAGE__->belongs_to(
'material_change',
'Rebus::Schema::Result::MaterialChange',
{'foreign.id' => 'self.material_change_id'},
{join_type => 'left', is_deferrable => 1, on_delete => "RESTRICT", on_update => "RESTRICT"},
);
=head2 buffer_submission
Type: belongs_to
Related object: L<Rebus::Schema::Result::BufferSubmission>
=cut
__PACKAGE__->belongs_to(
'buffer_submission',
'Rebus::Schema::Result::BufferSubmission',
{'foreign.id' => 'self.buffer_submission_id'},
{join_type => 'left', is_deferrable => 1, on_delete => "RESTRICT", on_update => "RESTRICT"},
);
=head2 list_change
Type: belongs_to
Related object: L<Rebus::Schema::Result::ListChange>
=cut
__PACKAGE__->belongs_to(
'list_change',
'Rebus::Schema::Result::ListChange',
{'foreign.id' => 'self.list_change_id'},
{join_type => 'left', is_deferrable => 1, on_delete => "RESTRICT", on_update => "RESTRICT"},
);
1;
@cxw42
Copy link

cxw42 commented Dec 16, 2019 •
edited
Loading

@mrenvoize I am getting the same error ("requires a hashref as argument") --- were you able to figure it out? Thanks!

Edit I posted too soon :) . request is a has_one relationship, so the arrayref should not be used.

In my case, I had a singular relationship as well (belongs_to), so it's a hashref, not an arrayref. Per this, it's only an arrayref for has_many relationships.

For any future readers, my example was:

In the Result class:

__PACKAGE__->belongs_to(
    'admin_role',
    'Foo::Schema::Result::Role',
    { 'foreign.id' => 'self.admin_role_id' },
);

When creating:

$rs->create({
    name => 'Foo',
    admin_role => { role_name => 'Foo role' },
});

The key for the related-row creation was admin_role (the relationship/accessor name), NOT admin_role_id (the actual foreign-key name).

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment