(tag string, rows int32)
| 775 | } |
| 776 | |
| 777 | func makeCommandComplete(tag string, rows int32) *pgproto3.CommandComplete { |
| 778 | switch tag { |
| 779 | case "INSERT", "DELETE", "UPDATE", "MERGE", "SELECT", "CREATE TABLE AS", "MOVE", "FETCH", "COPY": |
| 780 | if tag == "INSERT" { |
| 781 | tag = "INSERT 0" |
| 782 | } |
| 783 | tag = fmt.Sprintf("%s %d", tag, rows) |
| 784 | } |
| 785 | |
| 786 | return &pgproto3.CommandComplete{ |
| 787 | CommandTag: []byte(tag), |
| 788 | } |
| 789 | } |
| 790 | |
| 791 | // handleCopyData handles the COPY DATA message, by loading the data sent from the client. The |stop| response parameter |
| 792 | // is true if the connection handler should shut down the connection, |endOfMessages| is true if no more COPY DATA |
no outgoing calls
no test coverage detected