Function tableTransformer

plugins/destination/mssql/queries/tvp.go:89–123

(table *schema.Table)

type transformer func([][]any) any

func tableTransformer(table *schema.Table) transformer {
	// 1 prep the fields
	fields := make([]reflect.StructField, len(table.Columns))
	for i, col := range table.Columns {
		fields[i] = reflect.StructField{
			Name: "Fld_" + col.Name,
			Type: reflect.PointerTo(columnGoType(col.Type)), // to account for nullability
		}
	}

	// 2 prep transformer for each field
	row := reflect.StructOf(fields)
	rowSlice := reflect.SliceOf(row)

	rowTransformer := func(rowData []any) reflect.Value {
		v := reflect.New(row).Elem()
		for i, elem := range rowData {
			val := reflect.ValueOf(elem)
			switch {
			case elem == nil, val.IsNil():
			default:
				v.Field(i).Set(val)
			}
		}
		return v
	}

	return func(data [][]any) any {
		rows := reflect.MakeSlice(rowSlice, len(data), len(data))
		for i, elem := range data {
			rows.Index(i).Set(rowTransformer(elem))
		}
		return rows.Interface()
	}
}