return $version;
}
-sub on_connect
+sub connection {
+ my $self = shift;
+ $self->next::method(@_);
+ $self->_on_connect;
+ return $self;
+}
+
+sub _on_connect
{
my ($self) = @_;
my $vschema = DBIx::Class::Version->connect(@{$self->storage->connect_info()});
my $vtable = $vschema->resultset('Table');
my $pversion;
- if(!$self->exists($vtable))
+ if(!$self->_source_exists($vtable))
{
# $vschema->storage->debug(1);
$vschema->storage->ensure_connected();
# $self->upgrade($pversion, $self->schema_version);
}
-sub exists
+sub _source_exists
{
my ($self, $rs) = @_;