com.orientechnologies.orient.core.storage.disk

Class OLocalPaginatedStorage

java.lang.Object

com.orientechnologies.orient.core.storage.OStorageAbstract

com.orientechnologies.orient.core.storage.impl.local.OAbstractPaginatedStorage

com.orientechnologies.orient.core.storage.disk.OLocalPaginatedStorage

All Implemented Interfaces:

OSharedContainer, OBackgroundExceptionListener, OCheckpointRequestListener, OFreezableStorageComponent, OLowDiskSpaceListener, OPageIsBrokenListener, OIdentifiableStorage, OStorage, OBackupable

public class OLocalPaginatedStorage
extends OAbstractPaginatedStorage

Since:

28.03.13

Author:

Andrey Lomakin (a.lomakin-at-orientdb.com)

Nested Class Summary

Nested classes/interfaces inherited from interface com.orientechnologies.orient.core.storage.OStorage

OStorage.LOCKING_STRATEGY, OStorage.STATUS

Field Summary

Fields inherited from class com.orientechnologies.orient.core.storage.impl.local.OAbstractPaginatedStorage

atomicOperationsManager, atomicOperationsTable, DATABASE_INSTANCE_ID, fuzzyCheckpointExecutor, interruptionManager, readCache, sbTreeCollectionManager, writeAheadLog, writeCache

Fields inherited from class com.orientechnologies.orient.core.storage.OStorageAbstract

componentsFactory, configuration, mode, name, sharedContainer, stateLock, status, storageThreadGroup, url

Fields inherited from interface com.orientechnologies.orient.core.storage.OStorage

CLUSTER_DEFAULT_NAME

Constructor Summary

Constructors

Constructor and Description
OLocalPaginatedStorage(String name, String filePath, String mode, int id, OReadCache readCache, OClosableLinkedContainer<Long,OFileClassic> files, long walMaxSegSize)

Method Summary

Modifier and Type	Method and Description
protected void	addFileToDirectory(String name, InputStream stream, File directory)
List<String>	backup(OutputStream out, Map<String,Object> options, Callable<Object> callable, OCommandOutputListener iOutput, int compressionLevel, int bufferSize) Executes a backup of the database.
protected long	checkIfStorageDirty()
protected void	clearStorageDirty()
protected OLogSequenceNumber	copyWALToIncrementalBackup(ZipOutputStream zipOutputStream, long startSegment)
void	create(OContextConfiguration contextConfiguration)
protected OWriteAheadLog	createWalFromIBUFiles(File directory, OContextConfiguration contextConfiguration, Locale locale)
protected File	createWalTempDirectory()
static void	deleteFilesFromDisc(String name, int maxRetries, int waitTime, String databaseDirectory)
boolean	exists()
static boolean	exists(Path path)
Path	getStoragePath()
String	getType() Returns the storage's type.
String	getURL()
protected void	initConfiguration(OAtomicOperation atomicOperation, OContextConfiguration contextConfiguration)
protected void	initWalAndDiskCache(OContextConfiguration contextConfiguration)
protected boolean	isDirty()
protected boolean	isWriteAllowedDuringIncrementalBackup()
protected void	makeStorageDirty()
protected String	normalizeName(String name)
protected void	postCloseSteps(boolean onDelete, boolean jvmError, long lastTxId)
protected void	postCloseStepsAfterLock(Map<String,Object> params)
protected void	postDeleteSteps()
protected Map<String,Object>	preCloseSteps()
protected void	preCreateSteps()
void	restore(InputStream in, Map<String,Object> options, Callable<Object> callable, OCommandOutputListener iListener) Executes a restore of a database backup.

Methods inherited from class com.orientechnologies.orient.core.storage.impl.local.OAbstractPaginatedStorage

acquireReadLock, acquireWriteLock, addCluster, addCluster, addIndexEngine, browseCluster, callIndexEngine, ceilingPhysicalPositions, check, checkDatabaseInstanceId, checkForRecordValidity, checkOpenness, checkReadOnlyConditions, cleanOutRecord, clearIndex, clearProperties, close, closeClusters, closeIndexes, command, commit, commit, commitPreAllocated, completeGatheringPerformanceStatisticForCurrentThread, count, count, count, count, countRecords, createRecord, delete, deleteIndexEngine, deleteRecord, dropCluster, executeCommand, extractEngineAPIVersion, fireConfigurationUpdateNotifications, floorPhysicalPositions, freeze, fullIncrementalBackup, generateDatabaseInstanceId, getAtomicOperationsManager, getClusterDataRange, getClusterEncryption, getClusterIdByName, getClusterNameById, getClusterNames, getClusterNextPosition, getClusterRecordConflictStrategy, getClusterRecordConflictStrategy, getClusterRecordsSizeById, getClusterRecordsSizeByName, getClusters, getConfiguration, getCreatedAtVersion, getDefaultClusterId, getFullCheckpointCount, getId, getIdGen, getIndexCursor, getIndexDescCursor, getIndexEngine, getIndexFirstKey, getIndexKeyCursor, getIndexLastKey, getIndexSize, getIndexValue, getLastCloseTime, getLastClusterPosition, getLSN, getMode, getPerformanceStatisticManager, getPhysicalClusterNameById, getReadCache, getRecordMetadata, getRecordScanned, getRecordStatus, getRecoverListener, getRidsGroupedByCluster, getSBtreeCollectionManager, getSessionCount, getSize, getStorageTransaction, getWALInstance, getWriteCache, handleJVMError, hasIndexRangeQuerySupport, hideRecord, higherPhysicalPositions, incOnOpen, incrementalBackup, indexContainsKey, interruptExecution, isClosed, isDeleted, isRemote, isSystemCluster, iterateIndexEntriesBetween, iterateIndexEntriesMajor, iterateIndexEntriesMinor, loadExternalIndexEngine, loadIndexEngine, logAndPrepareForRethrow, logAndPrepareForRethrow, logAndPrepareForRethrow, lowDiskSpace, lowerPhysicalPositions, makeFullCheckpoint, makeFuzzyCheckpoint, onException, open, open, open, openClusters, openIndexes, pageIsBroken, pauseConfigurationUpdateNotifications, postCreateSteps, preallocateRids, putIndexValue, putRidIndexEntry, readDatabaseInstanceId, readRecord, readRecordIfVersionIsNotLatest, recordsChangedAfterLSN, recordsChangedRecently, recyclePosition, registerRecoverListener, release, releaseReadLock, releaseWriteLock, reload, removeKeyFromIndex, removeProperty, removeRidIndexEntry, renameCluster, requestCheckpoint, restoreAtomicUnit, restoreFrom, restoreFromIncrementalBackup, restoreFullIncrementalBackup, rollback, rollback, serializeDeltaContent, setCharset, setClusterAttribute, setClusterAttribute, setClusterSelection, setClusterStatus, setConflictStrategy, setDateFormat, setDateTimeFormat, setDefaultClusterId, setIndexMgrRecordId, setLocaleCountry, setLocaleLanguage, setMinimumClusters, setProperty, setRecordSerializer, setSchemaRecordId, setStorageConfigurationUpdateListener, setTimeZone, setValidation, startGatheringPerformanceStatisticForCurrentThread, supportIncremental, synch, truncateCluster, tryToDeleteTreeRidBag, underDistributedStorage, unregisterRecoverListener, updateIndexEntry, updateRecord, validatedPutIndexValue, wereDataRestoredAfterOpen, wereNonTxOperationsPerformedInPreviousOpen

Methods inherited from class com.orientechnologies.orient.core.storage.OStorageAbstract

close, dropCluster, existsResource, getComponentsFactory, getName, getResource, getStatus, getUnderlying, getVersion, isAssigningClusterIds, isDistributed, removeResource, shutdown, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.orient.core.storage.OStorage

close, dropCluster, getComponentsFactory, getName, getStatus, getUnderlying, getVersion, isAssigningClusterIds, isDistributed, shutdown

Methods inherited from interface com.orientechnologies.common.concur.resource.OSharedContainer

existsResource, getResource, removeResource

Constructor Detail

OLocalPaginatedStorage

public OLocalPaginatedStorage(String name,
                              String filePath,
                              String mode,
                              int id,
                              OReadCache readCache,
                              OClosableLinkedContainer<Long,OFileClassic> files,
                              long walMaxSegSize)

Method Detail

create

public void create(OContextConfiguration contextConfiguration)

Specified by:

create in interface OStorage

Overrides:

create in class OAbstractPaginatedStorage

normalizeName

protected final String normalizeName(String name)

Overrides:

normalizeName in class OStorageAbstract

exists

public final boolean exists()

getURL

public String getURL()

Specified by:

getURL in interface OStorage

Overrides:

getURL in class OStorageAbstract

getStoragePath

public final Path getStoragePath()

getType

public String getType()

Description copied from interface: OStorage

Returns the storage's type.

backup

public final List<String> backup(OutputStream out,
                                 Map<String,Object> options,
                                 Callable<Object> callable,
                                 OCommandOutputListener iOutput,
                                 int compressionLevel,
                                 int bufferSize)

Description copied from interface: OBackupable

Executes a backup of the database. During the backup the database will be frozen in read-only mode.

Parameters:

out - OutputStream used to write the backup content. Use a FileOutputStream to make the backup persistent on disk

options - Backup options as Map object

callable - Callback to execute when the database is locked

iOutput - Listener called for backup messages

compressionLevel - ZIP Compression level between 1 (the minimum) and 9 (maximum). The bigger is the compression, the smaller will be the final backup content, but will consume more CPU and time to execute

bufferSize - Buffer size in bytes, the bigger is the buffer, the more efficient will be the compression

See Also:

ODatabaseExport

restore

public final void restore(InputStream in,
                          Map<String,Object> options,
                          Callable<Object> callable,
                          OCommandOutputListener iListener)

Description copied from interface: OBackupable

Executes a restore of a database backup. During the restore the database will be frozen in read-only mode.

Parameters:

in - InputStream used to read the backup content. Use a FileInputStream to read a backup on a disk

options - Backup options as Map object

callable - Callback to execute when the database is locked

iListener - Listener called for backup messages

See Also:

ODatabaseImport

copyWALToIncrementalBackup

protected OLogSequenceNumber copyWALToIncrementalBackup(ZipOutputStream zipOutputStream,
                                                        long startSegment)
                                                 throws IOException

Specified by:

copyWALToIncrementalBackup in class OAbstractPaginatedStorage

Throws:

IOException

createWalTempDirectory

protected File createWalTempDirectory()

Specified by:

createWalTempDirectory in class OAbstractPaginatedStorage

addFileToDirectory

protected void addFileToDirectory(String name,
                                  InputStream stream,
                                  File directory)
                           throws IOException

Specified by:

addFileToDirectory in class OAbstractPaginatedStorage

Throws:

IOException

createWalFromIBUFiles

protected OWriteAheadLog createWalFromIBUFiles(File directory,
                                               OContextConfiguration contextConfiguration,
                                               Locale locale)
                                        throws IOException

Specified by:

createWalFromIBUFiles in class OAbstractPaginatedStorage

Throws:

IOException

checkIfStorageDirty

protected long checkIfStorageDirty()
                            throws IOException

Overrides:

checkIfStorageDirty in class OAbstractPaginatedStorage

Throws:

IOException

initConfiguration

protected void initConfiguration(OAtomicOperation atomicOperation,
                                 OContextConfiguration contextConfiguration)
                          throws IOException

Overrides:

initConfiguration in class OAbstractPaginatedStorage

Throws:

IOException

preCloseSteps

protected Map<String,Object> preCloseSteps()

Overrides:

preCloseSteps in class OAbstractPaginatedStorage

postCloseStepsAfterLock

protected void postCloseStepsAfterLock(Map<String,Object> params)

Overrides:

postCloseStepsAfterLock in class OAbstractPaginatedStorage

preCreateSteps

protected void preCreateSteps()
                       throws IOException

Overrides:

preCreateSteps in class OAbstractPaginatedStorage

Throws:

IOException

postCloseSteps

protected void postCloseSteps(boolean onDelete,
                              boolean jvmError,
                              long lastTxId)
                       throws IOException

Specified by:

postCloseSteps in class OAbstractPaginatedStorage

Throws:

IOException

postDeleteSteps

protected void postDeleteSteps()

Overrides:

postDeleteSteps in class OAbstractPaginatedStorage

deleteFilesFromDisc

public static void deleteFilesFromDisc(String name,
                                       int maxRetries,
                                       int waitTime,
                                       String databaseDirectory)

makeStorageDirty

protected void makeStorageDirty()
                         throws IOException

Overrides:

makeStorageDirty in class OAbstractPaginatedStorage

Throws:

IOException

clearStorageDirty

protected void clearStorageDirty()
                          throws IOException

Overrides:

clearStorageDirty in class OAbstractPaginatedStorage

Throws:

IOException

isDirty

protected boolean isDirty()

Overrides:

isDirty in class OAbstractPaginatedStorage

isWriteAllowedDuringIncrementalBackup

protected boolean isWriteAllowedDuringIncrementalBackup()

Specified by:

isWriteAllowedDuringIncrementalBackup in class OAbstractPaginatedStorage

initWalAndDiskCache

protected void initWalAndDiskCache(OContextConfiguration contextConfiguration)
                            throws IOException,
                                   InterruptedException

Specified by:

initWalAndDiskCache in class OAbstractPaginatedStorage

Throws:

IOException

InterruptedException

exists

public static boolean exists(Path path)