This is an automated email from the ASF dual-hosted git repository.
panjuan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 630c1ef Fix #10497 minor refactor (#10498)
630c1ef is described below
commit 630c1eff47e924866c2dfc5607e9442fec088ed5
Author: MingxingLAI <[email protected]>
AuthorDate: Thu May 27 16:09:54 2021 +0800
Fix #10497 minor refactor (#10498)
---
.../frontend/mysql/command/query/builder/ResponsePacketBuilder.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/mysql/command/query/builder/ResponsePacketBuilder.java
b/shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/mysql/command/query/builder/ResponsePacketBuilder.java
index 5a5c784..856ea2b 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/mysql/command/query/builder/ResponsePacketBuilder.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/mysql/command/query/builder/ResponsePacketBuilder.java
@@ -50,9 +50,9 @@ public final class ResponsePacketBuilder {
public static Collection<DatabasePacket<?>>
buildQueryResponsePackets(final QueryResponseHeader queryResponseHeader) {
Collection<DatabasePacket<?>> result = new LinkedList<>();
int sequenceId = 0;
- List<QueryHeader> queryHeader = queryResponseHeader.getQueryHeaders();
- result.add(new MySQLFieldCountPacket(++sequenceId,
queryHeader.size()));
- for (QueryHeader each : queryHeader) {
+ List<QueryHeader> queryHeaders = queryResponseHeader.getQueryHeaders();
+ result.add(new MySQLFieldCountPacket(++sequenceId,
queryHeaders.size()));
+ for (QueryHeader each : queryHeaders) {
result.add(new MySQLColumnDefinition41Packet(++sequenceId,
getColumnFieldDetailFlag(each), each.getSchema(), each.getTable(),
each.getTable(),
each.getColumnLabel(), each.getColumnName(),
each.getColumnLength(),
MySQLBinaryColumnType.valueOfJDBCType(each.getColumnType()),
each.getDecimals(), false));
}