change recover order

This commit is contained in:
hebo 2019-10-08 14:23:37 +08:00
parent a01de02f9a
commit 2c54f18374
2 changed files with 5 additions and 1 deletions

View File

@ -71,7 +71,7 @@ func (mqp *MysqlQueryPiece) GetSQL() (str *string) {
}
func (pmqp *PooledMysqlQueryPiece) Recovery() {
pmqp.recoverPool.Enqueue(pmqp)
pmqp.sliceBufferPool.Enqueue(pmqp.jsonContent[:0])
pmqp.jsonContent = nil
pmqp.recoverPool.Enqueue(pmqp)
}

View File

@ -83,6 +83,10 @@ func (bqp *BaseQueryPiece) Recovery() {
func marsharQueryPiece(qp interface{}) []byte {
var cacheBuffer = localSliceBufferPool.Dequeue()
if len(cacheBuffer) > 0 {
panic("there already have bytes in buffer")
}
buffer := bytes.NewBuffer(cacheBuffer)
err := json.NewEncoder(buffer).Encode(qp)
if err != nil {