databend-go/client_integration_test.go at main · databendlabs/databend-go · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
package godatabend

import (
	"context"
	"encoding/json"
	"os"
	"strconv"
	"testing"
	"time"

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

func TestIntegrationResumeQueryWithStatePreservesRows(t *testing.T) {
	cfg := integrationTestConfig(t)

	ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
	defer cancel()

	firstClient := NewAPIClientFromConfig(cfg)
	firstClient.MaxRowsPerPage = 1

	startResp, err := firstClient.StartQuery(ctx, "SELECT number FROM numbers(5) ORDER BY number")
	require.NoError(t, err)
	require.NotNil(t, startResp)
	require.False(t, startResp.ReadFinished())

	state := firstClient.GetState()
	require.NotNil(t, state)
	require.NotEmpty(t, state.SessionState)

	secondClient := NewAPIClientFromConfig(cfg).WithState(state)
	secondClient.MaxRowsPerPage = 1

	finalResp, err := secondClient.PollUntilQueryEnd(ctx, startResp)
	require.NoError(t, err)
	require.NotNil(t, finalResp)
	require.True(t, finalResp.ReadFinished())
	defer func() {
		require.NoError(t, secondClient.CloseQuery(context.Background(), finalResp))
	}()

	for i := 0; i < 5; i++ {
		value, ok := finalResp.cellString(i, 0)
		require.True(t, ok)
		assert.Equal(t, strconv.Itoa(i), value)
	}

	require.NotNil(t, finalResp.Stats)
	assert.Equal(t, uint64(5), finalResp.Stats.ResultProgress.Rows)
}

func TestIntegrationStateRestoresSessionSettings(t *testing.T) {
	cfg := integrationTestConfig(t)

	ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
	defer cancel()

	client := NewAPIClientFromConfig(cfg)
	_, err := client.QuerySync(ctx, "SET max_result_rows = 5")
	require.NoError(t, err)

	state := client.GetState()
	require.NotNil(t, state)
	require.NotEmpty(t, state.SessionState)

	restored := NewAPIClientFromConfig(cfg).WithState(state)
	resp, err := restored.QuerySync(ctx, "SELECT value FROM system.settings WHERE name = 'max_result_rows'")
	require.NoError(t, err)

	value, ok := resp.cellString(0, 0)
	require.True(t, ok)
	assert.Equal(t, "5", value)

	roundedState := restored.GetState()
	require.NotNil(t, roundedState)
	require.NotEmpty(t, roundedState.SessionState)

	var sessionState SessionState
	require.NoError(t, json.Unmarshal([]byte(roundedState.SessionState), &sessionState))
	assert.Equal(t, "5", sessionState.Settings["max_result_rows"])
}

func integrationTestConfig(t *testing.T) *Config {
	t.Helper()

	dsn := os.Getenv("TEST_DATABEND_DSN")
	if dsn == "" {
		t.Skip("TEST_DATABEND_DSN is not set")
	}

	cfg, err := ParseDSN(dsn)
	require.NoError(t, err)
	return cfg
}