Direct BEGIN queries to primary database server

Gemfile.lock

@@ -1,7 +1,7 @@
 PATH
   remote: .
   specs:
-    janus-ar (0.14.0)
+    janus-ar (0.15.1)
 
 GEM
   remote: http://rubygems.org/

lib/janus/query_director.rb

@@ -13,7 +13,7 @@ class QueryDirector
     SQL_REPLICA_MATCHERS = [/\A\s*(select|with.+\)\s*select)\s/i].freeze
     SQL_ALL_MATCHERS = [/\A\s*set\s/i].freeze
     SQL_SKIP_ALL_MATCHERS = [/\A\s*set\s+local\s/i].freeze
-    WRITE_PREFIXES = %w(INSERT UPDATE DELETE LOCK CREATE GRANT DROP ALTER TRUNCATE FLUSH).freeze
+    WRITE_PREFIXES = %w(INSERT UPDATE DELETE LOCK CREATE GRANT DROP ALTER TRUNCATE BEGIN SAVEPOINT FLUSH).freeze
 
     def initialize(sql, open_transactions)
       @_sql = sql

lib/janus/version.rb

@@ -5,7 +5,7 @@ module Janus
     module VERSION
       MAJOR = 0
       MINOR = 15
-      PATCH = 0
+      PATCH = 1
       PRE = nil
 
       def self.to_s

spec/lib/janus/query_director_spec.rb

@@ -15,7 +15,8 @@
     it { expect(described_class::SQL_REPLICA_MATCHERS).to eq([/\A\s*(select|with.+\)\s*select)\s/i]) }
     it { expect(described_class::SQL_ALL_MATCHERS).to eq([/\A\s*set\s/i]) }
     it {
-      expect(described_class::WRITE_PREFIXES).to eq %w(INSERT UPDATE DELETE LOCK CREATE GRANT DROP ALTER TRUNCATE FLUSH)
+      expect(described_class::WRITE_PREFIXES).to eq %w(INSERT UPDATE DELETE LOCK CREATE GRANT DROP ALTER TRUNCATE BEGIN
+                                                       SAVEPOINT FLUSH)
     }
 
     it { expect(described_class::ALL).to eq :all }