|
|
|
|
@ -1266,7 +1266,7 @@ char* extract_tag_from_query(const char* query) {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
bool PgSQL_Protocol::generate_ok_packet(bool send, bool ready, const char* msg, int rows, const char* query, PtrSize_t* _ptr) {
|
|
|
|
|
bool PgSQL_Protocol::generate_ok_packet(bool send, bool ready, const char* msg, int rows, const char* query, char trx_state, PtrSize_t* _ptr) {
|
|
|
|
|
// to avoid memory leak
|
|
|
|
|
assert(send == true || _ptr);
|
|
|
|
|
|
|
|
|
|
@ -1298,7 +1298,7 @@ bool PgSQL_Protocol::generate_ok_packet(bool send, bool ready, const char* msg,
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (ready == true) {
|
|
|
|
|
pgpkt.write_ReadyForQuery();
|
|
|
|
|
pgpkt.write_ReadyForQuery(trx_state);
|
|
|
|
|
pgpkt.set_multi_pkt_mode(false);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|