org.apache.derbyTesting.functionTests.util.corruptio

Class CorruptBaseStorageFactory

java.lang.Object

org.apache.derbyTesting.functionTests.util.corruptio.CorruptBaseStorageFactory

All Implemented Interfaces:

org.apache.derby.io.StorageFactory, org.apache.derby.io.WritableStorageFactory

Direct Known Subclasses:

CorruptDiskStorageFactory

abstract class CorruptBaseStorageFactory
extends java.lang.Object
implements org.apache.derby.io.WritableStorageFactory

This class provides a proxy base implementation of the WritableStorageFactory interface to instrument I/O operations for testing purposes. Some methods in this class adds support for corrupting the I/O operation sent by the engine before invoking the real storage factory underneath. By deault all the calls will go to the real storage factory defined by the concrete class, unless corruption is enabled through CorruptibleIo instance.

See Also:

CorruptibleIo, WritableStorageFactory

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.derby.io.WritableStorageFactory	realStorageFactory

Fields inherited from interface org.apache.derby.io.StorageFactory

VERSION_NUMBER

Constructor Summary

Constructors

Constructor and Description
CorruptBaseStorageFactory() Most of the initialization is done in the init method.

Method Summary

Modifier and Type	Method and Description
org.apache.derby.io.StorageFile	createTemporaryFile(java.lang.String prefix, java.lang.String suffix) Create and returns a temporary file in temporary file system of database.
java.lang.String	getCanonicalName() Get the canonical name of the database.
(package private) abstract org.apache.derby.io.WritableStorageFactory	getRealStorageFactory() get the real storage factory
char	getSeparator() Get the pathname separator character used by the StorageFile implementation.
int	getStorageFactoryVersion()
org.apache.derby.io.StorageFile	getTempDir() Get the abstract name of the directory that holds temporary files.
void	init(java.lang.String home, java.lang.String databaseName, java.lang.String tempDirName, java.lang.String uniqueName) Classes implementing the StorageFactory interface must have a null constructor.
boolean	isFast() This method is used to determine whether the storage is fast (RAM based) or slow (disk based).
boolean	isReadOnlyDatabase()
org.apache.derby.io.StorageFile	newStorageFile(org.apache.derby.io.StorageFile directoryName, java.lang.String fileName) Construct a StorageFile from a directory and file name.
org.apache.derby.io.StorageFile	newStorageFile(java.lang.String path) Construct a StorageFile from a path name.
org.apache.derby.io.StorageFile	newStorageFile(java.lang.String directoryName, java.lang.String fileName) Construct a StorageFile from a directory and file name.
void	setCanonicalName(java.lang.String name) Set the canonicalName.
void	shutdown()
boolean	supportsRandomAccess() Determine whether the storage supports random access.
boolean	supportsWriteSync() This method tests whether the "rws" and "rwd" modes are implemented.
void	sync(java.io.OutputStream stream, boolean metaData) Force the data of an output stream out to the underlying storage.

Methods inherited from class java.lang.Object

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

Field Detail

realStorageFactory

protected org.apache.derby.io.WritableStorageFactory realStorageFactory

Constructor Detail

CorruptBaseStorageFactory

CorruptBaseStorageFactory()

Most of the initialization is done in the init method.

Method Detail

init

public void init(java.lang.String home,
                 java.lang.String databaseName,
                 java.lang.String tempDirName,
                 java.lang.String uniqueName)
          throws java.io.IOException

Classes implementing the StorageFactory interface must have a null constructor. This method is called when the database is booted up to initialize the class. It should perform all actions necessary to start the basic storage, such as creating a temporary file directory. The init method will be called once, before any other method is called, and will not be called again.

Specified by:

init in interface org.apache.derby.io.StorageFactory

Parameters:

home - The name of the directory containing the database. It comes from the system.home system property. It may be null. A storage factory may decide to ignore this parameter. (For instance the classpath storage factory ignores it.)

databaseName - The name of the database (directory). All relative pathnames are relative to this directory. If null then the storage factory will only be used to deal with the directory containing the databases.

tempDirName - The name of the temporary file directory set in properties. If null then a default directory should be used. Each database should get a separate temporary file directory within this one to avoid collisions.

uniqueName - A unique name that can be used to create the temporary file directory for this database.

Throws:

java.io.IOException - on an error (unexpected).

shutdown

public void shutdown()

Specified by:

shutdown in interface org.apache.derby.io.StorageFactory

getCanonicalName

public java.lang.String getCanonicalName()
                                  throws java.io.IOException

Get the canonical name of the database. This is a name that uniquely identifies it. It is system dependent. The normal, disk based implementation uses method java.io.File.getCanonicalPath on the directory holding the database to construct the canonical name.

Specified by:

getCanonicalName in interface org.apache.derby.io.StorageFactory

Returns:

the canonical name

Throws:

java.io.IOException - if an IO error occurred during the construction of the name.

setCanonicalName

public void setCanonicalName(java.lang.String name)

Set the canonicalName. May need adjustment due to DERBY-5096

Specified by:

setCanonicalName in interface org.apache.derby.io.StorageFactory

Parameters:

name - uniquely identifiable name for this database

newStorageFile

public org.apache.derby.io.StorageFile newStorageFile(java.lang.String path)

Construct a StorageFile from a path name.

Specified by:

newStorageFile in interface org.apache.derby.io.StorageFactory

Parameters:

path - The path name of the file

Returns:

A corresponding StorageFile object

newStorageFile

public org.apache.derby.io.StorageFile newStorageFile(java.lang.String directoryName,
                                                      java.lang.String fileName)

Construct a StorageFile from a directory and file name.

Specified by:

newStorageFile in interface org.apache.derby.io.StorageFactory

Parameters:

directoryName - The directory part of the path name.

fileName - The name of the file within the directory.

Returns:

A corresponding StorageFile object

newStorageFile

public org.apache.derby.io.StorageFile newStorageFile(org.apache.derby.io.StorageFile directoryName,
                                                      java.lang.String fileName)

Construct a StorageFile from a directory and file name.

Specified by:

newStorageFile in interface org.apache.derby.io.StorageFactory

Parameters:

directoryName - The directory part of the path name.

fileName - The name of the file within the directory.

Returns:

A corresponding StorageFile object

getSeparator

public char getSeparator()

Get the pathname separator character used by the StorageFile implementation.

Specified by:

getSeparator in interface org.apache.derby.io.StorageFactory

Returns:

the pathname separator character. (Normally '/' or '\').

getTempDir

public org.apache.derby.io.StorageFile getTempDir()

Get the abstract name of the directory that holds temporary files.

Specified by:

getTempDir in interface org.apache.derby.io.StorageFactory

Returns:

a directory name

isFast

public boolean isFast()

This method is used to determine whether the storage is fast (RAM based) or slow (disk based). It may be used by the database engine to determine the default size of the page cache.

Specified by:

isFast in interface org.apache.derby.io.StorageFactory

Returns:

true if the storage is fast, false if it is slow.

isReadOnlyDatabase

public boolean isReadOnlyDatabase()

Specified by:

isReadOnlyDatabase in interface org.apache.derby.io.StorageFactory

supportsRandomAccess

public boolean supportsRandomAccess()

Determine whether the storage supports random access. If random access is not supported then it will only be accessed using InputStreams and OutputStreams (if the database is writable).

Specified by:

supportsRandomAccess in interface org.apache.derby.io.StorageFactory

Returns:

true if the storage supports random access, false if it is writable.

getStorageFactoryVersion

public int getStorageFactoryVersion()

Specified by:

getStorageFactoryVersion in interface org.apache.derby.io.StorageFactory

sync

public void sync(java.io.OutputStream stream,
                 boolean metaData)
          throws java.io.IOException,
                 java.io.SyncFailedException

Force the data of an output stream out to the underlying storage. That is, ensure that it has been made persistent. If the database is to be transient, that is, if the database does not survive a restart, then the sync method implementation need not do anything.

Specified by:

sync in interface org.apache.derby.io.WritableStorageFactory

Parameters:

stream - The stream to be synchronized.

metaData - If true then this method must force both changes to the file's contents and metadata to be written to storage; if false, it need only force file content changes to be written. The implementation is allowed to ignore this parameter and always force out metadata changes.

Throws:

java.io.IOException - if an I/O error occurs.

java.io.SyncFailedException - Thrown when the buffers cannot be flushed, or because the system cannot guarantee that all the buffers have been synchronized with physical media.

supportsWriteSync

public boolean supportsWriteSync()

This method tests whether the "rws" and "rwd" modes are implemented. If the "rws" and "rwd" modes are supported then the database engine will conclude that the write methods of "rws" mode StorageRandomAccessFiles are slow but the sync method is fast and optimize accordingly.

Specified by:

supportsWriteSync in interface org.apache.derby.io.WritableStorageFactory

Returns:

true if an StIRandomAccess file opened with "rws" or "rwd" modes immediately writes data to the underlying storage, false if not.

getRealStorageFactory

abstract org.apache.derby.io.WritableStorageFactory getRealStorageFactory()

get the real storage factory

createTemporaryFile

public org.apache.derby.io.StorageFile createTemporaryFile(java.lang.String prefix,
                                                           java.lang.String suffix)
                                                    throws java.io.IOException

Create and returns a temporary file in temporary file system of database.

Specified by:

createTemporaryFile in interface org.apache.derby.io.StorageFactory

Parameters:

prefix - String to prefix the random name generator. It can be null

suffix - String to suffix the random name generator. ".tmp" will be used if null.

Returns:

StorageFile

Throws:

java.io.IOException