bugfix: decoding None values

idatsy · idatsy · commit b834eaef8918 · 2024-08-24T15:29:43.000+01:00
diff --git a/py_questdb/__init__.py b/py_questdb/__init__.py
@@ -0,0 +1,3 @@
+from py_questdb.db import QuestDB
+
+__all__ = ['QuestDB']
diff --git a/py_questdb/db.py b/py_questdb/db.py
@@ -142,7 +142,9 @@ def parse_and_yield_query_response(
 
         for row in response.dataset:
             converted_row = {
-                field.name: converter(value) for field, converter, value in zip(response.columns, type_converter, row)
+                field.name: converter(value) if value is not None else None
+                for field, converter, value
+                in zip(response.columns, type_converter, row)
             }
 
             yield into_type(**converted_row) if into_type else converted_row

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,3 @@`
	`1`	`+from py_questdb.db import QuestDB`
	`2`	`+`
	`3`	`+__all__ = ['QuestDB']`
Original file line number	Diff line number	Diff line change
`@@ -142,7 +142,9 @@ def parse_and_yield_query_response(`
`142`	`142`
`143`	`143`	`for row in response.dataset:`
`144`	`144`	`converted_row = {`
`145`		`- field.name: converter(value) for field, converter, value in zip(response.columns, type_converter, row)`
	`145`	`+ field.name: converter(value) if value is not None else None`
	`146`	`+ for field, converter, value`
	`147`	`+ in zip(response.columns, type_converter, row)`
`146`	`148`	`}`
`147`	`149`
`148`	`150`	`yield into_type(**converted_row) if into_type else converted_row`