lib/SQL/Translator/Producer/SQL/SQLite.pm

   1 use MooseX::Declare;
   2 role SQL::Translator::Producer::SQL::SQLite {
   3     use MooseX::Types::Moose qw(HashRef);
   4     use SQL::Translator::Constants qw(:sqlt_types :sqlt_constants);
   5     use SQL::Translator::Types qw(Column Constraint Index Trigger Table View);
   6
   7     around _build_data_type_mapping {
   8         my $data_type_mapping = $self->$orig;
   9         $data_type_mapping->{SQL_FLOAT()} = 'real';
  10         $data_type_mapping->{SQL_BIGINT()} = 'integer';
  11
  12         return $data_type_mapping;
  13     };
  14
  15 method header_comment($producer, $comment_char) {
  16     $producer ||= caller;
  17     my $now = scalar localtime;
  18 my $DEFAULT_COMMENT = '-- ';
  19
  20     $comment_char = $DEFAULT_COMMENT
  21         unless defined $comment_char;
  22
  23     my $header_comment =<<"HEADER_COMMENT";
  24 ${comment_char}
  25 ${comment_char}Created by $producer
  26 ${comment_char}Created on $now
  27 ${comment_char}
  28 HEADER_COMMENT
  29
  30     # Any additional stuff passed in
  31     for my $additional_comment (@_) {
  32         $header_comment .= "${comment_char}${additional_comment}\n";
  33     }
  34
  35     return $header_comment;
  36 }
  37
  38 method produce {
  39     my $translator     = $self->translator;
  40 #    local $DEBUG       = $translator->debug;
  41 #    local $WARN        = $translator->show_warnings;
  42     my $no_comments    = $translator->no_comments;
  43     my $add_drop_table = $translator->add_drop_table;
  44     my $schema         = $translator->schema;
  45     my $producer_args  = $translator->producer_args;
  46     my $sqlite_version = $producer_args->{sqlite_version} || 0;
  47     my $no_txn         = $producer_args->{no_transaction};
  48
  49 #    debug("PKG: Beginning production\n");
  50
  51 #    %global_names = ();   #reset
  52
  53     my @create = ();
  54     push @create, $self->header_comment unless ($no_comments);
  55     $create[0] .= "\n\nBEGIN TRANSACTION" unless $no_txn;
  56
  57     for my $table ( $schema->get_tables ) {
  58         push @create, $self->create_table($table, { no_comments => $no_comments,
  59                                              sqlite_version => $sqlite_version,
  60                                           add_drop_table => $add_drop_table,});
  61     }
  62
  63     for my $view ( $schema->get_views ) {
  64       push @create, $self->create_view($view, {
  65         add_drop_view => $add_drop_table,
  66         no_comments   => $no_comments,
  67       });
  68     }
  69
  70     for my $trigger ( $schema->get_triggers ) {
  71       push @create, $self->create_trigger($trigger, {
  72         add_drop_trigger => $add_drop_table,
  73         no_comments   => $no_comments,
  74       });
  75     }
  76
  77     if (wantarray) {
  78       push @create, "COMMIT" unless $no_txn;
  79       return @create;
  80     } else {
  81       push @create, "COMMIT;\n" unless $no_txn;
  82       return join(";\n\n", @create );
  83     }
  84 }
  85
  86 # -------------------------------------------------------------------
  87 sub mk_name {
  88     my ($name, $scope, $critical) = @_;
  89 my $max_id_length = 30;
  90 #    $scope ||= \%global_names;
  91     if ( my $prev = $scope->{ $name } ) {
  92         my $name_orig = $name;
  93         $name        .= sprintf( "%02d", ++$prev );
  94         substr($name, $max_id_length - 3) = "00"
  95             if length( $name ) > $max_id_length;
  96
  97 #        warn "The name '$name_orig' has been changed to ",
  98 #             "'$name' to make it unique.\n" if $WARN;
  99
 100         $scope->{ $name_orig }++;
 101     }
 102
 103     $scope->{ $name }++;
 104     return $name;
 105 }
 106
 107 method create_view(View $view, $options?) {
 108     my $add_drop_view = $options->{add_drop_view};
 109
 110     my $view_name = $view->name;
 111 #    debug("PKG: Looking at view '${view_name}'\n");
 112
 113     # Header.  Should this look like what mysqldump produces?
 114     my $extra = $view->extra;
 115     my $create = '';
 116     $create .= "--\n-- View: ${view_name}\n--\n" unless $options->{no_comments};
 117     $create .= "DROP VIEW IF EXISTS $view_name;\n" if $add_drop_view;
 118     $create .= 'CREATE';
 119     $create .= " TEMPORARY" if exists($extra->{temporary}) && $extra->{temporary};
 120     $create .= ' VIEW';
 121     $create .= " IF NOT EXISTS" if exists($extra->{if_not_exists}) && $extra->{if_not_exists};
 122     $create .= " ${view_name}";
 123
 124     if( my $sql = $view->sql ){
 125       $create .= " AS\n    ${sql}";
 126     }
 127     return $create;
 128 }
 129
 130 method create_table(Table $table, HashRef $options) {
 131     my $table_name = $table->name;
 132     my $no_comments = $options->{no_comments};
 133     my $add_drop_table = $options->{add_drop_table};
 134     my $sqlite_version = $options->{sqlite_version} || 0;
 135
 136 #    debug("PKG: Looking at table '$table_name'\n");
 137
 138     my ( @index_defs, @constraint_defs );
 139     my @fields = $table->get_fields or die "No fields in $table_name";
 140
 141     my $temp = $options->{temporary_table} ? 'TEMPORARY ' : '';
 142     #
 143     # Header.
 144     #
 145     my $exists = ($sqlite_version >= 3.3) ? ' IF EXISTS' : '';
 146     my @create;
 147     my ($comment, $create_table) = "";
 148     $comment =  "--\n-- Table: $table_name\n--\n" unless $no_comments;
 149     if ($add_drop_table) {
 150       push @create, $comment . qq[DROP TABLE$exists $table_name];
 151     } else {
 152       $create_table = $comment;
 153     }
 154
 155     $create_table .= "CREATE ${temp}TABLE $table_name (\n";
 156
 157     #
 158     # Comments
 159     #
 160     if ( $table->comments and !$no_comments ){
 161         $create_table .= "-- Comments: \n-- ";
 162         $create_table .= join "\n-- ",  $table->comments;
 163         $create_table .= "\n--\n\n";
 164     }
 165
 166     #
 167     # How many fields in PK?
 168     #
 169     my $pk        = $table->primary_key;
 170     my @pk_fields = $pk ? $pk->fields : ();
 171
 172     #
 173     # Fields
 174     #
 175     my ( @field_defs, $pk_set );
 176     for my $field ( @fields ) {
 177         push @field_defs, $self->create_field($field);
 178     }
 179
 180     if (
 181          scalar @pk_fields > 1
 182          ||
 183          ( @pk_fields && !grep /INTEGER PRIMARY KEY/, @field_defs )
 184          ) {
 185         push @field_defs, 'PRIMARY KEY (' . join(', ', @pk_fields ) . ')';
 186     }
 187
 188     #
 189     # Indices
 190     #
 191     my $idx_name_default = 'A';
 192     for my $index ( $table->get_indices ) {
 193         push @index_defs,  $self->create_index($index);
 194     }
 195
 196     #
 197     # Constraints
 198     #
 199     my $c_name_default = 'A';
 200     for my $c ( $table->get_constraints ) {
 201         next unless $c->type eq UNIQUE;
 202         push @constraint_defs, $self->create_constraint($c);
 203     }
 204
 205     $create_table .= join(",\n", map { "  $_" } @field_defs ) . "\n)";
 206
 207     return (@create, $create_table, @index_defs, @constraint_defs );
 208 }
 209
 210 method create_field(Column $field, $options?) {
 211     my $field_name = $field->name;
 212 #    debug("PKG: Looking at field '$field_name'\n");
 213     my $field_comments = $field->comments
 214         ? "-- " . $field->comments . "\n  "
 215         : '';
 216
 217     my $field_def = $field_comments.$field_name;
 218
 219     # data type and size
 220     my $size      = $field->size;
 221     my $data_type = $field->data_type;
 222     $data_type    = 'varchar' if lc $data_type eq 'set';
 223     $data_type  = 'blob' if lc $data_type eq 'bytea';
 224
 225     if ( lc $data_type =~ /(text|blob)/i ) {
 226         $size = undef;
 227     }
 228
 229 #             if ( $data_type =~ /timestamp/i ) {
 230 #                 push @trigger_defs,
 231 #                     "CREATE TRIGGER ts_${table_name} ".
 232 #                     "after insert on $table_name\n".
 233 #                     "begin\n".
 234 #                     "  update $table_name set $field_name=timestamp() ".
 235 #                        "where id=new.id;\n".
 236 #                     "end;\n"
 237 #                 ;
 238 #
 239 #            }
 240
 241     #
 242     # SQLite is generally typeless, but newer versions will
 243     # make a field autoincrement if it is declared as (and
 244     # *only* as) INTEGER PRIMARY KEY
 245     #
 246     my $pk        = $field->table->primary_key;
 247     my @pk_fields = $pk ? $pk->fields : ();
 248
 249     if (
 250          $field->is_primary_key &&
 251          scalar @pk_fields == 1 &&
 252          (
 253           $data_type =~ /int(eger)?$/i
 254           ||
 255           ( $data_type =~ /^number?$/i && $size !~ /,/ )
 256           )
 257          ) {
 258         $data_type = 'INTEGER PRIMARY KEY';
 259         $size      = undef;
 260 #        $pk_set    = 1;
 261     }
 262
 263     $field_def .= sprintf " %s%s", $data_type,
 264     ( !$field->is_auto_increment && $size ) ? "($size)" : '';
 265
 266     # Null?
 267     $field_def .= ' NOT NULL' unless $field->is_nullable;
 268
 269     # Default?  XXX Need better quoting!
 270     my $default = $field->default_value;
 271
 272 #    if (defined $default) {
 273 #        SQL::Translator::Producer->_apply_default_value(
 274 #            \$field_def,
 275 #            $default,
 276 #            [
 277 #             'NULL'              => \'NULL',
 278 #             'now()'             => 'now()',
 279 #             'CURRENT_TIMESTAMP' => 'CURRENT_TIMESTAMP',
 280 #            ],
 281 #        );
 282 #    }
 283
 284     return $field_def;
 285
 286 }
 287
 288 method create_index(Index $index, $options?) {
 289     my $name   = $index->name;
 290     $name      = mk_name($name);
 291
 292     my $type   = $index->type eq 'UNIQUE' ? "UNIQUE " : '';
 293
 294     # strip any field size qualifiers as SQLite doesn't like these
 295     my @fields = map { s/\(\d+\)$//; $_ } $index->fields;
 296     (my $index_table_name = $index->table->name) =~ s/^.+?\.//; # table name may not specify schema
 297 #    warn "removing schema name from '" . $index->table->name . "' to make '$index_table_name'\n" if $WARN;
 298     my $index_def =
 299     "CREATE ${type}INDEX $name ON " . $index_table_name .
 300         ' (' . join( ', ', @fields ) . ')';
 301
 302     return $index_def;
 303 }
 304
 305 method create_constraint(Constraint $c, $options?) {
 306     my $name   = $c->name;
 307     $name      = mk_name($name);
 308     my @fields = $c->fields;
 309     (my $index_table_name = $c->table->name) =~ s/^.+?\.//; # table name may not specify schema
 310 #    warn "removing schema name from '" . $c->table->name . "' to make '$index_table_name'\n" if $WARN;
 311
 312     my $c_def =
 313     "CREATE UNIQUE INDEX $name ON " . $index_table_name .
 314         ' (' . join( ', ', @fields ) . ')';
 315     return $c_def;
 316 }
 317
 318 method create_trigger(Trigger $trigger, $options?) {
 319   my $add_drop = $options->{add_drop_trigger};
 320
 321   my @statements;
 322
 323   my $trigger_name = $trigger->name;
 324   my @events = $trigger->database_events;
 325   for my $evt ( @events ) {
 326
 327     my $trig_name = $trigger_name;
 328     if (@events > 1) {
 329       $trig_name .= "_$evt";
 330
 331 #      warn "Multiple database events supplied for trigger '$trigger_name', ",
 332 #        "creating trigger '$trig_name' for the '$evt' event.\n" if $WARN;
 333     }
 334
 335     push @statements,  "DROP TRIGGER IF EXISTS $trig_name" if $add_drop;
 336
 337
 338     $DB::single = 1;
 339     my $action = "";
 340     if (not ref $trigger->action) {
 341       $action .= "BEGIN " . $trigger->action . " END";
 342     }
 343     else {
 344       $action = $trigger->action->{for_each} . " "
 345         if $trigger->action->{for_each};
 346
 347       $action = $trigger->action->{when} . " "
 348         if $trigger->action->{when};
 349
 350       my $steps = $trigger->action->{steps} || [];
 351
 352       $action .= "BEGIN ";
 353       $action .= $_ . "; " for (@$steps);
 354       $action .= "END";
 355     }
 356
 357     push @statements, sprintf (
 358       'CREATE TRIGGER %s %s %s on %s %s',
 359       $trig_name,
 360       $trigger->perform_action_when,
 361       $evt,
 362       $trigger->on_table,
 363       $action
 364     );
 365   }
 366
 367   return @statements;
 368 }
 369
 370 method alter_table(@) { } # Noop
 371
 372 method add_field(Column $field) {
 373   return sprintf("ALTER TABLE %s ADD COLUMN %s",
 374       $field->table->name, $self->create_field($field))
 375 }
 376
 377 method alter_create_index(Index $index) {
 378   # This might cause name collisions
 379   return $self->create_index($index);
 380 }
 381
 382 method alter_create_constraint(Constraint $constraint) {
 383   return $self->create_constraint($constraint) if $constraint->type eq 'UNIQUE';
 384 }
 385
 386 method alter_drop_constraint(@args) { $self->alter_drop_index(@args) }
 387
 388 method alter_drop_index(Constraint $constraint) {
 389   return sprintf("DROP INDEX %s",
 390       $constraint->name);
 391 }
 392
 393 method batch_alter_table(Table $table, $diffs) {
 394   # If we have any of the following
 395   #
 396   #  rename_field
 397   #  alter_field
 398   #  drop_field
 399   #
 400   # we need to do the following <http://www.sqlite.org/faq.html#q11>
 401   #
 402   # BEGIN TRANSACTION;
 403   # CREATE TEMPORARY TABLE t1_backup(a,b);
 404   # INSERT INTO t1_backup SELECT a,b FROM t1;
 405   # DROP TABLE t1;
 406   # CREATE TABLE t1(a,b);
 407   # INSERT INTO t1 SELECT a,b FROM t1_backup;
 408   # DROP TABLE t1_backup;
 409   # COMMIT;
 410   #
 411   # Fun, eh?
 412   #
 413   # If we have rename_field we do similarly.
 414
 415   my $table_name = $table->name;
 416   my $renaming = $diffs->{rename_table} && @{$diffs->{rename_table}};
 417
 418   if ( @{$diffs->{rename_field}} == 0 &&
 419        @{$diffs->{alter_field}}  == 0 &&
 420        @{$diffs->{drop_field}}   == 0
 421        ) {
 422 #    return join("\n", map {
 423     return map {
 424         my $meth = __PACKAGE__->can($_) or die __PACKAGE__ . " cant $_";
 425         map { my $sql = $meth->(ref $_ eq 'ARRAY' ? @$_ : $_); $sql ?  ("$sql") : () } @{ $diffs->{$_} }
 426
 427       } grep { @{$diffs->{$_}} }
 428     qw/rename_table
 429        alter_drop_constraint
 430        alter_drop_index
 431        drop_field
 432        add_field
 433        alter_field
 434        rename_field
 435        alter_create_index
 436        alter_create_constraint
 437        alter_table/;
 438   }
 439
 440   my @sql;
 441   my $old_table = $renaming ? $diffs->{rename_table}[0][0] : $table;
 442
 443   do {
 444     local $table->{name} = $table_name . '_temp_alter';
 445     # We only want the table - dont care about indexes on tmp table
 446     my ($table_sql) = $self->create_table($table, {no_comments => 1, temporary_table => 1});
 447     push @sql,$table_sql;
 448   };
 449
 450   push @sql, "INSERT INTO @{[$table_name]}_temp_alter SELECT @{[ join(', ', $old_table->get_fields)]} FROM @{[$old_table]}",
 451              "DROP TABLE @{[$old_table]}",
 452              $self->create_table($table, { no_comments => 1 }),
 453              "INSERT INTO @{[$table_name]} SELECT @{[ join(', ', $old_table->get_fields)]} FROM @{[$table_name]}_temp_alter",
 454              "DROP TABLE @{[$table_name]}_temp_alter";
 455
 456   return @sql;
 457 #  return join("", @sql, "");
 458 }
 459
 460 method drop_table(Str $table) {
 461   return "DROP TABLE $table";
 462 }
 463
 464 method rename_table(Str $old_table, Str $new_table, $options?) {
 465   my $qt = $options->{quote_table_names} || '';
 466
 467   return "ALTER TABLE $qt$old_table$qt RENAME TO $qt$new_table$qt";
 468
 469 }
 470
 471 # No-op. Just here to signify that we are a new style parser.
 472 method preproces_schema(@) { }
 473 }