Function Open

roomserver/storage/postgres/storage.go:40–88

Open a postgres database.

(base *base.BaseDendrite, dbProperties *config.DatabaseOptions, cache caching.RoomServerCaches)

// Open a postgres database.
func Open(base *base.BaseDendrite, dbProperties *config.DatabaseOptions, cache caching.RoomServerCaches) (*Database, error) {
	var d Database
	var err error
	db, writer, err := base.DatabaseConnection(dbProperties, sqlutil.NewDummyWriter())
	if err != nil {
		return nil, fmt.Errorf("sqlutil.Open: %w", err)
	}

	// Create the tables.
	if err = d.create(db); err != nil {
		return nil, err
	}

	// Special case, since this migration uses several tables, so it needs to
	// be sure that all tables are created first.
	// TODO: Remove when we are sure we are not having goose artefacts in the db
	// This forces an error, which indicates the migration is already applied, since the
	// column event_nid was removed from the table
	var eventNID int
	err = db.QueryRow("SELECT event_nid FROM roomserver_state_block LIMIT 1;").Scan(&eventNID)
	if err == nil {
		m := sqlutil.NewMigrator(db)
		m.AddMigrations(sqlutil.Migration{
			Version: "roomserver: state blocks refactor",
			Up:      deltas.UpStateBlocksRefactor,
		})
		if err = m.Up(base.Context()); err != nil {
			return nil, err
		}
	} else {
		switch e := err.(type) {
		case *pq.Error:
			// ignore undefined_column (42703) errors, as this is expected at this point
			if e.Code != "42703" {
				return nil, err
			}
		default:
			return nil, err
		}
	}

	// Then prepare the statements. Now that the migrations have run, any columns referred
	// to in the database code should now exist.
	if err = d.prepare(db, writer, cache); err != nil {
		return nil, err
	}

	return &d, nil
}

func (d *Database) create(db *sql.DB) error {
	if err := CreateEventStateKeysTable(db); err != nil {