Function isAllDMLImpl

backend/plugin/parser/base/interface.go:343–368

(engine storepb.Engine, statement string)

}

func isAllDMLImpl(engine storepb.Engine, statement string) bool {
	stmts, err := ParseStatements(engine, statement)
	if err != nil {
		return false
	}
	asts := ExtractASTs(stmts)
	if len(asts) == 0 {
		return false
	}
	types, err := GetStatementTypes(engine, asts)
	if err != nil {
		return false
	}
	if len(types) == 0 {
		return false
	}
	for _, t := range types {
		switch t {
		case storepb.StatementType_INSERT, storepb.StatementType_UPDATE, storepb.StatementType_DELETE:
			// DML statement, continue
		default:
			return false
		}
	}
	return true
}

type ChangeSummary struct {
	ChangedResources *model.ChangedResources