| 388 | } |
| 389 | |
| 390 | void checkTypesOfKeys(const Block & block_left, const Names & key_names_left, |
| 391 | const Block & block_right, const Names & key_names_right) |
| 392 | { |
| 393 | size_t keys_size = key_names_left.size(); |
| 394 | |
| 395 | for (size_t i = 0; i < keys_size; ++i) |
| 396 | { |
| 397 | DataTypePtr left_type = removeNullable(recursiveRemoveLowCardinality(block_left.getByName(key_names_left[i]).type)); |
| 398 | DataTypePtr right_type = removeNullable(recursiveRemoveLowCardinality(block_right.getByName(key_names_right[i]).type)); |
| 399 | |
| 400 | if (!left_type->equals(*right_type)) |
| 401 | { |
| 402 | throw DB::Exception( |
| 403 | ErrorCodes::TYPE_MISMATCH, |
| 404 | "Type mismatch of columns to JOIN by: {} :: {} at left, {} :: {} at right", |
| 405 | key_names_left[i], left_type->getName(), |
| 406 | key_names_right[i], right_type->getName()); |
| 407 | } |
| 408 | } |
| 409 | } |
| 410 | |
| 411 | void checkTypesOfKeys(const Block & block_left, const Names & key_names_left, const String & condition_name_left, |
| 412 | const Block & block_right, const Names & key_names_right, const String & condition_name_right) |
no test coverage detected