private List getTimescaleEntities()

in timescaledb-connector/src/integration-test/java/com/epam/deltix/timebase/connector/service/timebase/TimebaseStreamReplicationServiceTest.java [170:265]
76 lines of code
20 McCabe index (conditional complexity)

    private List<BaseTestClass> getTimescaleEntities() {
        return jdbcTemplate.query("select * from \"someStreamName\"", (rs, rowNum) -> {
            String descriptorName = rs.getString("descriptor_name");
            String firstTestClass_charValue = rs.getString("charValue");
            int firstTestClass_intValue = rs.getInt("intValue");
            long firstTestClass_longValue = rs.getLong("longValue");
            byte[] baseTestClass_byteaValues = rs.getBytes("byteaValue");
            BigDecimal baseTestClass_decimal64Value = rs.getBigDecimal("decimal64Value");
            String baseTestClass_stringValue = rs.getString("stringValue");
            String secondTestClass_enumValue = rs.getString("enumValue");
            long secondTestClass_secondLongValue = rs.getLong("secondLongValue");
            String secondTestClass_secondValue1 = rs.getString("secondValue1");
            Timestamp eventTime = rs.getTimestamp("EventTime");
            String symbol = rs.getString("Symbol");
            String innerName = rs.getString("innerState_name");
            String innerValue = rs.getString("innerState_value");

            if (descriptorName.equals("com.epam.deltix.timebase.connector.model.FirstTestClass")) {
                FirstTestClass entity = new FirstTestClass();

                if (innerName != null && innerValue != null) {
                    entity.setInnerState(new InnerTestClass(innerName, innerValue));
                }

                if (firstTestClass_charValue != null) {
                    entity.setCharValue(firstTestClass_charValue.charAt(0));
                }

                if (firstTestClass_intValue != 0) {
                    entity.setIntValue(firstTestClass_intValue);
                }

                if (firstTestClass_longValue != 0) {
                    entity.setLongValue(firstTestClass_longValue);
                }

                if (baseTestClass_byteaValues != null) {
                    entity.setByteaValue(new ByteArrayList(baseTestClass_byteaValues));
                }

                if (baseTestClass_decimal64Value != null) {
                    entity.setDecimal64Value(Decimal64.fromBigDecimal(baseTestClass_decimal64Value));
                }

                if (baseTestClass_stringValue != null) {
                    entity.setStringValue(baseTestClass_stringValue);
                }

                if (eventTime != null) {
                    entity.setTimeStampMs(eventTime.getTime());
                }

                if (symbol != null) {
                    entity.setSymbol(symbol);
                }

                return entity;
            } else {
                SecondTestClass entity = new SecondTestClass();

                if (secondTestClass_enumValue != null) {
                    entity.setEnumValue(SomeTestEnum.valueOf(secondTestClass_enumValue));
                }

                if (secondTestClass_secondLongValue != 0) {
                    entity.setSecondLongValue(secondTestClass_secondLongValue);
                }

                if (secondTestClass_secondValue1 != null) {
                    entity.setSecondValue1(secondTestClass_secondValue1);
                }

                if (baseTestClass_byteaValues != null) {
                    entity.setByteaValue(new ByteArrayList(baseTestClass_byteaValues));
                }

                if (baseTestClass_decimal64Value != null) {
                    entity.setDecimal64Value(Decimal64.fromBigDecimal(baseTestClass_decimal64Value));
                }

                if (baseTestClass_stringValue != null) {
                    entity.setStringValue(baseTestClass_stringValue);
                }

                if (eventTime != null) {
                    entity.setTimeStampMs(eventTime.getTime());
                }

                if (symbol != null) {
                    entity.setSymbol(symbol);
                }

                return entity;
            }
        });
    }