[exo-jcr-commits] exo-jcr SVN: r3606 - jcr/trunk/exo.jcr.component.core/src/main/java/org/exoplatform/services/jcr/impl/core.
Author: tolusha
Date: 2010-12-07 08:24:01 -0500 (Tue, 07 Dec 2010)
New Revision: 3606
Modified:
jcr/trunk/exo.jcr.component.core/src/main/java/org/exoplatform/services/jcr/impl/core/RdbmsWorkspaceInitializer.java
Log:
EXOJCR-1078: implementation RDBMS workspace initialzer
Modified:
jcr/trunk/exo.jcr.component.core/src/main/java/org/exoplatform/services/jcr/impl/core/RdbmsWorkspaceInitializer.java
===================================================================
---
jcr/trunk/exo.jcr.component.core/src/main/java/org/exoplatform/services/jcr/impl/core/RdbmsWorkspaceInitializer.java 2010-12-07
11:10:27 UTC (rev 3605)
+++
jcr/trunk/exo.jcr.component.core/src/main/java/org/exoplatform/services/jcr/impl/core/RdbmsWorkspaceInitializer.java 2010-12-07
13:24:01 UTC (rev 3606)
@@ -44,7 +44,6 @@
import java.io.ByteArrayInputStream;
import java.io.EOFException;
import java.io.File;
-import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
@@ -120,6 +119,9 @@
*/
public static final byte LONG_LEN = 3;
+ /**
+ * List of temporary files.
+ */
protected List<File> spoolFileList = new ArrayList<File>();
/**
@@ -503,10 +505,12 @@
try
{
contentReader =
- new ObjectReaderImpl(new FileInputStream(new File(restorePath, tableName +
CONTENT_FILE_SUFFIX)));
+ new ObjectReaderImpl(PrivilegedFileHelper.fileInputStream(new
File(restorePath, tableName
+ + CONTENT_FILE_SUFFIX)));
contentLenReader =
- new ObjectReaderImpl(new FileInputStream(new File(restorePath, tableName +
CONTENT_LEN_FILE_SUFFIX)));
+ new ObjectReaderImpl(PrivilegedFileHelper.fileInputStream(new
File(restorePath, tableName
+ + CONTENT_LEN_FILE_SUFFIX)));
int columnCount = contentReader.readInt();
int[] columnType = new int[columnCount];
@@ -586,7 +590,6 @@
}
else
{
- // for Postgres
insertNode.setBinaryStream(i + 1, stream, (int)len);
}
}