Function initProjectDB

cmd/cql-proxy/api/project.go:1230–1262

(dbID proto.DatabaseID, key *asymmetric.PrivateKey)

}

func initProjectDB(dbID proto.DatabaseID, key *asymmetric.PrivateKey) (db *gorp.DbMap, err error) {
	nodeID, err := getDatabaseLeaderNodeID(dbID)
	if err != nil {
		err = errors.Wrapf(err, "could not get project leader node")
		return
	}

	db = storage.NewImpersonatedDB(
		conf.GConf.ThisNodeID,
		getNodePCaller(nodeID),
		dbID,
		key,
	)

	tblUser := db.AddTableWithName(model.ProjectUser{}, metaTableUserInfo).
		SetKeys(true, "ID")
	tblUser.AddIndex("____idx_user_1", "", []string{"provider", "email"}).SetUnique(true)
	tblConfig := db.AddTableWithName(model.ProjectConfig{}, metaTableProjectConfig).
		SetKeys(true, "ID")
	tblConfig.AddIndex("____idx_config_1", "", []string{"type", "key"}).SetUnique(true)
	db.AddTableWithName(model.Session{}, metaTableSession).SetKeys(false, "ID")

	err = db.CreateTablesIfNotExists()

	// ignore index error
	_ = db.CreateIndex()

	if log.GetLevel() == log.DebugLevel {
		db.TraceOn(string(dbID), log.StandardLogger())
	}

	return
}

func getProjectDB(c *gin.Context, dbID proto.DatabaseID) (project *model.Project, db *gorp.DbMap, err error) {
	developer := getDeveloperID(c)