| @@ 9126-9137 (lines=12) @@ | ||
| 9123 | } |
|
| 9124 | ||
| 9125 | // Check for COPY request |
|
| 9126 | if (pg_result_status($res) == 4) { |
|
| 9127 | // 4 == PGSQL_COPY_FROM |
|
| 9128 | while (!feof($fd)) { |
|
| 9129 | $copy = fgets($fd, 32768); |
|
| 9130 | $lineno++; |
|
| 9131 | pg_put_line($conn, $copy); |
|
| 9132 | if ($copy == "\\.\n" || $copy == "\\.\r\n") { |
|
| 9133 | pg_end_copy($conn); |
|
| 9134 | break; |
|
| 9135 | } |
|
| 9136 | } |
|
| 9137 | } |
|
| 9138 | } |
|
| 9139 | $query_buf = null; |
|
| 9140 | $query_start = $i + $thislen; |
|
| @@ 9200-9211 (lines=12) @@ | ||
| 9197 | } |
|
| 9198 | ||
| 9199 | // Check for COPY request |
|
| 9200 | if (pg_result_status($res) == 4) { |
|
| 9201 | // 4 == PGSQL_COPY_FROM |
|
| 9202 | while (!feof($fd)) { |
|
| 9203 | $copy = fgets($fd, 32768); |
|
| 9204 | $lineno++; |
|
| 9205 | pg_put_line($conn, $copy); |
|
| 9206 | if ($copy == "\\.\n" || $copy == "\\.\r\n") { |
|
| 9207 | pg_end_copy($conn); |
|
| 9208 | break; |
|
| 9209 | } |
|
| 9210 | } |
|
| 9211 | } |
|
| 9212 | } |
|
| 9213 | ||
| 9214 | fclose($fd); |
|