New Import

2 files changed, 244 insertions, 0 deletions

diff --git a/lib/perl/Local/Ampache/Ampache.pm b/lib/perl/Local/Ampache/Ampache.pm
new file mode 100755
index 00000000..3bceb7e6
--- /dev/null
+++ b/lib/perl/Local/Ampache/Ampache.pm
@@ -0,0 +1,237 @@
+#!/usr/bin/perl -w 
+
+# Find and file away MP3's.  Run multiple times and will
+#  ignore addition of duplicates in db (based on MD5 hash
+#  of full file path.
+
+package Local::Ampache;
+#use File::Find;
+use DBI;
+#use strict;
+use Data::Dumper;
+use vars qw($VERSION @ISA @EXPORT @EXPORT_OK %ampache);
+require Exporter;
+
+@ISA = qw(Exporter AutoLoader);
+@EXPORT = qw(
+
+);
+
+my $TRUE = 1;
+my $FALSE = 0;
+$VERSION = '';
+
+
+my %ampache = ();
+
+
+sub new {
+	my ($class, $path) = @_;
+
+
+	open(CONFIG, "< $path/config/ampache.cfg")
+        	or die "Could not find $path/config/ampache.cfg.  Is it readable by me?\n";
+
+        my %config = ();
+
+        while (<CONFIG>) {
+                next if ($_ =~ /^#.*/); 
+
+                if ( $_ =~ /(.*?)\s+=\s+(.*)/ ) {
+                        $config{$1} = $2;
+                }
+        }
+
+	my $name = $config{'local_db'};
+
+        my $self = 
+                {
+                        _name         => $config{'local_db'},
+                        _database     => $config{'local_db'},
+                        _sth_cache    => {},
+                        _connect      => {
+                                dbd      => 'mysql',
+                                host     => $config{'local_host'},
+                                port     => '3306',
+                                username => $config{'local_username'},
+                                password => $config{'local_pass'} 
+                        },
+                _dbh       => '',
+                _path   => $path,
+                _config => \%config,
+                _debug  => $FALSE
+        };
+
+        $VERSION = $config{'VERSION'};
+
+	$Local::Ampache::ampache{$name} = bless ($self, $class);
+	
+	$self->{_dbh} = $self->dbh( $name );
+	
+	return $self;
+
+} # End New Ampache Module
+
+sub DESTROY {
+	my ($self) = @_;
+   
+	foreach my $sth (values %{$self->{_sth_cache}}) {
+		if (defined($sth)) { $sth->finish(); } 
+	}
+	
+	if (defined($self->{_dbh}) and $self->{_dbh} ne "") {
+		$self->{_dbh}->disconnect();
+	}
+}
+
+sub get
+{
+    my ($class, $name) = @_;
+    
+    if (not $Local::Ampache::ampache{$name}) {
+        $Local::Ampache::ampache{$name} = Local::Ampache->new($name);
+    }
+    return bless $Local::Ampache::ampache{$name}, $class;
+}
+
+sub dbh
+{
+    my ($self, $database) = @_;
+    my $dbh = '';
+
+    if($self->{_dbh} ) 
+    {
+        return $self->{_dbh};
+    }
+    else
+    {
+        my $connect_string = [ sprintf("dbi:%s:database=%s;host=%s;port=%s",
+                                $self->{_connect}{dbd},
+                                $self->{_database},
+                                $self->{_connect}{host},
+                                $self->{_connect}{port}),
+                                $self->{_connect}{username},
+                                $self->{_connect}{password} ];
+        $dbh = DBI->connect( @{$connect_string}, 
+                              {PrintError => 0,
+                              RaiseError => 0,
+                              AutoCommit => 1});
+
+        if ( !$dbh ) 
+        {
+            die "Failed to connect to database.  Exiting.";
+        }
+    }
+
+    return $dbh;
+}
+
+sub prepare_sth_cache {
+        my ($self, $sql) = @_;
+
+        # the call to dbh() forces a connection if one has dropped
+        my $dbh = $self->dbh();
+        return $dbh->prepare($sql);
+}
+
+sub get_table_where
+{
+    my ($self, $name, $where,$select) = @_;
+    if (!$select) { $select = "*"; } 
+    my ($sql, $sth);
+    my $dbh = $self->dbh();
+    $sql = qq{SELECT $select FROM $name $where};
+    $sth = $dbh->prepare($sql);
+    $sth->execute();
+
+    my @table = ();
+    while ( my $ary = $sth->fetchrow_hashref() ) 
+    {
+        push(@table, $ary); 
+    }
+    return (@table);
+}
+
+sub get_catalog_option
+{
+    my ($self, $catalog, $field) = @_;
+    if(!$self->{_catalog}{$catalog}) {
+        print "Loading catalog settings\n";
+        my ($sql, $sth);
+        $sql = qq{SELECT * FROM catalog WHERE path = '$catalog'};
+        my $dbh = $self->dbh();
+        $sth = $dbh->prepare($sql);
+        $sth->execute();
+        $self->{_catalog}{$catalog} = $sth->fetchrow_hashref();
+    }
+    return $self->{_catalog}->{$catalog}->{$field};
+}
+
+sub change_flags
+{
+    my ($self, $song, $oldflag, $newflag) = @_;
+    my ($sql, $sth);
+    my $dbh = $self->dbh();
+    $sql = "UPDATE flagged SET type = '$newflag' WHERE song = '".$song->{'id'}."' AND type = '$oldflag'";
+    $sth = $dbh->prepare($sql);
+    $sth->execute();
+}
+
+ sub update_song
+{
+    my ($self, $filename, $song) = @_;
+    my ($sql, $sth);
+    my $dbh = $self->dbh();
+    $filename =~ s/'/\\'/g;
+    $filename =~ s/"/\\"/g;
+    $filename =~ s/\Q%\E//g;
+    $sql = "UPDATE song SET file = '$filename' WHERE id = '".$song->{'id'}."'";
+    $sth = $dbh->prepare($sql);
+    $sth->execute();
+}   
+
+sub get_song_info
+{
+    my ($self, $song) = @_;
+    my ($sql, $sth);
+    my $dbh = $self->dbh();
+    if ( not $self->{_sth_cache}{get_song_info}) 
+    {
+        $self->{_sth_cache}{get_song_info} = $self->prepare_sth_cache(
+            qq{SELECT catalog.path AS catalog,song.file,song.id,song.title,song.track,song.year,song.comment,album.name AS album, artist.name AS artist,genre FROM song,album,artist,catalog WHERE song.id = ? AND album.id = song.album AND artist.id = song.artist AND song.catalog = catalog.id});
+
+    }
+    $sth = $self->{_sth_cache}{get_song_info};
+    $sth->execute($song);
+
+    my @table = ();
+    while ( my $ary = $sth->fetchrow_hashref() ) 
+    {
+        push(@table, $ary); 
+    }
+    return (@table);
+}
+
+#sub get_song_info
+#{
+#    my ($self, $song) = @_;
+#
+#    my ($sql, $sth);
+#    my $dbh = $self->dbh();
+#    if ( not $self->{_sth_cache}{song_info}{$song} ) 
+#    {
+#        $sql = qq{SELECT * FROM song WHERE id = $song};
+#        $sth = $dbh->prepare($sql);
+#        $self->{_sth_cache}{song_info}{$song} = $sth;
+#    }
+#
+#    $sth = $self->{_sth_cache}{song_info}{$song};
+#    $sth->execute();
+#
+#    my @song_info = $sth->fetchrow_hashref(); 
+#    return (@song_info);
+#}
+
+
+1;
+__END__
diff --git a/lib/perl/Local/Ampache/Makefile.PL b/lib/perl/Local/Ampache/Makefile.PL
new file mode 100755
index 00000000..a51e5d54
--- /dev/null
+++ b/lib/perl/Local/Ampache/Makefile.PL
@@ -0,0 +1,7 @@
+use ExtUtils::MakeMaker;
+# See lib/ExtUtils/MakeMaker.pm for details of how to influence
+# the contents of the Makefile that is written.
+WriteMakefile(
+    'NAME'	=> 'Local::Ampache',
+    'VERSION_FROM' => 'Ampache.pm', # finds $VERSION
+);