Fixes afair#38 Add configuration for own name of cursor

Author: afair

Gemfile.lock

@@ -1,33 +1,33 @@
 PATH
   remote: .
   specs:
-    postgresql_cursor (0.6.2)
+    postgresql_cursor (0.6.3)
       activerecord (>= 3.1.0)
 
 GEM
   remote: https://rubygems.org/
   specs:
-    activemodel (5.2.1)
-      activesupport (= 5.2.1)
-    activerecord (5.2.1)
-      activemodel (= 5.2.1)
-      activesupport (= 5.2.1)
-      arel (>= 9.0)
-    activesupport (5.2.1)
+    activemodel (6.0.0)
+      activesupport (= 6.0.0)
+    activerecord (6.0.0)
+      activemodel (= 6.0.0)
+      activesupport (= 6.0.0)
+    activesupport (6.0.0)
       concurrent-ruby (~> 1.0, >= 1.0.2)
       i18n (>= 0.7, < 2)
       minitest (~> 5.1)
       tzinfo (~> 1.1)
-    arel (9.0.0)
-    concurrent-ruby (1.0.5)
-    i18n (1.1.0)
+      zeitwerk (~> 2.1, >= 2.1.8)
+    concurrent-ruby (1.1.5)
+    i18n (1.6.0)
       concurrent-ruby (~> 1.0)
-    minitest (5.11.3)
-    pg (1.0.0)
-    rake (12.3.1)
+    minitest (5.12.0)
+    pg (1.1.4)
+    rake (13.0.0)
     thread_safe (0.3.6)
     tzinfo (1.2.5)
       thread_safe (~> 0.1)
+    zeitwerk (2.1.10)
 
 PLATFORMS
   ruby
@@ -39,4 +39,4 @@ DEPENDENCIES
   rake
 
 BUNDLED WITH
-   1.16.3
+   1.17.3

README.md

@@ -67,6 +67,7 @@ All these methods take an options hash to control things more:
                       This library uses 1.0 (Optimize for 100% of the result set)
                       Do not override this value unless you understand it.
     with_hold:boolean Keep the cursor "open" even after a commit.
+    cursor_name:string Give your cursor a name.
 
 Notes:
 

lib/postgresql_cursor.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require 'postgresql_cursor/version'
 
 ActiveSupport.on_load :active_record do

lib/postgresql_cursor/active_record/relation/cursor_iterators.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 # Defines extension to ActiveRecord/AREL to use this library
 module PostgreSQLCursor
   module ActiveRecord
@@ -12,6 +14,7 @@ module CursorIterators
         #   block_size: 1..n      - The number of rows to fetch per db block fetch
         #   while: value          - Exits loop when block does not return this value.
         #   until: value          - Exits loop when block returns this value.
+        #   cursor_name: string   - Allows you to name your cursor.
         #
         # Example:
         #   Post.where(user_id:123).each_row { |hash| Post.process(hash) }

lib/postgresql_cursor/cursor.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 ################################################################################
 # PostgreSQLCursor: library class provides postgresql cursor for large result
 # set processing. Requires ActiveRecord, but can be adapted to other DBI/ORM libraries.
@@ -10,6 +12,7 @@
 #   while: value          - Exits loop when block does not return this value.
 #   until: value          - Exits loop when block returns this value.
 #   with_hold: boolean    - Allows the query to remain open across commit points.
+#   cursor_name: string   - Allows you to name your cursor.
 #
 # Exmaples:
 #   PostgreSQLCursor::Cursor.new("select ...").each { |hash| ... }
@@ -245,7 +248,7 @@ def column_types
     # Public: Opens (actually, "declares") the cursor. Call this before fetching
     def open
       set_cursor_tuple_fraction
-      @cursor = SecureRandom.uuid.gsub("-","")
+      @cursor = @options[:cursor_name] || SecureRandom.uuid.gsub("-","")
       hold = @options[:with_hold] ? 'with hold ' : ''
       @result = @connection.execute("declare cursor_#{@cursor} no scroll cursor #{hold}for #{@sql}")
       @block = []

lib/postgresql_cursor/version.rb

@@ -1,3 +1,3 @@
 module PostgresqlCursor
-  VERSION = "0.6.2.1"
+  VERSION = "0.6.3"
 end