Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package ch.epfl.dias.store.row;
- import java.io.IOException;
- import java.nio.file.Files;
- import java.nio.file.Path;
- import java.nio.file.Paths;
- import ch.epfl.dias.store.DataType;
- import ch.epfl.dias.store.Store;
- public class RowStore extends Store {
- private String filename;
- private DataType[] schema;
- private String delimiter;
- private Object IOException;
- public RowStore(DataType[] schema, String filename, String delimiter) {
- // TODO: Implement
- this.delimiter = delimiter;
- this.schema = schema;
- this.filename = filename;
- }
- @Override
- public void load() throws IOException {
- byte[] source = Files.readAllBytes(Paths.get(this.filename));
- String[] rowsOfFile = source.toString().split("\n");
- Object[] tupleElement;
- for(String row : rowsOfFile){
- for(String field : row.split(this.delimiter)){
- int j = 0;
- try{
- switch(this.schema[j]){
- case DOUBLE:
- tupleElement[j] = {Double.parseDouble(field)};
- j++;
- break;
- case INT:
- tupleElement = new Object[] {tupleElement, Integer.parseInt(field)};
- j++;
- break;
- case STRING:
- //tupleElement = new Object[] {tupleElement, field};
- j++;
- break;
- case BOOLEAN:
- //tupleElement = new Object[] {tupleElement, Boolean.parseBoolean(field)};
- j++;
- }
- } catch (Exception e){
- System.out.println(e.getMessage());
- throw new IOException();}
- }// for field
- } // for Row
- System.out.println(tupleElement.toString());
- }
- @Override
- public DBTuple getRow(int rownumber) {
- // TODO: Implement
- return null;
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement