diff --git a/lib/bulk_insert/worker.rb b/lib/bulk_insert/worker.rb
index 26e0b07..1dc6139 100644
--- a/lib/bulk_insert/worker.rb
+++ b/lib/bulk_insert/worker.rb
@@ -121,7 +121,11 @@ def compose_insert_query
 
           if ActiveRecord::VERSION::STRING >= "5.0.0"
             if column
-              type = @connection.lookup_cast_type_from_column(column)
+              type =
+                @connection.respond_to?(:lookup_cast_type_from_column) ?
+                  @connection.lookup_cast_type_from_column(column) :
+                  @connection.lookup_cast_type(column.sql_type)
+
               value = type.serialize(value)
             end
             values << @connection.quote(value)