rs.read.as(Clear::SQL::Any)

crystal-garage · Aug 24, 2024 · 2f702b8 · 2f702b8
1 parent 8be17f0
commit 2f702b8
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/src/clear/sql/insert_query.cr b/src/clear/sql/insert_query.cr
@@ -55,7 +55,7 @@ class Clear::SQL::InsertQuery
 
     loop do
       rs.each_column do |col|
-        h[col] = rs.read
+        h[col] = rs.read.as(Clear::SQL::Any)
       end
 
       yield(h)

diff --git a/src/clear/sql/query/fetch.cr b/src/clear/sql/query/fetch.cr
@@ -5,7 +5,7 @@ module Clear::SQL::Query::Fetch
 
     loop do
       rs.each_column do |col|
-        h[col] = rs.read
+        h[col] = rs.read.as(Clear::SQL::Any)
       end
 
       yield(h)

diff --git a/src/clear/sql/query/pluck.cr b/src/clear/sql/query/pluck.cr
@@ -32,7 +32,7 @@ module Clear::SQL::Query::Pluck
       o = [] of Clear::SQL::Any
 
       while rs.move_next
-        o << rs.read
+        o << rs.read.as(Clear::SQL::Any)
       end
       o
     ensure
@@ -85,7 +85,7 @@ module Clear::SQL::Query::Pluck
         o = [] of Tuple({% for t in T %}Clear::SQL::Any,{% end %})
 
         while rs.move_next
-            o << { {% for t in T %} rs.read, {% end %} }
+          o << { {% for t in T %} rs.read.as(Clear::SQL::Any), {% end %} }
         end
         o
       {% end %}