Skip to content

Commit

Permalink
Add quotes for sqlite
Browse files Browse the repository at this point in the history
  • Loading branch information
tulir committed Mar 28, 2024
1 parent 50d054b commit d47a474
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions database/legacymigrate/migrate.go
Original file line number Diff line number Diff line change
Expand Up @@ -209,7 +209,7 @@ func Migrate(ctx context.Context, targetDB *database.Database, sourceDialect, so
return err
}
err = dbutil.NewSimpleReflectRowIter[LegacyMessage](sourceDB.Query(origCtx, `
SELECT fbid, fb_txn_id, index, fb_chat, fb_receiver, fb_sender, timestamp, mxid, mx_room
SELECT fbid, fb_txn_id, "index", fb_chat, fb_receiver, fb_sender, timestamp, mxid, mx_room
FROM message WHERE fbid<>'' AND fb_sender<>0
`)).Iter(reinserter[*LegacyMessage, *database.Message]{targetDB, ctx}.do)
if err != nil {
Expand All @@ -220,7 +220,7 @@ func Migrate(ctx context.Context, targetDB *database.Database, sourceDialect, so
SELECT reaction.fb_msgid, message.fb_chat, reaction.fb_receiver,
reaction.fb_sender, reaction.reaction, reaction.mxid, reaction.mx_room
FROM reaction
JOIN message ON reaction.fb_msgid=message.fbid AND message.index=0
JOIN message ON reaction.fb_msgid=message.fbid AND message."index"=0
WHERE reaction.fb_sender<>0 AND message.fb_chat<>0 AND reaction.fb_msgid='mid.$gABC3ypFJHACT3lHXb2NrQyNVgAAq'
`)).Iter(reinserter[*LegacyReaction, *database.Reaction]{targetDB, ctx}.do)
if err != nil {
Expand Down

0 comments on commit d47a474

Please sign in to comment.