31.9. 와 관련된 기능copy토토 캔

기간 동안 서버로 데이터를 보냅니다copy_inState.

int pqputcopydata (pgconn *conn,
                  const char *버퍼,
                  int nbytes);

전송COPY데이터 지정된버퍼, OF 길이nbytes, 서버. 결과는 데이터를 전송 한 경우 1입니다. 시도가 차단 될 것이기 때문에 전송됩니다 (이 경우는 연결이 비 차단 모드에있는 경우 가능), 또는 -1 오류가 발생한 경우. (사용PQERRORMESSAGE반환 값은 -1입니다. 값이 0이면 기다리십시오 글을 쓰고 다시 시도하십시오.)

응용 프로그램은를 나눌 수 있습니다.COPY데이터 스트림이 버퍼로드로 스트림 편리한 크기. 버퍼로드 경계는 의미 론적이 없습니다 보낼 때의 중요성. 데이터의 내용 스트림은에서 기대하는 데이터 형식과 일치해야합니다.COPY토토 캔; 보다copy자세한 내용.

기간 동안 서버에 데이터 종료 표시를 보냅니다copy_inState.

int pqputcopyend (pgconn *conn,
                 const char *errormsg);

종료copy_in작동 성공적으로errormsgisNULL. 만약에errormsgisNULL그런 다음copy| 줄을 가리키면서errormsg오류로 사용됩니다 메시지. (이 정확한 오류를 가정해서는 안됩니다 그러나 메시지는 서버에서 돌아올 것입니다. 서버가 이미 실패했을 수도 있습니다COPY그 자체의 이유로. 또한 주목하십시오 사용시 강제 실패 옵션은 작동하지 않습니다. 3.0 pre-protocol 연결.)

종료 데이터가 전송 된 경우 결과는 1입니다. 시도가 차단 될 것이기 때문에 보내지 않은 경우 연결이 차단되지 않은 경우에만 사례가 가능합니다. 오류가 발생한 경우 모드), 또는 -1. (사용PQERRORMESSAGE반환 값은 -1입니다. 값이 0이면 기다리십시오 글을 쓰고 다시 시도하십시오.)

성공적으로 전화 한 후pqputcopyend, Callpqgetresult최종 결과를 얻으려면 상태의 상태Copy토토 캔. 하나 이 결과가 평소에서 사용할 수있을 때까지 기다릴 수 있습니다. 방법. 그런 다음 정상 작동으로 돌아갑니다.

기간 동안 서버로부터 데이터 수신Copy_outState.

int pqgetcopydata (pgconn *conn,
                  char ** 버퍼,
                  int async);

서버에서 다른 행의 데이터 행을 얻으려고합니다. 동안copy. 데이터는 항상입니다 한 번에 하나의 데이터 행을 반환했습니다. 부분 행만 인 경우 사용 가능하면 반환되지 않습니다. a의 성공적인 반환 데이터 행에는 유지할 메모리 청크를 할당하는 것이 포함됩니다. 데이터. 그만큼버퍼매개 변수 비이어야합니다NULL. *버퍼는 할당 된 것을 가리 키도록 설정되었습니다 기억 또는NULL어디에서 버퍼가 반환되지 않습니다. 비null결과 버퍼를 사용하여 자유롭게 해제해야PQFREEMEM더 이상 필요하지 않은 경우.

행이 성공적으로 반환되면 반환 값 행의 데이터 바이트 수입니다 (이것은 항상 0보다 큽니다). 반환 된 문자열은 항상입니다 무효가 종결되었지만 이것은 아마도 유용 할 것입니다 텍스트COPY. 0의 결과 를 나타냅니다.COPY아직도 있습니다 진행 중이지만 아직 사용 가능한 행이 없습니다 (이것은 가능 가능async참). -1의 결과는임을 나타냅니다.COPY가 완료되었습니다. -2의 결과가 나타납니다 오류가 발생했다 (ConsultPQERRORMESSAGE이유가 있습니다).

언제asynctrue (아님 영),pqgetCopyData의지 입력 대기를 차단하지 않습니다. 이면 0을 반환합니다.COPY아직 진행 중이지만 아니요 완전한 행을 사용할 수 있습니다. (이 경우 기다립니다 읽기 준비 후 전화pqconsumeInput호출 전pqgetCopyData다시.) 언제asyncis false (Zero),pqgetCopyData블록 데이터를 사용할 수 있거나 작업이 완료 될 때까지

이후pqgetCopyDatareturns -1, callpqgetresult최종 결과를 얻으려면 상태의 상태COPY토토 캔. 하나 이 결과가 평소에서 사용할 수있을 때까지 기다릴 수 있습니다. 방법. 그런 다음 정상 작동으로 돌아갑니다.

새로운 문자 라인을 읽습니다 (서버에 의해 전송) 크기의 버퍼 문자열로길이.

int pqgetline (pgconn *conn,
              char *버퍼,
              int 길이);

이 기능은 최대까지 복사합니다.길이-1 문자 버퍼와 종단 Newline을 제로 바이트로 변환합니다.pqgetline반환eof입력 끝에서 0 인 경우 0 전체 라인을 읽고 버퍼가 가득 찬 경우 1 그러나 종료 Newline은 아직 읽지 않았습니다.

신청서가 새로운 지 확인해야합니다. 라인은 두 문자로 구성됩니다\.는 서버에 가지고 있음을 나타냅니다 의 결과 보내기 완료COPY토토 캔. 응용 프로그램이 가능하다면 이상의 줄을받습니다.길이-1 문자 길이, 치료가 필요합니다 그것이 인식하기 위해\.올바르게 선 (예를 들어, 오해하지는 않습니다 터미네이터 라인에 대한 긴 데이터 라인의 끝).

행을 읽는다COPY데이터 (서버에 의해 전송) 버퍼없이 블로킹.

int pqgetlineAnecync (pgconn *conn,
                   char *버퍼,
                   int bufsize);

이 기능은와 유사합니다.pqgetline이지만 사용할 수 있습니다 읽어야하는 응용 프로그램COPY데이터 비동기 적으로, 즉 차단하지 않고. 가요 발행COPY토토 캔 및 apgres_copy_out응답, 신청서가 호출해야합니다pqconsumeInput및pqgetLineAnync데이터 종료까지 신호가 감지됩니다.

와 달리pqgetline,이 함수는 감지에 책임이 있습니다 데이터 끝.

각 호출에서pqgetLineAnsynca 완전한 데이터 행을 사용할 수 있습니다libpq의 입력 버퍼. 그렇지 않으면 아니요 나머지 행이 도착할 때까지 데이터가 반환됩니다. 그만큼 코피 종료 데이터 마커가있는 경우 함수는 -1을 반환합니다 데이터를 사용할 수없는 경우 인식되었거나 0 데이터의 바이트 수를 제공하는 양수 반환. -1이 반환되면 발신자는 다음 호출PQENDCOPY정상 처리에.

반환 된 데이터는 데이터 행을 넘어 확장되지 않습니다 경계. 가능하면 전체 행이 하나로 반환됩니다. 시간. 그러나 발신자가 제공하는 버퍼가 서버에서 보낸 행을 보유하기 위해 작은 데이터 행이 반환됩니다. 텍스트 데이터를 사용하면 다음과 같습니다 마지막으로 반환 된 바이트가를 테스트하여 감지\ n(이진에서COPY, 실제 구문 분석COPY데이터 형식이 필요합니다 동등한 결정을 내립니다.) 반환 문자열은 무효가 끝나지 않습니다. (추가하려면 a 널 종료, 확실히 A를 통과하십시오.bufsize방보다 작은 하나 실제로 사용할 수 있습니다.)

서버에 null 종결 문자열을 보냅니다. 보고 0 인 경우eof보낼 수없는 경우 문자열.

int pqputline (pgconn *conn,
              const char *string);

theCOPY데이터 스트림이 보낸다 일련의 전화pqputline와 동일한 형식이 있습니다 반품PQGETLINEASYNC, 신청서는 정확히 전송해야 할 의무가 없습니다 당 하나의 데이터 행pqputline전화; 부분 줄 또는 여러 줄을 보내는 것은 괜찮습니다. 전화 당.

서버로 널없는 문자열을 보냅니다. OK이고 0을 반환합니다.eof불가능한 경우 문자열을 보내려면.

int pqputnbytes (pgconn *conn,
                const char *버퍼,
                int nbytes);

이것은 똑같습니다pqputline30030_30221

서버와 동기화됩니다.

int pqendcopy (pgconn *conn);

이 기능은 서버가 끝날 때까지 기다립니다 사자. 마지막 문자열이있을 때 발행해야합니다 를 사용하여 서버로 전송되었습니다.pqputline또는 마지막 문자열이있는 경우 를 사용하여 서버로부터 접수되었습니다.pggetline. 발행해야합니다 서버가 얻을 수 있습니다"out in sync"클라이언트와. 이 기능에서 돌아 왔을 때 서버는 다음 SQL 토토 캔을받을 준비가되었습니다. 그만큼 성공적인 완료시, 0이 아닌 반환 값은 0입니다 그렇지 않으면. (사용PQERRORMESSAGE반환 값은 0이 아닙니다.)

사용시pqgetresult, 응용 프로그램은 A에 응답해야합니다.pgres_copy_out실행하여 결과pqgetline반복적으로, 뒤 이어PQENDCOPY터미네이터 라인이 표시됩니다. 그런 다음로 돌아 가야합니다.pqgetresult루프까지pqgetresultNULL을 반환합니다 바늘. 마찬가지로 Apgres_copy_in결과는 a 일련의pqputline전화 뒤 이어PQENDCOPY로 돌아 가기pqgetresult루프. 이 계약은 A를 보장합니다.COPY일련의 토토 캔SQL토토 캔이 있습니다 올바르게 실행.

구식 응용 프로그램이 A를 제출할 가능성이 높습니다COPYviaPQEXEC그리고 거래를 가정합니다 이후에 완료되었습니다.PQENDCOPY. 이것은 만 올바르게 작동합니다.COPY유일한SQL토토 캔의 토토 캔 끈.