tidy code
[id3fs.git] / 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     pop @elements if(@elements && ref($elements[$#elements]) eq "ID3FS::PathElement::Boolean");
305     # sort elements by precedence
306     @elements=$self->sort_elements(@elements);
307     $self->{tagtree}=$self->elements_to_tree(@elements);
308     if($self->{tagtree})
309     {
310         ($self->{sqlconditions},
311          $self->{andsneeded}) = $self->{tagtree}->to_sql();
312 #       print("SQL CONDITION(", $self->{andsneeded}, "): ",
313 #             $self->{sqlconditions}, "\n");
314 #       use Data::Dumper;
315 #       print Dumper $self->{tagtree};
316     }
317 }
318
319 sub state
320 {
321     my($self, $newstate)=@_;
322     $self->{state}=$newstate if(defined($newstate));
323     return $self->{state};
324 }
325
326 sub elements_to_tree
327 {
328     my($self, @elements)=@_;
329     return undef unless(@elements);
330     my ($left, $right, $op)=(undef, undef, undef);
331     my $thing=pop @elements;
332     if(ref($thing) eq "ID3FS::PathElement::Boolean")
333     {
334         my $op=$thing;
335         $right=$self->elements_to_tree(@elements);
336         if($op->{name} ne "NOT")
337         {
338             $left=$self->elements_to_tree(@elements);
339         }
340         return ID3FS::Path::Node->new($left, $op, $right);
341     }
342     else
343     {
344         return ID3FS::Path::Node->new($thing);
345     }
346 }
347
348 # Dijkstra's shunting-yard algorithm
349 sub sort_elements
350 {
351     my ($self, @input)=@_;
352     my @opstack=();
353     my @output=();
354 #    print "INPUT: ", join(', ', map { $_->{name}; } @input), "\n";
355     while(my $thing = shift @input)
356     {
357         if(ref($thing) eq "ID3FS::PathElement::Tag")
358         {
359             push(@output, $thing);
360         }
361         elsif(ref($thing) eq "ID3FS::PathElement::Boolean")
362         {
363             # bool
364             while(@opstack &&
365                   ($priorities{$thing->{name}} <= $priorities{$opstack[$#opstack]->{name}}))
366             {
367                 push(@output, pop(@opstack));
368             }
369             push(@opstack, $thing);
370         }
371     }
372     while(@opstack)
373     {
374         push(@output, pop(@opstack));
375     }
376 #    print "STACK: ", join(', ', map { $_->{name}; } @output), "\n";
377     return @output;
378 }
379
380 sub used_tags
381 {
382     my($self)=@_;
383     print "TAGTREE UNDEF\n" unless(defined($self->{tagtree}));
384     return undef unless(defined($self->{tagtree}));
385     return($self->{tagtree}->used_tags());
386 }
387
388 sub tag_has_values
389 {
390     my($self)=@_;
391     my $tail=$self->tail();
392     print "TAIL: ", ref($tail), "\n";
393     if($tail && ref($tail) eq "ID3FS::PathElement::Tag")
394     {
395         return($self->{db}->tag_has_values($tail->{id}));
396     }
397 }
398
399 sub trailing_tag_id
400 {
401     my($self)=@_;
402     my $tail=$self->tail();
403     if($tail && ref($tail) eq "ID3FS::PathElement::Tag")
404     {
405         return($tail->{id});
406     }
407     return undef;
408 }
409
410 sub trailing_tag_parent
411 {
412     my($self)=@_;
413     my $tail=$self->tail();
414     if($tail && ref($tail) eq "ID3FS::PathElement::Tag")
415     {
416         return($tail->{parents_id});
417     }
418     return undef;
419 }
420
421 sub tail
422 {
423     my($self)=@_;
424     return($self->{elements}->[$#{$self->{elements}}]);
425 }
426
427 # the one before last
428 sub tail_parent
429 {
430     my($self)=@_;
431     return($self->{elements}->[($#{$self->{elements}}) - 1]);
432 }
433
434 ######################################################################
435
436 sub tags
437 {
438     my($self)=@_;
439     if(!@{$self->{elements}}) # /
440     {
441         my $sql="SELECT DISTINCT name FROM tags WHERE parents_id='';";
442         return($self->{db}->cmd_firstcol($sql));
443     }
444     my $hasvals=$self->tag_has_values();
445     my $parent=$self->trailing_tag_parent();
446     print "THASVALS: $hasvals\n";
447     print "TPARENT: ", (defined($parent)? $parent : "NO"), "\n";
448     my @ids=();
449     my $sql=("SELECT tags.name FROM (\n" .
450              $self->tags_subselect() .
451              ") AS subselect\n" .
452              "INNER JOIN files_x_tags ON subselect.files_id=files_x_tags.files_id\n" .
453              "INNER JOIN tags ON files_x_tags.tags_id=tags.id\n");
454     my (@allused)=$self->used_tags();
455     my @used=grep { ref($_) ne "ARRAY"; } @allused;
456     my @used_with_vals=grep { ref($_) eq "ARRAY"; } @allused;
457     print "tags(): USED: ", join(", ", @used), "\n";
458     print "tags(): USED_WITH_VALS: ", join(", ", map { "[".$_->[0]. ", ".$_->[1]."]";} @used_with_vals), "\n";
459     my @orclauses=();
460     my @andclauses=();
461     my $id=$self->trailing_tag_id();
462     if($hasvals)
463     {
464         print "HAS_VALUES\n";
465         my @values=map { "'".$_->[1]."'"; } grep { $_->[0] == $id; } @used_with_vals;
466         my $clause="(tags.parents_id='$id'";
467         if(@values)
468         {
469             $clause .= " AND tags.id NOT IN (" . join(', ', @values) . ")";
470         }
471         $clause .= ")";
472         push(@orclauses, $clause);
473     }
474     else
475     {
476         print "HASNT VALUES\n";;
477         if(@used)
478         {
479             push(@orclauses, "(NOT (tags.parents_id='' AND tags.id IN (" . join(', ', @used) . ")))");
480         }
481         for my $pair (@used_with_vals)
482         {
483             push(@orclauses, "(NOT (tags.parents_id='" . $pair->[0] . "' AND tags.id='" . $pair->[1] . "'))");
484         }
485     }
486
487     my $parentclause= "(tags.parents_id='";
488     if($hasvals)
489     {
490         $parentclause .= $id;
491     }
492     elsif($parent)
493     {
494         $parentclause .= $parent;
495     }
496     $parentclause .= "')";
497     push(@andclauses, $parentclause);
498
499     if(@orclauses)
500     {
501         push(@andclauses, join(' OR ', @orclauses));
502     }
503     if(@andclauses)
504     {
505         $sql .= "WHERE " . join(' AND ', @andclauses) . "\n";
506     }
507     $sql .= "GROUP BY tags.name;";
508     print "SQL: $sql\n";
509     my @tagnames=$self->{db}->cmd_firstcol($sql);
510     print "SUBNAMES: ", join(', ', @tagnames), "\n";
511     return(@tagnames);
512 }
513
514 sub tag_values
515 {
516     my($self, $tagid)=@_;
517     my $sql=("SELECT DISTINCT name FROM tags\n" .
518              "WHERE parents_id=?");
519     my @tags=$self->{db}->cmd_firstcol($sql, $tagid);
520     @tags=map { length($_) ? $_ : "NOVALUE"; } @tags;
521     return @tags;
522 }
523
524 sub artists
525 {
526     my($self)=@_;
527     if(!@{$self->{elements}}) # /ALL
528     {
529         my $sql="SELECT DISTINCT name FROM artists;";
530         return($self->{db}->cmd_firstcol($sql));
531     }
532     my @ids=();
533     my $sql=("SELECT artists.name FROM (\n" .
534              $self->tags_subselect() .
535              ") AS subselect\n" .
536              "INNER JOIN files ON subselect.files_id=files.id\n" .
537              "INNER JOIN artists ON files.artists_id=artists.id\n" .
538              "GROUP BY artists.name;");
539     print "SQL: $sql\n";
540     my @tagnames=$self->{db}->cmd_firstcol($sql);
541     print "ARTISTS: ", join(', ', @tagnames), "\n";
542     return(@tagnames);
543 }
544
545 sub albums
546 {
547     my($self)=@_;
548     my @ids=();
549     my $tail=$self->tail();
550     # FIXME: rework PathElements
551     if(ref($tail) eq "ID3FS::PathElement::Artist")
552     {
553         return $self->artist_albums($tail->{id});
554     }
555     my $sql=("SELECT albums.name\n" .
556              "\tFROM (\n" .
557              $self->tags_subselect() .
558              "\t) AS subselect\n" .
559              "INNER JOIN files ON subselect.files_id=files.id\n" .
560              "INNER JOIN albums ON files.albums_id=albums.id\n" .
561              "GROUP BY albums.name;");
562     print "SQL(ALBUMS): \n$sql\n";
563     my @names=$self->{db}->cmd_firstcol($sql);
564     print "ALBUMS: ", join(', ', @names), "\n";
565     return(@names);
566 }
567
568 sub artist_albums
569 {
570     my($self, $artist_id)=@_;
571     my $sql=("SELECT albums.name FROM (\n" .
572              $self->tags_subselect() .
573              "\t) AS subselect\n" .
574              "INNER JOIN files ON subselect.files_id=files.id\n" .
575              "INNER JOIN albums ON albums.id=files.albums_id\n\t" .
576              "INNER JOIN artists ON artists.id=files.artists_id\n\t" .
577              "WHERE artists.id=? and albums.name <> ''\n\t" .
578              "GROUP BY albums.name\n");
579     print "ARTIST_ALBUMS SQL: $sql\n";
580     my @albums=$self->{db}->cmd_firstcol($sql, $artist_id);
581     print "ALBUMS: ", join(', ', @albums), "\n";
582     return(@albums);
583 }
584
585 sub artist_tracks
586 {
587     my($self, $artist_id)=@_;
588     my $sql=("SELECT files.name FROM (\n" .
589              $self->tags_subselect() .
590              "\t) AS subselect\n" .
591              "INNER JOIN files ON subselect.files_id=files.id\n" .
592              "INNER JOIN artists ON artists.id=files.artists_id\n\t" .
593              "INNER JOIN albums  ON albums.id=files.albums_id\n\t" .
594              "WHERE artists.id=? AND albums.name=''\n\t" .
595              "GROUP BY files.name\n");
596     print "ARTIST_TRACKS SQL: $sql\n";
597     my @names=$self->{db}->cmd_firstcol($sql, $artist_id);
598     print "ARTISTTRACKS: ", join(', ', @names), "\n";
599     return(@names);
600 }
601
602 sub album_tracks
603 {
604     my($self, $artist_id, $album_id)=@_;
605     my $sql=("SELECT files.name FROM files\n\t" .
606              "INNER JOIN albums  ON albums.id=files.albums_id\n\t" .
607              "INNER JOIN artists ON artists.id=files.artists_id\n\t" .
608              "WHERE artists.id=? AND albums.id=?\n\t" .
609              "GROUP BY files.name\n");
610     print "ALBUM_TRACKS SQL($artist_id, $album_id): $sql\n";
611     my @names=$self->{db}->cmd_firstcol($sql, $artist_id, $album_id);
612     print "TRACKS: ", join(', ', @names), "\n";
613     return(@names);
614 }
615
616 sub tracks
617 {
618     my($self)=@_;
619     # FIXME: rework PathElements
620     my $tail=$self->tail();
621     if(ref($tail) eq "ID3FS::PathElement::Artist")
622     {
623         return $self->artist_tracks($tail->{id});
624     }
625     elsif(ref($tail) eq "ID3FS::PathElement::Album")
626     {
627         my $artist_id=0;
628         my $artist=$self->tail_parent();
629         if(defined($artist) && (ref($artist) eq "ID3FS::PathElement::Artist"))
630         {
631             # should always happen
632             $artist_id=$artist->{id};
633         }
634         return $self->album_tracks($artist_id, $tail->{id});
635     }
636
637     my $sql=("SELECT files.name\n" .
638              "\tFROM (\n" .
639              $self->tags_subselect() .
640              "\t) AS subselect\n" .
641              "INNER JOIN files ON files.id=subselect.files_id\n" .
642              "GROUP BY files.name;");
643     print "SQL: $sql\n";
644     my @names=$self->{db}->cmd_firstcol($sql);
645     print "TRACKS: ", join(', ', @names), "\n";
646     return(@names);
647 }
648
649 sub filename
650 {
651     my($self, $mountpoint)=@_;
652     my $tail=$self->tail();
653     if(ref($tail) eq "ID3FS::PathElement::File")
654     {
655         my $id=$tail->{id};
656         my $sql=("SELECT paths.name, files.name FROM files\n" .
657                  "INNER JOIN paths ON files.paths_id=paths.id\n" .
658                  "WHERE files.id=?\n" .
659                  "GROUP BY paths.name, files.name");
660         print "FILENAME SQL: $sql\n";
661         my ($path, $name)=$self->{db}->cmd_onerow($sql, $id);
662         my $id3fs_path=join('/', map { $_->{name}; }  @{$self->{elements}});
663         return($self->{db}->relativise($path, $name, $mountpoint, $id3fs_path));
664     }
665     die("DB::filename: unhandled case\n"); #FIXME
666 }
667
668 sub tags_subselect
669 {
670     my($self)=@_;
671     my $tree=$self->{tagtree};
672     my $hasvals=$self->tag_has_values();
673     my $parent=$self->trailing_tag_parent();
674
675     my $tag=undef;
676     if($hasvals)
677     {
678         $tag=$self->trailing_tag_id();
679         print "Trailing id: $tag\n";
680     }
681     my ($sqlclause, $joinsneeded)=(undef, 1);
682     ($sqlclause, $joinsneeded) = $tree->to_sql($tag) if($tree);
683     print "SQL($joinsneeded): $sqlclause\n";
684     my $sql="\tSELECT fxt1.files_id FROM tags t1";
685     my @crosses=();
686     my @inners=();
687 #    $joinsneeded++ if($tag);
688     for(my $i=1; $i <= $joinsneeded; $i++)
689     {
690         if($i > 1)
691         {
692             push(@crosses, "CROSS JOIN tags t$i");
693         }
694         my $inner=("\tINNER JOIN files_x_tags fxt$i ON " .
695                    "t${i}.id=fxt${i}.tags_id");
696         if($i>2)
697         {
698             $inner .= " AND fxt1.files_id=fxt${i}.files_id";
699         }
700         push(@inners, $inner);
701     }
702     $sql .= ("\n\t" . join(" ", @crosses)) if(@crosses);
703     $sql .= ("\n" . join("\n", @inners)) if(@inners);
704     $sql .= "\n\tWHERE $sqlclause" if($sqlclause);
705 #    if($tag)
706 #    {
707 #       $sql .= " AND t${joinsneeded}.parents_id='$tag'";
708 #    }
709     $sql .= "\n\tGROUP BY fxt1.files_id\n";
710     return $sql;
711 }
712
713 sub tags_subselect_and_not
714 {
715     my($self,@constraints)=@_;
716     my ($tags, $tags_vals, $parent)=$self->constraints_tag_list(@constraints);
717     my @tags=@$tags;
718     my @tags_vals=@$tags_vals;;
719     my $cnt=1;
720     my @andclauses=();
721     my $sql='';
722     for my $tag (@tags)
723     {
724         if($cnt == 1)
725         {
726             $sql="\tSELECT fxt" . scalar(@tags) . ".files_id FROM files_x_tags fxt1\n";
727             push(@andclauses, "\t\tfxt${cnt}.tags_id=$tag");
728         }
729         else
730         {
731             $sql .= ("\tLEFT JOIN files_x_tags fxt$cnt ON fxt" .
732                  ($cnt-1) . ".files_id=fxt${cnt}.files_id\n");
733             push(@andclauses, "\t\tfxt${cnt}.tags_id IS NULL");
734         }
735         print "AND: @andclauses\n";
736         $cnt++;
737     }
738     if(@andclauses)
739     {
740         $sql .= "\tWHERE\n\t\t";
741         $sql .= join(" AND\n\t\t", @andclauses) . "\n";
742     }
743     $sql .= "\tGROUP BY fxt". scalar(@tags).".files_id\n";
744     return $sql;
745 }
746
747
748 sub tags_subselect_and
749 {
750     my($self,@constraints)=@_;
751     my ($tags, $tags_vals, $parent)=$self->constraints_tag_list(@constraints);
752     my @tags=@$tags;
753     my @tags_vals=@$tags_vals;;
754     my $cnt=1;
755     my @andclauses=();
756     my $sql='';
757     for my $tag (@tags)
758     {
759         if($cnt == 1)
760         {
761             $sql="\tSELECT fxt" . scalar(@tags) . ".files_id FROM files_x_tags fxt1\n";
762         }
763         else
764         {
765             $sql .= ("\tINNER JOIN files_x_tags fxt$cnt ON fxt" .
766                  ($cnt-1) . ".files_id=fxt${cnt}.files_id\n");
767         }
768         push(@andclauses, "\t\tfxt${cnt}.tags_id = $tag");
769         print "AND: @andclauses\n";
770         $cnt++;
771     }
772     if(@andclauses)
773     {
774         $sql .= "\tWHERE\n\t\t";
775         $sql .= join(" AND\n\t\t", @andclauses) . "\n";
776     }
777     $sql .= "\tGROUP BY fxt". scalar(@tags).".files_id\n";
778     return $sql;
779 }
780
781 sub tags_subselect_or
782 {
783     my($self,@constraints)=@_;
784     my ($tags, $tags_vals, $parent)=$self->constraints_tag_list(@constraints);
785     my @tags=@$tags;
786     my @tags_vals=@$tags_vals;;
787
788     my $sql=("\tSELECT files_x_tags.files_id FROM tags t1\n" .
789              "\tINNER JOIN files_x_tags ON t1.id=files_x_tags.tags_id\n");
790     my @orclauses=();
791     my @andclauses=();
792     # FIXME: and / or?
793     if(@tags)
794     {
795         push(@andclauses, "( t1.parents_id=" . (defined($parent) ? $parent : "''") . " )");
796         push(@andclauses, "( t1.id IN ( " . join(', ', @tags) ." ) )");
797     }
798     for my $pair (@tags_vals)
799     {
800         my($tag, $val)=@$pair;
801         push(@orclauses, "( t1.parents_id=$tag AND t1.id=$val )");
802     }
803 #    push(@andclauses, "( t1.parents_id=" . (defined($parent) ? $parent : "''") . " )");
804     if(@orclauses)
805     {
806         push(@andclauses, join("\n\t\tOR ", @orclauses));
807     }
808     if(@andclauses)
809     {
810         $sql .= "\tWHERE\n\t\t";
811         $sql .= join("\n\t\tAND ", @andclauses) . "\n";
812     }
813     $sql .= "\tGROUP BY files_x_tags.files_id\n";
814     return $sql;
815 }
816
817 sub constraints_tag_list
818 {
819     my($self, @constraints)=@_;
820     my $lasttag=undef;
821     my @tags=();
822     my @tags_vals=();
823     for my $constraint (@constraints)
824     {
825 #       print ref($constraint), ": ", $constraint->{name}, "\n";
826         if(ref($constraint) eq "ID3FS::PathElement::Tag")
827         {
828             if(defined($lasttag))
829             {
830 #               print "TAGVAL\n";
831                 push(@tags_vals, [$lasttag, $constraint->{id}]) if defined($constraint->{id});
832                 $lasttag=undef;
833             }
834             elsif($self->tag_has_values($constraint->{id}))
835             {
836 #               print "HASVALUES\n";
837                 $lasttag=$constraint->{id} if defined($constraint->{id});
838             }
839             else
840             {
841 #               print "NOVALUES\n";
842                 push(@tags, $constraint->{id}) if(defined($constraint->{id}));
843             }
844         }
845     }
846     unless($self->{db}->{postgres})
847     {
848         @tags=map{ "\"$_\""; } @tags;
849         @tags_vals=map( { [ map({ "\"$_\""; } @$_ ) ] } @tags_vals);
850         $lasttag="\"$lasttag\"" if defined($lasttag);
851     }
852     return(\@tags, \@tags_vals, $lasttag);
853 }
854
855
856 sub bare_tags
857 {
858     my($self)=@_;
859     my $sql=("SELECT tags.name FROM tags\n" .
860              "WHERE tags.parents_id=''\n" .
861              "GROUP BY tags.name\n");
862     my @names=$self->{db}->cmd_firstcol($sql);
863     return (@names);
864 }
865
866 sub tags_with_values
867 {
868     # FIXME: only shows one level of tag depth
869     my($self)=@_;
870     my $sql=("SELECT p.name, t.name  FROM tags t\n" .
871              "INNER JOIN tags p ON t.parents_id=p.id\n" .
872              "GROUP BY p.name, t.name\n");
873     print "SQL: $sql\n";
874     my $result=$self->{db}->cmd_rows($sql);
875     my $tags={};
876     for my $pair (@$result)
877     {
878         push(@{$tags->{$pair->[0]}}, $pair->[1]);
879     }
880     return $tags;
881 }
882
883 sub lookup_id
884 {
885     my($self, $table, $name)=@_;
886     my($id)=$self->{db}->cmd_onerow("SELECT id FROM $table where name=?", $name);
887     return $id;
888 }
889
890 1;