Cast aggregrate_id to text rather then varchar

zilverline · Dec 13, 2023 · 5faece3 · 5faece3
1 parent e404006
commit 5faece3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/sequent/migrations/view_schema.rb b/lib/sequent/migrations/view_schema.rb
@@ -441,7 +441,7 @@ def event_stream(aggregate_prefixes, event_types, exclude_already_replayed)
 
         event_stream = Sequent.configuration.event_record_class.where(event_type: event_types)
         event_stream = event_stream.where(<<~SQL, aggregate_prefixes)
-          substring(aggregate_id::varchar from 1 for #{LENGTH_OF_SUBSTRING_INDEX_ON_AGGREGATE_ID_IN_EVENT_STORE}) in (?)
+          substring(aggregate_id::text from 1 for #{LENGTH_OF_SUBSTRING_INDEX_ON_AGGREGATE_ID_IN_EVENT_STORE}) in (?)
         SQL
         if exclude_already_replayed
           event_stream = event_stream