diff --git a/taosWS/rows.go b/taosWS/rows.go index 9b8f0be..ae7ccb0 100644 --- a/taosWS/rows.go +++ b/taosWS/rows.go @@ -159,9 +159,6 @@ func (rs *rows) fetchBlock() error { } func (rs *rows) freeResult() error { - if rs.isStmt { - return nil - } tc := rs.conn reqID := tc.generateReqID() req := &WSFreeResultReq{ @@ -181,5 +178,6 @@ func (rs *rows) freeResult() error { if err != nil { return err } + err = tc.writeText(rs.buf.Bytes()) return nil }