| 1058 | |
| 1059 | |
| 1060 | void Connection::sendQueryPlan(const QueryPlan & query_plan) |
| 1061 | { |
| 1062 | writeVarUInt(Protocol::Client::QueryPlan, *out); |
| 1063 | |
| 1064 | if (query_plan.isSerialized()) |
| 1065 | { |
| 1066 | // Use cached serialization |
| 1067 | auto serialized_data = query_plan.getSerializedData(); |
| 1068 | out->write(serialized_data.data(), serialized_data.size()); |
| 1069 | } |
| 1070 | else |
| 1071 | { |
| 1072 | // Fallback: serialize on-the-fly |
| 1073 | query_plan.serialize(*out, server_query_plan_serialization_version); |
| 1074 | } |
| 1075 | } |
| 1076 | |
| 1077 | void Connection::sendCancel() |
| 1078 | { |
no test coverage detected