jOOQ-InsertPersonMessageProcessor-txAware.java

public class InsertPersonMessageProcessor implements MessageProcessor {
    
    @Autowired
    private TxAwareDataSourceConnectionProvider connProvider;
    
    @Override
    public MuleEvent process(MuleEvent event) throws MuleException {
        
        Map<String, Object> personInfo = event.getFlowVariable("personInfo");
        
        Connection connection;
        try {
            connection = connProvider.getConnection();
            
            DSLContext dslContext = DSL.using(connection, SQLDialect.DEFAULT);
            dslContext.insertInto(DSL.table("People"))
                        .columns(DSL.field("firstname"), DSL.field("lastname"), DSL.field("age"))
                        .values(personInfo.get("firstname"), personInfo.get("lastname"), personInfo.get("age"))
                        .execute();
            
        } catch (Exception e) {
            // handle exceptions accordingly
            throw new RuntimeException(e);
        }
        
        return event;
    }
}