For each remaining resultset in the stream, discards its rows and updates mc.affectedRows and mc.insertIds.
()
| 1243 | // For each remaining resultset in the stream, discards its rows and updates |
| 1244 | // mc.affectedRows and mc.insertIds. |
| 1245 | func (mc *okHandler) discardResults() error { |
| 1246 | for mc.status&statusMoreResultsExists != 0 { |
| 1247 | resLen, _, err := mc.readResultSetHeaderPacket() |
| 1248 | if err != nil { |
| 1249 | return err |
| 1250 | } |
| 1251 | if resLen > 0 { |
| 1252 | // columns |
| 1253 | if err := mc.conn().skipColumns(resLen); err != nil { |
| 1254 | return err |
| 1255 | } |
| 1256 | // rows |
| 1257 | if err := mc.conn().skipRows(); err != nil { |
| 1258 | return err |
| 1259 | } |
| 1260 | } |
| 1261 | } |
| 1262 | return nil |
| 1263 | } |
| 1264 | |
| 1265 | // https://dev.mysql.com/doc/dev/mysql-server/latest/page_protocol_binary_resultset.html#sect_protocol_binary_resultset_row |
| 1266 | func (rows *binaryRows) readRow(dest []driver.Value) error { |
no test coverage detected