prefix AS only for column aliases

Author: jamadam

lib/Data/ObjectDriver/SQL.pm

@@ -79,7 +79,7 @@ sub as_sql {
             if (blessed($col) && $col->isa('Data::ObjectDriver::SQL')) {
                 push @bind_for_select, @{ $col->{bind} };
                 @{ $col->{bind} } = ();
-                $col->as_subquery($alias);
+                $col->as_subquery(1, $alias);
             } else {
                 if ($alias) {
                     /(?:^|\.)\Q$alias\E$/ ? $col : "$col $alias";
@@ -120,7 +120,7 @@ sub as_sql {
             if (blessed($from) && $from->isa('Data::ObjectDriver::SQL')) {
                 push @bind_for_from, @{$from->{bind}};
                 @{$from->{bind}} = ();
-                $from->as_subquery;
+                $from->as_subquery(0);
             } else {
                 $stmt->_add_index_hint($from);
             }
@@ -146,11 +146,12 @@ sub as_sql {
 }
 
 sub as_subquery {
-    my ($stmt, $alias) = @_;
+    my ($stmt, $use_as, $alias) = @_;
     my $subquery = '(' . $stmt->as_sql . ')';
     $alias ||= $stmt->as;
     if ($alias) {
-        $subquery .= ' AS ' . $alias;
+        $subquery .= ' AS' if $use_as;
+        $subquery .= ' '. $alias;
     }
     $subquery;
 }
@@ -335,7 +336,7 @@ sub _mk_term {
                 $term = "$c $val->{op} " . $$value;
             } elsif (blessed($value) && $value->isa('Data::ObjectDriver::SQL')) {
                 local $value->{as} = undef;
-                $term = "$c $val->{op} ". $value->as_subquery;
+                $term = "$c $val->{op} ". $value->as_subquery(0);
                 push @bind, @{$value->{bind}};
             } else {
                 $term = "$c $val->{op} ?";

t/11-sql-with-models.t

@@ -39,15 +39,19 @@ $entry22->save;
 subtest 'as_subquery' => sub {
     my $stmt = Blog->driver->prepare_statement('Blog', { name => 'foo' }, { fetchonly => ['id'] });
 
-    is(sql_normalize($stmt->as_subquery), sql_normalize(<<'EOF'), 'right sql');
+    is(sql_normalize($stmt->as_subquery(1)), sql_normalize(<<'EOF'), 'right sql');
 (SELECT blog.id FROM blog WHERE (blog.name = ?))
 EOF
     is_deeply($stmt->{bind}, ['foo'], 'right bind values');
 
     $stmt->as('mysubquery');
 
-    is(sql_normalize($stmt->as_subquery), sql_normalize(<<'EOF'), 'right sql');
+    is(sql_normalize($stmt->as_subquery(1)), sql_normalize(<<'EOF'), 'right sql');
 (SELECT blog.id FROM blog WHERE (blog.name = ?)) AS mysubquery
+EOF
+
+    is(sql_normalize($stmt->as_subquery(0)), sql_normalize(<<'EOF'), 'right sql');
+(SELECT blog.id FROM blog WHERE (blog.name = ?)) mysubquery
 EOF
 };
 
@@ -186,7 +190,7 @@ FROM blog,
         SELECT entry.id, entry.blog_id, entry.text
         FROM entry
         WHERE (entry.text = ?)
-    ) AS sub
+    ) sub
 WHERE ((blog.id = sub.blog_id)) AND ((blog.id IN (?,?)))
 EOF
 
@@ -224,7 +228,7 @@ FROM blog,
         SELECT entry.id, entry.blog_id
         FROM entry
         WHERE (entry.text = ?)
-    ) AS sub
+    ) sub
 WHERE ((blog.id = sub.blog_id)) AND ((blog.id IN (?,?)))
 EOF
 
@@ -353,7 +357,7 @@ SELECT
     (SELECT max(id) FROM entry WHERE (entry.blog_id = blog.id) AND (entry.id < ?)) AS sub1
 FROM 
     blog,
-    (SELECT entry.id FROM entry WHERE (entry.text = ?)) AS sub2
+    (SELECT entry.id FROM entry WHERE (entry.text = ?)) sub2
 WHERE
     (blog.id IN (SELECT entry.blog_id FROM entry WHERE (entry.text = ?)))
 ORDER BY blog.id ASC, sub1 ASC