TsDB2/DB/core/inserter.go

package core

import "git.ycl.pub/yl32940/TsDB2/DB/core/types"

// Inserter 插入操作对象
type Inserter struct {
	table  *Table
	fields []types.FieldValue
}

func (table *Table) Insert() *Inserter {
	return &Inserter{table: table}
}

// Set 设置字段值
func (i *Inserter) Set(field string, value interface{}, typ types.FieldType) *Inserter {
	i.fields = append(i.fields, types.FieldValue{
		FieldName: []byte(field),
		Value:     value,
	})
	return i
}

// Exec 执行插入
func (i *Inserter) Exec() (uint64, error) {
	return i.table.InsertRow(i.fields)
}