com.northconcepts.datapipeline.filesystem.ftp

Class FtpFileSystem

java.lang.Object

com.northconcepts.datapipeline.core.DataObject

com.northconcepts.datapipeline.core.Endpoint

com.northconcepts.datapipeline.internal.lang.FileSystem

com.northconcepts.datapipeline.filesystem.ftp.FtpFileSystem

public class FtpFileSystem
extends FileSystem

Class for accessing the FTP file system.

Field Summary

Fields inherited from class com.northconcepts.datapipeline.core.Endpoint

BUFFER_SIZE, captureElapsedTime, DEFAULT_READ_BUFFER_SIZE

Fields inherited from class com.northconcepts.datapipeline.core.DataObject

id, log, name, TIMESTAMP_FORMAT

Constructor Summary

Constructors

Constructor and Description
FtpFileSystem() Connects to the FTP server on localhost (port 21) as an anonymous user.
FtpFileSystem(String hostName, int port, String userName, String password) Connects to the specified FTP server.

Method Summary

Modifier and Type	Method and Description
void	close() Closes the connection from an FTP server.
DataConnectionMode	getDataConnectionMode()
FileTransferMode	getFileTransferMode()
FileTransferType	getFileTransferType()
boolean	isRemoteVerification()
List<FTPFile>	listFolder(String folderName) Returns the contents of the folder.
List<FTPFile>	listRootFolder() Returns the contents of the root folder.
void	open() Opens a connection to an FTP server.
InputStream	readFile(String fileName) Reads the specified file in the root folder.
InputStream	readFile(String folderName, String fileName) Reads a file in the specified folder.
FtpFileSystem	setDataConnectionMode(DataConnectionMode dataConnectionMode) See DataConnectionMode
FtpFileSystem	setFileTransferMode(FileTransferMode fileTransferMode) See FileTransferMode
FtpFileSystem	setFileTransferType(FileTransferType fileTransferType) See FileTransferType
FtpFileSystem	setRemoteVerification(boolean remoteVerification)
OutputStream	writeFile(String fileName) Writes a file to the root folder.
OutputStream	writeFile(String folderName, String fileName) Writes a file to the specified folder.

Methods inherited from class com.northconcepts.datapipeline.core.Endpoint

addElapsedtime, addExceptionProperties, assertClosed, assertNotOpened, assertOpened, finalize, getClosedOn, getDescription, getElapsedTime, getElapsedTimeAsString, getNestedEndpoint, getOpenedOn, getOpenElapsedTime, getOpenElapsedTimeAsString, getRootEndpoint, getSelfTime, getSelfTimeAsString, getState, isCaptureElapsedTime, isClosed, isOpen, setCaptureElapsedTime, setDescription, toString

Methods inherited from class com.northconcepts.datapipeline.core.DataObject

exception, exception, exception, getId, getName, resetID

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

FtpFileSystem

public FtpFileSystem()

Connects to the FTP server on localhost (port 21) as an anonymous user.

FtpFileSystem

public FtpFileSystem(String hostName,
                     int port,
                     String userName,
                     String password)

Connects to the specified FTP server.

Parameters:

hostName - hostname of the FTP server

port - the port to connect to

userName - name of the user

password - password of the user

Method Detail

open

public void open()
          throws DataException

Opens a connection to an FTP server.

Overrides:

open in class Endpoint

Throws:

DataException

close

public void close()
           throws DataException

Closes the connection from an FTP server.

Overrides:

close in class Endpoint

Throws:

DataException

readFile

public InputStream readFile(String folderName,
                            String fileName)
                     throws Throwable

Reads a file in the specified folder. To specify a nested folder use "/" as separator.
Example:

• readFile("folderOne", "fileName") - reads the file in folderOne which is under the root folder
• readFile("folderOne/folderTwo", "fileName") - reads the file in folderTwo which is under folderOne
• readFile("/folderOne/folderTwo", "fileName") - reads the file in folderTwo which is under folderOne

Returns:

an InputStream or null

Throws:

Throwable

readFile

public InputStream readFile(String fileName)
                     throws Throwable

Reads the specified file in the root folder.

Returns:

an InputStream or null

Throws:

Throwable

listFolder

public List<FTPFile> listFolder(String folderName)
                         throws Throwable

Returns the contents of the folder. To specify a nested folder use "/" as separator.
Example:

• listFolder("folderOne") - reads the contents of folderOne which is under the root folder
• listFolder("folderOne/folderTwo") - reads the contents of folderTwo which is under folderOne
• listFolder("/folderOne/folderTwo") - reads the contents of folderTwo which is under folderOne

Throws:

Throwable

listRootFolder

public List<FTPFile> listRootFolder()
                             throws Throwable

Returns the contents of the root folder.

Throws:

Throwable

writeFile

public OutputStream writeFile(String fileName)
                       throws Throwable

Writes a file to the root folder. If there is a file with the same name, it is overwritten.

Parameters:

fileName - the name of the file

Throws:

Throwable

writeFile

public OutputStream writeFile(String folderName,
                              String fileName)
                       throws Throwable

Writes a file to the specified folder. If there is a file with the same name, it is overwritten.

Parameters:

folderName - the folder name

fileName - the name of the file

Throws:

Throwable

getDataConnectionMode

public DataConnectionMode getDataConnectionMode()

setDataConnectionMode

public FtpFileSystem setDataConnectionMode(DataConnectionMode dataConnectionMode)

See DataConnectionMode

getFileTransferType

public FileTransferType getFileTransferType()

setFileTransferType

public FtpFileSystem setFileTransferType(FileTransferType fileTransferType)

See FileTransferType

getFileTransferMode

public FileTransferMode getFileTransferMode()

setFileTransferMode

public FtpFileSystem setFileTransferMode(FileTransferMode fileTransferMode)

See FileTransferMode

Parameters:

fileTransferMode -

isRemoteVerification

public boolean isRemoteVerification()

setRemoteVerification

public FtpFileSystem setRemoteVerification(boolean remoteVerification)