Function appendValue

server/flightclient/flight_executor_arrow_test.go:1806–1857

appendValue is a test-only reimplementation of the subset of duckdbservice.AppendValue logic needed for MAP round-trip tests. It lives here because server cannot import duckdbservice. Keep in sync with duckdbservice.AppendValue when MAP handling changes.

(builder array.Builder, val interface{})

	defer src.Release()

	rb2 := array.NewRecordBuilder(alloc, schema)
	defer rb2.Release()
	val := extractArrowValue(src.Column(0), 0)
	appendValue(rb2.Field(0), val)

	dst := rb2.NewRecordBatch()
	defer dst.Release()

	col := dst.Column(0).(*array.Map)
	if col.IsNull(0) {
		t.Fatal("rebuilt MAP(VARCHAR,STRUCT) is null")
	}
	rebuilt := extractArrowValue(col, 0).(arrowmap.OrderedMapValue)
	point, ok := rebuilt.Values[0].(map[string]interface{})
	if !ok {
		t.Fatalf("point value is %T, want map[string]interface{}", rebuilt.Values[0])
	}
	if point["x"] != int32(10) || point["y"] != int32(20) {
		t.Errorf("point = %v, want {x:10, y:20}", point)
	}
}

func TestExtractThenAppend_ListOfMap(t *testing.T) {
	// LIST(MAP(VARCHAR, INT)) — list elements are maps.
	alloc := memory.NewGoAllocator()
	mt := arrow.MapOf(arrow.BinaryTypes.String, arrow.PrimitiveTypes.Int32)
	schema := arrow.NewSchema([]arrow.Field{
		{Name: "list", Type: arrow.ListOf(mt), Nullable: true},
	}, nil)

	rb := array.NewRecordBuilder(alloc, schema)
	defer rb.Release()
	lb := rb.Field(0).(*array.ListBuilder)
	mmb := lb.ValueBuilder().(*array.MapBuilder)
	lb.Append(true)
	mmb.Append(true)
	mmb.KeyBuilder().(*array.StringBuilder).Append("a")
	mmb.ItemBuilder().(*array.Int32Builder).Append(1)
	mmb.Append(true)
	mmb.KeyBuilder().(*array.StringBuilder).Append("b")
	mmb.ItemBuilder().(*array.Int32Builder).Append(2)

	src := rb.NewRecordBatch()
	defer src.Release()

	rb2 := array.NewRecordBuilder(alloc, schema)
	defer rb2.Release()
	val := extractArrowValue(src.Column(0), 0)
	appendValue(rb2.Field(0), val)

	dst := rb2.NewRecordBatch()
	defer dst.Release()

	lcol := dst.Column(0).(*array.List)
	if lcol.IsNull(0) {