diff options
| author | Ilnaz Nizametdinov <ilnaz@ydb.tech> | 2024-12-13 15:47:14 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-12-13 15:47:14 +0300 |
| commit | 65fee378ac1863807da03154c565ec11856662fd (patch) | |
| tree | 843bc516a5989fd5687a9b241518810b87a4c358 | |
| parent | a2ec9639d285d86bd25cfd3f842bb473b317150a (diff) | |
| download | ydb-65fee378ac1863807da03154c565ec11856662fd.tar.gz | |
Rename consistency settings (part 2) (#12603)
| -rw-r--r-- | ydb/core/kqp/provider/yql_kikimr_exec.cpp | 2 | ||||
| -rw-r--r-- | ydb/core/kqp/provider/yql_kikimr_type_ann.cpp | 2 | ||||
| -rw-r--r-- | ydb/core/kqp/ut/scheme/kqp_scheme_ut.cpp | 4 | ||||
| -rw-r--r-- | ydb/core/tx/replication/controller/assign_tx_id_ut.cpp | 2 |
4 files changed, 5 insertions, 5 deletions
diff --git a/ydb/core/kqp/provider/yql_kikimr_exec.cpp b/ydb/core/kqp/provider/yql_kikimr_exec.cpp index 6e8a2b18c5..2fde56811e 100644 --- a/ydb/core/kqp/provider/yql_kikimr_exec.cpp +++ b/ydb/core/kqp/provider/yql_kikimr_exec.cpp @@ -688,7 +688,7 @@ namespace { } else if (name == "password_secret_name") { dstSettings.EnsureStaticCredentials().PasswordSecretName = setting.Value().Cast<TCoDataCtor>().Literal().Cast<TCoAtom>().Value(); - } else if (name == "consistency_mode" || name == "consistency_level") { + } else if (name == "consistency_level") { auto value = ToString(setting.Value().Cast<TCoDataCtor>().Literal().Cast<TCoAtom>().Value()); if (to_lower(value) == "global") { dstSettings.EnsureGlobalConsistency(); diff --git a/ydb/core/kqp/provider/yql_kikimr_type_ann.cpp b/ydb/core/kqp/provider/yql_kikimr_type_ann.cpp index 4d499c2fb5..7fa2cacd19 100644 --- a/ydb/core/kqp/provider/yql_kikimr_type_ann.cpp +++ b/ydb/core/kqp/provider/yql_kikimr_type_ann.cpp @@ -1775,7 +1775,7 @@ virtual TStatus HandleCreateTable(TKiCreateTable create, TExprContext& ctx) over "user", "password", "password_secret_name", - "consistency_mode", + "consistency_level", "commit_interval", }; diff --git a/ydb/core/kqp/ut/scheme/kqp_scheme_ut.cpp b/ydb/core/kqp/ut/scheme/kqp_scheme_ut.cpp index cb8b9ca106..4011a33a1f 100644 --- a/ydb/core/kqp/ut/scheme/kqp_scheme_ut.cpp +++ b/ydb/core/kqp/ut/scheme/kqp_scheme_ut.cpp @@ -6712,7 +6712,7 @@ Y_UNIT_TEST_SUITE(KqpScheme) { `/Root/table` AS `/Root/replica` WITH ( CONNECTION_STRING = "grpc://localhost:2135/?database=/Root", - CONSISTENCY_MODE = "FOO" + CONSISTENCY_LEVEL = "FOO" ); )"; @@ -6727,7 +6727,7 @@ Y_UNIT_TEST_SUITE(KqpScheme) { `/Root/table` AS `/Root/replica` WITH ( CONNECTION_STRING = "grpc://localhost:2135/?database=/Root", - CONSISTENCY_MODE = "ROW", + CONSISTENCY_LEVEL = "ROW", COMMIT_INTERVAL = Interval("PT10S") ); )"; diff --git a/ydb/core/tx/replication/controller/assign_tx_id_ut.cpp b/ydb/core/tx/replication/controller/assign_tx_id_ut.cpp index 38e8fae2a9..dcf738ce9e 100644 --- a/ydb/core/tx/replication/controller/assign_tx_id_ut.cpp +++ b/ydb/core/tx/replication/controller/assign_tx_id_ut.cpp @@ -49,7 +49,7 @@ Y_UNIT_TEST_SUITE(AssignTxId) { `/Root/table` AS `/Root/replica` WITH ( CONNECTION_STRING = "grpc://%s/?database=/Root", - CONSISTENCY_MODE = "GLOBAL", + CONSISTENCY_LEVEL = "GLOBAL", COMMIT_INTERVAL = Interval("PT10S") ); )", env.GetEndpoint().c_str())) |