# database connection from the data given in the current context, and
# returns it.
sub _new_schema {
- my $context = C4::Context->new();
- my $db_driver = C4::Context::db_scheme2dbi($context->config("db_scheme"));
-
- my $db_name = $context->config("database");
- my $db_host = $context->config("hostname");
- my $db_port = $context->config("port") || '';
- my $db_user = $context->config("user");
- my $db_passwd = $context->config("pass");
-
- my $db_opts = ($db_driver eq 'mysql') ? { mysql_enable_utf8 => 1 } :
- ($db_driver eq 'Pg') ? { pg_enable_utf8 => 1 } :
- { };
- my $schema = Koha::Schema->connect(
- "DBI:$db_driver:dbname=$db_name;host=$db_host;port=$db_port",
- $db_user, $db_passwd, $db_opts );
+ my $schema = Koha::Schema->connect( sub { C4::Context->dbh } );
return $schema;
}
# Created by DBIx::Class::Schema::Loader v0.07025 @ 2013-10-14 20:56:21
# DO NOT MODIFY THIS OR ANYTHING ABOVE! md5sum:oDUxXckmfk6H9YCjW8PZTw
+__PACKAGE__->storage_type('Koha::Storage');
-# You can replace this text with custom content, and it will be preserved on regeneration
1;
--- /dev/null
+use utf8;
+package Koha::Storage;
+
+use strict;
+use warnings;
+
+use base 'DBIx::Class::Storage::DBI';
+sub DESTROY {
+ my $self = shift;
+
+ # destroy just the object if not native to this process/thread
+ $self->_preserve_foreign_dbh;
+
+ $self->_dbh(undef);
+}
+1;