[Bast-commits] r7057 - in
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib:
DBIx/Class DBIx/Class/CDBICompat DBIx/Class/InflateColumn
DBIx/Class/Relationship DBIx/Class/ResultSourceProxy
DBIx/Class/Schema DBIx/Class/Storage/DBI
DBIx/Class/Storage/DBI/ODBC DBIx/Class/Storage/DBI/Oracle
DBIx/Class/Storage/DBI/Replicated
DBIx/Class/Storage/DBI/Replicated/Balancer
SQL/Translator/Parser/DBIx SQL/Translator/Producer/DBIx/Class
ribasushi at dev.catalyst.perl.org
ribasushi at dev.catalyst.perl.org
Thu Jul 16 04:28:52 GMT 2009
Author: ribasushi
Date: 2009-07-16 04:28:44 +0000 (Thu, 16 Jul 2009)
New Revision: 7057
Modified:
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/ColumnCase.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/ColumnGroups.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/ColumnsAsHash.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/Copy.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/ImaDBI.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/Iterator.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/LazyLoading.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/LiveObjectIndex.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/Relationship.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/Relationships.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/Retrieve.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/TempColumns.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/DB.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Exception.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/InflateColumn/DateTime.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/InflateColumn/File.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Ordered.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/PK.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Relationship.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Relationship/Base.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Relationship/HasMany.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/ResultSetColumn.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/ResultSourceHandle.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/ResultSourceProxy/Table.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Schema.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Schema/Versioned.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/StartupCheck.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/DB2.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/ODBC/ACCESS.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/ODBC/DB2_400_SQL.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Oracle/Generic.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Pg.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Balancer.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Balancer/First.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Balancer/Random.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Introduction.pod
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Pool.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Replicant.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/WithDSN.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/UTF8Columns.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/SQL/Translator/Parser/DBIx/Class.pm
DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/SQL/Translator/Producer/DBIx/Class/File.pm
Log:
A couple of typos, and general whitespace cleanup (ick)
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/ColumnCase.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/ColumnCase.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/ColumnCase.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -16,10 +16,10 @@
sub has_a {
my($self, $col, @rest) = @_;
-
+
$self->_declare_has_a(lc $col, @rest);
$self->_mk_inflated_column_accessor($col);
-
+
return 1;
}
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/ColumnGroups.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/ColumnGroups.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/ColumnGroups.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -73,7 +73,7 @@
sub _has_custom_accessor {
my($class, $name) = @_;
-
+
no strict 'refs';
my $existing_accessor = *{$class .'::'. $name}{CODE};
return $existing_accessor && !$our_accessors{$existing_accessor};
@@ -90,7 +90,7 @@
my $fullname = join '::', $class, $name;
*$fullname = Sub::Name::subname $fullname, $accessor;
}
-
+
$our_accessors{$accessor}++;
return 1;
@@ -120,7 +120,7 @@
# warn " $field $alias\n";
{
no strict 'refs';
-
+
$class->_deploy_accessor($name, $accessor);
$class->_deploy_accessor($alias, $accessor);
}
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/ColumnsAsHash.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/ColumnsAsHash.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/ColumnsAsHash.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -39,16 +39,16 @@
my $class = shift;
my $new = $class->next::method(@_);
-
+
$new->_make_columns_as_hash;
-
+
return $new;
}
sub _make_columns_as_hash {
my $self = shift;
-
+
for my $col ($self->columns) {
if( exists $self->{$col} ) {
warn "Skipping mapping $col to a hash key because it exists";
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/Copy.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/Copy.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/Copy.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -25,7 +25,7 @@
sub copy {
my($self, $arg) = @_;
return $self->next::method($arg) if ref $arg;
-
+
my @primary_columns = $self->primary_columns;
croak("Need hash-ref to edit copied column values")
if @primary_columns > 1;
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/ImaDBI.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/ImaDBI.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/ImaDBI.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -59,7 +59,7 @@
$rel_obj->{cond}, $to, $from) );
return $join;
}
-
+
} );
sub db_Main {
@@ -115,7 +115,7 @@
sub transform_sql {
my ($class, $sql, @args) = @_;
-
+
my $tclass = $class->sql_transformer_class;
$class->ensure_class_loaded($tclass);
my $t = $tclass->new($class, $sql, @args);
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/Iterator.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/Iterator.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/Iterator.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -25,7 +25,7 @@
sub _init_result_source_instance {
my $class = shift;
-
+
my $table = $class->next::method(@_);
$table->resultset_class("DBIx::Class::CDBICompat::Iterator::ResultSet");
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/LazyLoading.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/LazyLoading.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/LazyLoading.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -16,12 +16,12 @@
# request in case the database modifies the new value (say, via a trigger)
sub update {
my $self = shift;
-
+
my @dirty_columns = keys %{$self->{_dirty_columns}};
-
+
my $ret = $self->next::method(@_);
$self->_clear_column_data(@dirty_columns);
-
+
return $ret;
}
@@ -30,12 +30,12 @@
sub create {
my $class = shift;
my($data) = @_;
-
+
my @columns = keys %$data;
-
+
my $obj = $class->next::method(@_);
return $obj unless defined $obj;
-
+
my %primary_cols = map { $_ => 1 } $class->primary_columns;
my @data_cols = grep !$primary_cols{$_}, @columns;
$obj->_clear_column_data(@data_cols);
@@ -46,7 +46,7 @@
sub _clear_column_data {
my $self = shift;
-
+
delete $self->{_column_data}{$_} for @_;
delete $self->{_inflated_column}{$_} for @_;
}
@@ -71,7 +71,7 @@
for my $col ($self->primary_columns) {
$changes->{$col} = undef unless exists $changes->{$col};
}
-
+
return $self->next::method($changes);
}
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/LiveObjectIndex.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/LiveObjectIndex.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/LiveObjectIndex.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -20,9 +20,9 @@
sub nocache {
my $class = shift;
-
+
return $class->__nocache(@_) if @_;
-
+
return 1 if $Class::DBI::Weaken_Is_Available == 0;
return $class->__nocache;
}
@@ -74,9 +74,9 @@
sub inflate_result {
my ($class, @rest) = @_;
my $new = $class->next::method(@rest);
-
+
return $new if $new->nocache;
-
+
if (my $key = $new->ID) {
#warn "Key $key";
my $live = $class->live_object_index;
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/Relationship.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/Relationship.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/Relationship.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -25,7 +25,7 @@
sub new {
my($class, $args) = @_;
-
+
return bless $args, $class;
}
@@ -34,7 +34,7 @@
my $code = sub {
$_[0]->{$key};
};
-
+
no strict 'refs';
*{$method} = Sub::Name::subname $method, $code;
}
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/Relationships.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/Relationships.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/Relationships.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -24,10 +24,10 @@
sub has_a {
my($self, $col, @rest) = @_;
-
+
$self->_declare_has_a($col, @rest);
$self->_mk_inflated_column_accessor($col);
-
+
return 1;
}
@@ -37,7 +37,7 @@
$self->throw_exception( "No such column ${col}" )
unless $self->has_column($col);
$self->ensure_class_loaded($f_class);
-
+
my $rel_info;
if ($args{'inflate'} || $args{'deflate'}) { # Non-database has_a
@@ -50,7 +50,7 @@
$args{'deflate'} = sub { shift->$meth; };
}
$self->inflate_column($col, \%args);
-
+
$rel_info = {
class => $f_class
};
@@ -59,9 +59,9 @@
$self->belongs_to($col, $f_class);
$rel_info = $self->result_source_instance->relationship_info($col);
}
-
+
$rel_info->{args} = \%args;
-
+
$self->_extend_meta(
has_a => $col,
$rel_info
@@ -72,7 +72,7 @@
sub _mk_inflated_column_accessor {
my($class, $col) = @_;
-
+
return $class->mk_group_accessors('inflated_column' => $col);
}
@@ -137,7 +137,7 @@
sub might_have {
my ($class, $rel, $f_class, @columns) = @_;
-
+
my $ret;
if (ref $columns[0] || !defined $columns[0]) {
$ret = $class->next::method($rel, $f_class, @columns);
@@ -153,7 +153,7 @@
might_have => $rel,
$rel_info
);
-
+
return $ret;
}
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/Retrieve.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/Retrieve.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/Retrieve.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -74,7 +74,7 @@
my $class = shift;
my $obj = $class->resultset_instance->new_result(@_);
$obj->in_storage(1);
-
+
return $obj;
}
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/TempColumns.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/TempColumns.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat/TempColumns.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -11,7 +11,7 @@
sub _add_column_group {
my ($class, $group, @cols) = @_;
-
+
return $class->next::method($group, @cols) unless $group eq 'TEMP';
my %new_cols = map { $_ => 1 } @cols;
@@ -61,11 +61,11 @@
sub set {
my($self, %data) = @_;
-
+
my $temp_data = $self->_extract_temp_data(\%data);
-
+
$self->set_temp($_, $temp_data->{$_}) for keys %$temp_data;
-
+
return $self->next::method(%data);
}
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/CDBICompat.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -11,7 +11,7 @@
DBIx::ContextualFetch
Clone
);
-
+
my @didnt_load;
for my $module (@Extra_Modules) {
push @didnt_load, $module unless eval qq{require $module};
@@ -149,13 +149,13 @@
package Foo;
use base qw(Class::DBI);
-
+
Foo->table("foo");
Foo->columns( All => qw(this that bar) );
package Bar;
use base qw(Class::DBI);
-
+
Bar->table("bar");
Bar->columns( All => qw(up down) );
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/DB.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/DB.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/DB.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -174,7 +174,7 @@
sub result_source_instance {
my $class = shift;
$class = ref $class || $class;
-
+
if (@_) {
my $source = $_[0];
$class->_result_source_instance([$source, $class]);
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Exception.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Exception.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Exception.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -61,7 +61,7 @@
else {
$msg = Carp::longmess($msg);
}
-
+
my $self = { msg => $msg };
bless $self => $class;
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/InflateColumn/DateTime.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/InflateColumn/DateTime.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/InflateColumn/DateTime.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -40,13 +40,13 @@
__PACKAGE__->add_columns(
starts_when => { data_type => 'varchar', inflate_datetime => 1 }
);
-
+
__PACKAGE__->add_columns(
starts_when => { data_type => 'varchar', inflate_date => 1 }
);
It's also possible to explicitly skip inflation:
-
+
__PACKAGE__->add_columns(
starts_when => { data_type => 'datetime', inflate_datetime => 0 }
);
@@ -86,7 +86,7 @@
In the case of an invalid date, L<DateTime> will throw an exception. To
bypass these exceptions and just have the inflation return undef, use
the C<datetime_undef_if_invalid> option in the column info:
-
+
"broken_date",
{
data_type => "datetime",
@@ -135,7 +135,7 @@
"please put it directly into the '$column' column definition.";
$locale = $info->{extra}{locale};
}
-
+
$locale = $info->{locale} if defined $info->{locale};
$timezone = $info->{timezone} if defined $info->{timezone};
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/InflateColumn/File.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/InflateColumn/File.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/InflateColumn/File.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -58,7 +58,7 @@
sub insert {
my $self = shift;
-
+
# cache our file columns so we can write them to the fs
# -after- we have a PK
my %file_column;
@@ -114,7 +114,7 @@
In your L<DBIx::Class> table class:
__PACKAGE__->load_components( "PK::Auto", "InflateColumn::File", "Core" );
-
+
# define your columns
__PACKAGE__->add_columns(
"id",
@@ -136,8 +136,8 @@
size => 255,
},
);
-
+
In your L<Catalyst::Controller> class:
FileColumn requires a hash that contains L<IO::File> as handle and the file's
@@ -152,15 +152,15 @@
body => '....'
});
$c->stash->{entry}=$entry;
-
+
And Place the following in your TT template
-
+
Article Subject: [% entry.subject %]
Uploaded File:
<a href="/static/files/[% entry.id %]/[% entry.filename.filename %]">File</a>
Body: [% entry.body %]
-
+
The file will be stored on the filesystem for later retrieval. Calling delete
on your resultset will delete the file from the filesystem. Retrevial of the
record automatically inflates the column back to the set hash with the
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Ordered.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Ordered.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Ordered.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -60,20 +60,20 @@
#!/use/bin/perl
use My::Item;
-
+
my $item = My::Item->create({ name=>'Matt S. Trout' });
# If using grouping_column:
my $item = My::Item->create({ name=>'Matt S. Trout', group_id=>1 });
-
+
my $rs = $item->siblings();
my @siblings = $item->siblings();
-
+
my $sibling;
$sibling = $item->first_sibling();
$sibling = $item->last_sibling();
$sibling = $item->previous_sibling();
$sibling = $item->next_sibling();
-
+
$item->move_previous();
$item->move_next();
$item->move_first();
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/PK.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/PK.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/PK.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -42,16 +42,16 @@
my ($self, $attrs) = @_;
delete $self->{_dirty_columns};
return unless $self->in_storage; # Don't reload if we aren't real!
-
+
if( my $current_storage = $self->get_from_storage($attrs)) {
-
+
# Set $self to the current.
%$self = %$current_storage;
-
+
# Avoid a possible infinite loop with
# sub DESTROY { $_[0]->discard_changes }
bless $current_storage, 'Do::Not::Exist';
-
+
return $self;
} else {
$self->in_storage(0);
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Relationship/Base.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Relationship/Base.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Relationship/Base.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -83,18 +83,18 @@
An arrayref containing a list of accessors in the foreign class to create in
the main class. If, for example, you do the following:
-
+
MyDB::Schema::CD->might_have(liner_notes => 'MyDB::Schema::LinerNotes',
undef, {
proxy => [ qw/notes/ ],
});
-
+
Then, assuming MyDB::Schema::LinerNotes has an accessor named notes, you can do:
my $cd = MyDB::Schema::CD->find(1);
$cd->notes('Notes go here'); # set notes -- LinerNotes object is
# created if it doesn't exist
-
+
=item accessor
Specifies the type of accessor that should be created for the relationship.
@@ -179,7 +179,7 @@
my $rel_info = $self->relationship_info($rel);
$self->throw_exception( "No such relationship ${rel}" )
unless $rel_info;
-
+
return $self->{related_resultsets}{$rel} ||= do {
my $attrs = (@_ > 1 && ref $_[$#_] eq 'HASH' ? pop(@_) : {});
$attrs = { %{$rel_info->{attrs} || {}}, %$attrs };
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Relationship/HasMany.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Relationship/HasMany.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Relationship/HasMany.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -40,7 +40,7 @@
$class->throw_exception(
"No such column ${f_key} on foreign class ${f_class} ($guess)"
) if $f_class_loaded && !$f_class->has_column($f_key);
-
+
$cond = { "foreign.${f_key}" => "self.${pri}" };
}
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Relationship.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Relationship.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Relationship.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -106,7 +106,7 @@
All helper methods are called similar to the following template:
__PACKAGE__->$method_name('relname', 'Foreign::Class', \%cond | \@cond, \%attrs);
-
+
Both C<$cond> and C<$attrs> are optional. Pass C<undef> for C<$cond> if
you want to use the default value for it, but still want to set C<\%attrs>.
@@ -297,7 +297,7 @@
'My::DBIC::Schema::Book',
{ 'foreign.author_id' => 'self.id' },
);
-
+
# OR (similar result, assuming related_class is storing our PK, in "author")
# (the "author" is guessed at from "Author" in the class namespace)
My::DBIC::Schema::Author->has_many(
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/ResultSetColumn.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/ResultSetColumn.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/ResultSetColumn.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -338,7 +338,7 @@
sub func {
my ($self,$function) = @_;
my $cursor = $self->func_rs($function)->cursor;
-
+
if( wantarray ) {
return map { $_->[ 0 ] } $cursor->all;
}
@@ -373,9 +373,9 @@
=head2 throw_exception
See L<DBIx::Class::Schema/throw_exception> for details.
-
+
=cut
-
+
sub throw_exception {
my $self=shift;
if (ref $self && $self->{_parent_resultset}) {
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/ResultSourceHandle.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/ResultSourceHandle.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/ResultSourceHandle.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -77,7 +77,7 @@
my ($self, $cloning) = @_;
my $to_serialize = { %$self };
-
+
my $class = $self->schema->class($self->source_moniker);
$to_serialize->{schema} = $class;
return (Storable::freeze($to_serialize));
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/ResultSourceProxy/Table.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/ResultSourceProxy/Table.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/ResultSourceProxy/Table.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -67,7 +67,7 @@
=head2 table
__PACKAGE__->table('tbl_name');
-
+
Gets or sets the table name.
=cut
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Schema/Versioned.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Schema/Versioned.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Schema/Versioned.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -308,7 +308,7 @@
# here to be sure.
# XXX - just fix it
$self->storage->sqlt_type;
-
+
my $upgrade_file = $self->ddl_filename(
$self->storage->sqlt_type,
$self->schema_version,
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Schema.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Schema.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Schema.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -755,7 +755,7 @@
[ 2, 'Indie Band' ],
...
]);
-
+
Since wantarray context is basically the same as looping over $rs->create(...)
you won't see any performance benefits and in this case the method is more for
convenience. Void context sends the column information directly to storage
@@ -806,10 +806,10 @@
sub connection {
my ($self, @info) = @_;
return $self if !@info && $self->storage;
-
+
my ($storage_class, $args) = ref $self->storage_type ?
($self->_normalize_storage_type($self->storage_type),{}) : ($self->storage_type, {});
-
+
$storage_class = 'DBIx::Class::Storage'.$storage_class
if $storage_class =~ m/^::/;
eval "require ${storage_class};";
@@ -1146,7 +1146,7 @@
$filename =~ s/::/-/g;
$filename = File::Spec->catfile($dir, "$filename-$version-$type.sql");
$filename =~ s/$version/$preversion-$version/ if($preversion);
-
+
return $filename;
}
@@ -1372,7 +1372,7 @@
$self->throw_exception
("No arguments to load_classes and couldn't load ${base} ($@)")
if $@;
-
+
if ($self eq $target) {
# Pathological case, largely caused by the docs on early C::M::DBIC::Plain
foreach my $moniker ($self->sources) {
@@ -1385,14 +1385,14 @@
$self->connection(@info);
return $self;
}
-
+
my $schema = $self->compose_namespace($target, $base);
{
no strict 'refs';
my $name = join '::', $target, 'schema';
*$name = Sub::Name::subname $name, sub { $schema };
}
-
+
$schema->connection(@info);
foreach my $moniker ($schema->sources) {
my $source = $schema->source($moniker);
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/StartupCheck.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/StartupCheck.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/StartupCheck.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -7,7 +7,7 @@
=head1 SYNOPSIS
use DBIx::Class::StartupCheck;
-
+
=head1 DESCRIPTION
This module used to check for, and if necessary issue a warning for, a
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/DB2.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/DB2.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/DB2.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -21,11 +21,11 @@
sub _sql_maker_opts {
my ( $self, $opts ) = @_;
-
+
if ( $opts ) {
$self->{_sql_maker_opts} = { %$opts };
}
-
+
return { limit_dialect => 'RowNumberOver', %{$self->{_sql_maker_opts}||{}} };
}
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/ODBC/ACCESS.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/ODBC/ACCESS.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/ODBC/ACCESS.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -40,11 +40,11 @@
sub bind_attribute_by_data_type {
my $self = shift;
-
+
my ( $data_type ) = @_;
-
+
return { TYPE => $data_type } if $data_type == DBI::SQL_LONGVARCHAR;
-
+
return;
}
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/ODBC/DB2_400_SQL.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/ODBC/DB2_400_SQL.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/ODBC/DB2_400_SQL.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -23,7 +23,7 @@
sub _sql_maker_opts {
my ($self) = @_;
-
+
$self->dbh_do(sub {
my ($self, $dbh) = @_;
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Oracle/Generic.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Oracle/Generic.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Oracle/Generic.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -139,7 +139,7 @@
sub get_autoinc_seq {
my ($self, $source, $col) = @_;
-
+
$self->dbh_do('_dbh_get_autoinc_seq', $source, $col);
}
@@ -210,7 +210,7 @@
sub _svp_begin {
my ($self, $name) = @_;
-
+
$self->dbh->do("SAVEPOINT $name");
}
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Pg.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Pg.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Pg.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -50,7 +50,7 @@
sub get_autoinc_seq {
my ($self,$source,$col) = @_;
-
+
my @pri = $source->primary_columns;
my ($schema,$table) = $source->name =~ /^(.+)\.(.+)$/ ? ($1,$2)
: (undef,$source->name);
@@ -71,7 +71,7 @@
bytea => { pg_type => DBD::Pg::PG_BYTEA },
blob => { pg_type => DBD::Pg::PG_BYTEA },
};
-
+
if( defined $bind_attributes->{$data_type} ) {
return $bind_attributes->{$data_type};
}
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Balancer/First.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Balancer/First.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Balancer/First.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -12,7 +12,7 @@
This class is used internally by L<DBIx::Class::Storage::DBI::Replicated>. You
shouldn't need to create instances of this class.
-
+
=head1 DESCRIPTION
Given a pool (L<DBIx::Class::Storage::DBI::Replicated::Pool>) of replicated
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Balancer/Random.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Balancer/Random.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Balancer/Random.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -13,7 +13,7 @@
This class is used internally by L<DBIx::Class::Storage::DBI::Replicated>. You
shouldn't need to create instances of this class.
-
+
=head1 DESCRIPTION
Given a pool (L<DBIx::Class::Storage::DBI::Replicated::Pool>) of replicated
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Balancer.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Balancer.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Balancer.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -14,7 +14,7 @@
=head1 SYNOPSIS
This role is used internally by L<DBIx::Class::Storage::DBI::Replicated>.
-
+
=head1 DESCRIPTION
Given a pool (L<DBIx::Class::Storage::DBI::Replicated::Pool>) of replicated
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Introduction.pod
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Introduction.pod 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Introduction.pod 2009-07-16 04:28:44 UTC (rev 7057)
@@ -69,7 +69,7 @@
=head1 PARTS OF REPLICATED STORAGE
A replicated storage contains several parts. First, there is the replicated
-storage itself (L<DBIx::Class::Storage::DBI::Replicated). A replicated storage
+storage itself (L<DBIx::Class::Storage::DBI::Replicated>). A replicated storage
takes a pool of replicants (L<DBIx::Class::Storage::DBI::Replicated::Pool>)
and a software balancer (L<DBIx::Class::Storage::DBI::Replicated::Pool>). The
balancer does the job of splitting up all the read traffic amongst each
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Pool.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Pool.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Pool.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -18,7 +18,7 @@
This class is used internally by L<DBIx::Class::Storage::DBI::Replicated>. You
shouldn't need to create instances of this class.
-
+
=head1 DESCRIPTION
In a replicated storage type, there is at least one replicant to handle the
@@ -89,11 +89,11 @@
actual replicant storage. For example if the $dsn element is something like:
"dbi:SQLite:dbname=dbfile"
-
+
You could access the specific replicant via:
$schema->storage->replicants->{'dbname=dbfile'}
-
+
This attributes also supports the following helper methods:
=over 4
@@ -129,11 +129,11 @@
default=>sub {{}},
provides => {
'set' => 'set_replicant',
- 'get' => 'get_replicant',
+ 'get' => 'get_replicant',
'empty' => 'has_replicants',
'count' => 'num_replicants',
'delete' => 'delete_replicant',
- 'values' => 'all_replicant_storages',
+ 'values' => 'all_replicant_storages',
},
);
@@ -152,7 +152,7 @@
sub connect_replicants {
my $self = shift @_;
my $schema = shift @_;
-
+
my @newly_created = ();
foreach my $connect_info (@_) {
$connect_info = [ $connect_info ]
@@ -170,7 +170,7 @@
$self->set_replicant( $key => $replicant);
push @newly_created, $replicant;
}
-
+
return @newly_created;
}
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Replicant.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Replicant.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/Replicant.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -14,7 +14,7 @@
=head1 SYNOPSIS
This class is used internally by L<DBIx::Class::Storage::DBI::Replicated>.
-
+
=head1 DESCRIPTION
Replicants are DBI Storages that follow a master DBI Storage. Typically this
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/WithDSN.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/WithDSN.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated/WithDSN.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -13,7 +13,7 @@
=head1 SYNOPSIS
This class is used internally by L<DBIx::Class::Storage::DBI::Replicated>.
-
+
=head1 DESCRIPTION
This role adds C<DSN: > info to storage debugging output.
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/Storage/DBI/Replicated.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -2,10 +2,10 @@
BEGIN {
use Carp::Clan qw/^DBIx::Class/;
-
+
## Modules required for Replication support not required for general DBIC
## use, so we explicitly test for these.
-
+
my %replication_required = (
'Moose' => '0.77',
'MooseX::AttributeHelpers' => '0.12',
@@ -13,17 +13,17 @@
'namespace::clean' => '0.11',
'Hash::Merge' => '0.11'
);
-
+
my @didnt_load;
-
+
for my $module (keys %replication_required) {
eval "use $module $replication_required{$module}";
push @didnt_load, "$module $replication_required{$module}"
if $@;
}
-
+
croak("@{[ join ', ', @didnt_load ]} are missing and are required for Replication")
- if @didnt_load;
+ if @didnt_load;
}
use Moose;
@@ -49,29 +49,29 @@
tasks.
You should set the 'storage_type attribute to a replicated type. You should
-also defined you arguments, such as which balancer you want and any arguments
+also define your arguments, such as which balancer you want and any arguments
that the Pool object should get.
$schema->storage_type( ['::DBI::Replicated', {balancer=>'::Random'}] );
-
+
Next, you need to add in the Replicants. Basically this is an array of
arrayrefs, where each arrayref is database connect information. Think of these
arguments as what you'd pass to the 'normal' $schema->connect method.
-
+
$schema->storage->connect_replicants(
[$dsn1, $user, $pass, \%opts],
[$dsn2, $user, $pass, \%opts],
[$dsn3, $user, $pass, \%opts],
);
-
+
Now, just use the $schema as you normally would. Automatically all reads will
be delegated to the replicants, while writes to the master.
$schema->resultset('Source')->search({name=>'etc'});
-
+
You can force a given query to use a particular storage using the search
attribute 'force_pool'. For example:
-
+
my $RS = $schema->resultset('Source')->search(undef, {force_pool=>'master'});
Now $RS will force everything (both reads and writes) to use whatever was setup
@@ -86,7 +86,7 @@
See L<DBIx::Class::Storage::DBI::Replicated::Instructions> for more help and
walkthroughs.
-
+
=head1 DESCRIPTION
Warning: This class is marked BETA. This has been running a production
@@ -125,7 +125,7 @@
MooseX::Types => 0.10
namespace::clean => 0.11
Hash::Merge => 0.11
-
+
You will need to install these modules manually via CPAN or make them part of the
Makefile for your distribution.
@@ -411,7 +411,7 @@
sub BUILDARGS {
my ($class, $schema, $storage_type_args, @args) = @_;
-
+
return {
schema=>$schema,
%$storage_type_args,
@@ -568,24 +568,24 @@
sub execute_reliably {
my ($self, $coderef, @args) = @_;
-
+
unless( ref $coderef eq 'CODE') {
$self->throw_exception('Second argument must be a coderef');
}
-
+
##Get copy of master storage
my $master = $self->master;
-
+
##Get whatever the current read hander is
my $current = $self->read_handler;
-
+
##Set the read handler to master
$self->read_handler($master);
-
+
## do whatever the caller needs
my @result;
my $want_array = wantarray;
-
+
eval {
if($want_array) {
@result = $coderef->(@args);
@@ -595,13 +595,13 @@
$coderef->(@args);
}
};
-
+
##Reset to the original state
$self->read_handler($current);
-
+
##Exception testing has to come last, otherwise you might leave the
##read_handler set to master.
-
+
if($@) {
$self->throw_exception("coderef returned an error: $@");
} else {
@@ -613,14 +613,14 @@
Sets the current $schema to be 'reliable', that is all queries, both read and
write are sent to the master
-
+
=cut
sub set_reliable_storage {
my $self = shift @_;
my $schema = $self->schema;
my $write_handler = $self->schema->storage->write_handler;
-
+
$schema->storage->read_handler($write_handler);
}
@@ -628,14 +628,14 @@
Sets the current $schema to be use the </balancer> for all reads, while all
writea are sent to the master only
-
+
=cut
sub set_balanced_storage {
my $self = shift @_;
my $schema = $self->schema;
my $balanced_handler = $self->schema->storage->balancer;
-
+
$schema->storage->read_handler($balanced_handler);
}
@@ -811,7 +811,7 @@
}
$self->master->cursor_class;
}
-
+
=head1 GOTCHAS
Due to the fact that replicants can lag behind a master, you must take care to
@@ -845,7 +845,7 @@
my $new_schema = $schema->clone;
$new_schema->set_reliable_storage;
-
+
## $new_schema will use only the Master storage for all reads/writes while
## the $schema object will use replicated storage.
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/UTF8Columns.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/UTF8Columns.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/DBIx/Class/UTF8Columns.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -25,7 +25,7 @@
package Artist;
__PACKAGE__->load_components(qw/UTF8Columns Core/);
__PACKAGE__->utf8_columns(qw/name description/);
-
+
# then belows return strings with utf8 flag
$artist->name;
$artist->get_column('description');
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/SQL/Translator/Parser/DBIx/Class.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/SQL/Translator/Parser/DBIx/Class.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/SQL/Translator/Parser/DBIx/Class.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -337,7 +337,7 @@
## Standalone
use MyApp::Schema;
use SQL::Translator;
-
+
my $schema = MyApp::Schema->connect;
my $trans = SQL::Translator->new (
parser => 'SQL::Translator::Parser::DBIx::Class',
Modified: DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/SQL/Translator/Producer/DBIx/Class/File.pm
===================================================================
--- DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/SQL/Translator/Producer/DBIx/Class/File.pm 2009-07-15 22:54:22 UTC (rev 7056)
+++ DBIx-Class/0.08/branches/new_replication_transaction_fixup/lib/SQL/Translator/Producer/DBIx/Class/File.pm 2009-07-16 04:28:44 UTC (rev 7057)
@@ -128,7 +128,7 @@
$tableextras{$table->name} .= "\n__PACKAGE__->belongs_to('" .
$cont->fields->[0]->name . "', '" .
"${dbixschema}::" . $cont->reference_table . "');\n";
-
+
my $other = "\n__PACKAGE__->has_many('" .
"get_" . $table->name. "', '" .
"${dbixschema}::" . $table->name. "', '" .
More information about the Bast-commits
mailing list