package DADA::App::DBIHandle;   

use lib qw(
    ../../ 
    ../../perllib
);



use DADA::Config;  
my $t = $DADA::Config::DEBUG_TRACE->{DADA_App_DBIHandle}; 
use Carp qw(carp croak); 

# Singleton.
# $dbh_stash holds DBH objects, one for each $pid. THis may or may not be a good idea...
my $dbh_stash = {}; 
require DBI; 	

if($DADA::Config::CPAN_DEBUG_SETTINGS{DBI} > 0){  
    DBI->trace($DADA::Config::CPAN_DEBUG_SETTINGS{DBI}, $PROGRAM_ERROR_LOG);
}

my $database  = $DADA::Config::SQL_PARAMS{database};
my $dbserver  = $DADA::Config::SQL_PARAMS{dbserver};    	  
my $port      = $DADA::Config::SQL_PARAMS{port};     	  
my $user      = $DADA::Config::SQL_PARAMS{user};         
my $pass      = $DADA::Config::SQL_PARAMS{pass};
my $email_id  = $DADA::Config::SQL_PARAMS{id_column} || 'email_id'; # DEV: This isn't set in the Config.pm (?!?!)
my $dbtype    = $DADA::Config::SQL_PARAMS{dbtype};




sub new {
	carp "Creating DBIHandle Object"
		if $t; 
	my $class = shift;
	my %args = (@_); 
	   my $self = {};			
       bless $self, $class;
	   $self->_init(%args); 
	   return $self;
}
sub _init  { 

	carp "Initializing DBIHandle Object"
		if $t; 
		
    my $self = shift; 
    my %args = @_; 
    $self->{sql_params} = {%DADA::Config::SQL_PARAMS}; 
    $self->{enabled} = 1; 
    $self->{is_connected}  = 0; 

}




sub dbh_obj {

    my $self = shift;
    carp "dbh_obj called."
      if $t;

    return undef 
		unless $self->{enabled};
	return $self->connectdb;
	
}



sub connectdb {

    my $self = shift;
    
    warn '$self->{enabled} ' . $self->{enabled}
        if $t; 
    
    return undef unless $self->{enabled};
    
    #Singleton.
    if( exists($dbh_stash->{$$}) && defined($dbh_stash->{$$}) && $dbh_stash->{$$}->ping ) {
        carp 'Returning already created $dbh for PID: ' . $$
          if $t;
        return $dbh_stash->{$$};
    }
    else { 
        carp 'Creating new $dbh for PID: ' . $$
          if $t;

        my $data_source;
        if ( $dbtype eq 'SQLite' ) {
            warn 'SQLite' 
                if $t; 
            $data_source =
              'dbi:' . $dbtype . ':' . $DADA::Config::FILES . '/' . $database;

            if ( $DADA::Config::DBI_PARAMS->{dada_connection_method} eq 'connect' )
            {
                $dbh_stash->{$$} = DBI->connect( "$data_source", "", "" )
                  || croak("can't connect to db: $DBI::errstr");
            }
            elsif ( $DADA::Config::DBI_PARAMS->{dada_connection_method} eq
                'connect_cached' )
            {

                $dbh_stash->{$$} =
                  DBI->connect_cached( "$data_source", "", "",
                    { dada_private_via_process => $$ } )
                  || croak("can't connect to db: $DBI::errstr");
            }
            else {
                croak "Incorrect dada_connection_method passed.";
            }

            for ( keys %{$DADA::Config::DBI_PARAMS} ) {
                next if $_ =~ m/dada/;
                $dbh_stash->{$$}->{$_} = $DADA::Config::DBI_PARAMS->{$_};
            }
        }
        else {

            $data_source = "dbi:$dbtype:dbname=$database;host=$dbserver;port=$port";

            if ( $DADA::Config::DBI_PARAMS->{dada_connection_method} eq 'connect' )
            {

                $dbh_stash->{$$} = DBI->connect( "$data_source", $user, $pass )
                  || croak("can't connect to db: $DBI::errstr");
            }
            elsif ( $DADA::Config::DBI_PARAMS->{dada_connection_method} eq
                'connect_cached' )
            {

                $dbh_stash->{$$} =
                  DBI->connect_cached( "$data_source", $user, $pass,
                    { dada_private_via_process => $$ } )
                  || croak("can't connect to db: $DBI::errstr");
            }
            else {
                croak "Incorrect dada_connection_method passed.";
            }

            for ( keys %{$DADA::Config::DBI_PARAMS} ) {
                next if $_ =~ m/dada/;

                $dbh_stash->{$$}->{$_} = $DADA::Config::DBI_PARAMS->{$_};
            }

            carp "Connected."
              if $t;

            $self->{is_connected} = 1;

        }
        return $dbh_stash->{$$};
    }
}





sub disconnectdb {
    my $self = shift;
    return undef unless $self->{enabled};

    carp "Disconnecting from DB..."
      if $t;

    $dbh_stash->{$$}->disconnect;
    $self->{is_connected} = 0;
    undef $dbh_stash->{$$}; 
    delete($dbh_stash->{$$}); 
    carp "Disconnected."
      if $t;

}





sub DESTROY { 


	my $self = shift;
		return undef unless $self->{enabled}; 

#	carp "Destroying DADA::App::DBIHandle object..."
#		if $t;
#		
#	if(defined($dbh)){ 
#		$self->disconnectdb ; 
#	}
#	else{ 
#	}
}


=pod

=head1 COPYRIGHT 

Copyright (c) 1999 - 2023 Justin Simoni All rights reserved. 

This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
as published by the Free Software Foundation; either version 2
of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 59 Temple Place - Suite 330, 
Boston, MA  02111-1307, USA.

=cut 




1;