package com.megatim.fdxcommons.tools.database.queries.metadata;

import com.megatim.fdxcommons.model.integration.TableDefinition;
import com.megatim.fdxcommons.tools.database.exceptions.BadDataValueException;
import com.megatim.fdxcommons.tools.database.exceptions.ColumnNotFoundException;
import com.megatim.fdxcommons.tools.database.exceptions.LocalDateTimeValueParseError;
import com.megatim.fdxcommons.tools.utils.FdxParsedDataAction;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ForkJoinPool;

/**
 *
 * @author Gabuntu
 */
public class FdxParsedData {

    private final List<LinkedHashMap<String, Object>> sourceData;
    private final TableDefinition tableDefinition;

    public FdxParsedData(List<LinkedHashMap<String, Object>> sourceData, TableDefinition tableDefinition) {
        this.sourceData = sourceData;
        this.tableDefinition = tableDefinition;
    }

    public List<Map<String, Object>> data() throws BadDataValueException, LocalDateTimeValueParseError, ColumnNotFoundException {
        ForkJoinPool pool = new ForkJoinPool();
        return pool.invoke(new FdxParsedDataAction(sourceData, tableDefinition));
    }

}