kalipso/racalmas
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

db.pm: add long-running connection cache

Browse Source
This commit is contained in:
Milan
2022-11-18 21:58:05 +01:00
parent 1851509586
commit b28cf1e6e0
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
lib/calcms/db.pm
View File

@@ -49,6 +49,8 @@ sub connect($;$) {
my $dsn = "DBI:mysql:database=$database;host=$hostname;port=$port"; my $dsn = "DBI:mysql:database=$database;host=$hostname;port=$port";
my $key = Digest::MD5::md5_hex($dsn.$username.$password); my $key = Digest::MD5::md5_hex($dsn.$username.$password);
return $options->{connections}->{$key} if defined $options->{connections}->{$key}; return $options->{connections}->{$key} if defined $options->{connections}->{$key};
state $connections = {};
return $connections->{$key} if defined $connections->{$key} and $connections->{$key}->ping;
my $dbh = DBI->connect( $dsn, $username, $password, { mysql_enable_utf8 => 1 } ) my $dbh = DBI->connect( $dsn, $username, $password, { mysql_enable_utf8 => 1 } )
|| die "could not connect to database: $DBI::errstr"; || die "could not connect to database: $DBI::errstr";
@@ -59,6 +61,7 @@ sub connect($;$) {
put( $dbh, "set time_zone='" . $options->{date}->{time_zone} . "'", undef ); put( $dbh, "set time_zone='" . $options->{date}->{time_zone} . "'", undef );
$request->{connection} = $dbh; $request->{connection} = $dbh;
$options->{connections}->{$key} = $dbh; $options->{connections}->{$key} = $dbh;
$connections->{$key} = $dbh;
return $dbh; return $dbh;
} }