Support comparing to null

Author: erikdubbelboer

filter/converter.go

@@ -166,6 +166,21 @@ func (c *Converter) convertFilter(filter map[string]any, paramIndex int) (string
 					innerResult = "(" + innerResult + ")"
 				}
 				conditions = append(conditions, innerResult)
+			case nil:
+				// Comparing a column to NULL needs a different implementation depending on if the column is in JSONB or not.
+				// JSONB columns are NULL even if they don't exist, so we need to check if the column exists first.
+				isNestedColumn := c.nestedColumn != ""
+				for _, exemption := range c.nestedExemptions {
+					if exemption == key {
+						isNestedColumn = false
+						break
+					}
+				}
+				if isNestedColumn {
+					conditions = append(conditions, fmt.Sprintf("(jsonb_path_match(%s, 'exists($.%s)') AND %s IS NULL)", c.nestedColumn, key, c.columnName(key)))
+				} else {
+					conditions = append(conditions, fmt.Sprintf("(%s IS NULL)", c.columnName(key)))
+				}
 			default:
 				conditions = append(conditions, fmt.Sprintf("(%s = $%d)", c.columnName(key), paramIndex))
 				paramIndex++

filter/converter_test.go

@@ -208,6 +208,22 @@ func TestConverter_Convert(t *testing.T) {
 			nil,
 			fmt.Errorf("empty objects not allowed"),
 		},
+		{
+			"null nornal column",
+			nil,
+			`{"name": null}`,
+			`("name" IS NULL)`,
+			nil,
+			nil,
+		},
+		{
+			"null jsonb column",
+			filter.WithNestedJSONB("meta"),
+			`{"name": null}`,
+			`(jsonb_path_match(meta, 'exists($.name)') AND "meta"->>'name' IS NULL)`,
+			nil,
+			nil,
+		},
 	}
 
 	for _, tt := range tests {

fuzz/fuzz_test.go

@@ -33,6 +33,7 @@ func FuzzConverter(f *testing.F) {
 		`{"name": {}}`,
 		`{"$or": []}`,
 		`{"status": {"$in": []}}`,
+		`{"name": null}`,
 	}
 	for _, tc := range tcs {
 		f.Add(tc)

integration/postgres_test.go

@@ -297,6 +297,18 @@ func TestIntegration_BasicOperators(t *testing.T) {
 			[]int{},
 			nil,
 		},
+		{
+			`column equal to null`,
+			`{"mount": null}`,
+			[]int{3, 4},
+			nil,
+		},
+		{
+			`jsonb equal to null`,
+			`{"pet": null}`,
+			[]int{10},
+			nil,
+		},
 	}
 
 	for _, tt := range tests {