pub const PGSQL_LOG_PASSWORDS: u32 = BIT_U32!(0);
fn log_pgsql(tx: &PgsqlTransaction, flags: u32, js: &mut JsonBuilder) -> Result<(), JsonError> {
+ js.open_object("pgsql")?;
js.set_uint("tx_id", tx.tx_id)?;
if let Some(request) = &tx.request {
js.set_object("request", &log_request(request, flags)?)?;
// TODO Log anomaly event instead?
js.set_bool("request", false)?;
js.set_bool("response", false)?;
+ js.close()?;
return Ok(());
}
if !tx.responses.is_empty() {
js.set_object("response", &log_response_object(tx)?)?;
}
+ js.close()?;
Ok(())
}
return TM_ECODE_FAILED;
}
- jb_open_object(jb, "pgsql");
if (!rs_pgsql_logger(txptr, thread->pgsqllog_ctx->flags, jb)) {
goto error;
}
- jb_close(jb);
OutputJsonBuilderBuffer(jb, thread->ctx);
jb_free(jb);