package DBIx::Handy;

use strict;
use DBI;

sub new {
    my $class = shift;
    my %config = @_;
    
    my $self = {'_CONFIG' => \%config};
    
    bless ($self,$class);
    
    return $self;    
}

sub connect {
    my $self = shift;
  
    # Configs
    my $c = $self->{_CONFIG};

    unless (defined $self->{_DBH}){
    $self->{_DBH} = DBI->connect('dbi:' . $c->{driver} .
                     ':database=' . $c->{database} .
                     ';host=' . $c->{host},
                     $c->{username}, $c->{password},
                     {'RaiseError' => 1}) or die "Could not connect to
+ database. Error message: $!";
    }
    
    return $self->{_DBH};
}

sub disconnect {
    my $self = shift;
    
    $self->{_DBH}->disconnect() if (defined $self->{_DBH});
    # If it fails, it's already disconnect ...
    return 1;
}

sub prepare {
    my $self = shift;
    my $sql = shift;

    $self->connect() if not defined($self->{_DBH});
    
    $self->{_STH} = $self->{_DBH}->prepare($sql);
    
    return $self->{_STH};
}

sub execute {
    my $self = shift;
    my %params = @_;

    $self->prepare($params{sql});
    $self->{_STH}->execute(@{$params{data}});

    if(defined $params{method}){
    my $method = $params{method};
    
    #if( @{ $params{method_params} } ){
    #    return $self->{_STH}->$method( @{ $params{method_params} } );
    #} else {
    #    return $self->{_STH}->$method();
    #}
    
    return $self->{_STH}->$method(  @{ $params{method_params} }  );
    } else {
    return $self->{_STH};
    }
}

sub insert {
    my $self = shift;
    my %params = @_;
    
    my @fields = $self->_GET_FIELDS($params{table});
  
    my $data = $params{data};
  
    my $sql = 'INSERT INTO ' . $params{table} . ' (';
    
    my ($sql_part1, $sql_part2, @data);
  
    foreach (@fields){
    if(defined($data->{$_}) && (length($data->{$_}) >= 1) && ($data->{
+$_} ne '')){
        $sql_part1 .= "$_,";
        $sql_part2 .= '?,';
        push (@data,$data->{$_});
    }
    }
  
    chop($sql_part1);
    chop($sql_part2); # to remove last ,
  
    $sql_part1 .= ')'; 
    $sql_part2 .= ')'; 
    $sql .= $sql_part1 . ' VALUES (' . $sql_part2;

    return $self->DB_execute(sql => $sql,
                 data => \@data,);    
}

sub update {
    my $self = shift;

    my %params = @_;

    my @fields = $self->_GET_FIELDS($params{table});

    my $data = $params{data};

    my $sql = 'UPDATE ' . $params{table} . ' SET ';
    my @data;

    foreach (@fields){
    if(defined($data->{$_}) && (length($data->{$_}) >= 1) &&
      ($data->{$_} ne '') && ($_ ne $params{id_field})  ){
        
        $sql .= $_ . ' = ?,';
        push @data,$data->{$_};
        
    }
    }

    chop($sql); # to remove last ,
    $sql .= ' WHERE ' . $params{id_field} . ' = ?'; # where id_field =
+ id_value

    push @data, $data->{$params{id_field}};

    return $self->DB_execute(sql => $sql,
                 data => \@data,); 
}

sub _GET_FIELDS {
    my $self = shift;
    my $table = shift;
    
    my $results = $self->execute(sql => 'SHOW COLUMNS FROM ' . $table 
+,
                 method_params => 'Field');
    
    return(keys %{$results});
}


1;
[download]