Added the cleanup parameter to Database->disconnect()

* This was added so that, in Database->reconnect(), no attempt is made
  to update or disconnect from the DBs, preventing problems when the
  target DB was unexpectedly lost.

Signed-off-by: Madison Kelly <mkelly@alteeve.com>
main
Madison Kelly 6 months ago
parent 80ef5232e8
commit 3a41639baa
  1. 29
      Anvil/Tools/Database.pm
  2. 2
      share/words.xml

@ -2339,7 +2339,11 @@ sub connect
This cleanly closes any open file handles to all connected databases and clears some internal database related variables. This cleanly closes any open file handles to all connected databases and clears some internal database related variables.
This method takes no parameters. Parameters;
=head3 cleanup (optional, default '1')
If set to C<< 1 >> (default), the disconnect will be cleaned up (marked inactive, clear locking, etc). If the DB handle was lost unexpectedly, this is not possible. Set this to C<< 0 >> to prevent this.
=cut =cut
sub disconnect sub disconnect
@ -2350,6 +2354,11 @@ sub disconnect
my $debug = defined $parameter->{debug} ? $parameter->{debug} : 3; my $debug = defined $parameter->{debug} ? $parameter->{debug} : 3;
$anvil->Log->entry({source => $THIS_FILE, line => __LINE__, level => $debug, key => "log_0125", variables => { method => "Database->disconnect()" }}); $anvil->Log->entry({source => $THIS_FILE, line => __LINE__, level => $debug, key => "log_0125", variables => { method => "Database->disconnect()" }});
my $cleanup = defined $parameter->{cleanup} ? $parameter->{cleanup} : 1;
$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => $debug, list => {
cleanup => $cleanup,
}});
my $marked_inactive = 0; my $marked_inactive = 0;
foreach my $uuid (sort {$a cmp $b} keys %{$anvil->data->{database}}) foreach my $uuid (sort {$a cmp $b} keys %{$anvil->data->{database}})
{ {
@ -2357,14 +2366,19 @@ sub disconnect
next if ((not $anvil->data->{cache}{database_handle}{$uuid}) or ($anvil->data->{cache}{database_handle}{$uuid} !~ /^DBI::db=HASH/)); next if ((not $anvil->data->{cache}{database_handle}{$uuid}) or ($anvil->data->{cache}{database_handle}{$uuid} !~ /^DBI::db=HASH/));
# Clear locks and mark that we're done running. # Clear locks and mark that we're done running.
if (not $marked_inactive) if ((not $marked_inactive) && ($cleanup))
{ {
$anvil->Log->entry({source => $THIS_FILE, line => __LINE__, level => 2, key => "log_0857", variables => { uuid => $uuid }});
$anvil->Database->mark_active({debug => $debug, set => 0}); $anvil->Database->mark_active({debug => $debug, set => 0});
$anvil->Database->locking({debug => $debug, release => 1}); $anvil->Database->locking({debug => $debug, release => 1});
$marked_inactive = 1; $marked_inactive = 1;
} }
$anvil->data->{cache}{database_handle}{$uuid}->disconnect; if ($cleanup)
{
$anvil->Log->entry({source => $THIS_FILE, line => __LINE__, level => 2, key => "log_0858", variables => { uuid => $uuid }});
$anvil->data->{cache}{database_handle}{$uuid}->disconnect;
}
delete $anvil->data->{cache}{database_handle}{$uuid}; delete $anvil->data->{cache}{database_handle}{$uuid};
$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => $debug, list => { uuid => $uuid }}); $anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => $debug, list => { uuid => $uuid }});
} }
@ -18159,6 +18173,8 @@ AND
This method disconnects from any connected databases, re-reads the config, and then tries to reconnect to any databases again. The number of connected datbaases is returned. This method disconnects from any connected databases, re-reads the config, and then tries to reconnect to any databases again. The number of connected datbaases is returned.
B<< Note >>: This calls C<< Database->disconnect({cleanup => 0}); >> to prevent attempts to talk to the potentially lost database handle.
Parameters; Parameters;
=head3 lost_uuid (optional) =head3 lost_uuid (optional)
@ -18190,7 +18206,10 @@ sub reconnect
} }
# Disconnect from all databases and then stop the daemon, then reconnect. # Disconnect from all databases and then stop the daemon, then reconnect.
$anvil->Database->disconnect({debug => $debug}); $anvil->Database->disconnect({
debug => $debug,
cleanup => 0,
});
sleep 2; sleep 2;
# Refresh configs. # Refresh configs.
@ -20931,7 +20950,7 @@ sub _test_access
# Try to reconnect. # Try to reconnect.
$anvil->Database->reconnect({ $anvil->Database->reconnect({
debug => $debug, debug => 2,
lost_uuid => $uuid, lost_uuid => $uuid,
}); });
$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => $debug, list => { $anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => $debug, list => {

@ -2744,6 +2744,8 @@ new key: [#!variable!new_key!#]</key>
<key name="log_0854">The connection to the database: [#!variable!server!#] has been restored!</key> <key name="log_0854">The connection to the database: [#!variable!server!#] has been restored!</key>
<key name="log_0855">Calling: [#!variable!shell_call!#] via a 'timeout' of: [#!variable!timeout!#] seconds.</key> <key name="log_0855">Calling: [#!variable!shell_call!#] via a 'timeout' of: [#!variable!timeout!#] seconds.</key>
<key name="log_0856">Calling: [#!variable!shell_call!#] on: [#!variable!target!#] via a 'timeout' of: [#!variable!timeout!#] seconds.</key> <key name="log_0856">Calling: [#!variable!shell_call!#] on: [#!variable!target!#] via a 'timeout' of: [#!variable!timeout!#] seconds.</key>
<key name="log_0857">Cleaning up the connection to the database on striker: [#!variable!uuid!#].</key>
<key name="log_0858">Disconnecting from the database on striker: [#!variable!uuid!#].</key>
<!-- Messages for users (less technical than log entries), though sometimes used for logs, too. --> <!-- Messages for users (less technical than log entries), though sometimes used for logs, too. -->
<key name="message_0001">The host name: [#!variable!target!#] does not resolve to an IP address.</key> <key name="message_0001">The host name: [#!variable!target!#] does not resolve to an IP address.</key>

Loading…
Cancel
Save