You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@marmotta.apache.org by ss...@apache.org on 2014/11/10 20:05:37 UTC
marmotta git commit: KiWi: - make sure column order in loader does
not matter
Repository: marmotta
Updated Branches:
refs/heads/develop 442763861 -> 117c6043a
KiWi:
- make sure column order in loader does not matter
Project: http://git-wip-us.apache.org/repos/asf/marmotta/repo
Commit: http://git-wip-us.apache.org/repos/asf/marmotta/commit/117c6043
Tree: http://git-wip-us.apache.org/repos/asf/marmotta/tree/117c6043
Diff: http://git-wip-us.apache.org/repos/asf/marmotta/diff/117c6043
Branch: refs/heads/develop
Commit: 117c6043ae967909b78c44ee50ee5fc914c30a3f
Parents: 4427638
Author: Sebastian Schaffert <ss...@apache.org>
Authored: Mon Nov 10 20:06:17 2014 +0100
Committer: Sebastian Schaffert <ss...@apache.org>
Committed: Mon Nov 10 20:06:17 2014 +0100
----------------------------------------------------------------------
.../org/apache/marmotta/kiwi/loader/pgsql/KiWiPostgresHandler.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/marmotta/blob/117c6043/libraries/kiwi/kiwi-loader/src/main/java/org/apache/marmotta/kiwi/loader/pgsql/KiWiPostgresHandler.java
----------------------------------------------------------------------
diff --git a/libraries/kiwi/kiwi-loader/src/main/java/org/apache/marmotta/kiwi/loader/pgsql/KiWiPostgresHandler.java b/libraries/kiwi/kiwi-loader/src/main/java/org/apache/marmotta/kiwi/loader/pgsql/KiWiPostgresHandler.java
index e3ebec9..4f63efe 100644
--- a/libraries/kiwi/kiwi-loader/src/main/java/org/apache/marmotta/kiwi/loader/pgsql/KiWiPostgresHandler.java
+++ b/libraries/kiwi/kiwi-loader/src/main/java/org/apache/marmotta/kiwi/loader/pgsql/KiWiPostgresHandler.java
@@ -52,7 +52,7 @@ public class KiWiPostgresHandler extends KiWiBatchHandler implements RDFHandler
protected void flushBacklogInternal() throws SQLException {
try {
// flush out nodes
- PGCopyOutputStream nodesOut = new PGCopyOutputStream(PGCopyUtil.getWrappedConnection(connection.getJDBCConnection()), "COPY nodes FROM STDIN (FORMAT csv)");
+ PGCopyOutputStream nodesOut = new PGCopyOutputStream(PGCopyUtil.getWrappedConnection(connection.getJDBCConnection()), "COPY nodes(id,ntype,svalue,dvalue,ivalue,tvalue,tzoffset,bvalue,ltype,lang,createdAt) FROM STDIN (FORMAT csv)");
PGCopyUtil.flushNodes(nodeBacklog, nodesOut);
nodesOut.close();