| 52 | } |
| 53 | |
| 54 | func (stmt *mysqlStmt) Exec(args []driver.Value) (driver.Result, error) { |
| 55 | if stmt.mc.closed.Load() { |
| 56 | return nil, driver.ErrBadConn |
| 57 | } |
| 58 | // Send command |
| 59 | err := stmt.writeExecutePacket(args) |
| 60 | if err != nil { |
| 61 | return nil, stmt.mc.markBadConn(err) |
| 62 | } |
| 63 | |
| 64 | mc := stmt.mc |
| 65 | handleOk := stmt.mc.clearResult() |
| 66 | |
| 67 | // Read Result |
| 68 | resLen, metadataFollows, err := handleOk.readResultSetHeaderPacket() |
| 69 | if err != nil { |
| 70 | return nil, err |
| 71 | } |
| 72 | |
| 73 | if resLen > 0 { |
| 74 | // Columns |
| 75 | if metadataFollows && stmt.mc.extCapabilities&clientCacheMetadata != 0 { |
| 76 | // we can not skip column metadata because next stmt.Query() may use it. |
| 77 | if stmt.columns, err = mc.readColumns(resLen, stmt.columns); err != nil { |
| 78 | return nil, err |
| 79 | } |
| 80 | } else { |
| 81 | if err = mc.skipColumns(resLen); err != nil { |
| 82 | return nil, err |
| 83 | } |
| 84 | } |
| 85 | |
| 86 | // Rows |
| 87 | if err = mc.skipRows(); err != nil { |
| 88 | return nil, err |
| 89 | } |
| 90 | } |
| 91 | |
| 92 | if err := handleOk.discardResults(); err != nil { |
| 93 | return nil, err |
| 94 | } |
| 95 | |
| 96 | copied := mc.result |
| 97 | return &copied, nil |
| 98 | } |
| 99 | |
| 100 | func (stmt *mysqlStmt) Query(args []driver.Value) (driver.Rows, error) { |
| 101 | return stmt.query(args) |