package tests

import (
	"context"
	"fmt"
	"github.com/stretchr/testify/require"
	"testing"

	"github.com/ClickHouse/clickhouse-go/v2"
	"github.com/stretchr/testify/assert"
)

func TestAppendStruct(t *testing.T) {
	TestProtocols(t, func(t *testing.T, protocol clickhouse.Protocol) {
		conn, err := GetNativeConnection(t, protocol, nil, nil, &clickhouse.Compression{
			Method: clickhouse.CompressionLZ4,
		})
		ctx := context.Background()
		require.NoError(t, err)
		const ddl = `
		CREATE TABLE test_append_struct (
			  HCol1 UInt8
			, HCol2 String
			, HCol3 Array(Nullable(String))
			, HCol4 Nullable(UInt8)
			, Col1  UInt8
			, Col2  String
			, Col3  Array(String)
			, Col4  Nullable(UInt8)
		) Engine MergeTree() ORDER BY tuple()
		`
		defer func() {
			conn.Exec(ctx, "DROP TABLE test_append_struct")
		}()
		require.NoError(t, conn.Exec(ctx, ddl))
		batch, err := conn.PrepareBatch(ctx, "INSERT INTO test_append_struct")
		require.NoError(t, err)
		type header struct {
			Col1 uint8     `ch:"HCol1"`
			Col2 *string   `ch:"HCol2"`
			Col3 []*string `ch:"HCol3"`
			Col4 *uint8    `ch:"HCol4"`
		}
		type data struct {
			header
			Col1 uint8
			Col2 string
			Col3 []string
			Col4 *uint8
		}
		for i := 0; i < 100; i++ {
			str := fmt.Sprintf("Str_%d", i)
			require.NoError(t, batch.AppendStruct(&data{
				header: header{
					Col1: uint8(i),
					Col2: &str,
					Col3: []*string{&str, nil, &str},
					Col4: nil,
				},
				Col1: uint8(i + 1),
				Col3: []string{"A", "B", "C", fmt.Sprint(i)},
			}))
		}
		require.Equal(t, 100, batch.Rows())
		require.NoError(t, batch.Send())
		for i := 0; i < 100; i++ {
			var result data
			require.NoError(t, conn.QueryRow(ctx, "SELECT * FROM test_append_struct WHERE HCol1 = $1", i).ScanStruct(&result))
			str := fmt.Sprintf("Str_%d", i)
			h := header{
				Col1: uint8(i),
				Col2: &str,
				Col3: []*string{&str, nil, &str},
				Col4: nil,
			}
			assert.Equal(t, h, result.header)
			require.Empty(t, result.Col2)
			assert.Equal(t, uint8(i+1), result.Col1)
			assert.Equal(t, []string{"A", "B", "C", fmt.Sprint(i)}, result.Col3)
			assert.Nil(t, result.Col4)
		}
		var results []data
		require.NoError(t, conn.Select(ctx, &results, "SELECT * FROM test_append_struct ORDER BY HCol1"))
		for i, result := range results {
			str := fmt.Sprintf("Str_%d", i)
			h := header{
				Col1: uint8(i),
				Col2: &str,
				Col3: []*string{&str, nil, &str},
			}
			assert.Equal(t, h, result.header)
			require.Empty(t, result.Col2)
			assert.Equal(t, uint8(i+1), result.Col1)
			assert.Equal(t, []string{"A", "B", "C", fmt.Sprint(i)}, result.Col3)
		}
	})
}