X-Git-Url: http://wagnertech.de/git?a=blobdiff_plain;f=SL%2FDB.pm;h=f90a9c6371a72710287499afbbe3c12384d2abd6;hb=abc7d88b97193fe5c1c23071cd56b62e928b1fd9;hp=bcbf2e146a1f9ca91cea9e96049fd0a2278173a8;hpb=a97d97a009197f5b5b72897e0b09fb5889e2eb90;p=kivitendo-erp.git diff --git a/SL/DB.pm b/SL/DB.pm index bcbf2e146..f90a9c637 100644 --- a/SL/DB.pm +++ b/SL/DB.pm @@ -13,6 +13,22 @@ __PACKAGE__->use_private_registry; my (%_db_registered, %_initial_sql_executed); +sub dbi_connect { + shift; + + return DBI->connect(@_) unless $::lx_office_conf{debug} && $::lx_office_conf{debug}->{dbix_log4perl}; + + require Log::Log4perl; + require DBIx::Log4perl; + + my $filename = $LXDebug::file_name; + my $config = $::lx_office_conf{debug}->{dbix_log4perl_config}; + $config =~ s/LXDEBUGFILE/${filename}/g; + + Log::Log4perl->init(\$config); + return DBIx::Log4perl->connect(@_); +} + sub create { my $domain = shift || SL::DB->default_domain; my $type = shift || SL::DB->default_type; @@ -21,14 +37,26 @@ sub create { my $db = __PACKAGE__->new_or_cached(domain => $domain, type => $type); + _execute_initial_sql($db); + return $db; } +my %_dateformats = ( 'yy-mm-dd' => 'ISO', + 'yyyy-mm-dd' => 'ISO', + 'mm/dd/yy' => 'SQL, US', + 'mm-dd-yy' => 'POSTGRES, US', + 'dd/mm/yy' => 'SQL, EUROPEAN', + 'dd-mm-yy' => 'POSTGRES, EUROPEAN', + 'dd.mm.yy' => 'GERMAN' + ); + sub _register_db { my $domain = shift; my $type = shift; my %connect_settings; + my $initial_sql; if (!%::myconfig) { $type = 'LXOFFICE_EMPTY'; @@ -44,6 +72,11 @@ sub _register_db { connect_options => { pg_enable_utf8 => $::locale && $::locale->is_utf8, }); } else { + my $european_dates = 0; + if ($::myconfig{dateformat}) { + $european_dates = 1 if $_dateformats{ $::myconfig{dateformat} } =~ m/european/i; + } + %connect_settings = ( driver => $::myconfig{dbdriver} || 'Pg', database => $::myconfig{dbname}, host => $::myconfig{dbhost}, @@ -51,11 +84,14 @@ sub _register_db { username => $::myconfig{dbuser}, password => $::myconfig{dbpasswd}, connect_options => { pg_enable_utf8 => $::locale && $::locale->is_utf8, - }); + }, + european_dates => $european_dates); } + my %flattened_settings = _flatten_settings(%connect_settings); + $domain = 'LXOFFICE' if $type =~ m/^LXOFFICE/; - $type .= join($SUBSCRIPT_SEPARATOR, map { $::connect_setings{$_} } sort keys %connect_settings); + $type .= join($SUBSCRIPT_SEPARATOR, map { ($_, $flattened_settings{$_}) } sort keys %flattened_settings); my $idx = "${domain}::${type}"; if (!$_db_registered{$idx}) { @@ -70,4 +106,32 @@ sub _register_db { return ($domain, $type); } +sub _execute_initial_sql { + my ($db) = @_; + + return if $_initial_sql_executed{$db} || !%::myconfig || !$::myconfig{dateformat}; + + $_initial_sql_executed{$db} = 1; + + # Don't rely on dboptions being set properly. Chose them from + # dateformat instead. + my $pg_dateformat = $_dateformats{ $::myconfig{dateformat} }; + $db->dbh->do("set DateStyle to '${pg_dateformat}'") if $pg_dateformat; +} + +sub _flatten_settings { + my %settings = @_; + my %flattened = (); + + while (my ($key, $value) = each %settings) { + if ('HASH' eq ref $value) { + %flattened = ( %flattened, _flatten_settings(%{ $value }) ); + } else { + $flattened{$key} = $value; + } + } + + return %flattened; +} + 1;