Function BuildDeleteSQL

pkg/ttl/sqlbuilder/sql.go:459–482

BuildDeleteSQL builds a delete SQL

(tbl *cache.PhysicalTable, rows [][]types.Datum, expire time.Time)

// BuildDeleteSQL builds a delete SQL
func BuildDeleteSQL(tbl *cache.PhysicalTable, rows [][]types.Datum, expire time.Time) (string, error) {
	if len(rows) == 0 {
		return "", errors.New("Cannot build delete SQL with empty rows")
	}

	b := NewSQLBuilder(tbl)
	if err := b.WriteDelete(); err != nil {
		return "", err
	}

	if err := b.WriteInCondition(tbl.KeyColumns, rows...); err != nil {
		return "", err
	}

	if err := b.WriteExpireCondition(expire); err != nil {
		return "", err
	}

	if err := b.WriteLimit(len(rows)); err != nil {
		return "", err
	}

	return b.Build()
}