use DBI;
use CGI;
+use POSIX qw(strftime);
+use IO::File;
+use Fcntl;
+use English qw(-no_match_vars);
+use Sys::Hostname;
use SL::Form;
+use SL::Mailer;
use SL::User;
use SL::Common;
use SL::Inifile;
+use SL::DBUpgrade2;
+use SL::DBUtils;
require "bin/mozilla/common.pl";
# create memberfile
if (!-f $memberfile) {
- open(FH, ">$memberfile") or $form->error("$memberfile : $!");
+ open(FH, ">$memberfile") or $form->error("$memberfile : $ERRNO");
print FH qq|# SQL-Ledger Accounting members
[root login]
$form->error($locale->text('File locked!')) if (-f "${memberfile}.LCK");
- open(FH, "$memberfile") or $form->error("$memberfile : $!");
+ open(FH, "$memberfile") or $form->error("$memberfile : $ERRNO");
my %members;
. $locale->text('Administration') . " / "
. $locale->text('Add User');
- $form->{Oracle_sid} = $sid;
- $form->{Oracle_dbport} = '1521';
- $form->{Oracle_dbhost} = `hostname`;
-
my $myconfig = {
"vclimit" => 200,
"countrycode" => "de",
$form->error(sprintf($locale->text("The directory %s does not exist."), $templates));
}
- opendir TEMPLATEDIR, "$templates/." or $form->error("$templates : $!");
+ opendir TEMPLATEDIR, "$templates/." or $form->error("$templates : $ERRNO");
my @all = readdir(TEMPLATEDIR);
my @alldir = sort grep { -d "$templates/$_" && !/^\.\.?$/ } @all;
my @allhtml = sort grep { -f "$templates/$_" && /\.html$/ } @all;
map { $form->{"myc_${_}"} = $myconfig->{$_} } keys %{ $myconfig };
- map { $form->{"Pg_${_}"} = $myconfig->{$_} } qw(dbhost dbport dbname dbuser dbpasswd);
-
# access control
my @acsorder = ();
my %acs = ();
my %excl = ();
- open(FH, $menufile) or $form->error("$menufile : $!");
+ open(FH, $menufile) or $form->error("$menufile : $ERRNO");
while ($item = <FH>) {
next unless $item =~ /\[/;
sub save {
- # no driver checked
- $form->error($locale->text('Database Driver not checked!'))
- unless $form->{dbdriver};
+ $form->{dbdriver} = 'Pg';
# no spaces allowed in login name
($form->{login}) = split / /, $form->{login};
}
$form->{acs} = join ";", @acs;
- # check which database was filled in
- if ($form->{dbdriver} eq 'Oracle') {
- $form->{sid} = $form->{Oracle_sid},;
- $form->{dbhost} = $form->{Oracle_dbhost},;
- $form->{dbport} = $form->{Oracle_dbport};
- $form->{dbpasswd} = $form->{Oracle_dbpasswd};
- $form->{dbuser} = $form->{Oracle_dbuser};
- $form->{dbname} = $form->{Oracle_dbuser};
-
- $form->isblank("dbhost", $locale->text('Hostname missing!'));
- $form->isblank("dbport", $locale->text('Port missing!'));
- $form->isblank("dbuser", $locale->text('Dataset missing!'));
- }
- if ($form->{dbdriver} eq 'Pg') {
- $form->{dbhost} = $form->{Pg_dbhost};
- $form->{dbport} = $form->{Pg_dbport};
- $form->{dbpasswd} = $form->{Pg_dbpasswd};
- $form->{dbuser} = $form->{Pg_dbuser};
- $form->{dbname} = $form->{Pg_dbname};
-
- $form->isblank("dbname", $locale->text('Dataset missing!'));
- $form->isblank("dbuser", $locale->text('Database User missing!'));
- }
+ $form->isblank("dbname", $locale->text('Dataset missing!'));
+ $form->isblank("dbuser", $locale->text('Database User missing!'));
foreach $item (keys %{$form}) {
$myconfig->{$item} = $form->{$item};
}
close(HTACCESS);
}
- open(HTACCESS, "> $file") or die "cannot open $file $!\n";
+ open(HTACCESS, "> $file") or die "cannot open $file $ERRNO\n";
$newfile .= $myconfig->{login} . ":" . $myconfig->{password} . "\n";
print(HTACCESS $newfile);
close(HTACCESS);
}
close(HTACCESS);
}
- open(HTACCESS, "> $file") or die "cannot open $file $!\n";
+ open(HTACCESS, "> $file") or die "cannot open $file $ERRNO\n";
print(HTACCESS $newfile);
close(HTACCESS);
}
umask(007);
# copy templates to the directory
- opendir TEMPLATEDIR, "$templates/." or $form - error("$templates : $!");
+ opendir TEMPLATEDIR, "$templates/." or $form - error("$templates : $ERRNO");
@templates = grep /$form->{mastertemplates}.*?\.(html|tex|sty|xml|txb)$/,
readdir TEMPLATEDIR;
closedir TEMPLATEDIR;
foreach $file (@templates) {
open(TEMP, "$templates/$file")
- or $form->error("$templates/$file : $!");
+ or $form->error("$templates/$file : $ERRNO");
$file =~ s/$form->{mastertemplates}-//;
open(NEW, ">$form->{templates}/$file")
- or $form->error("$form->{templates}/$file : $!");
+ or $form->error("$form->{templates}/$file : $ERRNO");
while ($line = <TEMP>) {
print NEW $line;
close(NEW);
}
} else {
- $form->error("$!: $form->{templates}");
+ $form->error("$ERRNO: $form->{templates}");
}
}
sub delete {
$form->error($locale->text('File locked!')) if (-f ${memberfile} . LCK);
- open(FH, ">${memberfile}.LCK") or $form->error("${memberfile}.LCK : $!");
+ open(FH, ">${memberfile}.LCK") or $form->error("${memberfile}.LCK : $ERRNO");
close(FH);
my $members = Inifile->new($memberfile);
}
-sub oracle_database_administration {
-
- $form->{dbdriver} = 'Oracle';
- dbselect_source();
-
-}
-
-sub dbdriver_defaults {
-
- # load some defaults for the selected driver
- %driverdefaults = (
- 'Pg' => { dbport => '5432',
- dbuser => 'postgres',
- dbdefault => 'template1',
- dbhost => 'localhost',
- connectstring => $locale->text('Connect to')
- },
- 'Oracle' => { dbport => '1521',
- dbuser => 'oralin',
- dbdefault => $sid,
- dbhost => `hostname`,
- connectstring => 'SID'
- });
-
- map { $form->{$_} = $driverdefaults{ $form->{dbdriver} }{$_} }
- keys %{ $driverdefaults{Pg} };
-
-}
-
sub dbselect_source {
+ $form->{dbport} = '5432';
+ $form->{dbuser} = 'postgres';
+ $form->{dbdefault} = 'template1';
+ $form->{dbhost} = 'localhost';
- dbdriver_defaults();
-
- $msg{Pg} =
- $locale->text(
- 'Leave host and port field empty unless you want to make a remote connection.'
- );
- $msg{Oracle} =
- $locale->text(
- 'You must enter a host and port for local and remote connections!');
-
- $form->{title} =
- "Lx-Office ERP / " . $locale->text('Database Administration');
-
- $form->header;
-
- print qq|
-<body class=admin>
-
-
-<center>
-<h2>$form->{title}</h2>
-
-<form method=post action=$form->{script}>
-
-<table>
-<tr><td>
-
-<table>
-
- <tr class=listheading>
- <th colspan=4>| . $locale->text('Database') . qq|</th>
- </tr>
+ $form->{title} = "Lx-Office ERP / " . $locale->text('Database Administration');
-<input type=hidden name=dbdriver value=$form->{dbdriver}>
-
- <tr><td>
- <table>
-
- <tr>
-
- <th align=right>| . $locale->text('Host') . qq|</th>
- <td><input name=dbhost size=25 value=$form->{dbhost}></td>
- <th align=right>| . $locale->text('Port') . qq|</th>
- <td><input name=dbport size=5 value=$form->{dbport}></td>
-
- </tr>
-
- <tr>
-
- <th align=right>| . $locale->text('User') . qq|</th>
- <td><input name="dbuser" size="10" value="$form->{dbuser}"></td>
- <th align=right>| . $locale->text('Password') . qq|</th>
- <td><input type="password" name="dbpasswd" size="10"></td>
-
- </tr>
-
- <tr>
-
- <th align=right>$form->{connectstring}</th>
- <td colspan=3><input name=dbdefault size=10 value=$form->{dbdefault}></td>
-
- </tr>
-
-</table>
-
-</td></tr>
-</table>
-
-<input name=callback type=hidden value="$form->{script}?action=list_users&rpw=$form->{rpw}">
-<input type=hidden name=rpw value=$form->{rpw}>
-
-<br>
-
-<input type=submit class=submit name=action value="|
- . $locale->text('Create Dataset') . qq|">|;
-# Vorübergehend Deaktiviert
-# <input type=submit class=submit name=action value="|
-# . $locale->text('Update Dataset') . qq|">
-print qq| <input type=submit class=submit name=action value="|
- . $locale->text('Delete Dataset') . qq|">
-
-</form>
-
-</td></tr>
-</table>
-
-<p>|
- . $locale->text(
- 'This is a preliminary check for existing sources. Nothing will be created or deleted at this stage!'
- )
-
- . qq|
-<br>$msg{$form->{dbdriver}}
-
-
-</body>
-</html>
-|;
+ $form->{ALLOW_DBBACKUP} = "$pg_dump_exe" ne "DISABLED";
+ $form->header();
+ print $form->parse_html_template("admin/dbadmin");
}
sub continue {
call_sub($form->{"nextsub"});
}
-sub update_dataset {
-
- %needsupdate = User->dbneedsupdate(\%$form);
+sub back {
+ call_sub($form->{"back_nextsub"});
+}
+sub update_dataset {
$form->{title} =
"Lx-Office ERP "
. $locale->text('Database Administration') . " / "
. $locale->text('Update Dataset');
- $form->header;
-
- print qq|
-<body class=admin>
-
-
-<center>
-<h2>$form->{title}</h2>
-|;
- my $field_id = 0;
- foreach $key (sort keys %needsupdate) {
- if ($needsupdate{$key} ne $form->{dbversion}) {
- $upd .= qq|<input id="$field_id" name="db$key" type="checkbox" value="1" checked> $key\n|;
- $form->{dbupdate} .= "db$key ";
- $field_id++;
- }
- }
+ my @need_updates = User->dbneedsupdate($form);
+ $form->{NEED_UPDATES} = \@need_updates;
+ $form->{ALL_UPDATED} = !scalar @need_updates;
- chop $form->{dbupdate};
-
- if ($form->{dbupdate}) {
-
- print qq|
-<table width=100%>
-<form method=post action=$form->{script}>
-
-<input type=hidden name="dbdriver" value="$form->{dbdriver}">
-<input type=hidden name="dbhost" value="$form->{dbhost}">
-<input type=hidden name="dbport" value="$form->{dbport}">
-<input type=hidden name="dbuser" value="$form->{dbuser}">
-<input type=hidden name="dbpasswd" value="$form->{dbpasswd}">
-<input type=hidden name="dbdefault" value="$form->{dbdefault}">
-
-<tr class=listheading>
- <th>| . $locale->text('The following Datasets need to be updated') . qq|</th>
-</tr>
-<tr>
-<td>
-
-$upd
+ $form->header();
+ print $form->parse_html_template("admin/update_dataset");
+}
-</td>
-</tr>
-<tr>
-<td>
+sub dbupdate {
+ $form->{stylesheet} = "lx-office-erp.css";
+ $form->{title} = $locale->text("Dataset upgrade");
+ $form->header();
-<input name=dbupdate type=hidden value="$form->{dbupdate}">
+ my $rowcount = $form->{rowcount} * 1;
+ my @update_rows = grep { $form->{"update_$_"} } (1 .. $rowcount);
+ $form->{NOTHING_TO_DO} = !scalar @update_rows;
+ my $saved_form = save_form();
-<input name=callback type=hidden value="$form->{script}?action=list_users&rpw=$form->{rpw}">
+ $| = 1;
-<input type=hidden name=rpw value=$form->{rpw}>
+ print $form->parse_html_template("admin/dbupgrade_all_header");
-<input type=hidden name=nextsub value=dbupdate>
+ foreach my $i (@update_rows) {
+ restore_form($saved_form);
-<hr size=3 noshade>
+ map { $form->{$_} = $form->{"${_}_${i}"} } qw(dbname dbdriver dbhost dbport dbuser dbpasswd);
-<br>
-<input type=submit class=submit name=action value="|
- . $locale->text('Continue') . qq|">
+ my $controls = parse_dbupdate_controls($form, $form->{dbdriver});
-</td></tr>
-</table>
-</form>
-|;
+ print $form->parse_html_template("admin/dbupgrade_header");
- } else {
+ $form->{dbupdate} = $form->{dbname};
+ $form->{$form->{dbname}} = 1;
- print $locale->text('All Datasets up to date!');
+ User->dbupdate($form);
+ User->dbupdate2($form, $controls);
+ print $form->parse_html_template("admin/dbupgrade_footer");
}
- print qq|
-
-</body>
-</html>
-|;
-
-}
-
-sub dbupdate {
- $form->{"stylesheet"} = "lx-office-erp.css";
- $form->{"title"} = $main::locale->text("Dataset upgrade");
- $form->header();
- my $dbname =
- join(" ",
- map({ s/\s//g; s/^db//; $_; }
- grep({ $form->{$_} }
- split(/\s+/, $form->{"dbupdate"}))));
- print($form->parse_html_template("dbupgrade/header",
- { "dbname" => $dbname }));
-
- User->dbupdate(\%$form);
-
- print qq|
-<hr>
-
-| . $locale->text('Dataset updated!') . qq|
-
-<br>
-
-<a id="enddatasetupdate" href="admin.pl?action=login&| .
-join("&", map({ "$_=" . $form->escape($form->{$_}); } qw(rpw))) .
-qq|">| . $locale->text("Continue") . qq|</a>|;
-
+ print $form->parse_html_template("admin/dbupgrade_all_done");
}
sub create_dataset {
$form->{CHARTS} = [];
- opendir SQLDIR, "sql/." or $form - error($!);
+ opendir SQLDIR, "sql/." or $form - error($ERRNO);
foreach $item (sort grep /-chart\.sql\z/, readdir SQLDIR) {
next if ($item eq 'Default-chart.sql');
$item =~ s/-chart\.sql//;
"Lx-Office ERP "
. $locale->text('Database Administration') . " / "
. $locale->text('Delete Dataset');
-
$form->header();
print $form->parse_html_template("admin/dbdelete");
}
+sub backup_dataset {
+ $form->{title} =
+ "Lx-Office ERP "
+ . $locale->text('Database Administration') . " / "
+ . $locale->text('Backup Dataset');
+
+ if ("$pg_dump_exe" eq "DISABLED") {
+ $form->error($locale->text('Database backups and restorations are disabled in lx-erp.conf.'));
+ }
+
+ my @dbsources = sort User->dbsources($form);
+ $form->{DATABASES} = [ map { { "dbname" => $_ } } @dbsources ];
+ $form->{NO_DATABASES} = !scalar @dbsources;
+
+ my $username = getpwuid $UID || "unknown-user";
+ my $hostname = hostname() || "unknown-host";
+ $form->{from} = "Lx-Office Admin <${username}\@${hostname}>";
+
+ $form->header();
+ print $form->parse_html_template("admin/backup_dataset");
+}
+
+sub backup_dataset_start {
+ $form->{title} =
+ "Lx-Office ERP "
+ . $locale->text('Database Administration') . " / "
+ . $locale->text('Backup Dataset');
+
+ $pg_dump_exe ||= "pg_dump";
+
+ if ("$pg_dump_exe" eq "DISABLED") {
+ $form->error($locale->text('Database backups and restorations are disabled in lx-erp.conf.'));
+ }
+
+ $form->isblank("dbname", $locale->text('The dataset name is missing.'));
+ $form->isblank("to", $locale->text('The email address is missing.')) if $form->{destination} eq "email";
+
+ my $tmpdir = "/tmp/lx_office_backup_" . Common->unique_id();
+ mkdir $tmpdir, 0700 || $form->error($locale->text('A temporary directory could not be created:') . " $ERRNO");
+
+ my $pgpass = IO::File->new("${tmpdir}/.pgpass", O_WRONLY | O_CREAT, 0600);
+
+ if (!$pgpass) {
+ unlink $tmpdir;
+ $form->error($locale->text('A temporary file could not be created:') . " $ERRNO");
+ }
+
+ print $pgpass "$form->{dbhost}:$form->{dbport}:$form->{dbname}:$form->{dbuser}:$form->{dbpasswd}\n";
+ $pgpass->close();
+
+ $ENV{HOME} = $tmpdir;
+
+ my @args = ("-Ft", "-c", "-o", "-h", $form->{dbhost}, "-U", $form->{dbuser});
+ push @args, ("-p", $form->{dbport}) if ($form->{dbport});
+ push @args, $form->{dbname};
+
+ my $cmd = "${pg_dump_exe} " . join(" ", map { s/\\/\\\\/g; s/\"/\\\"/g; $_ } @args);
+ my $name = "dataset_backup_$form->{dbname}_" . strftime("%Y%m%d", localtime()) . ".tar";
+
+ if ($form->{destination} ne "email") {
+ my $in = IO::File->new("$cmd |");
+
+ if (!$in) {
+ unlink "${tmpdir}/.pgpass";
+ rmdir $tmpdir;
+
+ $form->error($locale->text('The pg_dump process could not be started.'));
+ }
+
+ print "content-type: application/x-tar\n";
+ print "content-disposition: attachment; filename=\"${name}\"\n\n";
+
+ while (my $line = <$in>) {
+ print $line;
+ }
+
+ $in->close();
+
+ unlink "${tmpdir}/.pgpass";
+ rmdir $tmpdir;
+
+ } else {
+ my $tmp = $tmpdir . "/dump_" . Common::unique_id();
+
+ if (system("$cmd > $tmp") != 0) {
+ unlink "${tmpdir}/.pgpass", $tmp;
+ rmdir $tmpdir;
+
+ $form->error($locale->text('The pg_dump process could not be started.'));
+ }
+
+ my $mail = new Mailer;
+
+ map { $mail->{$_} = $form->{$_} } qw(from to cc subject message);
+
+ $mail->{charset} = $dbcharset ? $dbcharset : Common::DEFAULT_CHARSET;
+ $mail->{attachments} = [ { "filename" => $tmp, "name" => $name } ];
+ $mail->send();
+
+ unlink "${tmpdir}/.pgpass", $tmp;
+ rmdir $tmpdir;
+
+ $form->{title} =
+ "Lx-Office ERP "
+ . $locale->text('Database Administration') . " / "
+ . $locale->text('Backup Dataset');
+
+ $form->header();
+ print $form->parse_html_template("admin/backup_dataset_email_done");
+ }
+}
+
+sub restore_dataset {
+ $form->{title} =
+ "Lx-Office ERP "
+ . $locale->text('Database Administration') . " / "
+ . $locale->text('Restore Dataset');
+
+ if ("$pg_restore_exe" eq "DISABLED") {
+ $form->error($locale->text('Database backups and restorations are disabled in lx-erp.conf.'));
+ }
+
+ my $default_charset = $dbcharset;
+ $default_charset ||= Common::DEFAULT_CHARSET;
+
+ $form->{DBENCODINGS} = [];
+
+ foreach my $encoding (@Common::db_encodings) {
+ push @{ $form->{DBENCODINGS} }, { "dbencoding" => $encoding->{dbencoding},
+ "label" => $encoding->{label},
+ "selected" => $encoding->{charset} eq $default_charset };
+ }
+
+ $form->header();
+ print $form->parse_html_template("admin/restore_dataset");
+}
+
+sub restore_dataset_start {
+ $form->{title} =
+ "Lx-Office ERP "
+ . $locale->text('Database Administration') . " / "
+ . $locale->text('Restore Dataset');
+
+ $pg_restore_exe ||= "pg_restore";
+
+ if ("$pg_restore_exe" eq "DISABLED") {
+ $form->error($locale->text('Database backups and restorations are disabled in lx-erp.conf.'));
+ }
+
+ $form->isblank("new_dbname", $locale->text('The dataset name is missing.'));
+ $form->isblank("content", $locale->text('No backup file has been uploaded.'));
+
+ # Create temporary directories. Write the backup file contents to a temporary
+ # file. Create a .pgpass file with the username and password for the pg_restore
+ # utility.
+
+ my $tmpdir = "/tmp/lx_office_backup_" . Common->unique_id();
+ mkdir $tmpdir, 0700 || $form->error($locale->text('A temporary directory could not be created:') . " $ERRNO");
+
+ my $pgpass = IO::File->new("${tmpdir}/.pgpass", O_WRONLY | O_CREAT, 0600);
+
+ if (!$pgpass) {
+ unlink $tmpdir;
+ $form->error($locale->text('A temporary file could not be created:') . " $ERRNO");
+ }
+
+ print $pgpass "$form->{dbhost}:$form->{dbport}:$form->{new_dbname}:$form->{dbuser}:$form->{dbpasswd}\n";
+ $pgpass->close();
+
+ $ENV{HOME} = $tmpdir;
+
+ my $tmp = $tmpdir . "/dump_" . Common::unique_id();
+ my $tmpfile;
+
+ if (substr($form->{content}, 0, 2) eq "\037\213") {
+ $tmpfile = IO::File->new("| gzip -d > $tmp");
+ $tmpfile->binary();
+
+ } else {
+ $tmpfile = IO::File->new($tmp, O_WRONLY | O_CREAT | O_BINARY, 0600);
+ }
+
+ if (!$tmpfile) {
+ unlink "${tmpdir}/.pgpass";
+ rmdir $tmpdir;
+
+ $form->error($locale->text('A temporary file could not be created:') . " $ERRNO");
+ }
+
+ print $tmpfile $form->{content};
+ $tmpfile->close();
+
+ delete $form->{content};
+
+ # Try to connect to the database. Find out if a database with the same name exists.
+ # If yes, then drop the existing database. Create a new one with the name and encoding
+ # given by the user.
+
+ User::dbconnect_vars($form, "template1");
+
+ my %myconfig = map { $_ => $form->{$_} } grep /^db/, keys %{ $form };
+ my $dbh = $form->dbconnect(\%myconfig) || $form->dberror();
+
+ my ($query, $sth);
+
+ $form->{new_dbname} =~ s|[^a-zA-Z0-9_\-]||g;
+
+ $query = qq|SELECT COUNT(*) FROM pg_database WHERE datname = ?|;
+ my ($count) = selectrow_query($form, $dbh, $query, $form->{new_dbname});
+ if ($count) {
+ do_query($form, $dbh, qq|DROP DATABASE $form->{new_dbname}|);
+ }
+
+ my $found = 0;
+ foreach my $item (@Common::db_encodings) {
+ if ($item->{dbencoding} eq $form->{dbencoding}) {
+ $found = 1;
+ last;
+ }
+ }
+ $form->{dbencoding} = "LATIN9" unless $form->{dbencoding};
+
+ do_query($form, $dbh, qq|CREATE DATABASE $form->{new_dbname} ENCODING ? TEMPLATE template0|, $form->{dbencoding});
+
+ $dbh->disconnect();
+
+ # Spawn pg_restore on the temporary file.
+
+ my @args = ("-h", $form->{dbhost}, "-U", $form->{dbuser}, "-d", $form->{new_dbname});
+ push @args, ("-p", $form->{dbport}) if ($form->{dbport});
+ push @args, $tmp;
+
+ my $cmd = "${pg_restore_exe} " . join(" ", map { s/\\/\\\\/g; s/\"/\\\"/g; $_ } @args);
+
+ my $in = IO::File->new("$cmd 2>&1 |");
+
+ if (!$in) {
+ unlink "${tmpdir}/.pgpass", $tmp;
+ rmdir $tmpdir;
+
+ $form->error($locale->text('The pg_restore process could not be started.'));
+ }
+
+ $AUTOFLUSH = 1;
+
+ $form->header();
+ print $form->parse_html_template("admin/restore_dataset_start_header");
+
+ while (my $line = <$in>) {
+ print $line;
+ }
+ $in->close();
+
+ $form->{retval} = $CHILD_ERROR >> 8;
+ print $form->parse_html_template("admin/restore_dataset_start_footer");
+
+ unlink "${tmpdir}/.pgpass", $tmp;
+ rmdir $tmpdir;
+}
+
sub unlock_system {
unlink "$userspath/nologin";
projects / kivitendo-erp.git / blobdiff