Method Write

sqlchain/adapter/api/query.go:106–171

Exec defines write query for database.

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

// Exec defines write query for database.
func (a *queryAPI) Write(rw http.ResponseWriter, r *http.Request) {
	// check privilege
	hasPrivilege := false

	if config.GetConfig().TLSConfig == nil || !config.GetConfig().VerifyCertificate {
		// http mode or no certificate verification required
		hasPrivilege = true
	}

	if r.TLS != nil && len(r.TLS.PeerCertificates) > 0 {
		cert := r.TLS.PeerCertificates[0]

		for _, privilegedCert := range config.GetConfig().WriteCertificates {
			if cert.Equal(privilegedCert) {
				hasPrivilege = true
				break
			}
		}

		if !hasPrivilege {
			for _, privilegedCert := range config.GetConfig().AdminCertificates {
				if cert.Equal(privilegedCert) {
					hasPrivilege = true
					break
				}
			}
		}
	}

	// forbidden
	if !hasPrivilege {
		sendResponse(http.StatusForbidden, false, nil, nil, rw)
		return
	}

	var (
		qm  *queryMap
		err error
	)

	if qm, err = parseForm(r); err != nil {
		sendResponse(http.StatusBadRequest, false, err, nil, rw)
		return
	}

	log.WithFields(log.Fields{
		"db":    qm.Database,
		"query": qm.Query,
	}).Info("got exec")

	var (
		affectedRows int64
		lastInsertID int64
	)

	if affectedRows, lastInsertID, err = config.GetConfig().StorageInstance.Exec(
		qm.Database, qm.Query, qm.Args...); err != nil {
		sendResponse(http.StatusInternalServerError, false, err, nil, rw)