public RowData toInternal()

in flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/JdbcRowConverter.java [76:90]

• 14 lines of code
• 4 McCabe index (conditional complexity)

    public RowData toInternal(ResultSet resultSet, String em) throws SQLException {
        GenericRowData genericRowData = new GenericRowData(fieldLogicalTypes.length);

        for (int pos = 0; pos < fieldLogicalTypes.length; pos++) {
            try {
                Object field = resultSet.getObject(pos + 1);
                genericRowData.setField(pos, toInternalConverters[pos].deserialize(field));
            } catch (Exception e) {
                if ("strict".equalsIgnoreCase(em)) {
                    throw e;
                }
            }
        }
        return genericRowData;
    }