private String requestForModel()

in modules/persistence/src/main/java/org/apache/sandesha2/storage/jdbc/PersistentSenderBeanMgr.java [44:153]
109 lines of code
21 McCabe index (conditional complexity)

	private String requestForModel(SenderBean bean) {
		StringBuilder sql = new StringBuilder("select * from wsrm_sender");
		if (bean == null) return sql.toString();
		String op = " where ";
		String clause = bean.getSequenceID();
		if (clause != null) {
			sql.append(op);
			op = " and ";
			sql.append(" sequence_id='");
			sql.append(clause);
			sql.append("'");
		}
		clause = bean.getMessageID();
		if (clause != null) {
			sql.append(op);
			op = " and ";
			sql.append(" message_id='");
			sql.append(clause);
			sql.append("'");
		}
		clause = bean.getMessageContextRefKey();
		if (clause != null) {
			sql.append(op);
			op = " and ";
			sql.append(" message_context_ref_key='");
			sql.append(clause);
			sql.append("'");
		}
		clause = bean.getInternalSequenceID();
		if (clause != null) {
			sql.append(op);
			op = " and ";
			sql.append(" internal_sequence_id='");
			sql.append(clause);
			sql.append("'");
		}
		clause = bean.getToAddress();
		if (clause != null) {
			sql.append(op);
			op = " and ";
			sql.append(" to_address='");
			sql.append(clause);
			sql.append("'");
		}
		clause = bean.getInboundSequenceId();
		if (clause != null) {
			sql.append(op);
			op = " and ";
			sql.append(" inbound_sequence_id='");
			sql.append(clause);
			sql.append("'");
		}

		if ((bean.getFlags() & SenderBean.SEND_FLAG) != 0) {
			sql.append(op);
			op = " and ";
			sql.append(" send=");
			sql.append(bean.isSend() ? 1 : 0);
		}
		if ((bean.getFlags() & SenderBean.SEND_COUNT_FLAG) != 0) {
			sql.append(op);
			op = " and ";
			sql.append(" sent_count=");
			sql.append(bean.getSentCount());
		}
		if ((bean.getFlags() & 0x00000100) != 0) {
			sql.append(op);
			op = " and ";
			sql.append(" message_number=");
			sql.append(bean.getMessageNumber());
		}
		if ((bean.getFlags() & 0x00001000) != 0) {
			sql.append(op);
			op = " and ";
			sql.append(" resend=");
			sql.append(bean.isReSend() ? 1 : 0);
		}
		if ((bean.getFlags() & 0x00010000) != 0) {
			sql.append(op);
			op = " and ";
			sql.append(" time_to_send<=");
			sql.append(bean.getTimeToSend());
		}
		if ((bean.getFlags() & 0x00100000) != 0) {
			sql.append(op);
			op = " and ";
			sql.append(" message_type=");
			sql.append(bean.getMessageType());
		}
		if ((bean.getFlags() & 0x01000000) != 0) {
			sql.append(op);
			op = " and ";
			sql.append(" last_message=");
			sql.append(bean.isLastMessage() ? 1 : 0);
		}
		if ((bean.getFlags() & 0x10000000) != 0) {
			sql.append(op);
			op = " and ";
			sql.append(" inbound_message_number=");
			sql.append(bean.getInboundMessageNumber());
		}
		if ((bean.getFlags() & 0x00000002) != 0) {
			sql.append(op);
			op = " and ";
			sql.append(" transport_available=");
			sql.append(bean.isTransportAvailable() ? 1 : 0);
		}
		log.debug("requestForModel " + sql.toString());
		return sql.toString();
	}