(command byte, arg string)
| 451 | } |
| 452 | |
| 453 | func (mc *mysqlConn) writeCommandPacketStr(command byte, arg string) error { |
| 454 | // Reset Packet Sequence |
| 455 | mc.resetSequence() |
| 456 | |
| 457 | pktLen := 1 + len(arg) |
| 458 | data, err := mc.buf.takeBuffer(pktLen + 4) |
| 459 | if err != nil { |
| 460 | return err |
| 461 | } |
| 462 | |
| 463 | // Add command byte |
| 464 | data[4] = command |
| 465 | |
| 466 | // Add arg |
| 467 | copy(data[5:], arg) |
| 468 | |
| 469 | // Send CMD packet |
| 470 | err = mc.writePacket(data) |
| 471 | mc.syncSequence() |
| 472 | return err |
| 473 | } |
| 474 | |
| 475 | func (mc *mysqlConn) writeCommandPacketUint32(command byte, arg uint32) error { |
| 476 | // Reset Packet Sequence |
no test coverage detected