Method ComQuery

backend/handler.go:70–80

Naive query rewriting. This is just a temporary solution and should be replaced with a more robust implementation.

(
	ctx context.Context,
	c *mysql.Conn,
	query string,
	callback mysql.ResultSpoolFn,
)

func auditResultCallback(audit *QueryAudit, callback mysql.ResultSpoolFn, modifiers ...ResultModifier) mysql.ResultSpoolFn {
	return wrapResultCallback(func(res *sqltypes.Result, more bool) error {
		if err := callback(res, more); err != nil {
			return err
		}
		audit.AddRows(len(res.Rows))
		return nil
	}, modifiers...)
}

func (h *MyHandler) ComMultiQuery(
	ctx context.Context,
	c *mysql.Conn,
	query string,
	callback mysql.ResultSpoolFn,
) (rest string, returnErr error) {