openCMIS: Setting content stream for the document

CMIS provides following method to set the content stream for the document.

Document setContentStream(ContentStream contentStream, boolean overwrite)

Sets a new content stream for the document and refreshes this object afterwards. If the repository created a new version, this new document is returned. Otherwise the current document is returned.

ObjectId setContentStream(ContentStream contentStream, boolean overwrite, boolean refresh)

Sets a new content stream for the document. If the repository created a new version, the object ID of this new version is returned. Otherwise the object ID of the current document is returned.

In both the methods, if the 'overwrite' parameter is set to false and the document already has content, then the repository throws a CmisContentAlreadyExistsException.

if the 'refresh' argument is set to true, then the cmis object is refreshed after the new content has been set.

In both the methods, the stream in 'contentStream' argument is consumed but not closed by this method.

You can set the content stream at the time of creating the document (or) you can set the content stream after the document is created. i already explained the first case in my previous post, 'Creating documents', lets see how to set the content stream to alreadye xisting document.

Following application creates a file "sampleDoc.json" under root folder, once the document is created, it creates content stream from the input file "C:\\Users\\test.json" and set the document "sampleDoc.json".

In summary following application perform 3 steps.

a. Create a document "sampleDoc.json".

                  Map<String, String> properties = new HashMap<>();

                  properties.put("cmis:objectTypeId", "cmis:document");

                  properties.put("cmis:name", "sampleDoc.json");

                  Folder rootFolder = session.getRootFolder();

                  Document document = rootFolder.createDocument(properties, null, null);

b. Set the content stream to the document

                  ObjectFactoryImpl objectFactory = new ObjectFactoryImpl();

                  File file = new File(localFilePath);

                  try (InputStream stream = new FileInputStream(file)) {

                           String mimetype = Files.probeContentType(file.toPath());

                           ContentStream contentStream = objectFactory.createContentStream(file.getName(), file.length(), mimetype,

                                             stream);

                           document.setContentStream(contentStream, true, true);

                  } catch (IOException e) {

                           // TODO Auto-generated catch block

                           e.printStackTrace();

                  }

                 

c. Read the contents of the document.

                  ContentStream contentStream = document.getContentStream();

                  try (InputStream inputStream = contentStream.getStream();

                                    BufferedInputStream bufferedInputStream = new BufferedInputStream(inputStream)) {

                           byte[] buffer = new byte[65535];

                           int bytesRead = -1;

                           while ((bytesRead = bufferedInputStream.read(buffer)) != -1) {

                                    String str = new String(buffer, 0, bytesRead);

                                    System.out.print(str);

                           }

                  } catch (IOException e) {

                           System.out.println("Error occurred while processing the file content");

                           System.out.println(e.getMessage());

                  }

Following is the complete working application.

TestCmis.java

package com.sample.util;

import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.nio.file.Files;
import java.util.HashMap;
import java.util.Map;

import org.apache.chemistry.opencmis.client.api.Document;
import org.apache.chemistry.opencmis.client.api.Folder;
import org.apache.chemistry.opencmis.client.api.Session;
import org.apache.chemistry.opencmis.client.api.SessionFactory;
import org.apache.chemistry.opencmis.client.runtime.SessionFactoryImpl;
import org.apache.chemistry.opencmis.client.runtime.repository.ObjectFactoryImpl;
import org.apache.chemistry.opencmis.commons.SessionParameter;
import org.apache.chemistry.opencmis.commons.data.ContentStream;
import org.apache.chemistry.opencmis.commons.enums.BindingType;

public class TestCmis {

 private static String serverURL = "http://localhost:8080/chemistry-opencmis-server-inmemory-1.1.0/browser";
 private static String repositoryId = "A1";
 private static String localFilePath = "C:\\Users\\test.json";

 private static Session getSession() {
  Map<String, String> parameters = new HashMap<>();
  parameters.put(SessionParameter.BINDING_TYPE, BindingType.BROWSER.value());

  parameters.put(SessionParameter.USER, "");
  parameters.put(SessionParameter.PASSWORD, "");

  parameters.put(SessionParameter.REPOSITORY_ID, repositoryId);
  parameters.put(SessionParameter.BROWSER_URL, serverURL);

  SessionFactory sessionFactory = SessionFactoryImpl.newInstance();
  return sessionFactory.createSession(parameters);
 }

 private static void setTheContentStream(Document document) {
  /* Creating content stream */
  ObjectFactoryImpl objectFactory = new ObjectFactoryImpl();
  File file = new File(localFilePath);

  try (InputStream stream = new FileInputStream(file)) {
   String mimetype = Files.probeContentType(file.toPath());
   ContentStream contentStream = objectFactory.createContentStream(file.getName(), file.length(), mimetype,
     stream);
   document.setContentStream(contentStream, true, true);
  } catch (IOException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
 }

 private static void readTheContentsOfTheDocument(Document document) {
  ContentStream contentStream = document.getContentStream();

  try (InputStream inputStream = contentStream.getStream();
    BufferedInputStream bufferedInputStream = new BufferedInputStream(inputStream)) {

   byte[] buffer = new byte[65535];
   int bytesRead = -1;

   while ((bytesRead = bufferedInputStream.read(buffer)) != -1) {
    String str = new String(buffer, 0, bytesRead);
    System.out.print(str);
   }
  } catch (IOException e) {
   System.out.println("Error occurred while processing the file content");
   System.out.println(e.getMessage());
  }

 }

 public static void main(String args[]) throws IOException {

  Session session = getSession();

  /* Create the document 'sampleDoc.json' */
  Map<String, String> properties = new HashMap<>();
  properties.put("cmis:objectTypeId", "cmis:document");
  properties.put("cmis:name", "sampleDoc.json");

  Folder rootFolder = session.getRootFolder();

  Document document = rootFolder.createDocument(properties, null, null);

  setTheContentStream(document);
  readTheContentsOfTheDocument(document);

 }

}

Previous                                                 Next                                                 Home