(commandTag CommandTag, err error)
| 1906 | } |
| 1907 | |
| 1908 | func (rr *ResultReader) concludeCommand(commandTag CommandTag, err error) { |
| 1909 | // Keep the first error that is recorded. Store the error before checking if the command is already concluded to |
| 1910 | // allow for receiving an error after CommandComplete but before ReadyForQuery. |
| 1911 | if err != nil && rr.err == nil { |
| 1912 | rr.err = err |
| 1913 | } |
| 1914 | |
| 1915 | if rr.commandConcluded { |
| 1916 | return |
| 1917 | } |
| 1918 | |
| 1919 | rr.commandTag = commandTag |
| 1920 | rr.rowValues = nil |
| 1921 | rr.commandConcluded = true |
| 1922 | } |
| 1923 | |
| 1924 | // Batch is a collection of queries that can be sent to the PostgreSQL server in a single round-trip. |
| 1925 | type Batch struct { |
no outgoing calls
no test coverage detected