Package com.gigaspaces.internal.server.space.tiered_storage

Interface InternalRDBMS

public interface InternalRDBMS

Method Summary

Modifier and Type	Method	Description
void	addIndex(String typeName, boolean isUnique, String indexName)
void	closeTransactionConnection(long transactionId)
void	createTable(ITypeDesc typeDesc)
void	deleteData()
void	dropTable(ITypeDesc typeDesc)
List<TieredStorageBulkOperationResult>	executeBulk(List<TieredStorageBulkOperationRequest> operationRequests, ServerTransaction transaction)
long	getDiskSize()
IEntryHolder	getEntryByUID(String typeName, String uid)
long	getFreeSpaceSize()
SpaceTypeManager	getTypeManager()
boolean	initialize(String spaceName, String fullMemberName, SpaceTypeManager typeManager, boolean isBackup)
void	initialLoad(Context context, SpaceEngine engine, InitialLoadInfo initialLoadInfo)
void	insertEntry(Context context, IEntryHolder entryHolder)	Inserts a new entry to the internalDiskStorage
boolean	isKnownType(String name)
ISAdapterIterator<IEntryHolder>	makeEntriesIter(String typeName, ITemplateHolder templateHolder)
void	persistType(ITypeDesc typeDesc)
int	removeEntries(String typeName, ITemplateHolder templateHolder, int maxEntries)	Removes at most maxEntries entries of typeName that match templateHolder directly in the underlying store, without materializing them in the engine.
boolean	removeEntry(Context context, IEntryHolder entryHolder)	Removes an entry from the internalDiskStorage
void	setLogger(String fullMemberName)
void	shutDown()
void	unpersistType(ITypeDesc typeDesc)
void	updateEntry(Context context, IEntryHolder updatedEntry)	updates an entry.

Method Details

initialize

boolean initialize(String spaceName,
 String fullMemberName,
 SpaceTypeManager typeManager,
 boolean isBackup)
            throws SAException

Parameters:

spaceName -

fullMemberName -

typeManager -

Returns:

true if RDBMS is not empty on startup

Throws:

SAException

setLogger

void setLogger(String fullMemberName)

getDiskSize

long getDiskSize()
          throws SAException,
IOException

Throws:

SAException

IOException

getFreeSpaceSize

long getFreeSpaceSize()
               throws SAException,
IOException

Throws:

SAException

IOException

createTable

void createTable(ITypeDesc typeDesc)
          throws SAException

Throws:

SAException

addIndex

void addIndex(String typeName,
 boolean isUnique,
 String indexName)
       throws SAException

Throws:

SAException

dropTable

void dropTable(ITypeDesc typeDesc)
        throws SAException

Throws:

SAException

insertEntry

void insertEntry(Context context,
 IEntryHolder entryHolder)
          throws SAException

Inserts a new entry to the internalDiskStorage

Parameters:

entryHolder - entry to insert

Throws:

SAException

updateEntry

void updateEntry(Context context,
 IEntryHolder updatedEntry)
          throws SAException

updates an entry.

Parameters:

updatedEntry - new content, same UID and class

Throws:

SAException

removeEntry

boolean removeEntry(Context context,
 IEntryHolder entryHolder)
             throws SAException

Removes an entry from the internalDiskStorage

Parameters:

entryHolder - entry to remove

Throws:

SAException

removeEntries

int removeEntries(String typeName,
 ITemplateHolder templateHolder,
 int maxEntries)
           throws SAException

Removes at most maxEntries entries of typeName that match templateHolder directly in the underlying store, without materializing them in the engine. Backs the clear-table / JDBC DELETE pushdown (see SpaceEngine.tryPushdownClearTable): only the count is needed, the matched entries are not returned.

Matching: an empty / no-condition template matches the whole table; otherwise only the entries matching the template's criteria are removed. maxEntries == Integer.MAX_VALUE means unbounded (remove every match); a bounded clear (PIC-6174) removes an arbitrary maxEntries-sized subset of the matches - no ordering is guaranteed.

The implementation owns the per-type disk-entry bookkeeping for this path - the engine does not adjust the disk-entry counter here, so the implementation must keep it consistent with the rows actually removed.

Parameters:

typeName - the concrete type whose entries are removed (never the root type)

templateHolder - the match template; an empty template matches the whole table

maxEntries - the maximum number of entries to remove; Integer.MAX_VALUE for unbounded

Returns:

the number of entries removed; never negative, saturated at Integer.MAX_VALUE when more than that many rows were removed

Throws:

SAException - if the removal fails

getEntryByUID

IEntryHolder getEntryByUID(String typeName,
 String uid)
                    throws SAException

Throws:

SAException

makeEntriesIter

ISAdapterIterator<IEntryHolder> makeEntriesIter(String typeName,
 ITemplateHolder templateHolder)
                                         throws SAException

Throws:

SAException

isKnownType

boolean isKnownType(String name)

shutDown

void shutDown()

deleteData

void deleteData()
         throws SAException

Throws:

SAException

persistType

void persistType(ITypeDesc typeDesc)
          throws SAException

Throws:

SAException

unpersistType

void unpersistType(ITypeDesc typeDesc)
            throws SAException

Throws:

SAException

initialLoad

void initialLoad(Context context,
 SpaceEngine engine,
 InitialLoadInfo initialLoadInfo)
          throws SAException

Throws:

SAException

getTypeManager

SpaceTypeManager getTypeManager()

executeBulk

List<TieredStorageBulkOperationResult> executeBulk(List<TieredStorageBulkOperationRequest> operationRequests,
 ServerTransaction transaction)
                                            throws SQLException,
ClassNotFoundException

Throws:

SQLException

ClassNotFoundException

closeTransactionConnection

void closeTransactionConnection(long transactionId)
                         throws SQLException

Throws:

SQLException