Testfälle für neue API von DATEV angepasst

[mfinanz.git] / t / 000setup_database.t

diff --git a/t/000setup_database.t b/t/000setup_database.t
index f61c8a3c1a52207aeeb367356602a62edf5ed572..a927503b51e19ac7a20df16050c8839e50d13b38 100755 (executable)
--- a/t/000setup_database.t
+++ b/t/000setup_database.t
@@ -16,7 +16,7 @@ use SL::Layout::None;
 use SL::LxOfficeConf;
 use Support::TestSetup;
 
 use SL::LxOfficeConf;
 use Support::TestSetup;
 

-our ($db_cfg, $dbh);
+our ($db_cfg, $dbh, $superuser_dbh);

 
 sub dbg {
   # diag(@_);
 
 sub dbg {
   # diag(@_);


@@ -85,6 +85,7 @@ sub drop_and_create_database {
 
 sub report_success {
   $dbh->disconnect;
 
 sub report_success {
   $dbh->disconnect;

+  $superuser_dbh->disconnect if $superuser_dbh;

   ok(1, "Database has been setup sucessfully.");
   done_testing();
 }
   ok(1, "Database has been setup sucessfully.");
   done_testing();
 }


@@ -97,7 +98,8 @@ sub apply_dbupgrade {
 
   dbg("Applying $file");
 
 
   dbg("Applying $file");
 

-  my $error = $dbupdater->process_file($dbh, $file, $control);
+  my $script_dbh = $control && $control->{superuser_privileges} ? ($superuser_dbh // $dbh) : $dbh;
+  my $error      = $dbupdater->process_file($script_dbh, $file, $control);

 
   BAIL_OUT("Error applying $file: $error") if $error;
 }
 
   BAIL_OUT("Error applying $file: $error") if $error;
 }


@@ -117,6 +119,17 @@ sub create_initial_schema {
   my $dbupdater  = SL::DBUpgrade2->new(form => $::form, return_on_error => 1, silent => 1);
   my $coa        = 'Germany-DATEV-SKR03EU';
 
   my $dbupdater  = SL::DBUpgrade2->new(form => $::form, return_on_error => 1, silent => 1);
   my $coa        = 'Germany-DATEV-SKR03EU';
 

+  if ($db_cfg->{superuser_user} && ($db_cfg->{superuser_user} ne $db_cfg->{user})) {
+    @dbi_options = (
+      'dbi:Pg:dbname=' . $db_cfg->{db} . ';host=' . $db_cfg->{host} . ';port=' . $db_cfg->{port},
+      $db_cfg->{superuser_user},
+      $db_cfg->{superuser_password},
+      SL::DBConnect->get_options(PrintError => 0, PrintWarn => 0),
+    );
+
+    $superuser_dbh = SL::DBConnect->connect(@dbi_options) || BAIL_OUT("Database superuser connection failed: " . $DBI::errstr);
+  }
+

   apply_dbupgrade($dbupdater, "sql/lx-office.sql");
   apply_dbupgrade($dbupdater, "sql/${coa}-chart.sql");
 
   apply_dbupgrade($dbupdater, "sql/lx-office.sql");
   apply_dbupgrade($dbupdater, "sql/${coa}-chart.sql");