e5eCCXYR

1String row;
2            BufferedReader csvReader = new BufferedReader(new FileReader(filePath));
3            boolean hasColumnNames = false;
4            String[] columnNames = null;
5            while ((row = csvReader.readLine()) != null) {
6                String[] data = row.split(",");
7
8                if (!hasColumnNames)
9                {
10                    columnNames = data;
11                    String sql = "CREATE TABLE IF NOT EXISTS DataFrameDb " +
12                            "(IdPK INTEGER PRIMARY KEY AUTOINCREMENT";
13
14                    for (String columnName: columnNames) {
15                        sql += ",  " + columnName + "     CHAR(900)   NOT NULL ";
16                    }
17
18                    sql += ")";
19
20                    stmt.executeUpdate(sql);
21                    hasColumnNames = true;
22                    continue;
23                }
24
25                String sql = "INSERT INTO DataFrameDb (IdPK";
26
27                for (String columnName: columnNames) {
28                    sql += ", " + columnName;
29                }
30
31                sql += ") VALUES (NULL";
32
33                for (String cell: data) {
34                    sql += ", '" + cell + "'";
35                }
36
37                sql += ");";
38                stmt.executeUpdate(sql);
39
40            }
41            csvReader.close();