Method writeSingle

xenomint/state.go:321–356

(
	ctx context.Context, q *types.Query)

}

func (s *State) writeSingle(
	ctx context.Context, q *types.Query) (res sql.Result, err error,
) {
	var (
		containsDDL bool
		pattern     string
		args        []interface{}
		//start       = time.Now()

		//parsed, executed time.Duration
	)

	//defer func() {
	//	var fields = log.Fields{}
	//	fields["lastSeq"] = s.current
	//	if parsed > 0 {
	//		fields["1#parsed"] = float64(parsed.Nanoseconds()) / 1000
	//	}
	//	if executed > 0 {
	//		fields["2#executed"] = float64((executed - parsed).Nanoseconds()) / 1000
	//	}
	//	log.WithFields(fields).Debug("writeSingle duration stat (us)")
	//}()
	if containsDDL, pattern, args, err = convertQueryAndBuildArgs(q.Pattern, q.Args); err != nil {
		return
	}
	//parsed = time.Since(start)
	if res, err = s.handler.Exec(pattern, args...); err == nil {
		if containsDDL {
			atomic.StoreUint32(&s.hasSchemaChange, 1)
		}
		s.incSeq()
	}
	//executed = time.Since(start)
	return
}

func (s *State) write(
	ctx context.Context, req *types.Request, isLeader bool) (ref *QueryTracker, resp *types.Response, err error,