diff --git a/Gemfile.lock b/Gemfile.lock
index 459910b..2656071 100644
--- a/Gemfile.lock
+++ b/Gemfile.lock
@@ -1,7 +1,7 @@
 PATH
   remote: .
   specs:
-    janus-ar (0.1.0)
+    janus-ar (0.3.0)
 
 GEM
   remote: http://rubygems.org/
diff --git a/lib/active_record/connection_adapters/janus_mysql2_adapter.rb b/lib/active_record/connection_adapters/janus_mysql2_adapter.rb
index b4a5169..68cc343 100644
--- a/lib/active_record/connection_adapters/janus_mysql2_adapter.rb
+++ b/lib/active_record/connection_adapters/janus_mysql2_adapter.rb
@@ -25,14 +25,12 @@ class JanusMysql2Adapter < ActiveRecord::ConnectionAdapters::Mysql2Adapter
       SQL_SKIP_ALL_MATCHERS = [/\A\s*set\s+local\s/i].freeze
 
       def initialize(*args)
+        args[0][:janus]['replica']['database'] = args[0][:database]
+        args[0][:janus]['primary']['database'] = args[0][:database]
+
         @replica_config = args[0][:janus]['replica']
         args[0] = args[0][:janus]['primary']
 
-        if args[0]['database'].nil?
-          args[0]['database'] = nil
-          @replica_config['database'] = nil
-        end
-
         super(*args)
         @connection_parameters ||= args[0]
         update_config
diff --git a/lib/janus/version.rb b/lib/janus/version.rb
index 06cf6e6..1ceddec 100644
--- a/lib/janus/version.rb
+++ b/lib/janus/version.rb
@@ -4,7 +4,7 @@ module Janus
   unless defined?(::Janus::VERSION)
     module VERSION
       MAJOR = 0
-      MINOR = 3
+      MINOR = 4
       PATCH = 0
       PRE = nil