Method LogCommandExecute

backend/plugin/db/driver.go:289–306

LogCommandExecute logs the execution of a command.

(commandRange *storepb.Range, commandText string)

// LogCommandExecute logs the execution of a command.
func (o *ExecuteOptions) LogCommandExecute(commandRange *storepb.Range, commandText string) {
	if o == nil || o.CreateTaskRunLog == nil {
		return
	}
	ce := &storepb.TaskRunLog_CommandExecute{}
	if o.LogCommandStatement {
		ce.Statement = commandText
	} else {
		ce.Range = commandRange
	}
	err := o.CreateTaskRunLog(time.Now(), &storepb.TaskRunLog{
		Type:           storepb.TaskRunLog_COMMAND_EXECUTE,
		CommandExecute: ce,
	})
	if err != nil {
		slog.Warn("failed to log command execute", log.BBError(err))
	}
}

func (o *ExecuteOptions) LogCommandResponse(affectedRows int64, allAffectedRows []int64, rerr string) {
	if o == nil || o.CreateTaskRunLog == nil {