let has_hostname = hostname.is_some();

let(mut client,mut connection) =connect_raw(socket, tls, has_hostname, config).await?;

let rows = client.simple_query_raw("SHOW transaction_read_only");

pin_mut!(rows);

match next.await.transpose()?{

Some(SimpleQueryMessage::Row(row)) =>{

if row.try_get(0)? ==Some("on"){

let read_only_result = row.try_get(0)?;

if read_only_result ==Some("on")

&& config.target_session_attrs ==TargetSessionAttrs::ReadWrite

returnErr(Error::connect(io::Error::new(

io::ErrorKind::PermissionDenied,

}elseif read_only_result ==Some("off")

&& config.target_session_attrs ==TargetSessionAttrs::ReadOnly

returnErr(Error::connect(io::Error::new(

io::ErrorKind::PermissionDenied,