Method CreateDatabase

sqlchain/adapter/api/admin.go:67–93

CreateDatabase defines create database admin API.

(rw http.ResponseWriter, r *http.Request)

// CreateDatabase defines create database admin API.
func (a *adminAPI) CreateDatabase(rw http.ResponseWriter, r *http.Request) {
	nodeCntStr := r.FormValue("node")
	nodeCnt, err := strconv.Atoi(nodeCntStr)

	var dbID string

	defer func() {
		log.WithFields(log.Fields{
			"nodeCnt": nodeCnt,
			"db":      dbID,
		}).WithError(err).Debug("create database")
	}()

	if err != nil || nodeCnt <= 0 || nodeCnt >= math.MaxUint16 {
		sendResponse(http.StatusBadRequest, false, "Invalid node count supplied", nil, rw)
		return
	}

	if dbID, err = config.GetConfig().StorageInstance.Create(nodeCnt); err != nil {
		sendResponse(http.StatusInternalServerError, false, err, nil, rw)
		return
	}

	sendResponse(http.StatusCreated, true, nil, map[string]interface{}{
		"database": dbID,
	}, rw)
}

// DropDatabase defines drop database admin API.
func (a *adminAPI) DropDatabase(rw http.ResponseWriter, r *http.Request) {