go-clickhouse/ch/chschema/column_safe_gen.go

//go:build !amd64 && !arm64

package chschema

import (
	"github.com/uptrace/go-clickhouse/ch/chproto"
)

func (c *Int8Column) ReadFrom(rd *chproto.Reader, numRow int) error {
	c.AllocForReading(numRow)

	for i := range c.Column {
		n, err := rd.Int8()
		if err != nil {
			return err
		}
		c.Column[i] = n
	}

	return nil
}

func (c *Int8Column) WriteTo(wr *chproto.Writer) error {
	for _, n := range c.Column {
		wr.Int8(n)
	}
	return nil
}

func (c *UInt8Column) ReadFrom(rd *chproto.Reader, numRow int) error {
	c.AllocForReading(numRow)

	for i := range c.Column {
		n, err := rd.UInt8()
		if err != nil {
			return err
		}
		c.Column[i] = n
	}

	return nil
}

func (c *UInt8Column) WriteTo(wr *chproto.Writer) error {
	for _, n := range c.Column {
		wr.UInt8(n)
	}
	return nil
}

func (c *Int16Column) ReadFrom(rd *chproto.Reader, numRow int) error {
	c.AllocForReading(numRow)

	for i := range c.Column {
		n, err := rd.Int16()
		if err != nil {
			return err
		}
		c.Column[i] = n
	}

	return nil
}

func (c *Int16Column) WriteTo(wr *chproto.Writer) error {
	for _, n := range c.Column {
		wr.Int16(n)
	}
	return nil
}

func (c *UInt16Column) ReadFrom(rd *chproto.Reader, numRow int) error {
	c.AllocForReading(numRow)

	for i := range c.Column {
		n, err := rd.UInt16()
		if err != nil {
			return err
		}
		c.Column[i] = n
	}

	return nil
}

func (c *UInt16Column) WriteTo(wr *chproto.Writer) error {
	for _, n := range c.Column {
		wr.UInt16(n)
	}
	return nil
}

func (c *Int32Column) ReadFrom(rd *chproto.Reader, numRow int) error {
	c.AllocForReading(numRow)

	for i := range c.Column {
		n, err := rd.Int32()
		if err != nil {
			return err
		}
		c.Column[i] = n
	}

	return nil
}

func (c *Int32Column) WriteTo(wr *chproto.Writer) error {
	for _, n := range c.Column {
		wr.Int32(n)
	}
	return nil
}

func (c *UInt32Column) ReadFrom(rd *chproto.Reader, numRow int) error {
	c.AllocForReading(numRow)

	for i := range c.Column {
		n, err := rd.UInt32()
		if err != nil {
			return err
		}
		c.Column[i] = n
	}

	return nil
}

func (c *UInt32Column) WriteTo(wr *chproto.Writer) error {
	for _, n := range c.Column {
		wr.UInt32(n)
	}
	return nil
}

func (c *Int64Column) ReadFrom(rd *chproto.Reader, numRow int) error {
	c.AllocForReading(numRow)

	for i := range c.Column {
		n, err := rd.Int64()
		if err != nil {
			return err
		}
		c.Column[i] = n
	}

	return nil
}

func (c *Int64Column) WriteTo(wr *chproto.Writer) error {
	for _, n := range c.Column {
		wr.Int64(n)
	}
	return nil
}

func (c *UInt64Column) ReadFrom(rd *chproto.Reader, numRow int) error {
	c.AllocForReading(numRow)

	for i := range c.Column {
		n, err := rd.UInt64()
		if err != nil {
			return err
		}
		c.Column[i] = n
	}

	return nil
}

func (c *UInt64Column) WriteTo(wr *chproto.Writer) error {
	for _, n := range c.Column {
		wr.UInt64(n)
	}
	return nil
}

func (c *Float32Column) ReadFrom(rd *chproto.Reader, numRow int) error {
	c.AllocForReading(numRow)

	for i := range c.Column {
		n, err := rd.Float32()
		if err != nil {
			return err
		}
		c.Column[i] = n
	}

	return nil
}

func (c *Float32Column) WriteTo(wr *chproto.Writer) error {
	for _, n := range c.Column {
		wr.Float32(n)
	}
	return nil
}

func (c *Float64Column) ReadFrom(rd *chproto.Reader, numRow int) error {
	c.AllocForReading(numRow)

	for i := range c.Column {
		n, err := rd.Float64()
		if err != nil {
			return err
		}
		c.Column[i] = n
	}

	return nil
}

func (c *Float64Column) WriteTo(wr *chproto.Writer) error {
	for _, n := range c.Column {
		wr.Float64(n)
	}
	return nil
}