array_schema_evolution_experimental_test.go

package tiledb

import (
	"testing"

	"github.com/stretchr/testify/assert"
	"github.com/stretchr/testify/require"
)

func TestArraySchemaEvolution(t *testing.T) {
	config, err := NewConfig()
	require.NoError(t, err)
	assert.NotNil(t, config)

	// Test context with config
	context, err := NewContext(config)
	require.NoError(t, err)
	assert.NotNil(t, context)

	dimension, err := NewDimension(context, "test", TILEDB_INT32, []int32{1, 10}, int32(5))
	require.NoError(t, err)
	assert.NotNil(t, dimension)

	domain, err := NewDomain(context)
	require.NoError(t, err)
	assert.NotNil(t, domain)

	// Add dimension to domain
	require.NoError(t, domain.AddDimensions(dimension))

	arraySchema, err := NewArraySchema(context, TILEDB_DENSE)
	require.NoError(t, err)
	assert.NotNil(t, arraySchema)

	a1, err := NewAttribute(context, "a1", TILEDB_INT32)
	require.NoError(t, err)
	assert.NotNil(t, a1)

	a2, err := NewAttribute(context, "a2", TILEDB_INT32)
	require.NoError(t, err)
	assert.NotNil(t, a2)

	require.NoError(t, arraySchema.AddAttributes(a1, a2))

	require.NoError(t, arraySchema.SetCapacity(100))

	require.NoError(t, arraySchema.SetDomain(domain))

	require.NoError(t, arraySchema.Check())

	// tmpArrayPath is the array URI
	tmpArrayPath := t.TempDir()

	require.NoError(t, CreateArray(context, tmpArrayPath, arraySchema))

	arraySchemaEvolution, err := NewArraySchemaEvolution(context)
	require.NoError(t, err)

	a3, err := NewAttribute(context, "a3", TILEDB_INT32)
	require.NoError(t, err)
	assert.NotNil(t, a2)

	require.NoError(t, arraySchemaEvolution.AddAttribute(a3))

	// Will fail when try to add an attribute which already has the name
	err = arraySchemaEvolution.AddAttribute(a3)
	require.Error(t, err)

	// Remove atrribute a1
	require.NoError(t, arraySchemaEvolution.DropAttribute("a1"))

	bs, err := SerializeArraySchemaEvolution(arraySchemaEvolution,
		TILEDB_CAPNP, true)
	require.NoError(t, err)

	buff, err := NewBuffer(context)
	require.NoError(t, err)

	err = buff.SetBuffer(bs)
	require.NoError(t, err)

	newArraySchemaEvolution, err := DeserializeArraySchemaEvolution(buff,
		TILEDB_CAPNP, true)
	require.NoError(t, err)

	require.NoError(t, newArraySchemaEvolution.Evolve(tmpArrayPath))

	// Validate schema evolution changes
	ctx, err := NewContext(nil)
	require.NoError(t, err)
	defer ctx.Free()

	// Prepare the array for reading
	arr, err := NewArray(ctx, tmpArrayPath)
	require.NoError(t, err)
	defer arr.Free()

	require.NoError(t, arr.Open(TILEDB_READ))

	// Need to get the evolved schema
	arrAchema, err := arr.Schema()
	require.NoError(t, err)
	assert.NotNil(t, arrAchema)

	hasAttr, err := arrAchema.HasAttribute("a1")
	require.NoError(t, err)
	assert.False(t, hasAttr)

	hasAttr, err = arrAchema.HasAttribute("a2")
	require.NoError(t, err)
	assert.True(t, hasAttr)

	hasAttr, err = arrAchema.HasAttribute("a3")
	require.NoError(t, err)
	assert.True(t, hasAttr)

	attrNum, err := arrAchema.AttributeNum()
	require.NoError(t, err)
	assert.Equal(t, uint(2), attrNum)

	attrFromIndex, err := arrAchema.AttributeFromIndex(0)
	require.NoError(t, err)
	assert.NotNil(t, attrFromIndex)

	attrName, err := attrFromIndex.Name()
	require.NoError(t, err)
	assert.Equal(t, "a2", attrName)

	attrFromName, err := arrAchema.AttributeFromName("a3")
	require.NoError(t, err)
	assert.NotNil(t, attrFromName)

	attrName2, err := attrFromName.Name()
	require.NoError(t, err)
	assert.Equal(t, "a3", attrName2)

	require.NoError(t, arr.Close())
}