view src/main/java/nl/cwi/monetdb/embedded/resultset/QueryResultSetFloatColumn.java @ 55:9108ad9e5287 embedded

Be careful with copying and pasting code!
author Pedro Ferreira <pedro.ferreira@monetdbsolutions.com>
date Mon, 21 Nov 2016 16:18:28 +0100 (2016-11-21)
parents 6617eaf808cb
children 7c3a84de7605
line wrap: on
line source
/*
 * This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0.  If a copy of the MPL was not distributed with this
 * file, You can obtain one at http://mozilla.org/MPL/2.0/.
 *
 * Copyright 2016 MonetDB B.V.
 */

package nl.cwi.monetdb.embedded.resultset;

import nl.cwi.monetdb.embedded.env.MonetDBEmbeddedException;

/**
 * A MonetDB column converted to an array of Java float values.
 *
 * @author <a href="mailto:pedro.ferreira@monetdbsolutions.com">Pedro Ferreira</a>
 */
public class QueryResultSetFloatColumn extends AbstractQueryResultSetColumn<float[]> {

    /**
     * MonetDB's float null constant.
     */
    private static float FloatNullConstant;

    /**
     * Gets MonetDB's float null constant
     *
     * @return MonetDB's float null constant
     */
    public static float GetFloatNullConstant() { return FloatNullConstant; }

    /**
     * Array with the retrieved values.
     */
    private final float[] values;

    protected QueryResultSetFloatColumn(String columnType, long tablePointer, int resultSetIndex, String columnName,
                                        int columnDigits, int columnScale, int numberOfRows) {
        super(columnType, tablePointer, resultSetIndex, columnName, columnDigits, columnScale, numberOfRows);
        if(!this.getMapping().getJavaClass().equals(Float.class)) {
            throw new ClassCastException("The parameter must be of float type!!");
        }
        this.values = new float[numberOfRows];
    }

    @Override
    protected void fetchMoreData(int startIndex, int endIndex) throws MonetDBEmbeddedException {
        float[] values = this.fetchValuesInternal(this.tablePointer, this.resultSetIndex, startIndex, endIndex);
        System.arraycopy(values, 0, this.values, startIndex, values.length);
    }

    @Override
    protected float[] storeNewDataAndGetResult(int startIndex, int numberOfRowsToRetrieve) {
        float[] result = new float[numberOfRowsToRetrieve];
        System.arraycopy(this.values, startIndex, result, 0, numberOfRowsToRetrieve);
        return result;
    }

    @Override
    protected boolean[] checkIfIndexesAreNullImplementation(float[] values, boolean[] res) throws MonetDBEmbeddedException {
        for(int i = 0 ; i < values.length ; i++) {
            res[i] = (values[i] == FloatNullConstant);
        }
        return res;
    }

    @Override
    protected Float[] mapValuesToObjectArrayImplementation(float[] values) throws MonetDBEmbeddedException {
        Float[] res = new Float[values.length];
        for(int i = 0 ; i < values.length ; i++) {
            res[i] = (values[i] == FloatNullConstant) ? null : values[i];
        }
        return res;
    }

    /**
     * Internal implementation to fetch values from the column.
     */
    private native float[] fetchValuesInternal(long tablePointer, int resultSetIndex, int startIndex, int endIndex)
            throws MonetDBEmbeddedException;
}