diff --git a/lib/NGCP/CentralSchema.pm b/lib/NGCP/CentralSchema.pm
new file mode 100644
index 00000000..5a310d89
--- /dev/null
+++ b/lib/NGCP/CentralSchema.pm
@@ -0,0 +1,13 @@
+package NGCP::CentralSchema;
+use Moose;
+extends 'NGCP::Schema';
+
+our $VERSION = '2.007';
+
+sub connection {
+    my ($self) = @_;
+    $self->SUPER::connection($self->config->as_hash->{ngcp_central_connect_info});
+}
+
+no Moose;
+1;
diff --git a/lib/NGCP/Schema.pm b/lib/NGCP/Schema.pm
index 48a02aa0..8cc8661d 100644
--- a/lib/NGCP/Schema.pm
+++ b/lib/NGCP/Schema.pm
@@ -19,8 +19,11 @@ class_has('config', is => 'rw', isa => 'NGCP::Schema::Config', lazy => 1, defaul
 });
 
 sub connection {
-    my ($self) = @_;
-    $self->SUPER::connection($self->config->as_hash->{ngcp_connect_info});
+    my ($self, $cfg) = @_;
+    unless(defined $cfg->{dsn}) {
+        $cfg = $self->config->as_hash->{ngcp_connect_info};
+    }
+    $self->SUPER::connection($cfg);
 }
 
 sub validate {