@@ -202,17 +202,19 @@ def assert_result(df, users)
202202 assert_series users . map ( &:dec ) , df [ "dec" ]
203203 assert_series users . map ( &:txt ) , df [ "txt" ]
204204 assert_series users . map ( &:joined_time ) , df [ "joined_time" ]
205- assert_series [ { "hello" => "world" } , nil , { "hello" => nil } ] , df [ "settings" ]
206205
207206 if postgresql? || ( sqlite? && ar_version >= 8.1 )
208207 assert_series users . map ( &:active ) , df [ "active" ]
209208 assert_series users . map ( &:joined_on ) , df [ "joined_on" ]
209+ assert_series [ { "hello" => "world" } , nil , { "hello" => nil } ] , df [ "settings" ]
210210 elsif mysql?
211211 assert_series users . map ( &:active ) . map { |v | v ? 1 : 0 } , df [ "active" ]
212212 assert_series users . map ( &:joined_on ) , df [ "joined_on" ]
213+ assert_series [ '{"hello": "world"}' . b , nil , '{}' . b ] , df [ "settings" ]
213214 else
214215 assert_series users . map ( &:active ) . map { |v | v ? 1 : 0 } , df [ "active" ]
215216 assert_series users . map ( &:joined_on ) . map ( &:to_s ) , df [ "joined_on" ]
217+ assert_series [ '{"hello":"world"}' , nil , '{}' ] , df [ "settings" ]
216218 end
217219
218220 assert_schema df
@@ -239,7 +241,7 @@ def assert_schema(df)
239241 assert_equal Polars ::Datetime , schema [ "joined_at" ]
240242 assert_equal Polars ::Decimal , schema [ "dec" ]
241243 assert_equal Polars ::Datetime , schema [ "joined_time" ]
242- # assert_equal Polars::String , schema["settings"]
244+ assert_equal Polars ::Binary , schema [ "settings" ]
243245 else
244246 assert_equal Polars ::Int64 , schema [ "active" ]
245247 assert_equal Polars ::String , schema [ "joined_at" ]
@@ -265,7 +267,7 @@ def create_users
265267 dec : BigDecimal ( "1.5" ) ,
266268 txt : "txt" ,
267269 joined_time : now ,
268- settings : mysql? ? settings [ i ] . to_json : settings [ i ]
270+ settings : settings [ i ]
269271 )
270272 end
271273 # reload for time column
0 commit comments