kleine Korrektur
[kivitendo-erp.git] / SL / DB.pm
1 package SL::DB;
2
3 use strict;
4
5 use Carp;
6 use Data::Dumper;
7 use SL::DBConnect;
8 use English qw(-no_match_vars);
9 use Rose::DB;
10 use Rose::DBx::Cache::Anywhere;
11
12 use base qw(Rose::DB);
13
14 __PACKAGE__->db_cache_class('Rose::DBx::Cache::Anywhere');
15 __PACKAGE__->use_private_registry;
16
17 my (%_db_registered, %_initial_sql_executed);
18
19 sub dbi_connect {
20   shift;
21
22   return SL::DBConnect->connect(@_);
23 }
24
25 sub create {
26   my $domain = shift || SL::DB->default_domain;
27   my $type   = shift || SL::DB->default_type;
28
29   ($domain, $type) = _register_db($domain, $type);
30
31   my $db = __PACKAGE__->new_or_cached(domain => $domain, type => $type);
32
33   _execute_initial_sql($db);
34
35   return $db;
36 }
37
38 my %_dateformats = ( 'yy-mm-dd'   => 'ISO',
39                      'yyyy-mm-dd' => 'ISO',
40                      'mm/dd/yy'   => 'SQL, US',
41                      'dd/mm/yy'   => 'SQL, EUROPEAN',
42                      'dd.mm.yy'   => 'GERMAN'
43                    );
44
45 sub _register_db {
46   my $domain = shift;
47   my $type   = shift;
48
49   my %connect_settings;
50   my $initial_sql;
51
52   if (!%::myconfig) {
53     $type = 'LXOFFICE_EMPTY';
54     %connect_settings = ( driver => 'Pg' );
55
56   } elsif ($type eq 'LXOFFICE_AUTH') {
57     %connect_settings = ( driver          => $::myconfig{dbdriver} || 'Pg',
58                           database        => $::auth->{DB_config}->{db},
59                           host            => $::auth->{DB_config}->{host} || 'localhost',
60                           port            => $::auth->{DB_config}->{port} || 5432,
61                           username        => $::auth->{DB_config}->{user},
62                           password        => $::auth->{DB_config}->{password},
63                           connect_options => { pg_enable_utf8 => $::locale && $::locale->is_utf8,
64                                              });
65   } else {
66     my $european_dates = 0;
67     if ($::myconfig{dateformat}) {
68       $european_dates = 1 if $_dateformats{ $::myconfig{dateformat} }
69                           && $_dateformats{ $::myconfig{dateformat} } =~ m/european/i;
70     }
71
72     %connect_settings = ( driver          => $::myconfig{dbdriver} || 'Pg',
73                           database        => $::myconfig{dbname},
74                           host            => $::myconfig{dbhost} || 'localhost',
75                           port            => $::myconfig{dbport} || 5432,
76                           username        => $::myconfig{dbuser},
77                           password        => $::myconfig{dbpasswd},
78                           connect_options => { pg_enable_utf8 => $::locale && $::locale->is_utf8,
79                                              },
80                           european_dates  => $european_dates);
81   }
82
83   my %flattened_settings = _flatten_settings(%connect_settings);
84
85   $domain = 'LXOFFICE' if $type =~ m/^LXOFFICE/;
86   $type  .= join($SUBSCRIPT_SEPARATOR, map { ($_, $flattened_settings{$_} || '') } sort keys %flattened_settings);
87   my $idx = "${domain}::${type}";
88
89   if (!$_db_registered{$idx}) {
90     $_db_registered{$idx} = 1;
91
92     __PACKAGE__->register_db(domain => $domain,
93                              type   => $type,
94                              %connect_settings,
95                             );
96   }
97
98   return ($domain, $type);
99 }
100
101 sub _execute_initial_sql {
102   my ($db) = @_;
103
104   return if $_initial_sql_executed{$db} || !%::myconfig || !$::myconfig{dateformat};
105
106   $_initial_sql_executed{$db} = 1;
107
108   # Don't rely on dboptions being set properly. Chose them from
109   # dateformat instead.
110   my $pg_dateformat = $_dateformats{ $::myconfig{dateformat} };
111   $db->dbh->do("set DateStyle to '${pg_dateformat}'") if $pg_dateformat;
112 }
113
114 sub _flatten_settings {
115   my %settings  = @_;
116   my %flattened = ();
117
118   while (my ($key, $value) = each %settings) {
119     if ('HASH' eq ref $value) {
120       %flattened = ( %flattened, _flatten_settings(%{ $value }) );
121     } else {
122       $flattened{$key} = $value;
123     }
124   }
125
126   return %flattened;
127 }
128
129 1;