mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-06 22:43:10 -06:00
Code Issues Packages Projects Releases Wiki Activity

Comments on the sort order

Browse source
This commit is contained in:
Mark Haines 2017-02-13 18:41:30 +00:00
parent 0b68ed790d
commit 2333384096
1 changed files with 11 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/github.com/matrix-org/dendrite/roomserver/storage/sql.go
View file

@ -383,8 +383,7 @@ const bulkSelectStateEventByIDSQL = "" +
const bulkSelectStateAtEventByIDSQL = "" + const bulkSelectStateAtEventByIDSQL = "" +
"SELECT event_type_nid, event_state_key_nid, event_nid, state_snapshot_nid FROM events" + "SELECT event_type_nid, event_state_key_nid, event_nid, state_snapshot_nid FROM events" +
" WHERE event_id = ANY($1)" + " WHERE event_id = ANY($1)"
" ORDER BY event_type_nid, event_state_key_nid ASC"
const updateEventStateSQL = "" + const updateEventStateSQL = "" +
"UPDATE events SET state_snapshot_nid = $2 WHERE event_nid = $1" "UPDATE events SET state_snapshot_nid = $2 WHERE event_nid = $1"
@ -603,9 +602,12 @@ const insertStateSQL = "" +
" VALUES ($1, $2)" + " VALUES ($1, $2)" +
" RETURNING state_snapshot_nid" " RETURNING state_snapshot_nid"
// Bulk state data NID lookup.
// Sorting by state_snapshot_nid means we can use binary search over the result
// to lookup the state data NIDs for a state snapshot NID.
const bulkSelectStateDataNIDsSQL = "" + const bulkSelectStateDataNIDsSQL = "" +
"SELECT state_snapshot_nid, state_data_nids FROM state_snapshots" + "SELECT state_snapshot_nid, state_data_nids FROM state_snapshots" +
" WHERE state_snapshot_nid = ANY($1) ORDER BY state_snapshot_nid" " WHERE state_snapshot_nid = ANY($1) ORDER BY state_snapshot_nid ASC"
func (s *statements) prepareState(db *sql.DB) (err error) { func (s *statements) prepareState(db *sql.DB) (err error) {
_, err = db.Exec(stateSchema) _, err = db.Exec(stateSchema)
@ -687,6 +689,12 @@ const insertStateDataSQL = "" +
const selectNextStateDataNIDSQL = "" + const selectNextStateDataNIDSQL = "" +
"SELECT nextval('state_data_nid_seq')" "SELECT nextval('state_data_nid_seq')"
// Bulk state lookup by numeric event ID.
// Sort by the state_data_nid, event_type_nid, event_state_key_nid
// This means that all the entries for a given state_data_nid will appear
// together in the list and those entries will sorted by event_type_nid
// and event_state_key_nid. This property makes it easier to merge two
// state data blocks together.
const bulkSelectStateDataEntriesSQL = "" + const bulkSelectStateDataEntriesSQL = "" +
"SELECT state_data_nid, event_type_nid, event_state_key_nid, event_nid" + "SELECT state_data_nid, event_type_nid, event_state_key_nid, event_nid" +
" FROM state_data WHERE state_data_nid = ANY($1)" + " FROM state_data WHERE state_data_nid = ANY($1)" +