use strict;
BEGIN {
- unshift @INC, "modules/override"; # Use our own versions of various modules (e.g. YAML).
- push @INC, "modules/fallback"; # Only use our own versions of modules if there's no system version.
+ use FindBin;
+
+ unshift(@INC, $FindBin::Bin . '/../modules/override'); # Use our own versions of various modules (e.g. YAML).
+ push (@INC, $FindBin::Bin . '/..'); # '.' will be removed from @INC soon.
}
use CGI qw( -no_xhtml);
use Digest::MD5 qw(md5_hex);
use English qw( -no_match_vars );
use Getopt::Long;
-use List::MoreUtils qw(none);
+use List::MoreUtils qw(apply none uniq);
use List::UtilsBy qw(partition_by);
use Pod::Usage;
use Rose::DB::Object 0.809;
use SL::DBUtils;
use SL::DB;
use SL::Form;
+use SL::InstanceConfiguration;
use SL::Locale;
use SL::LXDebug;
use SL::LxOfficeConf;
use SL::DB::Helper::ALL;
use SL::DB::Helper::Mappings;
+chdir($FindBin::Bin . '/..');
+
my %blacklist = SL::DB::Helper::Mappings->get_blacklist;
my %package_names = SL::DB::Helper::Mappings->get_package_names;
our %lx_office_conf;
our $script = __FILE__;
-$script =~ s:.*/::;
+$script =~ s{.*/}{};
$OUTPUT_AUTOFLUSH = 1;
$Data::Dumper::Sortkeys = 1;
my %config;
-our %foreign_key_name_map = (
- oe => { payment => 'payment_terms', },
- ar => { payment => 'payment_terms', },
- ap => { payment => 'payment_terms', },
-
- orderitems => { parts => 'part', trans => 'order', },
- delivery_order_items => { parts => 'part' },
- invoice => { parts => 'part' },
- follow_ups => { 'employee_obj' => 'created_for' },
-
- periodic_invoices_configs => { oe => 'order' },
+# Maps column names in tables to foreign key relationship names. For
+# example:
+#
+# »follow_up_access« contains a column named »who«. Rose normally
+# names the resulting relationship after the class the target table
+# uses. In this case the target table is »employee« and the
+# corresponding class SL::DB::Employee. The resulting relationship
+# would be named »employee«.
+#
+# In order to rename this relationship we have to map »who« to
+# e.g. »granted_by«:
+# follow_up_access => { who => 'granted_by' },
+
+our %foreign_key_name_map = (
+ KIVITENDO => {
+ oe => { payment_id => 'payment_terms', },
+ ar => { payment_id => 'payment_terms', },
+ ap => { payment_id => 'payment_terms', },
+
+ orderitems => { parts_id => 'part', trans_id => 'order', },
+ delivery_order_items => { parts_id => 'part' },
+ invoice => { parts_id => 'part' },
+ follow_ups => { created_for_user => 'created_for_employee', created_by => 'created_by_employee', },
+ follow_up_access => { who => 'with_access', what => 'to_follow_ups_by', },
+
+ periodic_invoices_configs => { oe_id => 'order', email_recipient_contact_id => 'email_recipient_contact' },
+ reconciliation_links => { acc_trans_id => 'acc_trans' },
+
+ assembly => { parts_id => 'part', id => 'assembly_part' },
+ assortment_items => { parts_id => 'part' },
+
+ dunning => { trans_id => 'invoice', fee_interest_ar_id => 'fee_interest_invoice' },
+ },
);
sub setup {
SL::LxOfficeConf->read;
- my $client = $config{client} || $::lx_office_conf{devel}{client};
+ my $client = $config{client} || $::lx_office_conf{devel}{client};
+ my $new_client = $config{new_client};
- if (!$client) {
+ if (!$client && !$new_client) {
error("No client found in config. Please provide a client:");
usage();
}
- $::lxdebug = LXDebug->new();
- $::locale = Locale->new("de");
- $::form = new Form;
- $form->{script} = 'rose_meta_data.pl';
- $::auth = SL::Auth->new();
+ $::lxdebug = LXDebug->new();
+ $::lxdebug->disable_sub_tracing;
+ $::locale = Locale->new("de");
+ $::form = new Form;
+ $::instance_conf = SL::InstanceConfiguration->new;
+ $form->{script} = 'rose_meta_data.pl';
+
+ if ($new_client) {
+ $::auth = SL::Auth->new(unit_tests_database => 1);
+ $client = 1;
+ drop_and_create_test_database();
+ } else {
+ $::auth = SL::Auth->new();
+ }
if (!$::auth->set_client($client)) {
error("No client with ID or name '$client' found in config. Please provide a client:");
}
}
+sub fix_relationship_names {
+ my ($domain, $table, $fkey_text) = @_;
+
+ if ($fkey_text !~ m/key_columns \s+ => \s+ \{ \s+ ['"]? ( [^'"\s]+ ) /x) {
+ die "fix_relationship_names: could not extract the key column for domain/table $domain/$table; foreign key definition text:\n${fkey_text}\n";
+ }
+
+ my $column_name = $1;
+ my %changes = map { %{$_} } grep { $_ } ($foreign_key_name_map{$domain}->{ALL}, $foreign_key_name_map{$domain}->{$table});
+
+ if (my $desired_name = $changes{$column_name}) {
+ $fkey_text =~ s/^ \s\s [^\s]+ \b/ ${desired_name}/msx;
+ }
+
+ return $fkey_text;
+}
+
sub process_table {
my ($domain, $table, $package) = @_;
my $schema = '';
eval <<CODE;
package SL::DB::AUTO::$package;
- use SL::DB::Object;
- use base qw(SL::DB::Object);
+ use parent qw(SL::DB::Object);
__PACKAGE__->meta->table('$table');
$schema_str
$foreign_key_definition =~ s/::AUTO::/::/g;
if ($foreign_key_definition && ($definition =~ /\Q$foreign_key_definition\E/)) {
+ # These positions refer to the whole setup call, not just the
+ # parameters/actual relationship definitions.
my ($start, $end) = ($-[0], $+[0]);
- while (my ($auto_generated_name, $desired_name) = each %{ $foreign_key_name_map{$table} || {} }) {
- $foreign_key_definition =~ s/^ \s \s ${auto_generated_name} \b/ ${desired_name}/msx;
- }
+ # Match the function parameters = the actual relationship
+ # definitions
+ next unless $foreign_key_definition =~ m/\(\n(.+)\n\)/s;
- # Sort foreign key definitions alphabetically
- if ($foreign_key_definition =~ m/\(\n(.+)\n\)/s) {
- my ($list_start, $list_end) = ($-[0], $+[0]);
- my @foreign_keys = split m/\n\n/m, $1;
- my $sorted_foreign_keys = "(\n" . join("\n\n", sort @foreign_keys) . "\n)";
+ my ($list_start, $list_end) = ($-[0], $+[0]);
- substr $foreign_key_definition, $list_start, $list_end - $list_start, $sorted_foreign_keys;;
- }
+ # Split the whole chunk on double new lines. The resulting
+ # elements are one relationship each. Then fix the relationship
+ # names and sort them by their new names.
+ my @new_foreign_keys = sort map { fix_relationship_names($domain, $table, $_) } split m/\n\n/m, $1;
- substr($definition, $start, $end - $start) = $foreign_key_definition;
+ # Replace the function parameters = the actual relationship
+ # definitions with the new ones.
+ my $sorted_foreign_keys = "(\n" . join("\n\n", @new_foreign_keys) . "\n)";
+ substr $foreign_key_definition, $list_start, $list_end - $list_start, $sorted_foreign_keys;
+
+ # Replace the whole setup call in the auto-generated output with
+ # our new version.
+ substr $definition, $start, $end - $start, $foreign_key_definition;
}
$definition =~ s/(meta->table.*)\n/$1\n$schema_str/m if $schema;
+ $definition =~ s{^use base}{use parent}m;
my $full_definition = <<CODE;
# This file has been auto-generated. Do not modify it; it will be overwritten
use strict;
-use SL::DB::Helper::Manager;
-use base qw(SL::DB::Helper::Manager);
+use parent qw(SL::DB::Helper::Manager);
sub object_class { 'SL::DB::${package}' }
my ($options) = @_;
GetOptions(
'client=s' => \ my $client,
+ 'test-client' => \ my $use_test_client,
all => \ my $all,
'db=s' => \ my $db,
'no-commit|dry-run' => \ my $nocommit,
diff => \ my $diff,
);
- $options->{client} = $client;
- $options->{all} = $all;
- $options->{db} = $db;
- $options->{nocommit} = $nocommit;
- $options->{quiet} = $quiet;
- $options->{color} = -t STDOUT ? 1 : 0;
+ $options->{client} = $client;
+ $options->{new_client} = $use_test_client;
+ $options->{all} = $all;
+ $options->{db} = $db;
+ $options->{nocommit} = $nocommit;
+ $options->{quiet} = $quiet;
+ $options->{color} = -t STDOUT ? 1 : 0;
if ($diff) {
if (eval { require Text::Diff; 1 }) {
pod2usage(verbose => 99, sections => 'SYNOPSIS');
}
+sub list_all_tables {
+ my ($db) = @_;
+
+ my @schemas = (undef, uniq apply { s{\..*}{} } grep { m{\.} } keys %{ $package_names{KIVITENDO} });
+ my @tables;
+
+ foreach my $schema (@schemas) {
+ $db->schema($schema);
+ push @tables, map { $schema ? "${schema}.${_}" : $_ } $db->list_tables;
+ }
+
+ $db->schema(undef);
+
+ return @tables;
+}
+
sub make_tables {
my %tables_by_domain;
if ($config{all}) {
foreach my $domain (@domains) {
my $db = SL::DB::create(undef, $domain);
- $tables_by_domain{$domain} = [ grep { my $table = $_; none { $_ eq $table } @{ $blacklist{$domain} } } $db->list_tables ];
+ $tables_by_domain{$domain} = [ grep { my $table = $_; none { $_ eq $table } @{ $blacklist{$domain} } } list_all_tables($db) ];
$db->disconnect;
}
}
}
+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");
+}
+
parse_args(\%config);
setup();
check_errors_in_package_names();
=head1 SYNOPSIS
- scripts/rose_auto_create_model.pl --client name-or-id [db1:]table1 [[db2:]table2 ...]
- scripts/rose_auto_create_model.pl --client name-or-id [--all|-a]
+ scripts/rose_auto_create_model.pl OPTIONS TARGET
+
+ # use other client than devel.client
+ scripts/rose_auto_create_model.pl --test-client TARGET
+ scripts/rose_auto_create_model.pl --client name-or-id TARGET
+ # TARGETS:
# updates all models
- scripts/rose_auto_create_model.pl --client name-or-id --all [--db db]
+ scripts/rose_auto_create_model.pl --all [--db db]
# updates only customer table, login taken from config
scripts/rose_auto_create_model.pl customer
=over 4
+=item C<--test-client, -t>
+
+Use the C<testing/database> to create a new testing database, and connect to
+the first client there. Overrides C<client>.
+
+If neither C<test-client> nor C<client> are set, the config key C<devel/client>
+will be used.
+
=item C<--client, -c CLIENT>
-Provide a client whose database settings are used. If not present the
-client is loaded from the config key C<devel/client>. If that too is
-not found, an error is thrown.
+Provide a client whose database settings are used. C<CLIENT> can be either a
+database ID or a client's name.
-Note that C<CLIENT> can be either a database ID or a client's name.
+If neither C<test-client> nor C<client> are set, the config key C<devel/client>
+will be used.
=item C<--all, -a>
projects / kivitendo-erp.git / blobdiff