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

Class PostgresSequentialSequentialFileDriver

java.lang.Object

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

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

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

public final class PostgresSequentialSequentialFileDriver
extends JDBCSequentialFileFactoryDriver

Field Summary

Fields inherited from class org.apache.activemq.artemis.jdbc.store.file.JDBCSequentialFileFactoryDriver

appendToLargeObject, appendToLargeObjectResultSetConcurrency, appendToLargeObjectResultSetType, copyFileRecord, createFile, createFileAutogeneratedKeys, createFileColumnNames, deleteFile, readLargeObject, renameFile, selectFileByFileName, selectFileNamesByExtension

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

connectionProvider, sqlProvider

Constructor Summary

Constructors

Constructor and Description
PostgresSequentialSequentialFileDriver()
PostgresSequentialSequentialFileDriver(JDBCConnectionProvider connectionProvider, SQLProvider provider)

Method Summary

Modifier and Type	Method and Description
void	createFile(JDBCSequentialFile file) Creates a new database row representing the supplied file.
void	loadFile(JDBCSequentialFile file) Loads an existing file.
protected void	prepareStatements()
int	readFromFile(JDBCSequentialFile file, ByteBuffer bytes) Reads data from the file (at file.readPosition) into the byteBuffer.
int	writeToFile(JDBCSequentialFile file, byte[] data, boolean append) Persists data to this files associated database mapping.

Methods inherited from class org.apache.activemq.artemis.jdbc.store.file.JDBCSequentialFileFactoryDriver

calculateReadLength, copyFileData, createSchema, deleteFile, destroy, fileExists, getMaxSize, listFiles, openFile, renameFile, writeToFile

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

createTable, getJdbcConnectionProvider, setJdbcConnectionProvider, setSqlProvider, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

PostgresSequentialSequentialFileDriver

public PostgresSequentialSequentialFileDriver()
                                       throws SQLException

Throws:

SQLException

PostgresSequentialSequentialFileDriver

public PostgresSequentialSequentialFileDriver(JDBCConnectionProvider connectionProvider,
                                              SQLProvider provider)

Method Detail

prepareStatements

protected void prepareStatements()

Overrides:

prepareStatements in class JDBCSequentialFileFactoryDriver

createFile

public void createFile(JDBCSequentialFile file)
                throws SQLException

Description copied from class: JDBCSequentialFileFactoryDriver

Creates a new database row representing the supplied file.

Overrides:

createFile in class JDBCSequentialFileFactoryDriver

Throws:

SQLException

loadFile

public void loadFile(JDBCSequentialFile file)
              throws SQLException

Description copied from class: JDBCSequentialFileFactoryDriver

Loads an existing file.

Overrides:

loadFile in class JDBCSequentialFileFactoryDriver

Throws:

SQLException

writeToFile

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

Description copied from class: JDBCSequentialFileFactoryDriver

Persists data to this files associated database mapping.

Overrides:

writeToFile in class JDBCSequentialFileFactoryDriver

Returns:

Throws:

SQLException

readFromFile

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

Description copied from class: JDBCSequentialFileFactoryDriver

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

Overrides:

readFromFile in class JDBCSequentialFileFactoryDriver

Returns:

Throws:

SQLException