use Test::More;
use SQL::Translator;
use SQL::Translator::Schema::Constants;
+use SQL::Translator::Utils qw//;
use Test::SQL::Translator qw(maybe_plan);
BEGIN {
- maybe_plan(233, "SQL::Translator::Parser::MySQL");
+ maybe_plan(295, "SQL::Translator::Parser::MySQL");
SQL::Translator::Parser::MySQL->import('parse');
}
{
my $tr = SQL::Translator->new;
- my $data = q|create table sessions (
+ my $data = q|create table "sessions" (
id char(32) not null default '0' primary key,
a_session text,
ssn varchar(12) unique key,
- age int key
+ age int key,
+ fulltext key `session_fulltext` (a_session)
);|;
my $val = parse($tr, $data);
is( $f2->is_primary_key, 0, 'Field is not PK' );
my @indices = $table->get_indices;
- is( scalar @indices, 1, 'Right number of indices (1)' );
+ is( scalar @indices, 2, 'Right number of indices (2)' );
+ my $i = pop @indices;
+ is( $i->type, 'FULLTEXT', 'Found fulltext' );
my @constraints = $table->get_constraints;
is( scalar @constraints, 2, 'Right number of constraints (2)' );
my $tr = SQL::Translator->new;
my $data = parse($tr,
q[
- CREATE TABLE check (
+ CREATE TABLE `check` (
check_id int(7) unsigned zerofill NOT NULL default '0000000'
auto_increment primary key,
successful date NOT NULL default '0000-00-00',
`m`.`user_id` AS `user_access`
from (`asset` `a` join `M_ACCESS_CONTROL` `m` on((`a`.`acl_id` = `m`.`acl_id`))) */;
DELIMITER ;;
+ /*!50001 CREATE */
+ /*! VIEW `vs_asset2` AS
+ select `a`.`asset_id` AS `asset_id`,`a`.`fq_name` AS `fq_name`,
+ `cfgmgmt_mig`.`ap_extract_folder`(`a`.`fq_name`) AS `folder_name`,
+ `cfgmgmt_mig`.`ap_extract_asset`(`a`.`fq_name`) AS `asset_name`,
+ `a`.`annotation` AS `annotation`,`a`.`asset_type` AS `asset_type`,
+ `a`.`foreign_asset_id` AS `foreign_asset_id`,
+ `a`.`foreign_asset_id2` AS `foreign_asset_id2`,`a`.`dateCreated` AS `date_created`,
+ `a`.`dateModified` AS `date_modified`,`a`.`container_id` AS `container_id`,
+ `a`.`creator_id` AS `creator_id`,`a`.`modifier_id` AS `modifier_id`,
+ `m`.`user_id` AS `user_access`
+ from (`asset` `a` join `M_ACCESS_CONTROL` `m` on((`a`.`acl_id` = `m`.`acl_id`))) */;
+ DELIMITER ;;
+ /*!50001 CREATE OR REPLACE */
+ /*! VIEW `vs_asset3` AS
+ select `a`.`asset_id` AS `asset_id`,`a`.`fq_name` AS `fq_name`,
+ `cfgmgmt_mig`.`ap_extract_folder`(`a`.`fq_name`) AS `folder_name`,
+ `cfgmgmt_mig`.`ap_extract_asset`(`a`.`fq_name`) AS `asset_name`,
+ `a`.`annotation` AS `annotation`,`a`.`asset_type` AS `asset_type`,
+ `a`.`foreign_asset_id` AS `foreign_asset_id`,
+ `a`.`foreign_asset_id2` AS `foreign_asset_id2`,`a`.`dateCreated` AS `date_created`,
+ `a`.`dateModified` AS `date_modified`,`a`.`container_id` AS `container_id`,
+ `a`.`creator_id` AS `creator_id`,`a`.`modifier_id` AS `modifier_id`,
+ `m`.`user_id` AS `user_access`
+ from (`asset` `a` join `M_ACCESS_CONTROL` `m` on((`a`.`acl_id` = `m`.`acl_id`))) */;
+ DELIMITER ;;
/*!50003 CREATE*/ /*!50020 DEFINER=`cmdomain`@`localhost`*/ /*!50003 FUNCTION `ap_from_millitime_nullable`( millis_since_1970 BIGINT ) RETURNS timestamp
DETERMINISTIC
BEGIN
my $t1f2 = shift @fields;
is( $t1f2->data_type, 'timestamp', 'Field is a timestamp' );
ok( !$t1f2->is_nullable, 'Field is not nullable' );
- is( $t1f2->default_value, 'CURRENT_TIMESTAMP', 'Field has right default value' );
+ is_deeply(
+ $t1f2->default_value,
+ \'CURRENT_TIMESTAMP',
+ 'Field has right default value'
+ );
is( $t1f2->extra('on update'), 'CURRENT_TIMESTAMP', 'Field has right on update qualifier' );
my @views = $schema->get_views;
- is( scalar @views, 1, 'Right number of views (1)' );
- my $view1 = shift @views;
+ is( scalar @views, 3, 'Right number of views (3)' );
+ my ($view3, $view1, $view2) = @views;
is( $view1->name, 'vs_asset', 'Found "vs_asset" view' );
+ is( $view2->name, 'vs_asset2', 'Found "vs_asset2" view' );
+ is( $view3->name, 'vs_asset3', 'Found "vs_asset3" view' );
like($view1->sql, qr/ALGORITHM=UNDEFINED/, "Detected algorithm");
like($view1->sql, qr/vs_asset/, "Detected view vs_asset");
unlike($view1->sql, qr/cfgmgmt_mig/, "Did not detect cfgmgmt_mig");
is($collate, 'latin1_bin', "Collate found");
is($charset, 'latin1', "Character set found");
}
+
+# Test the mysql version parser (probably needs to migrate to t/utils.t)
+my $parse_as = {
+ perl => {
+ '3.23.2' => 3.023002,
+ '4' => 4.000000,
+ '50003' => 5.000003,
+ '5.01.0' => 5.001000,
+ '5.1' => 5.001000,
+ },
+ mysql => {
+ '3.23.2' => 32302,
+ '4' => 40000,
+ '50003' => 50003,
+ '5.01.0' => 50100,
+ '5.1' => 50100,
+ },
+};
+
+for my $target (keys %$parse_as) {
+ for my $str (keys %{$parse_as->{$target}}) {
+ cmp_ok (
+ SQL::Translator::Utils::parse_mysql_version ($str, $target),
+ '==',
+ $parse_as->{$target}{$str},
+ "'$str' parsed as $target version '$parse_as->{$target}{$str}'",
+ );
+ }
+}
+
+eval { SQL::Translator::Utils::parse_mysql_version ('bogus5.1') };
+ok ($@, 'Exception thrown on invalid version string');
+
+{
+ my $tr = SQL::Translator->new;
+ my $data = q|create table merge_example (
+ id int(11) NOT NULL auto_increment,
+ shape_field geometry NOT NULL,
+ PRIMARY KEY (id),
+ SPATIAL KEY shape_field (shape_field)
+ ) ENGINE=MRG_MyISAM UNION=(`sometable_0`,`sometable_1`,`sometable_2`);|;
+
+ my $val = parse($tr, $data);
+ my $schema = $tr->schema;
+ is( $schema->is_valid, 1, 'Schema is valid' );
+ my @tables = $schema->get_tables;
+ is( scalar @tables, 1, 'Right number of tables (1)' );
+ my $table = shift @tables;
+ is( $table->name, 'merge_example', 'Found "merge_example" table' );
+
+ my $tableTypeFound = 0;
+ my $unionFound = 0;
+ for my $t_option_ref ( $table->options ) {
+ my($key, $value) = %{$t_option_ref};
+ if ( $key eq 'ENGINE' ) {
+ is($value, 'MRG_MyISAM', 'Table has right table engine option' );
+ $tableTypeFound = 1;
+ } elsif ( $key eq 'UNION' ) {
+ is_deeply($value, [ 'sometable_0','sometable_1','sometable_2' ],
+ "UNION option has correct set");
+ $unionFound = 1;
+ }
+ }
+
+ fail('Table did not have a type option') unless $tableTypeFound;
+ fail('Table did not have a union option') unless $unionFound;
+
+ my @fields = $table->get_fields;
+ is( scalar @fields, 2, 'Right number of fields (2)' );
+ my $f1 = shift @fields;
+ my $f2 = shift @fields;
+ is( $f1->name, 'id', 'First field name is "id"' );
+ is( $f1->data_type, 'int', 'Type is "int"' );
+ is( $f1->size, 11, 'Size is "11"' );
+ is( $f1->is_nullable, 0, 'Field cannot be null' );
+ is( $f1->is_primary_key, 1, 'Field is PK' );
+
+ is( $f2->name, 'shape_field', 'Second field name is "shape_field"' );
+ is( $f2->data_type, 'geometry', 'Type is "geometry"' );
+ is( $f2->is_nullable, 0, 'Field cannot be null' );
+ is( $f2->is_primary_key, 0, 'Field is not PK' );
+
+ my @indices = $table->get_indices;
+ is( scalar @indices, 1, 'Right number of indices (1)' );
+ my $i1 = shift @indices;
+ is( $i1->name, 'shape_field', 'No name on index' );
+ is( $i1->type, SPATIAL, 'Spatial index' );
+
+ my @constraints = $table->get_constraints;
+ is( scalar @constraints, 1, 'Right number of constraints (1)' );
+ my $c = shift @constraints;
+ is( $c->type, PRIMARY_KEY, 'Constraint is a PK' );
+ is( join(',', $c->fields), 'id', 'Constraint is on "id"' );
+}
+
+{
+ my @data = (
+ q|create table quote (
+ id int(11) NOT NULL auto_increment,
+ PRIMARY KEY (id)
+ ) ENGINE="innodb";|,
+ q|create table quote (
+ id int(11) NOT NULL auto_increment,
+ PRIMARY KEY (id)
+ ) ENGINE='innodb';|,
+ q|create table quote (
+ id int(11) NOT NULL auto_increment,
+ PRIMARY KEY (id)
+ ) ENGINE=innodb;|,
+ );
+ for my $data (@data) {
+ my $tr = SQL::Translator->new;
+
+ my $val = parse($tr, $data);
+ my $schema = $tr->schema;
+ is( $schema->is_valid, 1, 'Schema is valid' );
+ my @tables = $schema->get_tables;
+ is( scalar @tables, 1, 'Right number of tables (1)' );
+ my $table = shift @tables;
+ is( $table->name, 'quote', 'Found "quote" table' );
+
+ my $tableTypeFound = 0;
+ for my $t_option_ref ( $table->options ) {
+ my($key, $value) = %{$t_option_ref};
+ if ( $key eq 'ENGINE' ) {
+ is($value, 'innodb', 'Table has right table engine option' );
+ $tableTypeFound = 1;
+ }
+ }
+
+ fail('Table did not have a type option') unless $tableTypeFound;
+
+ my @fields = $table->get_fields;
+ my $f1 = shift @fields;
+ is( $f1->name, 'id', 'First field name is "id"' );
+ is( $f1->data_type, 'int', 'Type is "int"' );
+ is( $f1->size, 11, 'Size is "11"' );
+ is( $f1->is_nullable, 0, 'Field cannot be null' );
+ is( $f1->is_primary_key, 1, 'Field is PK' );
+ }
+}
+
projects / dbsrgits/SQL-Translator.git / blobdiff