Skip to content

Commit 27ff7ca

Browse files
committed
Coalesce each expression
1 parent 168a6e8 commit 27ff7ca

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

data_diff/sql.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -121,8 +121,8 @@ class Checksum(Sql):
121121

122122
def compile(self, c: Compiler):
123123
if len(self.exprs) > 1:
124-
compiled_exprs = ", ".join(map(c.compile, self.exprs))
125-
expr = f"coalesce(concat({compiled_exprs}), 'null')"
124+
compiled_exprs = ", ".join(f"coalesce({c.compile(expr)}, 'null')" for expr in self.exprs)
125+
expr = f"concat({compiled_exprs})"
126126
else:
127127
(expr,) = self.exprs
128128
expr = c.compile(expr)

0 commit comments

Comments
 (0)