Decimal migration fix (#9606)

Author: azevaykin

ydb/core/scheme/scheme_types_proto.cpp

@@ -55,4 +55,12 @@ TTypeInfoMod TypeInfoModFromProtoColumnType(ui32 typeId, const NKikimrProto::TTy
     }
 }
 
+NKikimrProto::TTypeInfo DefaultDecimalProto() {
+    NKikimrProto::TTypeInfo typeInfoProto;
+    typeInfoProto.SetDecimalPrecision(NScheme::DECIMAL_PRECISION);
+    typeInfoProto.SetDecimalScale(NScheme::DECIMAL_SCALE);
+    return typeInfoProto;
+}
+
+
 } // namespace NKikimr::NScheme

ydb/core/scheme/scheme_types_proto.h

@@ -19,4 +19,6 @@ struct TTypeInfoMod {
 
 TTypeInfoMod TypeInfoModFromProtoColumnType(ui32 typeId, const NKikimrProto::TTypeInfo* typeInfo);
 
+NKikimrProto::TTypeInfo DefaultDecimalProto();
+
 } // namespace NKikimr::NScheme

ydb/core/tablet_flat/flat_dbase_apply.cpp

@@ -52,8 +52,12 @@ bool TSchemeModifier::Apply(const TAlterRecord &delta)
         }
 
         std::optional<NKikimrProto::TTypeInfo> typeInfoProto;
-        if (delta.HasColumnTypeInfo())
+        if (delta.HasColumnTypeInfo()) {
             typeInfoProto = delta.GetColumnTypeInfo();
+        } else if (delta.GetColumnType() == NScheme::NTypeIds::Decimal) {
+            // Migration from table with no decimal typeInfo
+            typeInfoProto = NKikimr::NScheme::DefaultDecimalProto();
+        }
         changes |= AddColumnWithTypeInfo(table, delta.GetColumnName(), delta.GetColumnId(),
             delta.GetColumnType(), typeInfoProto, delta.GetNotNull(), null);
     } else if (action == TAlterRecord::DropColumn) {

ydb/core/tx/datashard/datashard_user_table.cpp

@@ -266,8 +266,17 @@ void TUserTable::ParseProto(const NKikimrSchemeOp::TTableDescription& descr)
     for (const auto& col : descr.GetColumns()) {
         TUserColumn& column = Columns[col.GetId()];
         if (column.Name.empty()) {
-            auto typeInfoMod = NScheme::TypeInfoModFromProtoColumnType(col.GetTypeId(),
-                col.HasTypeInfo() ? &col.GetTypeInfo() : nullptr);
+            std::optional<NKikimrProto::TTypeInfo> typeInfo;
+            if (col.HasTypeInfo()) {
+                typeInfo = col.GetTypeInfo();
+            } else if (col.GetTypeId() == NScheme::NTypeIds::Decimal) {
+                // Migration from table with no decimal typeInfo
+                typeInfo = NKikimr::NScheme::DefaultDecimalProto();
+            } else {
+                typeInfo = {};
+            }
+
+            auto typeInfoMod = NScheme::TypeInfoModFromProtoColumnType(col.GetTypeId(), typeInfo ? &*typeInfo : nullptr);
             column = TUserColumn(typeInfoMod.TypeInfo, typeInfoMod.TypeMod, col.GetName());
         }
         column.Family = col.GetFamily();