import org.apache.commons.vfs.FileContent; //导入依赖的package包/类
/** Load the resource specified by the given path.  If monitor is true then
    the ResourceLoader implementation will monitor the resource and call the
    ResourceRecipient each time the resource is modified.
    
    @param path The path
    @param handler The ResourceRecipient callback
    @param monitor True to monitor the resource
    @throws ResourceException
*/

public void loadResource(String path, ResourceRecipient handler, 
boolean monitor) throws ResourceException{
    InputStream in = null;
    try{
        FileSystemManager fsManager = getFileSystemManager();
        log.debug("Resource path: " + path);
        FileObject file = fsManager.resolveFile(path);
        if(!file.exists()){
            throw new FileNotFoundException("File not found: " + file);
        }
        
        FileContent content = file.getContent();
        in = content.getInputStream();
        handler.load(in);
        
        if(monitor){
            ResourceVFSMonitor resourceMonitor = new ResourceVFSMonitor(
                file, getDelay(), handler);
            getMonitors().add(resourceMonitor);
            resourceMonitor.startMonitor();
        }
    } catch(Exception e){
        e.printStackTrace();
        throw new ResourceException(e);
    } finally {
        IOUtilities.close(in);
    }
}
 

import org.apache.commons.vfs.FileContent; //导入依赖的package包/类
/**
 * Read the data from the given file into a byte array and return
 * the array.
 *
 * @param file The file
 * @return The byte array
 * @throws IOException
 */

public static byte[] readData(FileObject file) throws IOException {
    BufferedInputStream in = null;
    ByteArrayOutputStream out = null;

    try {
        FileContent content = file.getContent();
        in = new BufferedInputStream(content.getInputStream());
        out = new ByteArrayOutputStream();

        int c = -1;
        while ((c = in.read()) != -1) {
            out.write(c);
        }

        return out.toByteArray();
    } finally {
        IOUtilities.close(in);
        IOUtilities.close(out);
    }
}
 

import org.apache.commons.vfs.FileContent; //导入依赖的package包/类
public FileContentInfo create(FileContent fileContent) throws FileSystemException
{
    WebdavFileObject file = (WebdavFileObject) (FileObjectUtils
        .getAbstractFileObject(fileContent.getFile()));

    String contentType = null;
    String contentEncoding = null;

    DavPropertyNameSet nameSet = new DavPropertyNameSet();
    nameSet.add(DavPropertyName.GETCONTENTTYPE);
    DavPropertySet propertySet = file.getProperties((URLFileName) file.getName(), nameSet, true);

    DavProperty property = propertySet.get(DavPropertyName.GETCONTENTTYPE);
    if (property != null)
    {
        contentType = (String) property.getValue();
    }
    property = propertySet.get(WebdavFileObject.RESPONSE_CHARSET);
    if (property != null)
    {
        contentEncoding = (String) property.getValue();
    }

    return new DefaultFileContentInfo(contentType, contentEncoding);
}
 

import org.apache.commons.vfs.FileContent; //导入依赖的package包/类
/**
 * Finds the provider to use to create a filesystem from a given file.
 */
public String getScheme(final FileObject file) throws FileSystemException
{
    // Check the file's mime type for a match
    final FileContent content = file.getContent();
    // final String mimeType = (String) content.getAttribute("content-type");
    final String mimeType = content.getContentInfo().getContentType();
    if (mimeType != null)
    {
        return (String) mimeTypeMap.get(mimeType);
    }

    // Check the file's extension for a match
    final String extension = file.getName().getExtension();
    return (String) extensionMap.get(extension);
}
 

import org.apache.commons.vfs.FileContent; //导入依赖的package包/类
/**
 * <p>
 * byte형으로 파일의 내용을 읽어온다.
 * <p>
 * @param file
 *        <code>FileObject</code>
 * @return 파일 내용
 * @throws IOException
 */
public static byte[] getContent(final FileObject file) throws IOException {
    final FileContent content = file.getContent();
    final int size = (int) content.getSize();
    final byte[] buf = new byte[size];

    final InputStream in = content.getInputStream();
    try {
        int read = 0;
        for (int pos = 0; pos < size && read >= 0; pos += read) {
            read = in.read(buf, pos, size - pos);
        }
    } finally {
        in.close();
    }

    return buf;
}
 

import org.apache.commons.vfs.FileContent; //导入依赖的package包/类
/**
 * Write the byte array to the given file.
 *
 * @param file The file to write to
 * @param data The data array
 * @throws IOException
 */

public static void writeData(FileObject file, byte[] data)
        throws IOException {
    OutputStream out = null;
    try {
        FileContent content = file.getContent();
        out = content.getOutputStream();
        out.write(data);
    } finally {
        close(out);
    }
}
 

import org.apache.commons.vfs.FileContent; //导入依赖的package包/类
protected boolean setPropertyValue(Element root, Element propertyEl) {
  LogFactory.getLog(getClass()).debug(String.format("[%s].set('%s')", object.getName(), propertyEl.asXML()));

  if (!ALL_PROPERTIES.contains(propertyEl.getName())) {
    final String nameSpace = propertyEl.getNamespaceURI();
    final String attributeName = getFQName(nameSpace, propertyEl.getName());
    try {
      FileContent objectContent = object.getContent();
      final String command = propertyEl.getParent().getParent().getName();
      if (TAG_PROP_SET.equals(command)) {
        StringWriter propertyValueWriter = new StringWriter();
        propertyEl.write(propertyValueWriter);
        propertyValueWriter.close();
        objectContent.setAttribute(attributeName, propertyValueWriter.getBuffer().toString());
      } else if (TAG_PROP_REMOVE.equals(command)) {
        objectContent.setAttribute(attributeName, null);
      }
      root.addElement(propertyEl.getQName());
      return true;
    } catch (IOException e) {
      LogFactory.getLog(getClass()).error(String.format("can't store attribute property '%s' = '%s'",
                                                        attributeName,
                                                        propertyEl.asXML()), e);
    }
  }
  return false;
}
 

import org.apache.commons.vfs.FileContent; //导入依赖的package包/类
public static OutputStream getOutputStream(FileObject fileObject, boolean append) throws IOException
{
    FileObject parent = fileObject.getParent();
    if (parent!=null)
    {
        if (!parent.exists())
        {
            throw new IOException(Messages.getString("KettleVFS.Exception.ParentDirectoryDoesNotExist", getFilename(parent)));
        }
    }
    try
    {
     fileObject.createFile();
     FileContent content = fileObject.getContent();
     return content.getOutputStream(append);
    }
    catch(FileSystemException e)
    {
    	// Perhaps if it's a local file, we can retry using the standard
    	// File object.  This is because on Windows there is a bug in VFS.
    	//
    	if (fileObject instanceof LocalFile) 
    	{
    		try
    		{
     		String filename = getFilename(fileObject);
     		return new FileOutputStream(new File(filename), append);
    		}
    		catch(Exception e2)
    		{
    			throw e; // throw the original exception: hide the retry.
    		}
    	}
    	else
    	{
    		throw e;
    	}
    }
}
 

import org.apache.commons.vfs.FileContent; //导入依赖的package包/类
public static OutputStream getOutputStream(FileObject fileObject, boolean append) throws IOException
{
    FileObject parent = fileObject.getParent();
    if (parent!=null)
    {
        if (!parent.exists())
        {
            throw new IOException(BaseMessages.getString(PKG, "KettleVFS.Exception.ParentDirectoryDoesNotExist", getFilename(parent)));
        }
    }
    try
    {
     fileObject.createFile();
     FileContent content = fileObject.getContent();
     return content.getOutputStream(append);
    }
    catch(FileSystemException e)
    {
    	// Perhaps if it's a local file, we can retry using the standard
    	// File object.  This is because on Windows there is a bug in VFS.
    	//
    	if (fileObject instanceof LocalFile) 
    	{
    		try
    		{
     		String filename = getFilename(fileObject);
     		return new FileOutputStream(new File(filename), append);
    		}
    		catch(Exception e2)
    		{
    			throw e; // throw the original exception: hide the retry.
    		}
    	}
    	else
    	{
    		throw e;
    	}
    }
}
 

import org.apache.commons.vfs.FileContent; //导入依赖的package包/类
public JarURLConnectionImpl(JarFileObject file, FileContent content)
    throws MalformedURLException, FileSystemException
{
    //This is because JarURLConnection SUCKS!!
    super(new URL(HACK_URL));

    this.url = file.getURL();
    this.content = content;
    this.parentURL = file.getURL();
    this.entryName = file.getName().getPath();
    this.file = file;
}
 

import org.apache.commons.vfs.FileContent; //导入依赖的package包/类
public FileContentInfo create(FileContent fileContent) throws FileSystemException
{
    HttpFileObject httpFile = (HttpFileObject) (FileObjectUtils
        .getAbstractFileObject(fileContent.getFile()));

    String contentType = null;
    String contentEncoding = null;

    Header header = httpFile.getHeadMethod().getResponseHeader("content-type");
    if (header != null)
    {
        HeaderElement[] element;
        try
        {
            element = header.getValues();
        }
        catch (HttpException e)
        {
            throw new FileSystemException(e);
        }
        if (element != null && element.length > 0)
        {
            contentType = element[0].getName();
        }
    }

    contentEncoding = httpFile.getHeadMethod().getResponseCharSet();

    return new DefaultFileContentInfo(contentType, contentEncoding);
}
 

import org.apache.commons.vfs.FileContent; //导入依赖的package包/类
/**
 * Returns the file's content.
 * @return the FileContent for this FileObject.
 * @throws FileSystemException if an error occurs.
 */
public FileContent getContent() throws FileSystemException
{
    synchronized (fs)
    {
        attach();
        if (content == null)
        {
            content = doCreateFileContent();
        }
        return content;
    }
}
 

import org.apache.commons.vfs.FileContent; //导入依赖的package包/类
public FileContentInfo create(FileContent fileContent)
{
    String contentType = null;

    String name = fileContent.getFile().getName().getBaseName();
    if (name != null)
    {
        FileNameMap fileNameMap = URLConnection.getFileNameMap();
        contentType = fileNameMap.getContentTypeFor(name);
    }

    return new DefaultFileContentInfo(contentType, null);
}
 

import org.apache.commons.vfs.FileContent; //导入依赖的package包/类
public FileContent getContent() throws FileSystemException
    {
    synchronized (this)
    {
            return super.getContent();
    }
}
 

import org.apache.commons.vfs.FileContent; //导入依赖的package包/类
/**
 * Asserts that the content of a file is the same as expected. Checks the
 * length reported by getSize() is correct, then reads the content as
 * a byte stream and compares the result with the expected content.
 * Assumes files are encoded using UTF-8.
 */
protected void assertSameContent(final String expected,
                                 final FileObject file)
    throws Exception
{
    // Check the file exists, and is a file
    assertTrue(file.exists());
    assertSame(FileType.FILE, file.getType());

    // Get file content as a binary stream
    final byte[] expectedBin = expected.getBytes("utf-8");

    // Check lengths
    final FileContent content = file.getContent();
    assertEquals("same content length", expectedBin.length, content.getSize());

    // Read content into byte array
    final InputStream instr = content.getInputStream();
    final ByteArrayOutputStream outstr;
    try
    {
        outstr = new ByteArrayOutputStream(expectedBin.length);
        final byte[] buffer = new byte[256];
        int nread = 0;
        while (nread >= 0)
        {
            outstr.write(buffer, 0, nread);
            nread = instr.read(buffer);
        }
    }
    finally
    {
        instr.close();
    }

    // Compare
    assertTrue("same binary content", Arrays.equals(expectedBin, outstr.toByteArray()));
}
 

import org.apache.commons.vfs.FileContent; //导入依赖的package包/类
@Test
public void testReadOnlyGetContentInputStream() throws IOException {
    createRealFile();

    final FileContent content = readOnlyFile.getContent();
    try {
        content.getInputStream().close();
    } finally {
        content.close();
    }
}
 

import org.apache.commons.vfs.FileContent; //导入依赖的package包/类
@Test
public void testReadOnlyGetContentOutputStream() throws IOException {
    createRealFile();

    final FileContent content = readOnlyFile.getContent();
    try {
        content.getOutputStream();
        fail("Expected exception");
    } catch (FileSystemException x) {
    } finally {
        content.close();
    }
}
 

import org.apache.commons.vfs.FileContent; //导入依赖的package包/类
@Test
public void testReadOnlyGetContentRandomInputStream() throws IOException {
    createRealFile();

    final FileContent content = readOnlyFile.getContent();
    try {
        content.getRandomAccessContent(RandomAccessMode.READ).close();
    } finally {
        content.close();
    }
}
 

import org.apache.commons.vfs.FileContent; //导入依赖的package包/类
@Test
public void testReadOnlyGetContentRandomOutputStream() throws IOException {
    createRealFile();

    final FileContent content = readOnlyFile.getContent();
    try {
        content.getRandomAccessContent(RandomAccessMode.READWRITE).close();
        fail("Expected exception");
    } catch (FileSystemException x) {
    } finally {
        content.close();
    }
}
 

import org.apache.commons.vfs.FileContent; //导入依赖的package包/类
@Test
public void testReadWriteGetContentInputStream() throws IOException {
    createRealFile();

    final FileContent content = readWriteFile.getContent();
    try {
        content.getInputStream().close();
    } finally {
        content.close();
    }
}