internal/bind/numeric_args_test.go - master - githubmirror/ydb-go-sdk

internal/bind/numeric_args_test.go
328 строк7 KB
Aleksey Myasnikov
* Added public package `github.com/ydb-platform/ydb-go-sdk/v3/types` and marked as deprecated all public API in `github.com/ydb-platform/ydb-go-sdk/v3/table/types` as deprecated (#2217)
30 июн 2026, 13:52
Не верифицирован
30 июн 2026, 13:52419b93a
package bind

import (
	"testing"
	"time"

	"github.com/stretchr/testify/require"

	"github.com/ydb-platform/ydb-go-sdk/v3/table"
	"github.com/ydb-platform/ydb-go-sdk/v3/types"
)

func TestNumericArgsBindRewriteQuery(t *testing.T) {
	var (
		now = time.Now()
		b   = NumericArgs{}
	)
	for _, tt := range []struct {
		sql    string
		args   []any
		yql    string
		params []any
		err    error
	}{
		{
			sql: `SELECT $123abc, $2`,
			args: []any{
				100,
			},
			err: ErrInconsistentArgs,
		},
		{
			sql: `SELECT $123abc, $1`,
			args: []any{
				200,
			},
			yql: `-- origin query with numeric args replacement
SELECT $123abc, $p0`,
			params: []any{
				table.ValueParam("$p0", types.Int32Value(200)),
			},
		},
		{
			sql: `SELECT $1, $2`,
			args: []any{
				table.ValueParam("$name1", types.Int32Value(100)),
				table.ValueParam("$name2", types.Int32Value(200)),
			},
			yql: `-- origin query with numeric args replacement
SELECT $name1, $name2`,
			params: []any{
				table.ValueParam("$name1", types.Int32Value(100)),
				table.ValueParam("$name2", types.Int32Value(200)),
			},
		},
		{
			sql: `SELECT $1, $2`,
			args: []any{
				table.ValueParam("$namedArg", types.Int32Value(100)),
				200,
			},
			yql: `-- origin query with numeric args replacement
SELECT $namedArg, $p1`,
			params: []any{
				table.ValueParam("$namedArg", types.Int32Value(100)),
				table.ValueParam("$p1", types.Int32Value(200)),
			},
		},
		{
			sql: `SELECT $0, $1`,
			args: []any{
				100,
				200,
			},
			err: ErrUnexpectedNumericArgZero,
		},
		{
			sql: `SELECT $1, $2`,
			args: []any{
				100,
				200,
			},
			yql: `-- origin query with numeric args replacement
SELECT $p0, $p1`,
			params: []any{
				table.ValueParam("$p0", types.Int32Value(100)),
				table.ValueParam("$p1", types.Int32Value(200)),
			},
		},
		{
			sql: `SELECT $1, $2`,
			args: []any{
				100,
			},
			err: ErrInconsistentArgs,
		},
		{
			sql: `SELECT $1, "$2"`,
			args: []any{
				100,
			},
			yql: `-- origin query with numeric args replacement
SELECT $p0, "$2"`,
			params: []any{
				table.ValueParam("$p0", types.Int32Value(100)),
			},
		},
		{
			sql: `SELECT $1, '$2'`,
			args: []any{
				100,
			},
			yql: `-- origin query with numeric args replacement
SELECT $p0, '$2'`,
			params: []any{
				table.ValueParam("$p0", types.Int32Value(100)),
			},
		},
		{
			sql: "SELECT $1, `$2`",
			args: []any{
				100,
			},
			yql: "-- origin query with numeric args replacement\nSELECT $p0, `$2`",
			params: []any{
				table.ValueParam("$p0", types.Int32Value(100)),
			},
		},
		{
			sql:    "SELECT ?, $1, $p0",
			params: []any{},
			err:    ErrInconsistentArgs,
		},
		{
			sql: "SELECT $1, $2, $3",
			args: []any{
				1,
				"test",
				[]string{
					"test1",
					"test2",
					"test3",
				},
			},
			yql: `-- origin query with numeric args replacement
SELECT $p0, $p1, $p2`,
			params: []any{
				table.ValueParam("$p0", types.Int32Value(1)),
				table.ValueParam("$p1", types.TextValue("test")),
				table.ValueParam("$p2", types.ListValue(
					types.TextValue("test1"),
					types.TextValue("test2"),
					types.TextValue("test3"),
				)),
			},
		},
		{
			sql: "SELECT $1, $2, $3, $1, $2",
			args: []any{
				1,
				"test",
				[]string{
					"test1",
					"test2",
					"test3",
				},
			},
			yql: `-- origin query with numeric args replacement
SELECT $p0, $p1, $p2, $p0, $p1`,
			params: []any{
				table.ValueParam("$p0", types.Int32Value(1)),
				table.ValueParam("$p1", types.TextValue("test")),
				table.ValueParam("$p2", types.ListValue(
					types.TextValue("test1"),
					types.TextValue("test2"),
					types.TextValue("test3"),
				)),
			},
		},
		{
			sql: "SELECT $1, $2, $3",
			args: []any{
				types.Int32Value(1),
				types.TextValue("test"),
				types.ListValue(
					types.TextValue("test1"),
					types.TextValue("test2"),
					types.TextValue("test3"),
				),
			},
			yql: `-- origin query with numeric args replacement
SELECT $p0, $p1, $p2`,
			params: []any{
				table.ValueParam("$p0", types.Int32Value(1)),
				table.ValueParam("$p1", types.TextValue("test")),
				table.ValueParam("$p2", types.ListValue(
					types.TextValue("test1"),
					types.TextValue("test2"),
					types.TextValue("test3"),
				)),
			},
		},
		{
			sql: "SELECT $1, a, b, c WHERE id = $1 AND date < $2 AND value IN ($3)",
			args: []any{
				1, now, []string{"3"},
			},
			yql: `-- origin query with numeric args replacement
SELECT $p0, a, b, c WHERE id = $p0 AND date < $p1 AND value IN ($p2)`,
			params: []any{
				table.ValueParam("$p0", types.Int32Value(1)),
				table.ValueParam("$p1", types.TimestampValueFromTime(now)),
				table.ValueParam("$p2", types.ListValue(types.TextValue("3"))),
			},
		},
		{
			sql: "SELECT 1",
			yql: "SELECT 1",
		},
		{
			sql: `
SELECT 1`,
			yql: `
SELECT 1`,
		},
		{
			sql: "SELECT $1, $2",
			args: []any{
				1,
			},
			err: ErrInconsistentArgs,
		},
		{
			sql: "SELECT $1, $2 -- some comment with $3",
			args: []any{
				100,
				200,
			},
			yql: `-- origin query with numeric args replacement
SELECT $p0, $p1 -- some comment with $3`,
			params: []any{
				table.ValueParam("$p0", types.Int32Value(100)),
				table.ValueParam("$p1", types.Int32Value(200)),
			},
		},
		{
			sql: "SELECT $1 /* some comment with $3 */, $2",
			args: []any{
				100,
				200,
			},
			yql: `-- origin query with numeric args replacement
SELECT $p0 /* some comment with $3 */, $p1`,
			params: []any{
				table.ValueParam("$p0", types.Int32Value(100)),
				table.ValueParam("$p1", types.Int32Value(200)),
			},
		},
		{
			sql: "SELECT $1, $2 -- some comment with $3",
			args: []any{
				100,
			},
			err: ErrInconsistentArgs,
		},
		{
			sql: "SELECT $1, $2, $3",
			args: []any{
				100,
				200,
			},
			err: ErrInconsistentArgs,
		},
		{
			sql: `
SELECT $1 /* some comment with $3 */, $2`,
			args: []any{
				100,
				200,
			},
			yql: `-- origin query with numeric args replacement

SELECT $p0 /* some comment with $3 */, $p1`,
			params: []any{
				table.ValueParam("$p0", types.Int32Value(100)),
				table.ValueParam("$p1", types.Int32Value(200)),
			},
		},
		{
			sql: "SELECT $1, $2",
			args: []any{
				100,
				200,
			},
			yql: `-- origin query with numeric args replacement
SELECT $p0, $p1`,
			params: []any{
				table.ValueParam("$p0", types.Int32Value(100)),
				table.ValueParam("$p1", types.Int32Value(200)),
			},
		},
		{
			sql: "SELECT $1, $2",
			args: []any{
				100,
				200,
			},
			yql: `-- origin query with numeric args replacement
SELECT $p0, $p1`,
			params: []any{
				table.ValueParam("$p0", types.Int32Value(100)),
				table.ValueParam("$p1", types.Int32Value(200)),
			},
		},
	} {
		t.Run("", func(t *testing.T) {
			yql, params, err := b.ToYdb(tt.sql, tt.args...)
			if tt.err != nil {
				require.Error(t, err)
				require.ErrorIs(t, err, tt.err)
			} else {
				require.NoError(t, err)
				require.Equal(t, tt.yql, yql)
				require.Equal(t, tt.params, params)
			}
		})
	}
}