Skip to content

Commit cb4850c

Browse files
Fix SQL composition.
Used sql.Identifier where it needed to use sql.Literal.
1 parent 1d7f6f4 commit cb4850c

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

db_wrapper/model.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -143,7 +143,7 @@ def compose_one_change(change: Tuple[str, Any]) -> sql.Composed:
143143
value = change[1]
144144

145145
return sql.SQL("{key} = {value}").format(
146-
key=sql.Identifier(key), value=sql.Identifier(value))
146+
key=sql.Identifier(key), value=sql.Literal(value))
147147

148148
def compose_changes(changes: Dict[str, Any]) -> sql.Composed:
149149
return sql.SQL(',').join(
@@ -157,7 +157,7 @@ def compose_changes(changes: Dict[str, Any]) -> sql.Composed:
157157
).format(
158158
table=self._table,
159159
changes=compose_changes(changes),
160-
id_value=sql.Identifier(id_value),
160+
id_value=sql.Literal(id_value),
161161
)
162162

163163
result: List[T] = await self._client.execute_and_return(query)
@@ -183,7 +183,7 @@ async def one_by_id(self, id_value: str) -> T:
183183
'RETURNING *;'
184184
).format(
185185
table=self._table,
186-
id_value=sql.Identifier(id_value)
186+
id_value=sql.Literal(id_value)
187187
)
188188

189189
result: List[T] = await self._client.execute_and_return(query)

0 commit comments

Comments
 (0)