X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FSQL%2FTranslator%2FProducer.pm;h=7363ee936ff91d0762863d67aadbab5750ef03e9;hb=2c64974b8705c149608a8e2d2b053fb337d7916c;hp=a8f42833b6b5691d068f4fc0d27fcd028c6e60de;hpb=c87fe35dc5f1d0ba85aad40c2dd748052bafc256;p=dbsrgits%2FSQL-Translator-2.0-ish.git

diff --git a/lib/SQL/Translator/Producer.pm b/lib/SQL/Translator/Producer.pm
index a8f4283..7363ee9 100644
--- a/lib/SQL/Translator/Producer.pm
+++ b/lib/SQL/Translator/Producer.pm
@@ -1,5 +1,81 @@
-package SQL::Translator::Producer;
-use Moose;
-extends 'SQL::Translator';
+use MooseX::Declare;
+class SQL::Translator::Producer {
+    use SQL::Translator::Constants qw(:sqlt_types);
+    use MooseX::Types::Moose qw(ArrayRef Bool HashRef ScalarRef Str);
+    use SQL::Translator::Types qw(Column Table Translator);
+    
+    has 'data_type_mapping' => (
+        isa => HashRef,
+        is => 'ro',
+        lazy_build => 1
+    );
 
-1;
+    has 'translator' => (
+        isa => Translator,
+        is => 'ro',
+        weak_ref => 1,
+        required => 1,
+        handles => [ qw(schema) ],
+    );
+
+    method _build_data_type_mapping {
+        return { 
+            SQL_LONGVARCHAR() => 'text',
+            SQL_TIMESTAMP()   => 'timestamp',
+            SQL_TYPE_TIMESTAMP() => 'timestamp without time zone',
+            SQL_TYPE_TIMESTAMP_WITH_TIMEZONE() => 'timestamp',
+            SQL_INTEGER()     => 'integer',
+            SQL_CHAR()        => 'char',
+            SQL_VARCHAR()     => 'varchar',
+            SQL_BIGINT()      => 'bigint',
+            SQL_FLOAT()       => 'numeric',
+        };
+    }
+
+    method produce {
+        my $schema = $self->schema;
+
+        $self->_create_table($_) for values %{$schema->tables};
+    }
+    
+    method _create_table(Table $table) {
+        my $no_comments    = 0;
+        my $add_drop_table = 1;
+        my $sqlite_version = 0;
+    
+        my $create_table;
+        my (@column_defs, @index_defs, @constraint_defs);
+    
+        $create_table .= 'DROP TABLE '   . $table->name . ";\n" if $add_drop_table;
+        $create_table .= 'CREATE TABLE ' . $table->name . " (\n";
+    
+        push @column_defs, $self->_create_column($_) for values %{$table->columns};
+        $create_table .= join(",\n", map { '  ' . $_ } @column_defs ) . "\n)";
+        print $create_table . "\n";
+    }
+    
+    method _create_column(Column $column) {
+        my $column_def;
+        $column_def  = $column->name . ' ' . $column->data_type;
+        $column_def .= '(' . $column->size . ')' if $column->size;
+        $column_def .= ' NOT NULL' unless $column->is_nullable;
+        $column_def;
+    }
+
+    method _default_value(ScalarRef|Str $default, ArrayRef $exceptions) {
+      if ($exceptions and ! ref $default) {
+        for (my $i = 0; $i < @$exceptions; $i += 2) {
+          my ($pat, $val) = @$exceptions[ $i, $i + 1 ];
+          if (ref $pat and $default =~ $pat) {
+          $default = $val;
+          last;
+          } elsif (lc $default eq lc $pat) {
+              $default = $val;
+              last
+          }
+        }
+      }
+
+      return ref($default) ? " DEFAULT $$default" : " DEFAULT '$default'";
+    }
+}