lib/ID3FS/Path.pm

   1 package ID3FS::Path;
   2
   3 use strict;
   4 use warnings;
   5 use ID3FS::PathElement::Artist;
   6 use ID3FS::PathElement::Album;
   7 use ID3FS::PathElement::Boolean;
   8 use ID3FS::PathElement::File;
   9 use ID3FS::PathElement::Tag;
  10 use ID3FS::PathElement::Tagval;
  11 use ID3FS::Path::Node;
  12
  13 our ($STATE_INVALID, $STATE_ROOT, $STATE_TAG, $STATE_TAGVAL,
  14      $STATE_BOOLEAN, $STATE_ALBUMS, $STATE_TRACKLIST,
  15      $STATE_FILE)=(0..7);
  16
  17 our %priorities=( "OR" => 0, "AND" => 1, "NOT" => 2 );
  18
  19 sub new
  20 {
  21     my $proto=shift;
  22     my $class=ref($proto) || $proto;
  23     my $self={};
  24     bless($self,$class);
  25
  26     $self->{elements}=[];
  27     $self->{db}=shift;
  28     $self->{path}=shift;
  29     $self->parse();
  30 #    print "STATE: ", $self->state(), "\n";
  31     return $self;
  32 }
  33
  34 sub isdir
  35 {
  36     my($self)=@_;
  37     if(($self->state() == $STATE_FILE) ||
  38        ($self->state() == $STATE_INVALID))
  39     {
  40         return 0;
  41     }
  42     return 1;
  43 }
  44
  45 sub isfile
  46 {
  47     my($self)=@_;
  48     return 1 if($self->state() == $STATE_FILE);
  49     return 0;
  50 }
  51
  52 sub isvalid
  53 {
  54     my($self)=@_;
  55     return($self->state() != $STATE_INVALID);
  56 }
  57
  58 sub dest
  59 {
  60     my($self, $mountpoint)=@_;
  61     if($self->state() == $STATE_FILE)
  62     {
  63         return $self->filename($mountpoint, $self);
  64     }
  65     return "ERROR"; #should never happen?
  66 }
  67
  68 sub dirents
  69 {
  70     my($self)=@_;
  71     my @dents=();
  72     my $state=$self->state();
  73 #    print "DIRENTS: STATE: $state\n";
  74 #    print "DIRENTS: FILE: $self->{path}\n";
  75     if($state==$STATE_TAG || $state==$STATE_TAGVAL)
  76     {
  77         my $tag=$self->tail();
  78         if($state==$STATE_TAG &&
  79            defined($tag) &&
  80            ref($tag) eq "ID3FS::PathElement::Tag" &&
  81            $self->{db}->tag_has_values($tag->{id}))
  82         {
  83             @dents=$self->tags();
  84         }
  85         else
  86         {
  87             @dents=(qw(AND OR TRACKS NOARTIST),
  88                     $self->artists());
  89         }
  90     }
  91     elsif($state==$STATE_BOOLEAN)
  92     {
  93         my $parent=$self->tail();
  94         unless(defined($parent) &&
  95                ref($parent) eq "ID3FS::PathElement::Boolean" &&
  96                $parent->{name} eq "NOT")
  97         {
  98             push(@dents, "NOT");
  99         }
 100         push(@dents, $self->tags());
 101     }
 102     elsif($state==$STATE_ROOT)
 103     {
 104         @dents=(qw(ALL NOT), $self->tags());
 105     }
 106     elsif($state==$STATE_ALBUMS)
 107     {
 108         @dents=(qw(TRACKS NOALBUM),$self->albums());
 109     }
 110     elsif($state==$STATE_TRACKLIST)
 111     {
 112         @dents=$self->tracks();
 113     }
 114     else
 115     {
 116         print "DIRENTS: UNHANDLED STATE: $state\n";
 117     }
 118     return(@dents);
 119 }
 120
 121 sub parse
 122 {
 123     my($self)=@_;
 124     @{$self->{components}}=split(/\//, $self->{path});
 125     shift @{$self->{components}}; # drop empty field before leading /
 126 #    print "PATH: $self->{path}\n";
 127     $self->state($STATE_ROOT);
 128     return if($self->{path} eq "/");
 129     my @parts=@{$self->{components}};
 130     my($tag, $tagval);
 131     $self->{elements}=[];
 132     while(my $name=shift @parts)
 133     {
 134 #       print "NAME: $name\n";
 135         my $state=$self->state();
 136         if($state==$STATE_INVALID)
 137         {
 138 #           print "SM: INVALID: $name\n";
 139             return;
 140         }
 141         elsif($state==$STATE_ROOT)
 142         {
 143 #           print "SM: ROOT: $name\n";
 144             if($name eq "ALL")
 145             {
 146                 $self->state($STATE_TAG);
 147             }
 148             elsif($name eq "NOT")
 149             {
 150                 push(@{$self->{elements}}, ID3FS::PathElement::Boolean->new($self->{db}, $name));
 151                 $self->state($STATE_BOOLEAN);
 152             }
 153             else
 154             {
 155                 $tag=ID3FS::PathElement::Tag->new($self->{db}, $name);
 156                 if($tag)
 157                 {
 158                     push(@{$self->{elements}}, $tag);
 159                     $self->state($STATE_TAG);
 160                 }
 161                 else
 162                 {
 163                     $self->state($STATE_INVALID);
 164                 }
 165             }
 166         }
 167         elsif($state==$STATE_TAG || $state==$STATE_TAGVAL)
 168         {
 169 #           print "SM: TAG/TAGVAL($state): $name\n";
 170             my $tag=$self->tail();
 171             if($state==$STATE_TAG &&
 172                defined($tag) &&
 173                ref($tag) eq "ID3FS::PathElement::Tag" &&
 174                $self->{db}->tag_has_values($tag->{id}))
 175             {
 176 #               print "Parsing: parent: $tag->{id}\n";
 177                 my $tagval=ID3FS::PathElement::Tag->new($self->{db}, $name, $tag->{id});
 178                 if(defined($tagval))
 179                 {
 180                     $self->state($STATE_TAGVAL);
 181                     # stay in tag state
 182                     push(@{$self->{elements}}, $tagval);
 183                 }
 184                 else
 185                 {
 186                     $self->state($STATE_INVALID);
 187                 }
 188             }
 189             elsif($name eq "TRACKS")
 190             {
 191                 $self->state($STATE_TRACKLIST);
 192             }
 193             elsif($name eq "NOARTIST")
 194             {
 195                 $self->state($STATE_TRACKLIST);
 196             }
 197             elsif($name eq "AND")
 198             {
 199                 $self->state($STATE_BOOLEAN);
 200                 push(@{$self->{elements}}, ID3FS::PathElement::Boolean->new($self->{db}, $name));
 201             }
 202             elsif($name eq "OR")
 203             {
 204                 $self->state($STATE_BOOLEAN);
 205                 push(@{$self->{elements}}, ID3FS::PathElement::Boolean->new($self->{db}, $name));
 206             }
 207             else
 208             {
 209                 my $artist=ID3FS::PathElement::Artist->new($self->{db}, $name);
 210                 if($artist)
 211                 {
 212                     push(@{$self->{elements}}, $artist);
 213                     $self->state($STATE_ALBUMS);
 214                 }
 215                 else
 216                 {
 217                     $self->state($STATE_INVALID);
 218                 }
 219             }
 220         }
 221         elsif($state==$STATE_BOOLEAN)
 222         {
 223 #           print "SM: BOOLEAN: $name\n";
 224             my $parent=$self->tail();
 225             my $allownot=1;
 226             if(defined($parent) &&
 227                ref($parent) eq "ID3FS::PathElement::Boolean" &&
 228                $parent->{name} eq "NOT")
 229             {
 230                 $allownot=0;
 231             }
 232             if($allownot && $name eq "NOT")
 233             {
 234                 $self->state($STATE_BOOLEAN);
 235                 push(@{$self->{elements}}, ID3FS::PathElement::Boolean->new($self->{db}, $name));
 236             }
 237             else
 238             {
 239                 my $tag=ID3FS::PathElement::Tag->new($self->{db}, $name);
 240                 if($tag)
 241                 {
 242                     push(@{$self->{elements}}, $tag);
 243                     $self->state($STATE_TAG);
 244                 }
 245                 else
 246                 {
 247                     $self->state($STATE_INVALID);
 248                 }
 249             }
 250         }
 251         elsif($state==$STATE_ALBUMS)
 252         {
 253 #           print "SM: ALBUM: $name\n";
 254             if($name eq "TRACKS")
 255             {
 256                 $self->state($STATE_TRACKLIST);
 257             }
 258             elsif($name eq "NOALBUM")
 259             {
 260                 $self->state($STATE_TRACKLIST);
 261             }
 262             else
 263             {
 264                 my $album=ID3FS::PathElement::Album->new($self->{db}, $name);
 265                 if($album)
 266                 {
 267                     push(@{$self->{elements}}, $album);
 268                     $self->state($STATE_TRACKLIST);
 269                 }
 270                 else
 271                 {
 272                     $self->state($STATE_INVALID);
 273                 }
 274             }
 275         }
 276         elsif($state==$STATE_TRACKLIST)
 277         {
 278 #           print "SM: TRACKLIST: $name\n";
 279             my $track=ID3FS::PathElement::File->new($self->{db}, $name);
 280             if($track)
 281             {
 282                 push(@{$self->{elements}}, $track);
 283                 $self->state($STATE_FILE);
 284             }
 285             else
 286             {
 287                 $self->state($STATE_INVALID);
 288             }
 289         }
 290         elsif($state==$STATE_FILE)
 291         {
 292 #           print "SM: FILE: $name\n";
 293             # Can't have anything after a filename
 294             $self->state($STATE_INVALID);
 295         }
 296         else
 297         {
 298             print "SM: ERROR: UNKNOWN STATE: $self->{state}\n";
 299             $self->state($STATE_INVALID);
 300         }
 301     }
 302     # remove trailing boolean
 303     my @elements=@{$self->{elements}};
 304     while(@elements && ref($elements[$#elements]) eq "ID3FS::PathElement::Boolean")
 305     {
 306         pop @elements;
 307     }
 308     # sort elements by precedence
 309     @elements=$self->sort_elements(@elements);
 310     $self->{tagtree}=$self->elements_to_tree(\@elements);
 311     if($self->{tagtree})
 312     {
 313         ($self->{sqlconditions},
 314          $self->{andsneeded}) = $self->{tagtree}->to_sql();
 315 #       print "TREE: ",  $self->{tagtree}->print(), "\n";
 316 #       print("SQL CONDITION(", $self->{andsneeded}, "): ",
 317 #             $self->{sqlconditions}, "\n");
 318 #       use Data::Dumper;
 319 #       print Dumper $self->{tagtree};
 320     }
 321 }
 322
 323 sub state
 324 {
 325     my($self, $newstate)=@_;
 326     $self->{state}=$newstate if(defined($newstate));
 327     return $self->{state};
 328 }
 329
 330 sub elements_to_tree
 331 {
 332     my($self, $elements)=@_;
 333     return undef unless(@$elements);
 334     my ($left, $right, $op)=(undef, undef, undef);
 335     my $thing=pop @$elements;
 336     if(ref($thing) eq "ID3FS::PathElement::Boolean")
 337     {
 338         my $op=$thing;
 339         $right=$self->elements_to_tree($elements);
 340         if($op->{name} ne "NOT")
 341         {
 342             $left=$self->elements_to_tree($elements);
 343         }
 344         return ID3FS::Path::Node->new($left, $op, $right);
 345     }
 346     else
 347     {
 348         return ID3FS::Path::Node->new($thing);
 349     }
 350 }
 351
 352 # Dijkstra's shunting-yard algorithm
 353 sub sort_elements
 354 {
 355     my ($self, @input)=@_;
 356     my @opstack=();
 357     my @output=();
 358 #    print "INPUT: ", join(', ', map { $_->{name}; } @input), "\n";
 359     while(my $thing = shift @input)
 360     {
 361         if(ref($thing) eq "ID3FS::PathElement::Tag")
 362         {
 363             # Handle tag values by dropping parent
 364             if(@input && ref($input[0]) eq "ID3FS::PathElement::Tag")
 365             {
 366                 $thing=shift @input;
 367             }
 368             push(@output, $thing);
 369         }
 370         elsif(ref($thing) eq "ID3FS::PathElement::Boolean")
 371         {
 372             # bool
 373             while(@opstack &&
 374                   ($priorities{$thing->{name}} <= $priorities{$opstack[$#opstack]->{name}}))
 375             {
 376                 push(@output, pop(@opstack));
 377             }
 378             push(@opstack, $thing);
 379         }
 380     }
 381     while(@opstack)
 382     {
 383         push(@output, pop(@opstack));
 384     }
 385 #    print "STACK: ", join(', ', map { $_->{name}; } @output), "\n";
 386     return @output;
 387 }
 388
 389 sub used_tags
 390 {
 391     my($self)=@_;
 392     print "TAGTREE UNDEF\n" unless(defined($self->{tagtree}));
 393     return undef unless(defined($self->{tagtree}));
 394     return($self->{tagtree}->used_tags());
 395 }
 396
 397 sub tag_has_values
 398 {
 399     my($self)=@_;
 400     my $tail=$self->tail();
 401     if($tail && ref($tail) eq "ID3FS::PathElement::Tag")
 402     {
 403         return($self->{db}->tag_has_values($tail->{id}));
 404     }
 405 }
 406
 407 sub trailing_tag_id
 408 {
 409     my($self)=@_;
 410     my $tail=$self->tail();
 411     if($tail && ref($tail) eq "ID3FS::PathElement::Tag")
 412     {
 413         return($tail->{id});
 414     }
 415     return undef;
 416 }
 417
 418 sub trailing_tag_parent
 419 {
 420     my($self)=@_;
 421     my $tail=$self->tail();
 422     if($tail && ref($tail) eq "ID3FS::PathElement::Tag")
 423     {
 424         return($tail->{parents_id});
 425     }
 426     return undef;
 427 }
 428
 429 sub tail
 430 {
 431     my($self)=@_;
 432     return($self->{elements}->[$#{$self->{elements}}]);
 433 }
 434
 435 # the one before last
 436 sub tail_parent
 437 {
 438     my($self)=@_;
 439     return($self->{elements}->[($#{$self->{elements}}) - 1]);
 440 }
 441
 442 ######################################################################
 443
 444 sub tags
 445 {
 446     my($self)=@_;
 447     if(!@{$self->{elements}}) # /
 448     {
 449         my $sql="SELECT DISTINCT name FROM tags WHERE parents_id='';";
 450         return($self->{db}->cmd_firstcol($sql));
 451     }
 452     my $hasvals=$self->tag_has_values();
 453     my $parent=$self->trailing_tag_parent();
 454 #    print "THASVALS: $hasvals\n";
 455 #    print "TPARENT: ", (defined($parent)? $parent : "NO"), "\n";
 456     my @ids=();
 457     my $sql=("SELECT tags.name FROM (\n" .
 458              $self->tags_subselect() .
 459              ") AS subselect\n" .
 460              "INNER JOIN files_x_tags ON subselect.files_id=files_x_tags.files_id\n" .
 461              "INNER JOIN tags ON files_x_tags.tags_id=tags.id\n");
 462     my (@allused)=$self->used_tags();
 463     my @used=grep { ref($_) ne "ARRAY"; } @allused;
 464     my @used_with_vals=grep { ref($_) eq "ARRAY"; } @allused;
 465 #    print "tags(): USED: ", join(", ", @used), "\n";
 466 #    print "tags(): USED_WITH_VALS: ", join(", ", map { "[".$_->[0]. ", ".$_->[1]."]";} @used_with_vals), "\n";
 467     my @orclauses=();
 468     my @andclauses=();
 469     my $id=$self->trailing_tag_id();
 470     if($hasvals)
 471     {
 472 #       print "HAS_VALUES\n";
 473         my @values=map { "'".$_->[1]."'"; } grep { $_->[0] == $id; } @used_with_vals;
 474         my $clause="(tags.parents_id='$id'";
 475         if(@values)
 476         {
 477             $clause .= " AND tags.id NOT IN (" . join(', ', @values) . ")";
 478         }
 479         $clause .= ")";
 480         push(@andclauses, $clause);
 481     }
 482     else
 483     {
 484 #       print "HASNT VALUES\n";;
 485         if(@used)
 486         {
 487             push(@andclauses, "(NOT (tags.parents_id='' AND tags.id IN (" . join(', ', @used) . ")))");
 488         }
 489         for my $pair (@used_with_vals)
 490         {
 491             push(@andclauses, "(NOT (tags.parents_id='" . $pair->[0] . "' AND tags.id='" . $pair->[1] . "'))");
 492         }
 493     }
 494
 495     my $parentclause= "(tags.parents_id='";
 496     if($hasvals)
 497     {
 498         $parentclause .= $id;
 499     }
 500     elsif($parent)
 501     {
 502         $parentclause .= $parent;
 503     }
 504     $parentclause .= "')";
 505     push(@andclauses, $parentclause);
 506
 507     if(@orclauses)
 508     {
 509         push(@andclauses, '( ' . join(' OR ', @orclauses) . ' )');
 510     }
 511     if(@andclauses)
 512     {
 513         $sql .= "WHERE " . join(' AND ', @andclauses) . "\n";
 514     }
 515     $sql .= "GROUP BY tags.name;";
 516     print "SQL: $sql\n";
 517     my @tagnames=$self->{db}->cmd_firstcol($sql);
 518     print "SUBNAMES: ", join(', ', @tagnames), "\n";
 519     return(@tagnames);
 520 }
 521
 522 sub tag_values
 523 {
 524     my($self, $tagid)=@_;
 525     my $sql=("SELECT DISTINCT name FROM tags\n" .
 526              "WHERE parents_id=?");
 527     my @tags=$self->{db}->cmd_firstcol($sql, $tagid);
 528     @tags=map { length($_) ? $_ : "NOVALUE"; } @tags;
 529     return @tags;
 530 }
 531
 532 sub artists
 533 {
 534     my($self)=@_;
 535     if(!@{$self->{elements}}) # /ALL
 536     {
 537         my $sql="SELECT DISTINCT name FROM artists;";
 538         return($self->{db}->cmd_firstcol($sql));
 539     }
 540     my @ids=();
 541     my $sql=("SELECT artists.name FROM (\n" .
 542              $self->tags_subselect() .
 543              ") AS subselect\n" .
 544              "INNER JOIN files ON subselect.files_id=files.id\n" .
 545              "INNER JOIN artists ON files.artists_id=artists.id\n" .
 546              "GROUP BY artists.name;");
 547     print "SQL: $sql\n";
 548     my @tagnames=$self->{db}->cmd_firstcol($sql);
 549     print "ARTISTS: ", join(', ', @tagnames), "\n";
 550     return(@tagnames);
 551 }
 552
 553 sub albums
 554 {
 555     my($self)=@_;
 556     my @ids=();
 557     my $tail=$self->tail();
 558     # FIXME: rework PathElements
 559     if(ref($tail) eq "ID3FS::PathElement::Artist")
 560     {
 561         return $self->artist_albums($tail->{id});
 562     }
 563     my $sql=("SELECT albums.name\n" .
 564              "\tFROM (\n" .
 565              $self->tags_subselect() .
 566              "\t) AS subselect\n" .
 567              "INNER JOIN files ON subselect.files_id=files.id\n" .
 568              "INNER JOIN albums ON files.albums_id=albums.id\n" .
 569              "GROUP BY albums.name;");
 570     print "SQL(ALBUMS): \n$sql\n";
 571     my @names=$self->{db}->cmd_firstcol($sql);
 572     print "ALBUMS: ", join(', ', @names), "\n";
 573     return(@names);
 574 }
 575
 576 sub artist_albums
 577 {
 578     my($self, $artist_id)=@_;
 579     my $sql=("SELECT albums.name FROM (\n" .
 580              $self->tags_subselect() .
 581              "\t) AS subselect\n" .
 582              "INNER JOIN files ON subselect.files_id=files.id\n" .
 583              "INNER JOIN albums ON albums.id=files.albums_id\n\t" .
 584              "INNER JOIN artists ON artists.id=files.artists_id\n\t" .
 585              "WHERE artists.id=? and albums.name <> ''\n\t" .
 586              "GROUP BY albums.name\n");
 587     print "ARTIST_ALBUMS SQL: $sql\n";
 588     my @albums=$self->{db}->cmd_firstcol($sql, $artist_id);
 589     print "ALBUMS: ", join(', ', @albums), "\n";
 590     return(@albums);
 591 }
 592
 593 sub artist_tracks
 594 {
 595     my($self, $artist_id)=@_;
 596     my $sql=("SELECT files.name FROM (\n" .
 597              $self->tags_subselect() .
 598              "\t) AS subselect\n" .
 599              "INNER JOIN files ON subselect.files_id=files.id\n" .
 600              "INNER JOIN artists ON artists.id=files.artists_id\n\t" .
 601              "INNER JOIN albums  ON albums.id=files.albums_id\n\t" .
 602              "WHERE artists.id=? AND albums.name=''\n\t" .
 603              "GROUP BY files.name\n");
 604     print "ARTIST_TRACKS SQL: $sql\n";
 605     my @names=$self->{db}->cmd_firstcol($sql, $artist_id);
 606     print "ARTISTTRACKS: ", join(', ', @names), "\n";
 607     return(@names);
 608 }
 609
 610 sub album_tracks
 611 {
 612     my($self, $artist_id, $album_id)=@_;
 613     my $sql=("SELECT files.name FROM files\n\t" .
 614              "INNER JOIN albums  ON albums.id=files.albums_id\n\t" .
 615              "INNER JOIN artists ON artists.id=files.artists_id\n\t" .
 616              "WHERE artists.id=? AND albums.id=?\n\t" .
 617              "GROUP BY files.name\n");
 618     print "ALBUM_TRACKS SQL($artist_id, $album_id): $sql\n";
 619     my @names=$self->{db}->cmd_firstcol($sql, $artist_id, $album_id);
 620     print "TRACKS: ", join(', ', @names), "\n";
 621     return(@names);
 622 }
 623
 624 sub tracks
 625 {
 626     my($self)=@_;
 627     # FIXME: rework PathElements
 628     my $tail=$self->tail();
 629     if(ref($tail) eq "ID3FS::PathElement::Artist")
 630     {
 631         return $self->artist_tracks($tail->{id});
 632     }
 633     elsif(ref($tail) eq "ID3FS::PathElement::Album")
 634     {
 635         my $artist_id=0;
 636         my $artist=$self->tail_parent();
 637         if(defined($artist) && (ref($artist) eq "ID3FS::PathElement::Artist"))
 638         {
 639             # should always happen
 640             $artist_id=$artist->{id};
 641         }
 642         return $self->album_tracks($artist_id, $tail->{id});
 643     }
 644
 645     my $sql=("SELECT files.name\n" .
 646              "\tFROM (\n" .
 647              $self->tags_subselect() .
 648              "\t) AS subselect\n" .
 649              "INNER JOIN files ON files.id=subselect.files_id\n" .
 650              "GROUP BY files.name;");
 651     print "SQL: $sql\n";
 652     my @names=$self->{db}->cmd_firstcol($sql);
 653     print "TRACKS: ", join(', ', @names), "\n";
 654     return(@names);
 655 }
 656
 657 sub filename
 658 {
 659     my($self, $mountpoint)=@_;
 660     my $tail=$self->tail();
 661     if(ref($tail) eq "ID3FS::PathElement::File")
 662     {
 663         my $id=$tail->{id};
 664         my $sql=("SELECT paths.name, files.name FROM files\n" .
 665                  "INNER JOIN paths ON files.paths_id=paths.id\n" .
 666                  "WHERE files.id=?\n" .
 667                  "GROUP BY paths.name, files.name");
 668         print "FILENAME SQL: $sql\n";
 669         my ($path, $name)=$self->{db}->cmd_onerow($sql, $id);
 670         my $id3fs_path=join('/', map { $_->{name}; }  @{$self->{elements}});
 671         return($self->{db}->relativise($path, $name, $mountpoint, $id3fs_path));
 672     }
 673     die("DB::filename: unhandled case\n"); #FIXME
 674 }
 675
 676 sub tags_subselect
 677 {
 678     my($self)=@_;
 679     my $tree=$self->{tagtree};
 680     my $hasvals=$self->tag_has_values();
 681     my $parent=$self->trailing_tag_parent();
 682
 683 #    print "ELEMENTS: ", join('/', map { $_->{name}; } @{$self->{elements}}), "\n";
 684 #    print "TREE: ", $tree->print(), "\n";
 685     my $tag=undef;
 686     if($hasvals)
 687     {
 688         $tag=$self->trailing_tag_id();
 689 #       print "Trailing id: $tag\n";
 690     }
 691     my ($sqlclause, $joinsneeded)=(undef, 1);
 692     ($sqlclause, $joinsneeded) = $tree->to_sql($tag) if($tree);
 693 #    print "SQL($joinsneeded): $sqlclause\n";
 694     my $sql="\tSELECT fxt1.files_id FROM tags t1";
 695     my @crosses=();
 696     my @inners=();
 697 #    $joinsneeded++ if($tag);
 698     for(my $i=1; $i <= $joinsneeded; $i++)
 699     {
 700         my $inner=("\tINNER JOIN files_x_tags fxt$i ON " .
 701                    "t${i}.id=fxt${i}.tags_id");
 702         if($i > 1)
 703         {
 704             push(@crosses, "CROSS JOIN tags t$i");
 705             $inner .= " AND fxt1.files_id=fxt${i}.files_id";
 706         }
 707         push(@inners, $inner);
 708     }
 709     $sql .= ("\n\t" . join(" ", @crosses)) if(@crosses);
 710     $sql .= ("\n" . join("\n", @inners)) if(@inners);
 711     $sql .= "\n\tWHERE $sqlclause" if($sqlclause);
 712 #    if($tag)
 713 #    {
 714 #       $sql .= " AND t${joinsneeded}.parents_id='$tag'";
 715 #    }
 716     $sql .= "\n\tGROUP BY fxt1.files_id\n";
 717     return $sql;
 718 }
 719
 720 sub tags_subselect_and_not
 721 {
 722     my($self,@constraints)=@_;
 723     my ($tags, $tags_vals, $parent)=$self->constraints_tag_list(@constraints);
 724     my @tags=@$tags;
 725     my @tags_vals=@$tags_vals;;
 726     my $cnt=1;
 727     my @andclauses=();
 728     my $sql='';
 729     for my $tag (@tags)
 730     {
 731         if($cnt == 1)
 732         {
 733             $sql="\tSELECT fxt" . scalar(@tags) . ".files_id FROM files_x_tags fxt1\n";
 734             push(@andclauses, "\t\tfxt${cnt}.tags_id=$tag");
 735         }
 736         else
 737         {
 738             $sql .= ("\tLEFT JOIN files_x_tags fxt$cnt ON fxt" .
 739                  ($cnt-1) . ".files_id=fxt${cnt}.files_id\n");
 740             push(@andclauses, "\t\tfxt${cnt}.tags_id IS NULL");
 741         }
 742         print "AND: @andclauses\n";
 743         $cnt++;
 744     }
 745     if(@andclauses)
 746     {
 747         $sql .= "\tWHERE\n\t\t";
 748         $sql .= join(" AND\n\t\t", @andclauses) . "\n";
 749     }
 750     $sql .= "\tGROUP BY fxt". scalar(@tags).".files_id\n";
 751     return $sql;
 752 }
 753
 754
 755 sub tags_subselect_and
 756 {
 757     my($self,@constraints)=@_;
 758     my ($tags, $tags_vals, $parent)=$self->constraints_tag_list(@constraints);
 759     my @tags=@$tags;
 760     my @tags_vals=@$tags_vals;;
 761     my $cnt=1;
 762     my @andclauses=();
 763     my $sql='';
 764     for my $tag (@tags)
 765     {
 766         if($cnt == 1)
 767         {
 768             $sql="\tSELECT fxt" . scalar(@tags) . ".files_id FROM files_x_tags fxt1\n";
 769         }
 770         else
 771         {
 772             $sql .= ("\tINNER JOIN files_x_tags fxt$cnt ON fxt" .
 773                  ($cnt-1) . ".files_id=fxt${cnt}.files_id\n");
 774         }
 775         push(@andclauses, "\t\tfxt${cnt}.tags_id = $tag");
 776         print "AND: @andclauses\n";
 777         $cnt++;
 778     }
 779     if(@andclauses)
 780     {
 781         $sql .= "\tWHERE\n\t\t";
 782         $sql .= join(" AND\n\t\t", @andclauses) . "\n";
 783     }
 784     $sql .= "\tGROUP BY fxt". scalar(@tags).".files_id\n";
 785     return $sql;
 786 }
 787
 788 sub tags_subselect_or
 789 {
 790     my($self,@constraints)=@_;
 791     my ($tags, $tags_vals, $parent)=$self->constraints_tag_list(@constraints);
 792     my @tags=@$tags;
 793     my @tags_vals=@$tags_vals;;
 794
 795     my $sql=("\tSELECT files_x_tags.files_id FROM tags t1\n" .
 796              "\tINNER JOIN files_x_tags ON t1.id=files_x_tags.tags_id\n");
 797     my @orclauses=();
 798     my @andclauses=();
 799     # FIXME: and / or?
 800     if(@tags)
 801     {
 802         push(@andclauses, "( t1.parents_id=" . (defined($parent) ? $parent : "''") . " )");
 803         push(@andclauses, "( t1.id IN ( " . join(', ', @tags) ." ) )");
 804     }
 805     for my $pair (@tags_vals)
 806     {
 807         my($tag, $val)=@$pair;
 808         push(@orclauses, "( t1.parents_id=$tag AND t1.id=$val )");
 809     }
 810 #    push(@andclauses, "( t1.parents_id=" . (defined($parent) ? $parent : "''") . " )");
 811     if(@orclauses)
 812     {
 813         push(@andclauses, join("\n\t\tOR ", @orclauses));
 814     }
 815     if(@andclauses)
 816     {
 817         $sql .= "\tWHERE\n\t\t";
 818         $sql .= join("\n\t\tAND ", @andclauses) . "\n";
 819     }
 820     $sql .= "\tGROUP BY files_x_tags.files_id\n";
 821     return $sql;
 822 }
 823
 824 sub constraints_tag_list
 825 {
 826     my($self, @constraints)=@_;
 827     my $lasttag=undef;
 828     my @tags=();
 829     my @tags_vals=();
 830     for my $constraint (@constraints)
 831     {
 832 #       print ref($constraint), ": ", $constraint->{name}, "\n";
 833         if(ref($constraint) eq "ID3FS::PathElement::Tag")
 834         {
 835             if(defined($lasttag))
 836             {
 837 #               print "TAGVAL\n";
 838                 push(@tags_vals, [$lasttag, $constraint->{id}]) if defined($constraint->{id});
 839                 $lasttag=undef;
 840             }
 841             elsif($self->tag_has_values($constraint->{id}))
 842             {
 843 #               print "HASVALUES\n";
 844                 $lasttag=$constraint->{id} if defined($constraint->{id});
 845             }
 846             else
 847             {
 848 #               print "NOVALUES\n";
 849                 push(@tags, $constraint->{id}) if(defined($constraint->{id}));
 850             }
 851         }
 852     }
 853     unless($self->{db}->{postgres})
 854     {
 855         @tags=map{ "\"$_\""; } @tags;
 856         @tags_vals=map( { [ map({ "\"$_\""; } @$_ ) ] } @tags_vals);
 857         $lasttag="\"$lasttag\"" if defined($lasttag);
 858     }
 859     return(\@tags, \@tags_vals, $lasttag);
 860 }
 861
 862
 863 sub bare_tags
 864 {
 865     my($self)=@_;
 866     my $sql=("SELECT tags.name FROM tags\n" .
 867              "WHERE tags.parents_id=''\n" .
 868              "GROUP BY tags.name\n");
 869     my @names=$self->{db}->cmd_firstcol($sql);
 870     return (@names);
 871 }
 872
 873 sub tags_with_values
 874 {
 875     # FIXME: only shows one level of tag depth
 876     my($self)=@_;
 877     my $sql=("SELECT p.name, t.name  FROM tags t\n" .
 878              "INNER JOIN tags p ON t.parents_id=p.id\n" .
 879              "GROUP BY p.name, t.name\n");
 880     print "SQL: $sql\n";
 881     my $result=$self->{db}->cmd_rows($sql);
 882     my $tags={};
 883     for my $pair (@$result)
 884     {
 885         push(@{$tags->{$pair->[0]}}, $pair->[1]);
 886     }
 887     return $tags;
 888 }
 889
 890 sub lookup_id
 891 {
 892     my($self, $table, $name)=@_;
 893     my($id)=$self->{db}->cmd_onerow("SELECT id FROM $table where name=?", $name);
 894     return $id;
 895 }
 896
 897 1;