+sub check_errors_in_package_names {
+ foreach my $domain (sort keys %package_names) {
+ my @both = grep { $package_names{$domain}->{$_} } @{ $blacklist{$domain} || [] };
+ next unless @both;
+
+ print "Error: domain '$domain': The following table names are present in both the black list and the package name hash: ", join(' ', sort @both), "\n";
+ exit 1;
+ }
+}
+
+sub drop_and_create_test_database {
+ my $db_cfg = $::lx_office_conf{'testing/database'} || die 'testing/database missing';
+
+ my @dbi_options = (
+ 'dbi:Pg:dbname=' . $db_cfg->{template} . ';host=' . $db_cfg->{host} . ';port=' . $db_cfg->{port},
+ $db_cfg->{user},
+ $db_cfg->{password},
+ SL::DBConnect->get_options,
+ );
+
+ $::auth->reset;
+ my $dbh_template = SL::DBConnect->connect(@dbi_options) || BAIL_OUT("No database connection to the template database: " . $DBI::errstr);
+ my $auth_dbh = $::auth->dbconnect(1);
+
+ if ($auth_dbh) {
+ notice("Database exists; dropping");
+ $auth_dbh->disconnect;
+
+ dbh_do($dbh_template, "DROP DATABASE \"" . $db_cfg->{db} . "\"", message => "Database could not be dropped");
+ }
+
+ notice("Creating database");
+
+ dbh_do($dbh_template, "CREATE DATABASE \"" . $db_cfg->{db} . "\" TEMPLATE \"" . $db_cfg->{template} . "\" ENCODING 'UNICODE'", message => "Database could not be created");
+ $dbh_template->disconnect;
+
+ notice("Creating initial schema");
+
+ @dbi_options = (
+ 'dbi:Pg:dbname=' . $db_cfg->{db} . ';host=' . $db_cfg->{host} . ';port=' . $db_cfg->{port},
+ $db_cfg->{user},
+ $db_cfg->{password},
+ SL::DBConnect->get_options(PrintError => 0, PrintWarn => 0),
+ );
+
+ my $dbh = SL::DBConnect->connect(@dbi_options) || BAIL_OUT("Database connection failed: " . $DBI::errstr);
+ $::auth->{dbh} = $dbh;
+ my $dbupdater = SL::DBUpgrade2->new(form => $::form, return_on_error => 1, silent => 1);
+ my $coa = 'Germany-DATEV-SKR03EU';
+
+ apply_dbupgrade($dbupdater, $dbh, "sql/lx-office.sql");
+ apply_dbupgrade($dbupdater, $dbh, "sql/${coa}-chart.sql");
+
+ dbh_do($dbh, qq|UPDATE defaults SET coa = '${coa}', accounting_method = 'cash', profit_determination = 'income', inventory_system = 'periodic', curr = 'EUR'|);
+ dbh_do($dbh, qq|CREATE TABLE schema_info (tag TEXT, login TEXT, itime TIMESTAMP DEFAULT now(), PRIMARY KEY (tag))|);
+
+ notice("Creating initial auth schema");
+
+ $dbupdater = SL::DBUpgrade2->new(form => $::form, return_on_error => 1, auth => 1);
+ apply_dbupgrade($dbupdater, $dbh, 'sql/auth_db.sql');
+
+ apply_upgrades(auth => 1, dbh => $dbh);
+
+ $::auth->reset;
+
+ notice("Creating client, user, group and employee");
+
+ dbh_do($dbh, qq|DELETE FROM auth.clients|);
+ dbh_do($dbh, qq|INSERT INTO auth.clients (id, name, dbhost, dbport, dbname, dbuser, dbpasswd, is_default) VALUES (1, 'Unit-Tests', ?, ?, ?, ?, ?, TRUE)|,
+ bind => [ @{ $db_cfg }{ qw(host port db user password) } ]);
+ dbh_do($dbh, qq|INSERT INTO auth."user" (id, login) VALUES (1, 'unittests')|);
+ dbh_do($dbh, qq|INSERT INTO auth."group" (id, name) VALUES (1, 'Vollzugriff')|);
+ dbh_do($dbh, qq|INSERT INTO auth.clients_users (client_id, user_id) VALUES (1, 1)|);
+ dbh_do($dbh, qq|INSERT INTO auth.clients_groups (client_id, group_id) VALUES (1, 1)|);
+ dbh_do($dbh, qq|INSERT INTO auth.user_group (user_id, group_id) VALUES (1, 1)|);
+
+ my %config = (
+ default_printer_id => '',
+ template_format => '',
+ default_media => '',
+ email => 'unit@tester',
+ tel => '',
+ dateformat => 'dd.mm.yy',
+ show_form_details => '',
+ name => 'Unit Tester',
+ signature => '',
+ hide_cvar_search_options => '',
+ numberformat => '1.000,00',
+ favorites => '',
+ copies => '',
+ menustyle => 'v3',
+ fax => '',
+ stylesheet => 'lx-office-erp.css',
+ mandatory_departments => 0,
+ countrycode => 'de',
+ );
+
+ my $sth = $dbh->prepare(qq|INSERT INTO auth.user_config (user_id, cfg_key, cfg_value) VALUES (1, ?, ?)|) || BAIL_OUT($dbh->errstr);
+ dbh_do($dbh, $sth, bind => [ $_, $config{$_} ]) for sort keys %config;
+ $sth->finish;
+
+ $sth = $dbh->prepare(qq|INSERT INTO auth.group_rights (group_id, "right", granted) VALUES (1, ?, TRUE)|) || BAIL_OUT($dbh->errstr);
+ dbh_do($dbh, $sth, bind => [ $_ ]) for sort $::auth->all_rights;
+ $sth->finish;
+
+ dbh_do($dbh, qq|INSERT INTO employee (id, login, name) VALUES (1, 'unittests', 'Unit Tester')|);
+
+ $::auth->set_client(1) || BAIL_OUT("\$::auth->set_client(1) failed");
+ %::myconfig = $::auth->read_user(login => 'unittests');
+
+ apply_upgrades(dbh => $dbh);
+}
+
+sub apply_upgrades {
+ my %params = @_;
+ my $dbupdater = SL::DBUpgrade2->new(form => $::form, return_on_error => 1, auth => $params{auth});
+ my @unapplied_scripts = $dbupdater->unapplied_upgrade_scripts($params{dbh});
+
+ my $all = @unapplied_scripts;
+ my $i;
+ for my $script (@unapplied_scripts) {
+ ++$i;
+ print "\rUpgrade $i/$all";
+ apply_dbupgrade($dbupdater, $params{dbh}, $script);
+ }
+ print " - done.\n";
+}
+
+sub apply_dbupgrade {
+ my ($dbupdater, $dbh, $control_or_file) = @_;
+
+ my $file = ref($control_or_file) ? ("sql/Pg-upgrade2" . ($dbupdater->{auth} ? "-auth" : "") . "/$control_or_file->{file}") : $control_or_file;
+ my $control = ref($control_or_file) ? $control_or_file : undef;
+
+ my $error = $dbupdater->process_file($dbh, $file, $control);
+
+ die("Error applying $file: $error") if $error;
+}
+
+sub dbh_do {
+ my ($dbh, $query, %params) = @_;
+
+ if (ref($query)) {
+ return if $query->execute(@{ $params{bind} || [] });
+ die($dbh->errstr);
+ }
+
+ return if $dbh->do($query, undef, @{ $params{bind} || [] });
+
+ die($params{message} . ": " . $dbh->errstr) if $params{message};
+ die("Query failed: " . $dbh->errstr . " ; query: $query");
+}
+
projects / kivitendo-erp.git / blobdiff