Populate SQLite tables from CSV

src/main/java/uk/ac/ed/pguaglia/real/db/Database.java

@@ -59,20 +59,19 @@ public class Database {
 		String create = String.format("CREATE TABLE %s (%s)", name, String.join(",", attributes));
 		var stmt = conn.createStatement();
 		stmt.execute(create);
-		Reader in = new FileReader(datafile);
+		Reader in = new FileReader(data);
 		CSVParser csv = CSVFormat.RFC4180.parse(in);
-		String insert = "INSERT INTO " + name + "VALUES ";
-		String values = "";
+		String insert = "INSERT INTO " + name + " VALUES ";
 		for (CSVRecord r : csv.getRecords()) {
 			int n = r.size();
 			if (attributes.size() != n) {
 				throw new DatabaseException("Record size does not match");
 			}
-			String[] rec = new String[n];
+			var rec = new ArrayList<String>();
 			for (int i=0; i < n; i++) {
-				rec[i] = r.get(i);
+				rec.add(r.get(i));
 			}
-			records.add(rec);
+			stmt.execute(insert + "(" + String.join(",", rec) + ")");
 		}
 	}
 

src/main/java/uk/ac/ed/pguaglia/real/runtime/CommandLineApp.java

@@ -256,6 +256,10 @@ public final class CommandLineApp {
 		} catch (IOException e) {
 			e.printStackTrace();
 			System.exit(-1);
+		} catch (SQLException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+			System.exit(-1);
 		}
 
 		LineReader lineReader = null;
@@ -383,7 +387,7 @@ public final class CommandLineApp {
 						save(db, line, false);
 						continue mainLoop;
 					case ADD:
-						addTable(line, db.schema());
+						addTable(line, db);
 						continue mainLoop;
 					}
 					continue mainLoop;
@@ -507,7 +511,7 @@ public final class CommandLineApp {
 		return false;
 	}
 
-	private static void addTable(String line, Schema sch) {
+	private static void addTable(String line, Database db) {
 		Pattern p = Pattern.compile("\\w+\\(\\w+(,\\w+)*\\):.+");
 		Matcher m = p.matcher(line.replaceAll("\\s", ""));
 		if (m.matches() == false) {
@@ -526,7 +530,8 @@ public final class CommandLineApp {
 			attributes.add(attr.strip());
 		}
 		try {
-			sch.addTable(tableName, attributes, new File(filename));
+			db.schema().addTable(tableName, attributes, new File(filename));
+			db.addTable(tableName, attributes, new File(filename));
 		} catch (Exception e) {
 			System.err.println("ERROR: " + e.getMessage());
 		}