Method writeDataPoint

pkg/ttl/sqlbuilder/sql.go:277–304

(cols []*model.ColumnInfo, dp []types.Datum)

}

func (b *SQLBuilder) writeDataPoint(cols []*model.ColumnInfo, dp []types.Datum) error {
	writeBrackets := len(cols) > 1
	if len(cols) != len(dp) {
		return errors.Errorf("col count not match %d != %d", len(cols), len(dp))
	}

	if writeBrackets {
		b.restoreCtx.WritePlain("(")
	}

	first := true
	for i, d := range dp {
		if first {
			first = false
		} else {
			b.restoreCtx.WritePlain(", ")
		}
		if err := writeDatum(b.restoreCtx, d, &cols[i].FieldType); err != nil {
			return err
		}
	}

	if writeBrackets {
		b.restoreCtx.WritePlain(")")
	}

	return nil
}

// ScanQueryGenerator generates SQLs for scan task
type ScanQueryGenerator struct {