MongoDB: DescribeTable draft #229
Conversation
ninaiad
requested review from
vitalyisaev2,
dorooleg and
uzhastik
as code owners
| @@ -144,6 +144,41 @@ func WithPredicate(val *api_service_protos.TPredicate) ValidateTableOption { | |||
| } | |||
| } | |||
|
|
|||
| func (b *Base[ID, IDBUILDER]) ValidateTableMetadata( | |||
There was a problem hiding this comment.
Это можно будет убрать после реализации ReadSplit (для других источников сейчас, кажется, нет тестов, которые проверяют только DescribeTable)
| case primitive.A: | ||
| if len(v) > 0 { | ||
| if innerType, err := typeMap(v[0], logger); err != nil { | ||
| return nil, err |
There was a problem hiding this comment.
сейчас весь массив остается сериализованным, если внутренний тип не распарсился, но можно переделать на массив строк
| columnNames = append(columnNames, v.Key) | ||
| deducedTypes[v.Key] = t | ||
| logger.Debug(fmt.Sprintf("BsonToYqlColumn: new column %v %v", v.Key, tString)) | ||
| } else if prevTypeString != tString { |
There was a problem hiding this comment.
типы сравниваются по их строчному представлению
я пока не нашла как это сделать лучше, если не проверять явно все возможные типы по-отдельности - могу переделать так
|
|
||
| defer conn.Disconnect(ctx) | ||
|
|
||
| if !mongoDbOptions.DoParse { |
There was a problem hiding this comment.
тут ранее подключаемся к бд, даже когда не нужно читать данные из нее
можно убрать, но так есть проверка, что данные для подключения корректные
| @@ -1,5 +1,5 @@ | |||
| package utils | |||
|
|
|||
| type TableIDTypes interface { | |||
| int32 | int64 | |||
| int32 | int64 | string | |||
There was a problem hiding this comment.
вообще тут должен быть массив байт для ObjectId из монго, но в рамках тестов будет удобнее работать со строками, поэтому я предлагаю попробовать так
|
|
||
| func getUnparsedDocSchema(tableName string) *api_service_protos.TSchema { | ||
| return &api_service_protos.TSchema{Columns: []*Ydb.Column{ | ||
| {Name: idColumn, Type: common.MakePrimitiveType(Ydb.Type_STRING)}, |
There was a problem hiding this comment.
nb: единственные два случая в MongoDB, где используется не optional тип - _id и json, соответствующий всему документу из коллекции
No description provided.