| 452 | } |
| 453 | |
| 454 | void MySQLHandler::comInitDB(ReadBuffer & payload) |
| 455 | { |
| 456 | String database; |
| 457 | readStringUntilEOF(database, payload); |
| 458 | database = formatTenantDatabaseNameWithTenantId(database, connection_context->getTenantId(), '.'); |
| 459 | LOG_DEBUG(log, "Setting current database to {}", database); |
| 460 | connection_context->setCurrentDatabase(database); |
| 461 | packet_endpoint->sendPacket(OKPacket(0, client_capabilities, 0, 0, 1), true); |
| 462 | } |
| 463 | |
| 464 | void MySQLHandler::comFieldList(ReadBuffer & payload) |
| 465 | { |
nothing calls this directly
no test coverage detected