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

Provide stream ID statements

Browse source
This commit is contained in:
Neil Alexander 2022-10-11 15:14:25 +01:00
parent c0030f5b00
commit 2c052ea292
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
2 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
syncapi/storage/sqlite3/relations_table.go
View file

@ -68,8 +68,10 @@ type relationsStatements struct {
selectMaxRelationIDStmt *sql.Stmt selectMaxRelationIDStmt *sql.Stmt
} }
func NewSqliteRelationsTable(db *sql.DB) (tables.Relations, error) { func NewSqliteRelationsTable(db *sql.DB, streamID *StreamIDStatements) (tables.Relations, error) {
s := &relationsStatements{} s := &relationsStatements{
streamIDStatements: streamID,
}
_, err := db.Exec(relationsSchema) _, err := db.Exec(relationsSchema)
if err != nil { if err != nil {
return nil, err return nil, err

2
syncapi/storage/sqlite3/syncserver.go
View file

@ -123,7 +123,7 @@ func (d *SyncServerDatasource) prepare(ctx context.Context) (err error) {
if err != nil { if err != nil {
return err return err
} }
relations, err := NewSqliteRelationsTable(d.db) relations, err := NewSqliteRelationsTable(d.db, &d.streamID)
if err != nil { if err != nil {
return err return err
} }