aboutsummaryrefslogtreecommitdiff
path: root/currentstateserver/storage/sqlite3/storage.go
diff options
context:
space:
mode:
Diffstat (limited to 'currentstateserver/storage/sqlite3/storage.go')
-rw-r--r--currentstateserver/storage/sqlite3/storage.go40
1 files changed, 0 insertions, 40 deletions
diff --git a/currentstateserver/storage/sqlite3/storage.go b/currentstateserver/storage/sqlite3/storage.go
deleted file mode 100644
index e79afd70..00000000
--- a/currentstateserver/storage/sqlite3/storage.go
+++ /dev/null
@@ -1,40 +0,0 @@
-package sqlite3
-
-import (
- "database/sql"
-
- "github.com/matrix-org/dendrite/currentstateserver/storage/shared"
- "github.com/matrix-org/dendrite/internal/config"
- "github.com/matrix-org/dendrite/internal/sqlutil"
-)
-
-type Database struct {
- shared.Database
- db *sql.DB
- writer sqlutil.Writer
- sqlutil.PartitionOffsetStatements
-}
-
-// NewDatabase creates a new sync server database
-// nolint: gocyclo
-func NewDatabase(dbProperties *config.DatabaseOptions) (*Database, error) {
- var d Database
- var err error
- if d.db, err = sqlutil.Open(dbProperties); err != nil {
- return nil, err
- }
- d.writer = sqlutil.NewExclusiveWriter()
- if err = d.PartitionOffsetStatements.Prepare(d.db, d.writer, "currentstate"); err != nil {
- return nil, err
- }
- currRoomState, err := NewSqliteCurrentRoomStateTable(d.db)
- if err != nil {
- return nil, err
- }
- d.Database = shared.Database{
- DB: d.db,
- Writer: d.writer,
- CurrentRoomState: currRoomState,
- }
- return &d, nil
-}