org.apache.activemq.artemis.jdbc.store.file

Class JDBCSequentialFileFactoryDriver

java.lang.Object

org.apache.activemq.artemis.jdbc.store.drivers.AbstractJDBCDriver

org.apache.activemq.artemis.jdbc.store.file.JDBCSequentialFileFactoryDriver

Direct Known Subclasses:

PostgresSequentialSequentialFileDriver

public class JDBCSequentialFileFactoryDriver
extends AbstractJDBCDriver

Field Summary

Fields

Modifier and Type	Field and Description
protected PreparedStatement	appendToLargeObject
protected PreparedStatement	copyFileRecord
protected PreparedStatement	createFile
protected PreparedStatement	deleteFile
protected PreparedStatement	readLargeObject
protected PreparedStatement	renameFile
protected PreparedStatement	selectFileByFileName
protected PreparedStatement	selectFileNamesByExtension

Fields inherited from class org.apache.activemq.artemis.jdbc.store.drivers.AbstractJDBCDriver

connection, sqlProvider

Method Summary

Modifier and Type	Method and Description
long	calculateReadLength(long objectLength, int bufferSpace, long readPosition)
void	copyFileData(JDBCSequentialFile fileFrom, JDBCSequentialFile fileTo) Copy the data content of FileFrom to FileTo
void	createFile(JDBCSequentialFile file) Creates a new database row representing the supplied file.
protected void	createSchema()
void	deleteFile(JDBCSequentialFile file) Deletes the associated row in the database.
void	destroy() Drop all tables and data
long	fileExists(JDBCSequentialFile file) Checks to see if a file with filename and extension exists.
long	getMaxSize()
List<String>	listFiles(String extension)
void	loadFile(JDBCSequentialFile file) Loads an existing file.
void	openFile(JDBCSequentialFile file) Opens the supplied file.
protected void	prepareStatements()
int	readFromFile(JDBCSequentialFile file, ByteBuffer bytes) Reads data from the file (at file.readPosition) into the byteBuffer.
void	renameFile(JDBCSequentialFile file, String newFileName) Updates the fileName field to the new value.
int	writeToFile(JDBCSequentialFile file, byte[] data) Persists data to this files associated database mapping.

Methods inherited from class org.apache.activemq.artemis.jdbc.store.drivers.AbstractJDBCDriver

createTable, getConnection, setConnection, setDataSource, setJdbcConnectionUrl, setJdbcDriverClass, setNetworkTimeout, setSqlProvider, start, stop

Methods inherited from class java.lang.Object

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

Field Detail

deleteFile

protected PreparedStatement deleteFile

createFile

protected PreparedStatement createFile

selectFileByFileName

protected PreparedStatement selectFileByFileName

copyFileRecord

protected PreparedStatement copyFileRecord

renameFile

protected PreparedStatement renameFile

readLargeObject

protected PreparedStatement readLargeObject

appendToLargeObject

protected PreparedStatement appendToLargeObject

selectFileNamesByExtension

protected PreparedStatement selectFileNamesByExtension

Method Detail

createSchema

protected void createSchema()
                     throws SQLException

Specified by:

createSchema in class AbstractJDBCDriver

Throws:

SQLException

prepareStatements

protected void prepareStatements()
                          throws SQLException

Specified by:

prepareStatements in class AbstractJDBCDriver

Throws:

SQLException

listFiles

public List<String> listFiles(String extension)
                       throws Exception

Throws:

Exception

openFile

public void openFile(JDBCSequentialFile file)
              throws SQLException

Opens the supplied file. If the file does not exist in the database it will create a new one.

Parameters:

file -

Throws:

SQLException

fileExists

public long fileExists(JDBCSequentialFile file)
                throws SQLException

Checks to see if a file with filename and extension exists. If so returns the ID of the file or returns -1.

Parameters:

file -

Returns:

Throws:

SQLException

loadFile

public void loadFile(JDBCSequentialFile file)
              throws SQLException

Loads an existing file.

Parameters:

file -

Throws:

SQLException

createFile

public void createFile(JDBCSequentialFile file)
                throws SQLException

Creates a new database row representing the supplied file.

Parameters:

file -

Throws:

SQLException

renameFile

public void renameFile(JDBCSequentialFile file,
                       String newFileName)
                throws SQLException

Updates the fileName field to the new value.

Parameters:

file -

newFileName -

Throws:

SQLException

deleteFile

public void deleteFile(JDBCSequentialFile file)
                throws SQLException

Deletes the associated row in the database.

Parameters:

file -

Throws:

SQLException

writeToFile

public int writeToFile(JDBCSequentialFile file,
                       byte[] data)
                throws SQLException

Persists data to this files associated database mapping.

Parameters:

file -

data -

Returns:

Throws:

SQLException

readFromFile

public int readFromFile(JDBCSequentialFile file,
                        ByteBuffer bytes)
                 throws SQLException

Reads data from the file (at file.readPosition) into the byteBuffer.

Parameters:

file -

bytes -

Returns:

Throws:

SQLException

copyFileData

public void copyFileData(JDBCSequentialFile fileFrom,
                         JDBCSequentialFile fileTo)
                  throws SQLException

Copy the data content of FileFrom to FileTo

Parameters:

fileFrom -

fileTo -

Throws:

SQLException

destroy

public void destroy()
             throws SQLException

Drop all tables and data

Overrides:

destroy in class AbstractJDBCDriver

Throws:

SQLException

calculateReadLength

public long calculateReadLength(long objectLength,
                                int bufferSpace,
                                long readPosition)

getMaxSize

public long getMaxSize()