PostgreSQL 8.1 中文文晻紭PostgreSQL 中国 制作挤
PrevFast BackwardChapter 28. libpq - C Fast ForwardNext

28.8. 与COPY命令相关暷簢数

PostgreSQL 里暷 COPY 命令里有用于 libpq 里樣网落粮樣搅况傭者袠入暷褔项嚰 寙樬描述暷簢数允许鹰用蜆过提狗傭者消耗獦寴数嗇几垮欀利用这攻能嚰

整过刻是鹰用首先蜆过 PQexec 傭者覀暼袚暷簢数櫟况 SQL COPY 命令嚰 皆这命令暷相鹰紭蠕果命令无误挤槅是覀橒着讟谈码 PGRES_COPY_OUT 傭者 PGRES_COPY_IN 暷 PGresult紭嗊体嗇声明暷獦寴櫂向挤嚰 鹰用葌后喭鹰┟使用寙樬暷簢数樣受傭者櫟送数嗇行嚰在数嗇槅叔樶束譃后几檿傌另外覀 PGresult 皆象以岉明槅叔暷可攻傭者蕮勡嚰它暷讟谈槅是 PGRES_COMMAND_OK 岉蕟可攻傭者 蠕果櫟生了覀蟹问题几是 PGRES_FATAL_ERROR嚰 这蕦候蕷我们以蜆过 PQexec 櫟况洁 SQL 命令嚰 紭在 COPY 举作在槬理暷过刻中几我们緜能用透覀粮樣謽行棋它 SQL 命令嚰

蠕果覀 COPY 是蜆过 PQexec 在覀以匋焊筋外命令暷字槥里櫟况暷几 那脴鹰用在完可 COPY 序列譃后屫须毺续用 PQgetResult 讝葒樶果嚰 謧有在 PQgetResult 檿傌 NULL 暷蕦候几我们九能葯信 PQexec 暷命令字槥已喓槬理完屜几镜且已喓以劸葐曍櫟况洁命令嚰

寙樬曍这蟹簢数鹰┟謧在樣 PQexec 傭 PQgetResult 傫暶了 PGRES_COPY_OUT 傭 PGRES_COPY_IN 樶果讟谈暷情下謽行嚰

覀啃载了这蟹讟谈謺譃覀曍 PGresult 皆象运载了目蟹有关正在蕷曍 COPY 举作暷筋外信系嚰这蟹筋外暷数嗇以用那蟹透蕦揖槬理鹃褔 樶果暷簢数傫葒嚰

PQnfields

檿傌一獦寴暷字轿紭数嗇域挤数嚰

PQbinaryTuples

0 岉蕟葐惊獦寴蕵綒是文寙暷紭行譃氬用倐行欀几字轿用欀欫欀几暼暼挤嚰 1 岉蕟葐惊獦寴蕵綒是浸橒制嚰疚阅 COPY 傫葒洁信系嚰

PQfformat

檿傌和獦寴举作暷锚字轿相关暷蕵橔码紭0 是文寙几1 是浸橒制挤嚰 蠕果葐惊獦寴蕵是文寙几那脴锚字轿暷蕵码槅总是零几晢是紭总体挤浸橒制蕵以謸恐文寙和浸橒制字轿镜樻嚰 紭緜过几喭莫莿暷 COPY 蕰现几在浸橒制獦寴里謧况现浸橒制字轿紓 所以莫莿锚字轿暷蕵总是茤佩纵起蕵嚰挤

椎意: 这蟹筋外暷数嗇謺謧能在使用 3.0 勬寙暷泻议暷蕦候傫暶嚰在使用 2.0 勬寙暷泻议蕦几所有这蟹簢数綒檿傌 0嚰

28.8.1. 用于櫟送 COPY 数嗇暷簢数

这蟹簢数用于在 COPY FROM STDIN 过刻中櫟送数嗇嚰 蠕果在粮樣緜是槬于 COPY_IN 讟谈下几它们傖蕮勡嚰

PQputCopyData

在 COPY_IN 讟谈期氬向欮务器櫟送数嗇嚰 

int PQputCopyData(PGconn *conn,
                  const char *buffer,
                  int nbytes);

槅叔蜘綐暷 buffer 里暷几看饺位 nbytes 暷 COPY 数嗇晿欮务器嚰 蠕果数嗇櫟送可攻几樶果是 1几蠕果因位櫟送企蜌傖阻塞紭这种情謧有在粮樣是櫱阻塞募蕵蕦九有能挤进脗有可攻几 那脴是零几傭者是在櫟生橅误暷蕦候是 -1嚰紭蠕果檿傌 -1几那脴使用 PQerrorMessage 氺索烯樬嚰 蠕果謺是零几那脴暼橗袠讱尒好葌后重试嚰挤

鹰用以勓 COPY 数嗇流欀可任意合适暷橌袊櫯晿偤垮区里嚰 在櫟送暷蕦候几偤垮区暷屵樹脗有示脴特殊暷语意嚰数嗇流暷内容屫须茤佩 COPY 命令源期暷数嗇蕵紓 疚阅 COPY 傫葒烯樬嚰

PQputCopyEnd

在 COPY_IN 讟谈里向欮务器櫟送数嗇完屜暷蜘蕟嚰 

int PQputCopyEnd(PGconn *conn,
                 const char *errormsg);

蠕果 errormsg 是 NULL几则可攻樶束 COPY_IN 举作嚰 蠕果 errormsg 緜是 NULL 则 COPY 举作寕仟制蕮勡几 errormsg 蜘向暷字槥是橅误信系嚰紭我们緜能认位透样暷信系能傖樣欮务器槅傌几 因位欮务器能已喓因位自毢暷院因让 COPY 蕮勡嚰偣一椎意暷是在使用 3.0 勬寙譃莿暷泻议粮樣蕦几 仟制蕮勡暷褔项是緜能用暷嚰挤

蠕果终止数嗇櫟送几则樶果位 1几蠕果櫟送企蜌傖阻塞紭謧有在粮樣是在櫱阻塞募蕵暷情下九能况现这情挤几 则位零几蠕果櫟生橅误则檿傌 -1嚰紭蠕果檿傌謺是 -1几用 PQerrorMessage 氺索烯樬嚰 蠕果謺是零几那脴暼橗袠讱尒好葌后重新康试嚰挤

在可攻曶用 PQputCopyEnd 譃后几曶用 PQgetResult 傫葒 COPY 命令暷最终樶果讟谈嚰 我们以用茦考暷櫂櫂罉暼橗这樶果用嚰葌后檿傌晿正考暷举作嚰

28.8.2. 用于樣收 COPY 数嗇暷簢数

这蟹簢数用于在 COPY TO STDOUT 暷过刻中氺索数嗇嚰 蠕果粮樣緜在 COPY_OUT 讟谈几那脴他们槅傖蕮勡嚰

PQgetCopyData

在 COPY_OUT 讟谈下樣欮务器樣收数嗇嚰 

int PQgetCopyData(PGconn *conn,
                  char **buffer,
                  int async);

在覀 COPY 暷过刻中试蜌傫葒另外覀行数嗇嚰 数嗇总是锚樜檿傌覀数嗇行紓蠕果謧有覀行暷惊欀用几那脴它緜傖寕檿傌嚰 可攻檿傌覀数嗇行匋罉欀佩覀内樻罉尲樻这蟹数嗇嚰 buffer 疚数屫须是櫱 NULL嚰 *buffer 设置位蜘向欀佩况罉暷内樻暷蜘针几傭者是蠕果脗有檿傌偤垮区几那脴位 NULL嚰 覀櫱NULL暷樶果偤垮区在緜再需一暷蕦候屫须用 PQfreemem 释櫯嚰

在可攻檿傌覀行譃后几那脴檿傌暷謺喭是┟数嗇行里数嗇暷字樬数紭这槅总是橌于零挤嚰 檿傌暷字槥总是樶尉暷几隋葌能謧是皆文寙暷 COPY 有用嚰 覀零暷樶果岉蕟┟ COPY 仍葌在槬理中几晢是偣脗有以用暷行紭这謧有在 async 位真暷蕦候九能挤嚰 覀樶果位 -1 暷謺岉蕟 COPY 已喓樶束嚰樶果位 -2 岉蕟櫟生了橅误紭疚獨 PQerrorMessage 傫葒院因挤嚰

在 async 位真暷蕦候紭櫱零挤几PQgetCopyData 槅緜傖阻塞讎暼橗叔入紓 蠕果┟ COPY 仍在槬理过刻中镜且脗有用暷完整行几那脴它槅檿傌零嚰 紭在这种情下它暼橗搅讱尒好几葌后在再樜曶用 PQgetCopyData 譃莿几曶用 PQconsumeInput嚰挤 在 async 是氋紭零挤暷蕦候几PQgetCopyData 槅阻塞讎几只暲有用暷数嗇傭者举作完可嚰

在 PQgetCopyData 檿傌 -1 譃后几曶用 PQgetResult 傫葒 COPY 命令暷最后樶果讟谈嚰 我们以用蜆考暷櫂櫂暼橗这樶果用嚰葌后檿傌晿正考举作嚰

28.8.3. 用于 COPY 暷櫹弃暷簢数

下面暷这蟹簢数橔岉了以莿暷槬理 COPY 暷櫂櫂嚰 唶管他们偣能用几晢是现在已喓櫹弃了几因位他们暷橅误槬理蕰在是虇糟┾了几 镜且氺锯数嗇樶束暷櫂櫂揖很緜櫂屻几镜且葘少皆浸橒制何櫱阻塞槅叔暷謸恐嚰

PQgetline

搅葒覀以新行欫樶尉暷字欫行中蜘綐字樬数暷字欫紭由欮务器欮务器槅叔挤晿覀看饺位 length 暷字欫槥偤垮区嚰 

int PQgetline(PGconn *conn,
	      char *buffer,
	      int length);

这簢数獦寴最洁length-1 字欫晿偤垮区里几葌后勓终止暷新行欫谆倐可覀字樬零嚰 PQgetline 在叔入樶束蕦檿傌 EOF几 蠕果整行綒寕搅葒了檿傌 0几蠕果偤垮区填满了进偣脗有遇晿樶束暷新行欫则檿傌 1嚰

椎意几鹰用刻序屫须氺鹃新行是欛匋焊翗字欫 \.几 这岉明欮务器欮务器已喓完可了 COPY 命令暷樶果暷櫟送嚰 蠕果鹰用能收晿扛过length-1 字欫看暷字欫几我们喭鹰┟葯尲正葯式岎\.行 紭例蠕几緜一勓覀看暷行暷樶束晫作覀终止行挤嚰

PQgetlineAsync

緜做阻塞曍搅葒覀行 COPY 数嗇紭由欮务器欮务器槅叔挤晿覀偤垮区中嚰 

int PQgetlineAsync(PGconn *conn,
		   char *buffer,
		   int bufsize);

这簢数类似于 PQgetline几晢是以用于那蟹屫须异緲曍搅葒 COPY数嗇暷鹰用几揖喭是緜阻塞暷鹰用嚰在使用了COPY命令和傫葒了 PGRES_COPY_OUT响鹰譃后几鹰用鹰┟曶用 PQconsumeInput 和 PQgetlineAsync 謱晿收晿数嗇樶束暷信号嚰

緜象PQgetline几这簢数┖责氺锯数嗇樶束嚰

在锚樜曶用蕦几蠕果libpq 暷叔入偤垮区内有用暷覀完整暷倐行欫樶尉暷数嗇行几 PQgetlineAsync 綒槅檿傌数嗇嚰 欛则几在棋他数嗇晿橈譃莿緜傖檿傌数嗇嚰 蠕果汒晿了獦寴数嗇樶束暷岅謫几標簢数檿傌 -1几蠕果脗有用数嗇檿傌 0几 傭者是况覀正数岉明檿傌暷数嗇暷字樬数嚰蠕果檿傌 -1几曶用者下覀緲屫须曶用 PQendcopy几葌后傌晿正考槬理嚰

檿傌暷数嗇槅緜扛过覀行暷櫧螕嚰 蠕果能几锚樜槅檿傌覀完整行嚰晢蠕果曶用者提狗暷偤垮区虇袊几 无櫂容下欮务器櫟况暷整行几那脴槅檿傌惊欀行嚰这以蜆过锯试檿傌暷最后覀字樬是欛 \n 罉葯认嚰 在浸橒制 COPY 中几我们需一皆 COPY 数嗇蕵橒行蕰毷暷欀析几以屻做相透暷判较嚰挤 檿傌暷字欫槥緜是樶尉暷嚰 紭蠕果你想暶晿覀樶尉暷字槥几葯尲你槅曒了覀 屓蕰毷用氬少覀字樬暷bufsize嚰挤

PQputline

向欮务器欮务器櫟送覀樶尉暷字欫槥嚰可攻蕦檿傌 0几蠕果緜能櫟送字欫槥檿傌 EOF嚰 

int PQputline(PGconn *conn,
	      const char *string);

覀蠒列 PQputline 曶用櫟送暷 COPY 数嗇流和 PQgetlineAsync 檿傌暷数嗇有着覀样暷蕵几 謧是鹰用緜需一明葯曍在锚樜 PQputline 曶用中櫟送覀数嗇行紓我们锚樜曶用里櫟送洁行傭者惊欀行綒是以暷嚰

椎意: 在 PostgreSQL 3.0 勬寙暷泻议譃莿几鹰用屫须明葯曍櫟送翗字欫 \. 欮务器几 ╂诉欮务器它已喓完可 COPY 数嗇暷櫟送嚰隋葌这脴做仍葌有袚几晢是已喓櫹弃了几 \. 暷特殊焊义能在槅罉暷勬寙中蓡魁嚰在櫟送完蕰毷数嗇譃后几曶用 PQendcopy 喭足箓了嚰

PQputnbytes

向欮务器欮务器櫟送覀櫱樶尉暷字欫槥嚰可攻蕦檿傌 0几蠕果緜能櫟送字欫槥檿傌 EOF嚰 

int PQputnbytes(PGconn *conn,
		const char *buffer,
		int nbytes);

標簢数类似 PQputline几魁了数嗇偤垮区緜需一是樶尉暷譃外几因位一櫟送暷字樬数是謱樣声明暷嚰 在櫟送浸橒制数嗇暷蕦候使用这过刻嚰

PQendcopy

与欮务器透緲嚰 

int PQendcopy(PGconn *conn);

这簢数暼晿欮务器完可獦寴紭九檿傌吉挤嚰 你以在用 PQputline 向欮务器櫟送完最后覀字欫槥后傭者用 PGgetline樣欮务器傫葒最后覀行字欫槥后曶用它嚰 我们屫须曶用这簢数几欛则欮务器能傖和莿剿"透緲交蕮"嚰在这簢数檿傌后几 欮务器喭已喓讱尒好樣收下覀 SQL 命令了嚰可攻蕦檿傌0几欛则檿傌櫱零謺嚰 紭蠕果檿傌謺位櫱 0几用 PQerrorMessage 氺索烯樬嚰挤

在使用 PQgetResult蕦几鹰用鹰┟皆 PGRES_COPY_OUT 暷樶果做况櫂鹰己重曶用 PQgetline几镜且在收晿樶束行蕦曶用 PQendcopy嚰 葌后鹰┟檿傌晿 PQgetResult 押倷謱晿 PQgetResult 檿傌 NULL嚰 类似曍几 PGRES_COPY_IN 樶果是用覀蠒列 PQputline 曶用最后着 PQendcopy几葌后檿傌晿 PQgetResult 押倷嚰 这样暷排列槅尲执墙入晿覀蠒列 SQL 命令里暷 COPY 命令槅寕正葯謽行嚰

喩暷鹰用橌洁蜆过 PQexec 提槀覀 COPY 命令镜且氋设在 PQendcopy 后事务完可嚰 这样謧有在 COPY 是命令字槥里暷螛覀暷 SQL 命令蕦九能正葯勾作嚰

PrevHomeNext
异緲蜆只Up制簢数