2022-05-16-room-backfill-state.go 675 B

12345678910111213141516171819202122232425
  1. package upgrades
  2. import (
  3. "database/sql"
  4. )
  5. func init() {
  6. upgrades[46] = upgrade{"Create the backfill state table", func(tx *sql.Tx, ctx context) error {
  7. _, err := tx.Exec(`
  8. CREATE TABLE backfill_state (
  9. user_mxid TEXT,
  10. portal_jid TEXT,
  11. portal_receiver TEXT,
  12. processing_batch BOOLEAN,
  13. backfill_complete BOOLEAN,
  14. first_expected_ts INTEGER,
  15. PRIMARY KEY (user_mxid, portal_jid, portal_receiver),
  16. FOREIGN KEY (user_mxid) REFERENCES "user"(mxid) ON DELETE CASCADE ON UPDATE CASCADE,
  17. FOREIGN KEY (portal_jid, portal_receiver) REFERENCES portal(jid, receiver) ON DELETE CASCADE
  18. )
  19. `)
  20. return err
  21. }}
  22. }