mirror of
https://github.com/matrix-org/dendrite.git
synced 2025-12-20 13:23:22 -06:00
Fix queries
This commit is contained in:
parent
544f3b0a61
commit
49498fb794
|
|
@ -50,7 +50,7 @@ const insertSendToDeviceMessageSQL = `
|
||||||
`
|
`
|
||||||
|
|
||||||
const selectSendToDeviceMessagesSQL = `
|
const selectSendToDeviceMessagesSQL = `
|
||||||
SELECT id, sender, user_id, device_id, content, sent_by_token
|
SELECT id, user_id, device_id, content, sent_by_token
|
||||||
FROM syncapi_send_to_device
|
FROM syncapi_send_to_device
|
||||||
WHERE user_id = $1 AND device_id = $2
|
WHERE user_id = $1 AND device_id = $2
|
||||||
`
|
`
|
||||||
|
|
|
||||||
|
|
@ -100,9 +100,9 @@ func (s *sendToDeviceStatements) SelectSendToDeviceMessages(
|
||||||
|
|
||||||
for rows.Next() {
|
for rows.Next() {
|
||||||
var id types.SendToDeviceNID
|
var id types.SendToDeviceNID
|
||||||
var sender, userID, deviceID, content string
|
var userID, deviceID, content string
|
||||||
var sentByToken *string
|
var sentByToken *string
|
||||||
if err = rows.Scan(&id, &sender, &userID, &deviceID, &content, &sentByToken); err != nil {
|
if err = rows.Scan(&id, &userID, &deviceID, &content, &sentByToken); err != nil {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
event := types.SendToDeviceEvent{
|
event := types.SendToDeviceEvent{
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue