Add create_records to speed things up when inserting many records

lib/sequent/core/base_event_handler.rb

@@ -42,7 +42,7 @@ def initialize(record_session = Sequent::Core::RecordSessions::ActiveRecordSessi
         @record_session = record_session
       end
 
-      def_delegators :@record_session, :update_record, :create_record, :create_or_update_record, :get_record!, :get_record,
+      def_delegators :@record_session, :update_record, :create_record, :create_records, :create_or_update_record, :get_record!, :get_record,
                      :delete_all_records, :update_all_records, :do_with_records, :do_with_record, :delete_record,
                      :find_records, :last_record, :execute
 

lib/sequent/core/record_sessions/active_record_session.rb

@@ -33,6 +33,21 @@ def create_record(record_class, values)
           record
         end
 
+        def create_records(record_class, array_of_value_hashes)
+          table = Arel::Table.new(record_class.table_name)
+
+          query = array_of_value_hashes.map do |values|
+            insert_manager = Arel::InsertManager.new(ActiveRecord::Base)
+            insert_manager.into(table)
+            insert_manager.insert(values.map do |key, value|
+              [table[key], value]
+            end)
+            insert_manager.to_sql
+          end.join(";")
+
+          execute(query)
+        end
+
         def create_or_update_record(record_class, values, created_at = Time.now)
           record = get_record(record_class, values)
           unless record

lib/sequent/core/record_sessions/replay_events_session.rb

@@ -198,6 +198,10 @@ def hash
           record
         end
 
+        def create_records(record_class, array_of_value_hashes)
+          array_of_value_hashes.each { |values| create_record(record_class, values) }
+        end
+
         def create_or_update_record(record_class, values, created_at = Time.now)
           record = get_record(record_class, values)
           unless record