use strict;
use warnings;
-use base qw/
- DBIx::Class::Schema::Loader::DBI::Component::QuotedDefault
- DBIx::Class::Schema::Loader::DBI
-/;
-use Carp::Clan qw/^DBIx::Class/;
-use Text::Balanced qw( extract_bracketed );
-use Class::C3;
+use base 'DBIx::Class::Schema::Loader::DBI::Component::QuotedDefault';
+use mro 'c3';
+use DBIx::Class::Schema::Loader::Table ();
-our $VERSION = '0.05003';
+our $VERSION = '0.07047';
=head1 NAME
DBIx::Class::Schema::Loader::DBI::SQLite - DBIx::Class::Schema::Loader::DBI SQLite Implementation.
-=head1 SYNOPSIS
-
- package My::Schema;
- use base qw/DBIx::Class::Schema::Loader/;
-
- __PACKAGE__->loader_options( debug => 1 );
-
- 1;
-
=head1 DESCRIPTION
-See L<DBIx::Class::Schema::Loader::Base>.
+See L<DBIx::Class::Schema::Loader> and L<DBIx::Class::Schema::Loader::Base>.
=head1 METHODS
=head2 rescan
-SQLite will fail all further commands on a connection if the
-underlying schema has been modified. Therefore, any runtime
-changes requiring C<rescan> also require us to re-connect
-to the database. The C<rescan> method here handles that
-reconnection for you, but beware that this must occur for
-any other open sqlite connections as well.
+SQLite will fail all further commands on a connection if the underlying schema
+has been modified. Therefore, any runtime changes requiring C<rescan> also
+require us to re-connect to the database. The C<rescan> method here handles
+that reconnection for you, but beware that this must occur for any other open
+sqlite connections as well.
=cut
+sub _setup {
+ my $self = shift;
+
+ $self->next::method(@_);
+
+ if (not defined $self->preserve_case) {
+ $self->preserve_case(0);
+ }
+
+ if ($self->db_schema) {
+ warn <<'EOF';
+db_schema is not supported on SQLite, the option is implemented only for qualify_objects testing.
+EOF
+ if ($self->db_schema->[0] eq '%') {
+ $self->db_schema(undef);
+ }
+ }
+}
+
sub rescan {
my ($self, $schema) = @_;
$self->next::method($schema);
}
-sub _extra_column_info {
- my ($self, $table, $col_name, $sth, $col_num) = @_;
- ($table, $col_name) = @{$table}{qw/TABLE_NAME COLUMN_NAME/} if ref $table;
- my %extra_info;
-
- my $dbh = $self->schema->storage->dbh;
- my $has_autoinc = eval {
- my $get_seq = $self->{_cache}->{sqlite_sequence}
- ||= $dbh->prepare(q{SELECT count(*) FROM sqlite_sequence WHERE name = ?});
- $get_seq->execute($table);
- my ($ret) = $get_seq->fetchrow_array;
- $get_seq->finish;
- $ret;
- };
-
- if (!$@ && $has_autoinc) {
- my $sth = $dbh->prepare(
- "pragma table_info(" . $dbh->quote_identifier($table) . ")"
- );
- $sth->execute;
- my $cols = $sth->fetchall_hashref('name');
- if ($cols->{$col_name}{pk}) {
- $extra_info{is_auto_increment} = 1;
+sub _columns_info_for {
+ my $self = shift;
+ my ($table) = @_;
+
+ my $result = $self->next::method(@_);
+
+ local $self->dbh->{FetchHashKeyName} = 'NAME_lc';
+
+ my $sth = $self->dbh->prepare(
+ "pragma table_info(" . $self->dbh->quote_identifier($table) . ")"
+ );
+ $sth->execute;
+ my $cols = $sth->fetchall_hashref('name');
+
+ # copy and case according to preserve_case mode
+ # no need to check for collisions, SQLite does not allow them
+ my %cols;
+ while (my ($col, $info) = each %$cols) {
+ $cols{ $self->_lc($col) } = $info;
+ }
+
+ my ($num_pk, $pk_col) = (0);
+ # SQLite doesn't give us the info we need to do this nicely :(
+ # If there is exactly one column marked PK, and its type is integer,
+ # set it is_auto_increment. This isn't 100%, but it's better than the
+ # alternatives.
+ while (my ($col_name, $info) = each %$result) {
+ if ($cols{$col_name}{pk}) {
+ $num_pk++;
+ if (lc($cols{$col_name}{type}) eq 'integer') {
+ $pk_col = $col_name;
+ }
+ }
+ }
+
+ while (my ($col, $info) = each %$result) {
+ if ((eval { ${ $info->{default_value} } }||'') eq 'CURRENT_TIMESTAMP') {
+ ${ $info->{default_value} } = 'current_timestamp';
+ }
+ if ($num_pk == 1 and defined $pk_col and $pk_col eq $col) {
+ $info->{is_auto_increment} = 1;
}
}
- return \%extra_info;
+ return $result;
}
sub _table_fk_info {
my ($self, $table) = @_;
- my $dbh = $self->schema->storage->dbh;
- my $sth = $dbh->prepare(
- "pragma foreign_key_list(" . $dbh->quote_identifier($table) . ")"
+ my $sth = $self->dbh->prepare(
+ "pragma foreign_key_list(" . $self->dbh->quote_identifier($table) . ")"
);
$sth->execute;
my $rel = $rels[ $fk->{id} ] ||= {
local_columns => [],
remote_columns => undef,
- remote_table => lc $fk->{table}
+ remote_table => DBIx::Class::Schema::Loader::Table->new(
+ loader => $self,
+ name => $fk->{table},
+ ($self->db_schema ? (
+ schema => $self->db_schema->[0],
+ ignore_schema => 1,
+ ) : ()),
+ ),
+ };
+
+ push @{ $rel->{local_columns} }, $self->_lc($fk->{from});
+ push @{ $rel->{remote_columns} }, $self->_lc($fk->{to}) if defined $fk->{to};
+
+ $rel->{attrs} ||= {
+ on_delete => uc $fk->{on_delete},
+ on_update => uc $fk->{on_update},
};
- push @{ $rel->{local_columns} }, lc $fk->{from};
- push @{ $rel->{remote_columns} }, lc $fk->{to} if defined $fk->{to};
warn "This is supposed to be the same rel but remote_table changed from ",
- $rel->{remote_table}, " to ", $fk->{table}
- if $rel->{remote_table} ne lc $fk->{table};
+ $rel->{remote_table}->name, " to ", $fk->{table}
+ if $rel->{remote_table}->name ne $fk->{table};
}
$sth->finish;
+
+ # now we need to determine whether each FK is DEFERRABLE, this can only be
+ # done by parsing the DDL from sqlite_master
+
+ my $ddl = $self->dbh->selectcol_arrayref(<<"EOF", undef, $table->name, $table->name)->[0];
+select sql from sqlite_master
+where name = ? and tbl_name = ?
+EOF
+
+ foreach my $fk (@rels) {
+ my $local_cols = '"?' . (join '"? \s* , \s* "?', map quotemeta, @{ $fk->{local_columns} }) . '"?';
+ my $remote_cols = '"?' . (join '"? \s* , \s* "?', map quotemeta, @{ $fk->{remote_columns} || [] }) . '"?';
+ my ($deferrable_clause) = $ddl =~ /
+ foreign \s+ key \s* \( \s* $local_cols \s* \) \s* references \s* (?:\S+|".+?(?<!")") \s*
+ (?:\( \s* $remote_cols \s* \) \s*)?
+ (?:(?:
+ on \s+ (?:delete|update) \s+ (?:set \s+ null|set \s+ default|cascade|restrict|no \s+ action)
+ |
+ match \s* (?:\S+|".+?(?<!")")
+ ) \s*)*
+ ((?:not)? \s* deferrable)?
+ /sxi;
+
+ if ($deferrable_clause) {
+ $fk->{attrs}{is_deferrable} = $deferrable_clause =~ /not/i ? 0 : 1;
+ }
+ else {
+ # check for inline constraint if 1 local column
+ if (@{ $fk->{local_columns} } == 1) {
+ my ($local_col) = @{ $fk->{local_columns} };
+ my ($remote_col) = @{ $fk->{remote_columns} || [] };
+ $remote_col ||= '';
+
+ my ($deferrable_clause) = $ddl =~ /
+ "?\Q$local_col\E"? \s* (?:\w+\s*)* (?: \( \s* \d\+ (?:\s*,\s*\d+)* \s* \) )? \s*
+ references \s+ (?:\S+|".+?(?<!")") (?:\s* \( \s* "?\Q$remote_col\E"? \s* \))? \s*
+ (?:(?:
+ on \s+ (?:delete|update) \s+ (?:set \s+ null|set \s+ default|cascade|restrict|no \s+ action)
+ |
+ match \s* (?:\S+|".+?(?<!")")
+ ) \s*)*
+ ((?:not)? \s* deferrable)?
+ /sxi;
+
+ if ($deferrable_clause) {
+ $fk->{attrs}{is_deferrable} = $deferrable_clause =~ /not/i ? 0 : 1;
+ }
+ else {
+ $fk->{attrs}{is_deferrable} = 0;
+ }
+ }
+ else {
+ $fk->{attrs}{is_deferrable} = 0;
+ }
+ }
+ }
+
return \@rels;
}
sub _table_uniq_info {
my ($self, $table) = @_;
- my $dbh = $self->schema->storage->dbh;
- my $sth = $dbh->prepare(
- "pragma index_list(" . $dbh->quote($table) . ")"
+ my $sth = $self->dbh->prepare(
+ "pragma index_list(" . $self->dbh->quote($table) . ")"
);
$sth->execute;
my @uniqs;
while (my $idx = $sth->fetchrow_hashref) {
next unless $idx->{unique};
+
my $name = $idx->{name};
- my $get_idx_sth = $dbh->prepare("pragma index_info(" . $dbh->quote($name) . ")");
+ my $get_idx_sth = $self->dbh->prepare("pragma index_info(" . $self->dbh->quote($name) . ")");
$get_idx_sth->execute;
my @cols;
while (my $idx_row = $get_idx_sth->fetchrow_hashref) {
- push @cols, lc $idx_row->{name};
+ push @cols, $self->_lc($idx_row->{name});
}
$get_idx_sth->finish;
+
+ # Rename because SQLite complains about sqlite_ prefixes on identifiers
+ # and ignores constraint names in DDL.
+ $name = (join '_', @cols) . '_unique';
+
push @uniqs, [ $name => \@cols ];
}
$sth->finish;
- return \@uniqs;
+ return [ sort { $a->[0] cmp $b->[0] } @uniqs ];
}
sub _tables_list {
- my $self = shift;
+ my ($self) = @_;
- my $dbh = $self->schema->storage->dbh;
- my $sth = $dbh->prepare("SELECT * FROM sqlite_master");
+ my $sth = $self->dbh->prepare("SELECT * FROM sqlite_master");
$sth->execute;
my @tables;
while ( my $row = $sth->fetchrow_hashref ) {
- next unless lc( $row->{type} ) eq 'table';
+ next unless $row->{type} =~ /^(?:table|view)\z/i;
next if $row->{tbl_name} =~ /^sqlite_/;
- push @tables, $row->{tbl_name};
+ push @tables, DBIx::Class::Schema::Loader::Table->new(
+ loader => $self,
+ name => $row->{tbl_name},
+ ($self->db_schema ? (
+ schema => $self->db_schema->[0],
+ ignore_schema => 1, # for qualify_objects tests
+ ) : ()),
+ );
}
$sth->finish;
- return $self->_filter_tables(@tables);
+ return $self->_filter_tables(\@tables);
+}
+
+sub _table_info_matches {
+ my ($self, $table, $info) = @_;
+
+ my $table_schema = $table->schema;
+ $table_schema = 'main' if !defined $table_schema;
+ return $info->{TABLE_SCHEM} eq $table_schema
+ && $info->{TABLE_NAME} eq $table->name;
}
=head1 SEE ALSO
L<DBIx::Class::Schema::Loader>, L<DBIx::Class::Schema::Loader::Base>,
L<DBIx::Class::Schema::Loader::DBI>
-=head1 AUTHOR
+=head1 AUTHORS
-See L<DBIx::Class::Schema::Loader/AUTHOR> and L<DBIx::Class::Schema::Loader/CONTRIBUTORS>.
+See L<DBIx::Class::Schema::Loader/AUTHORS>.
=head1 LICENSE
=cut
1;
+# vim:et sts=4 sw=4 tw=0:
projects / dbsrgits/DBIx-Class-Schema-Loader.git / blobdiff