1 package DBIx::Class::Schema::Loader::DBI::SQLite;
5 use base qw/DBIx::Class::Schema::Loader::DBI/;
6 use Carp::Clan qw/^DBIx::Class/;
7 use Text::Balanced qw( extract_bracketed );
10 our $VERSION = '0.04999_07';
14 DBIx::Class::Schema::Loader::DBI::SQLite - DBIx::Class::Schema::Loader::DBI SQLite Implementation.
19 use base qw/DBIx::Class::Schema::Loader/;
21 __PACKAGE__->loader_options( debug => 1 );
27 See L<DBIx::Class::Schema::Loader::Base>.
33 SQLite will fail all further commands on a connection if the
34 underlying schema has been modified. Therefore, any runtime
35 changes requiring C<rescan> also require us to re-connect
36 to the database. The C<rescan> method here handles that
37 reconnection for you, but beware that this must occur for
38 any other open sqlite connections as well.
43 my ($self, $schema) = @_;
45 $schema->storage->disconnect if $schema->storage;
46 $self->next::method($schema);
49 # XXX this really needs a re-factor
50 sub _sqlite_parse_table {
51 my ($self, $table) = @_;
57 my $dbh = $self->schema->storage->dbh;
58 my $sth = $self->{_cache}->{sqlite_master}
59 ||= $dbh->prepare(q{SELECT sql FROM sqlite_master WHERE tbl_name = ?});
61 $sth->execute($table);
62 my ($sql) = $sth->fetchrow_array;
65 # Cut "CREATE TABLE ( )" blabla...
66 $sql =~ /^[\w\s']+\((.*)\)$/si;
69 # strip single-line comments
70 $cols =~ s/\-\-.*\n/\n/g;
72 # temporarily replace any commas inside parens,
73 # so we don't incorrectly split on them below
74 my $cols_no_bracketed_commas = $cols;
75 while ( my $extracted =
76 ( extract_bracketed( $cols, "()", "[^(]*" ) )[0] )
78 my $replacement = $extracted;
79 $replacement =~ s/,/--comma--/g;
80 $replacement =~ s/^\(//;
81 $replacement =~ s/\)$//;
82 $cols_no_bracketed_commas =~ s/$extracted/$replacement/m;
85 # Split column definitions
86 for my $col ( split /,/, $cols_no_bracketed_commas ) {
88 # put the paren-bracketed commas back, to help
89 # find multi-col fks below
90 $col =~ s/\-\-comma\-\-/,/g;
92 $col =~ s/^\s*FOREIGN\s+KEY\s*//i;
94 # Strip punctuations around key and table names
95 $col =~ s/[\[\]'"]/ /g;
101 if($col =~ /^(.*)\s+UNIQUE/i) {
103 $colname =~ s/\s+.*$//;
104 push(@uniqs, [ "${colname}_unique" => [ lc $colname ] ]);
106 elsif($col =~/^\s*UNIQUE\s*\(\s*(.*)\)/i) {
109 my @cols = map { lc } split(/\s*,\s*/, $cols);
110 my $name = join(q{_}, @cols) . '_unique';
111 push(@uniqs, [ $name => \@cols ]);
114 if ($col =~ /AUTOINCREMENT/i) {
116 $auto_inc{lc $1} = 1;
119 next if $col !~ /^(.*\S)\s+REFERENCES\s+(\w+) (?: \s* \( (.*) \) )? /ix;
121 my ($cols, $f_table, $f_cols) = ($1, $2, $3);
123 if($cols =~ /^\(/) { # Table-level
131 my @cols = map { s/\s*//g; lc $_ } split(/\s*,\s*/,$cols);
134 my @f_cols = map { s/\s*//g; lc $_ } split(/\s*,\s*/,$f_cols);
135 croak "Mismatched column count in rel for $table => $f_table"
140 local_columns => \@cols,
141 remote_columns => $rcols,
142 remote_table => $f_table,
146 return { rels => \@rels, uniqs => \@uniqs, auto_inc => \%auto_inc };
149 sub _extra_column_info {
150 my ($self, $table, $col_name, $sth, $col_num) = @_;
151 ($table, $col_name) = @{$table}{qw/TABLE_NAME COLUMN_NAME/} if ref $table;
154 $self->{_sqlite_parse_data}->{$table} ||=
155 $self->_sqlite_parse_table($table);
157 if ($self->{_sqlite_parse_data}->{$table}->{auto_inc}->{$col_name}) {
158 $extra_info{is_auto_increment} = 1;
165 my ($self, $table) = @_;
167 $self->{_sqlite_parse_data}->{$table} ||=
168 $self->_sqlite_parse_table($table);
170 return $self->{_sqlite_parse_data}->{$table}->{rels};
173 sub _table_uniq_info {
174 my ($self, $table) = @_;
176 $self->{_sqlite_parse_data}->{$table} ||=
177 $self->_sqlite_parse_table($table);
179 return $self->{_sqlite_parse_data}->{$table}->{uniqs};
185 my $dbh = $self->schema->storage->dbh;
186 my $sth = $dbh->prepare("SELECT * FROM sqlite_master");
189 while ( my $row = $sth->fetchrow_hashref ) {
190 next unless lc( $row->{type} ) eq 'table';
191 next if $row->{tbl_name} =~ /^sqlite_/;
192 push @tables, $row->{tbl_name};
200 L<DBIx::Class::Schema::Loader>, L<DBIx::Class::Schema::Loader::Base>,
201 L<DBIx::Class::Schema::Loader::DBI>