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 <[email protected]> Authored: Mon Nov 10 20:06:17 2014 +0100 Committer: Sebastian Schaffert <[email protected]> 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();
