Skip to content

Commit cd0941b

Browse files
Add PK constraint
1 parent 476ee55 commit cd0941b

File tree

1 file changed

+2
-7
lines changed

1 file changed

+2
-7
lines changed

src/main/java/be/maximl/output/SQLiteWriter.java

+2-7
Original file line numberDiff line numberDiff line change
@@ -64,17 +64,12 @@ private void setupTable(FeatureVectorFactory.FeatureVector vec) throws SQLExcept
6464
sql.append(entry.getKey());
6565
sql.append(" ");
6666

67-
if(entry.getKey().equals("meta_id")) {
68-
sql.append("PRIMARY KEY ");
69-
}
70-
7167
int type = JdbcTypeJavaClassMappings.INSTANCE.determineJdbcTypeCodeForJavaClass(entry.getValue().getClass());
7268
sql.append(JDBCType.values()[type]);
7369

74-
if (it.hasNext()) {
75-
sql.append(",");
76-
}
70+
sql.append(",");
7771
}
72+
sql.append("CONSTRAINT PK_data PRIMARY KEY (meta_id,meta_file)");
7873
sql.append(")");
7974

8075
Statement statement = connection.createStatement();

0 commit comments

Comments
 (0)