myrocks support

Author: shanth96

activerecord/lib/active_record/connection_adapters.rb

@@ -67,6 +67,7 @@ def resolve(adapter_name) # :nodoc:
     register "sqlite3", "ActiveRecord::ConnectionAdapters::SQLite3Adapter", "active_record/connection_adapters/sqlite3_adapter"
     register "mysql2", "ActiveRecord::ConnectionAdapters::Mysql2Adapter", "active_record/connection_adapters/mysql2_adapter"
     register "trilogy", "ActiveRecord::ConnectionAdapters::TrilogyAdapter", "active_record/connection_adapters/trilogy_adapter"
+    register "trilogy_myrocks", "ActiveRecord::ConnectionAdapters::TrilogyMyRocksAdapter", "active_record/connection_adapters/trilogy_myrocks_adapter"
     register "postgresql", "ActiveRecord::ConnectionAdapters::PostgreSQLAdapter", "active_record/connection_adapters/postgresql_adapter"
 
     eager_autoload do

activerecord/lib/active_record/connection_adapters/abstract/transaction.rb

@@ -494,6 +494,44 @@ def commit
       end
     end
 
+    class FakeTransaction < Transaction
+      def initialize(connection, parent_transaction, **options)
+        super(connection, **options)
+
+        parent_transaction.state.add_child(@state)
+
+        if isolation_level
+          raise ActiveRecord::TransactionIsolationError, "cannot set transaction isolation in a nested transaction"
+        end
+      end
+
+      def materialize!
+        super
+      end
+
+      def restart
+        return unless materialized?
+
+        @instrumenter.finish(:restart)
+        @instrumenter.start
+
+        @parent.restart
+      end
+
+      def rollback
+        @state.rollback!
+        @instrumenter.finish(:rollback) if materialized?
+      end
+
+      def commit
+        @state.commit!
+        @instrumenter.finish(:commit) if materialized?
+      end
+
+      def full_rollback?; false; end
+    end
+
+
     class TransactionManager # :nodoc:
       def initialize(connection)
         @stack = []
@@ -522,6 +560,14 @@ def begin_transaction(isolation: nil, joinable: true, _lazy: true)
                 joinable: joinable,
                 run_commit_callbacks: run_commit_callbacks
               )
+             elsif !@connection.supports_savepoints?
+              FakeTransaction.new(
+                @connection,
+                current_transaction,
+                isolation: isolation,
+                joinable: joinable,
+                run_commit_callbacks: run_commit_callbacks
+              )
             else
               SavepointTransaction.new(
                 @connection,

activerecord/lib/active_record/connection_adapters/trilogy_myrocks_adapter.rb

@@ -0,0 +1,13 @@
+# frozen_string_literal: true
+
+module ActiveRecord
+  module ConnectionAdapters
+    class TrilogyMyRocksAdapter < TrilogyAdapter
+      ADAPTER_NAME = "TrilogyMyRocks"
+
+      def supports_savepoints?
+        false
+      end
+    end
+  end
+end