| @@ 8922-8933 (lines=12) @@ | ||
| 8919 | } |
|
| 8920 | ||
| 8921 | // Check for COPY request |
|
| 8922 | if (pg_result_status($res) == 4) { |
|
| 8923 | // 4 == PGSQL_COPY_FROM |
|
| 8924 | while (!feof($fd)) { |
|
| 8925 | $copy = fgets($fd, 32768); |
|
| 8926 | $lineno++; |
|
| 8927 | pg_put_line($conn, $copy); |
|
| 8928 | if ($copy == "\\.\n" || $copy == "\\.\r\n") { |
|
| 8929 | pg_end_copy($conn); |
|
| 8930 | break; |
|
| 8931 | } |
|
| 8932 | } |
|
| 8933 | } |
|
| 8934 | } |
|
| 8935 | $query_buf = null; |
|
| 8936 | $query_start = $i + $thislen; |
|
| @@ 8996-9007 (lines=12) @@ | ||
| 8993 | } |
|
| 8994 | ||
| 8995 | // Check for COPY request |
|
| 8996 | if (pg_result_status($res) == 4) { |
|
| 8997 | // 4 == PGSQL_COPY_FROM |
|
| 8998 | while (!feof($fd)) { |
|
| 8999 | $copy = fgets($fd, 32768); |
|
| 9000 | $lineno++; |
|
| 9001 | pg_put_line($conn, $copy); |
|
| 9002 | if ($copy == "\\.\n" || $copy == "\\.\r\n") { |
|
| 9003 | pg_end_copy($conn); |
|
| 9004 | break; |
|
| 9005 | } |
|
| 9006 | } |
|
| 9007 | } |
|
| 9008 | } |
|
| 9009 | ||
| 9010 | fclose($fd); |
|