Skip to content

Commit dce8587

Browse files
committed
re-add stmt close + remove state print
1 parent 6259296 commit dce8587

File tree

2 files changed

+1
-2
lines changed

2 files changed

+1
-2
lines changed

Sources/MySQL/Connection/MySQLConnection+Query.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ extension MySQLConnection {
6666
)
6767
let comClose = MySQLPacket.ComStmtClose(statementID: ok.statementID)
6868
var columns: [MySQLColumnDefinition41] = []
69-
return self.send([.comStmtExecute(comExecute)]) { message in
69+
return self.send([.comStmtExecute(comExecute), .comStmtClose(comClose)]) { message in
7070
switch message {
7171
case .columnDefinition41(let col):
7272
columns.append(col)

Sources/MySQL/Pipeline/MySQLPacketDecoder.swift

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -198,7 +198,6 @@ final class MySQLPacketDecoder: ByteToMessageDecoder {
198198

199199
/// Statement Protocol (Prepared Query)
200200
func decodeStatementProtocol(ctx: ChannelHandlerContext, buffer: inout ByteBuffer, statementState: MySQLStatementProtocolState, capabilities: MySQLCapabilities) throws -> DecodingState {
201-
print(statementState)
202201
switch statementState {
203202
case .waitingPrepare:
204203
// check for error packet

0 commit comments

Comments
 (0)