|
|
@ -269,7 +269,7 @@ pub struct NotificationResponse {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
#[derive(Debug, PartialEq, Eq)]
|
|
|
|
#[derive(Debug, PartialEq, Eq)]
|
|
|
|
pub struct CopyOutResponse {
|
|
|
|
pub struct CopyResponse {
|
|
|
|
pub identifier: u8,
|
|
|
|
pub identifier: u8,
|
|
|
|
pub length: u32,
|
|
|
|
pub length: u32,
|
|
|
|
pub column_cnt: u16,
|
|
|
|
pub column_cnt: u16,
|
|
|
@ -298,7 +298,7 @@ pub enum PgsqlBEMessage {
|
|
|
|
ParameterStatus(ParameterStatusMessage),
|
|
|
|
ParameterStatus(ParameterStatusMessage),
|
|
|
|
BackendKeyData(BackendKeyDataMessage),
|
|
|
|
BackendKeyData(BackendKeyDataMessage),
|
|
|
|
CommandComplete(RegularPacket),
|
|
|
|
CommandComplete(RegularPacket),
|
|
|
|
CopyOutResponse(CopyOutResponse),
|
|
|
|
CopyOutResponse(CopyResponse),
|
|
|
|
ConsolidatedCopyDataOut(ConsolidatedDataRowPacket),
|
|
|
|
ConsolidatedCopyDataOut(ConsolidatedDataRowPacket),
|
|
|
|
CopyDone(NoPayloadMessage),
|
|
|
|
CopyDone(NoPayloadMessage),
|
|
|
|
ReadyForQuery(ReadyForQueryMessage),
|
|
|
|
ReadyForQuery(ReadyForQueryMessage),
|
|
|
@ -1041,7 +1041,7 @@ pub fn parse_copy_out_response(i: &[u8]) -> IResult<&[u8], PgsqlBEMessage, Pgsql
|
|
|
|
let (i, _formats) = many_m_n(0, columns.to_usize(), be_u16)(i)?;
|
|
|
|
let (i, _formats) = many_m_n(0, columns.to_usize(), be_u16)(i)?;
|
|
|
|
Ok((
|
|
|
|
Ok((
|
|
|
|
i,
|
|
|
|
i,
|
|
|
|
PgsqlBEMessage::CopyOutResponse(CopyOutResponse {
|
|
|
|
PgsqlBEMessage::CopyOutResponse(CopyResponse {
|
|
|
|
identifier,
|
|
|
|
identifier,
|
|
|
|
length,
|
|
|
|
length,
|
|
|
|
column_cnt: columns,
|
|
|
|
column_cnt: columns,
|
|
|
|