| 455 | } |
| 456 | |
| 457 | void MySQLHandler::comFieldList(ReadBuffer & payload) |
| 458 | { |
| 459 | ComFieldList packet; |
| 460 | packet.readPayloadWithUnpacked(payload); |
| 461 | const auto session_context = session->sessionContext(); |
| 462 | String database = session_context->getCurrentDatabase(); |
| 463 | StoragePtr table_ptr = DatabaseCatalog::instance().getTable({database, packet.table}, session_context); |
| 464 | auto metadata_snapshot = table_ptr->getInMemoryMetadataPtr(session_context, false); |
| 465 | for (const NameAndTypePair & column : metadata_snapshot->getColumns().getAll()) |
| 466 | { |
| 467 | ColumnDefinition column_definition( |
| 468 | database, packet.table, packet.table, column.name, column.name, CharacterSet::binary, 100, ColumnType::MYSQL_TYPE_STRING, 0, 0, true |
| 469 | ); |
| 470 | packet_endpoint->sendPacket(column_definition); |
| 471 | } |
| 472 | packet_endpoint->sendPacket(OKPacket(0xfe, client_capabilities, 0, 0, 0)); |
| 473 | } |
| 474 | |
| 475 | void MySQLHandler::comPing() |
| 476 | { |
nothing calls this directly
no test coverage detected