Function createProjectTable

cmd/cql-proxy/api/project.go:794–926

(c *gin.Context)

}

func createProjectTable(c *gin.Context) {
	r := struct {
		DB            proto.DatabaseID `json:"db" json:"project" form:"db" form:"project" uri:"db" uri:"project" binding:"required,len=64"`
		Table         string           `json:"table" form:"table" uri:"table" binding:"required,max=128"`
		ColumnNames   []string         `json:"names" form:"names" binding:"required,min=1,dive,required,max=32"`
		ColumnTypes   []string         `json:"types" form:"types" binding:"required,min=1,dive,required,max=16"`
		PrimaryKey    string           `json:"primary_key" form:"primary_key" binding:"omitempty,max=32"`
		AutoIncrement bool             `json:"auto_increment" form:"auto_increment"`
	}{}

	_ = c.ShouldBindUri(&r)

	if err := c.ShouldBind(&r); err != nil {
		abortWithError(c, http.StatusBadRequest, err)
		return
	}

	if len(r.ColumnNames) != len(r.ColumnTypes) {
		abortWithError(c, http.StatusBadRequest, ErrMismatchedColumnNamesAndTypes)
		return
	}

	if strings.EqualFold(r.Table, metaTableProjectConfig) || strings.EqualFold(r.Table, metaTableUserInfo) ||
		strings.EqualFold(r.Table, metaTableSession) || strings.HasPrefix(r.Table, deletedTablePrefix) {
		abortWithError(c, http.StatusBadRequest, ErrReservedTableName)
		return
	}

	// try find primary key in columns
	pkIdx := -1

	if r.PrimaryKey != "" {
		for idx, colName := range r.ColumnNames {
			if strings.EqualFold(colName, r.PrimaryKey) {
				pkIdx = idx

				if r.AutoIncrement &&
					!strings.EqualFold(r.ColumnTypes[idx], "NUMBER") &&
					!strings.EqualFold(r.ColumnTypes[idx], "INTEGER") {
					abortWithError(c, http.StatusBadRequest, ErrInvalidAutoIncrementColumnType)
					return
				}

				break
			}
		}

		if pkIdx == -1 {
			abortWithError(c, http.StatusBadRequest, ErrUnknownPrimaryKeyColumn)
			return
		}
	}

	_, projectDB, err := getProjectDB(c, r.DB)
	if err != nil {
		_ = c.Error(err)
		abortWithError(c, http.StatusForbidden, ErrLoadProjectDatabaseFailed)
		return