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

Fix database is locked errors

Browse source
This commit is contained in:
0x1a8510f2 2022-10-20 21:43:50 +01:00
parent 304146713d
commit f58597f574
No known key found for this signature in database
GPG key ID: 1C692E355D76775D
1 changed files with 12 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
internal/sqlutil/sqlutil.go
View file

@ -5,6 +5,7 @@ import (
"flag"
"fmt"
"regexp"
"strings"
"github.com/matrix-org/dendrite/setup/config"
"github.com/sirupsen/logrus"
@ -25,6 +26,17 @@ func Open(dbProperties *config.DatabaseOptions, writer Writer) (*sql.DB, error)
if err != nil {
return nil, fmt.Errorf("ParseFileURI: %w", err)
}
// add query parameters to the dsn
if strings.Contains(dsn, "?") {
dsn += "&"
} else {
dsn += "?"
}
// wait some time before erroring if the db is locked
// https://gitlab.com/cznic/sqlite/-/issues/106#note_1058094993
dsn += "_pragma=busy_timeout%3d10000"
case dbProperties.ConnectionString.IsPostgres():
driverName = "postgres"
dsn = string(dbProperties.ConnectionString)