org.hsqldb.persist

public Class LobManager

Author: Fred Toussi (fredt@users dot sourceforge.net)
Since: 1.9.0
Version: 2.7.3

Nested and Inner Type Summary

Modifier and Type	Class and Description
private static interface	LobManager.ALLOC_BLOCKS
private static interface	LobManager.ALLOC_PART
private static interface	LobManager.DELETE_BLOCKS
private static interface	LobManager.DIVIDE_BLOCK
private static interface	LobManager.GET_LOB_PART
private static interface	LobManager.LOB_IDS
pack-priv static interface	LobManager.LOBS
private static interface	LobManager.UPDATE_LENGTH
private static interface	LobManager.UPDATE_USAGE

Field Summary

Modifier and Type	Field and Description
pack-priv byte[]	byteBuffer
pack-priv boolean	compressLobs
pack-priv Statement	createLob
pack-priv Statement	createLobPartCall
private static final String	createLobPartCallSQL
private static final String	createLobSQL
pack-priv Statement	createPart
private static final String	createPartSQL
pack-priv Statement	createSingleLobPartCall
private static final String	createSingleLobPartCallSQL
pack-priv boolean	cryptLobs
pack-priv Database	database
pack-priv byte[]	dataBuffer
pack-priv Deflater	deflater
pack-priv Statement	deleteLobCall
private static final String	deleteLobCallSQL
pack-priv Statement	deleteLobPartCall
private static final String	deleteLobPartCallSQL
private static final String	deleteUnusedCallSQL
pack-priv Statement	deleteUnusedLobs
pack-priv Statement	divideLobPartCall
private static final String	divideLobPartCallSQL
private static final String	existsBlocksSQL
pack-priv Statement	getLastPart
private static final String	getLastPartSQL
pack-priv Statement	getLob
pack-priv Statement	getLobCount
private static final String	getLobCountSQL
private static final String	getLobPartSQL
private static final String	getLobSQL
pack-priv Statement	getLobUseLimit
private static final String	getLobUseLimitSQL
pack-priv Statement	getNextLobId
private static final String	getNextLobIdSQL
private static final String	getPartsSQL
pack-priv Statement	getSpanningBlocks
pack-priv Statement	getSpanningParts
pack-priv Inflater	inflater
private static final String	initialiseBlocksSQL
pack-priv int	largeLobBlockSize
pack-priv int	lobBlockSize
pack-priv LobStore	lobStore
pack-priv ReadWriteLock	lock
pack-priv Statement	mergeUnusedSpace
private static final String	mergeUnusedSpaceSQL
pack-priv static final String	resourceFileName
pack-priv volatile boolean	storeModified
pack-priv Session	sysLobSession
pack-priv int	totalBlockLimitCount
pack-priv Statement	updateLobLength
private static final String	updateLobLengthSQL
pack-priv Statement	updateLobUsage
private static final String	updateLobUsageSQL
pack-priv long	usageChanged
pack-priv Lock	writeLock

Constructor Summary

Access	Constructor and Description
public	LobManager(Database database)

Method Summary

Modifier and Type	Method and Description
public Result	adjustUsageCount(Session session, long lobID, int delta) Executes in user session.
public void	close()
public int	compare(long lobId, byte[] b)
public int	compare(BlobData a, BlobData b)
public int	compare(Collation collation, long lobId, String b)
public int	compare(Collation collation, ClobData a, ClobData b)
private int	compareBytesCompressed(long aID, long bID)
private int	compareBytesNormal(long aID, long bID)
private int	compareTextCompressed(Collation collation, long aID, long bID)
private int	compareTextNormal(Collation collation, long aID, long bID)
public void	compileStatements()
private void	copyBlockSet(int[][] source, int[][] target)
public long	createBlob(Session session, long length)
private Result	createBlockAddresses(long lobID, int offset, int count)
public long	createClob(Session session, long length)
public Result	createDuplicateLob(long lobID)
public Result	createDuplicateLob(long lobID, long newLength)
private Result	createFullBlockAddresses(long lobID, int offset, int count)
private Result	createPart(long lobID, long partOffset, int dataLength, int byteLength, int blockOffset, int blockCount)
public void	createSchema()
private int	deflate(byte[] data, int offset, int length)
private void	deleteBlockAddresses(long lobID, int offset, int limit)
public Result	deleteLob(long lobID)
public Result	deleteUnusedLobs()
private void	divideBlockAddresses(long lobID, int offset)
public BlobData	getBlob(long lobID)
private int	getBlockAddress(int[][] blockAddresses, int blockOffset)
private int[][]	getBlockAddresses(long lobID, int offset, int limit)
public Result	getBytes(long lobID, long offset, int length)
private Result	getBytesCompressed(long lobID, long offset, int length)
private Result	getBytesNormal(long lobID, long offset, int length)
public Result	getChars(long lobID, long offset, int length)
public ClobData	getClob(long lobID)
private long[]	getLastPart(long lobID)
public Result	getLength(long lobID)
public Result	getLob(long lobID, long offset, long length) Used for SUBSTRING
public int	getLobCount()
private Object[]	getLobHeader(long lobID)
public LobStore	getLobStore()
private Long	getNewLobID()
private Result	getPartBytesCompressedInBuffer(long lobID, long[] part)
private long[][]	getParts(long lobID, long offset, long limit)
public Result	getTruncateLength(long lobID)
public long	getUsageChanged()
private void	inflate(byte[] data, int length)
private void	initialiseLobSpace()
public void	lock()
public void	open()
public Result	setBytes(long lobID, long offset, byte[] dataBytes, int dataLength) returns new LOB length
private Result	setBytesBA(long lobID, long offset, byte[] dataBytes, int dataLength)
private Result	setBytesBACompressed(long lobID, long offset, byte[] dataBytes, int dataLength)
private Result	setBytesBACompressedPart(long lobID, long offset, byte[] dataBytes, int dataLength) Only for loading parts of the same lob, not for overwriting parts of existing lob
private Result	setBytesBANormal(long lobID, long offset, byte[] dataBytes, int dataLength)
public Result	setBytesForNewBlob(long lobID, InputStream inputStream, long length) for new blob only blob length is set to inputStream size (not given length which could be incorrect)
private Result	setBytesIS(long lobID, InputStream inputStream, long offset, long length)
private Result	setBytesISCompressed(long lobID, InputStream inputStream, long baseOffset, long length)
private Result	setBytesISNormal(long lobID, InputStream inputStream, long length)
public Result	setChars(long lobID, long offset, char[] chars, int dataLength) returns new full length of Clob
public Result	setCharsForNewClob(long lobID, InputStream inputStream, long length)
private Result	setLength(long lobID, long length)
public void	setUsageChanged()
public void	synch()
public Result	truncate(long lobID, long offset)
public void	unlock()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

byteBuffer	back to summary
pack-priv byte[] byteBuffer

compressLobs	back to summary
pack-priv boolean compressLobs

createLob	back to summary
pack-priv Statement createLob

createLobPartCall	back to summary
pack-priv Statement createLobPartCall

createLobPartCallSQL	back to summary
private static final String createLobPartCallSQL

createLobSQL	back to summary
private static final String createLobSQL

createPart	back to summary
pack-priv Statement createPart

createPartSQL	back to summary
private static final String createPartSQL

createSingleLobPartCall	back to summary
pack-priv Statement createSingleLobPartCall

createSingleLobPartCallSQL	back to summary
private static final String createSingleLobPartCallSQL

cryptLobs	back to summary
pack-priv boolean cryptLobs

database	back to summary
pack-priv Database database

dataBuffer	back to summary
pack-priv byte[] dataBuffer

deflater	back to summary
pack-priv Deflater deflater

deleteLobCall	back to summary
pack-priv Statement deleteLobCall

deleteLobCallSQL	back to summary
private static final String deleteLobCallSQL

deleteLobPartCall	back to summary
pack-priv Statement deleteLobPartCall

deleteLobPartCallSQL	back to summary
private static final String deleteLobPartCallSQL

deleteUnusedCallSQL	back to summary
private static final String deleteUnusedCallSQL

deleteUnusedLobs	back to summary
pack-priv Statement deleteUnusedLobs

divideLobPartCall	back to summary
pack-priv Statement divideLobPartCall

divideLobPartCallSQL	back to summary
private static final String divideLobPartCallSQL

existsBlocksSQL	back to summary
private static final String existsBlocksSQL

getLastPart	back to summary
pack-priv Statement getLastPart

getLastPartSQL	back to summary
private static final String getLastPartSQL

getLob	back to summary
pack-priv Statement getLob

getLobCount	back to summary
pack-priv Statement getLobCount

getLobCountSQL	back to summary
private static final String getLobCountSQL

getLobPartSQL	back to summary
private static final String getLobPartSQL

getLobSQL	back to summary
private static final String getLobSQL

getLobUseLimit	back to summary
pack-priv Statement getLobUseLimit

getLobUseLimitSQL	back to summary
private static final String getLobUseLimitSQL

getNextLobId	back to summary
pack-priv Statement getNextLobId

getNextLobIdSQL	back to summary
private static final String getNextLobIdSQL

getPartsSQL	back to summary
private static final String getPartsSQL

getSpanningBlocks	back to summary
pack-priv Statement getSpanningBlocks

getSpanningParts	back to summary
pack-priv Statement getSpanningParts

inflater	back to summary
pack-priv Inflater inflater

initialiseBlocksSQL	back to summary
private static final String initialiseBlocksSQL

largeLobBlockSize	back to summary
pack-priv int largeLobBlockSize

lobBlockSize	back to summary
pack-priv int lobBlockSize

lobStore	back to summary
pack-priv LobStore lobStore

lock	back to summary
pack-priv ReadWriteLock lock

mergeUnusedSpace	back to summary
pack-priv Statement mergeUnusedSpace

mergeUnusedSpaceSQL	back to summary
private static final String mergeUnusedSpaceSQL

resourceFileName	back to summary
pack-priv static final String resourceFileName

storeModified	back to summary
pack-priv volatile boolean storeModified

sysLobSession	back to summary
pack-priv Session sysLobSession

totalBlockLimitCount	back to summary
pack-priv int totalBlockLimitCount

updateLobLength	back to summary
pack-priv Statement updateLobLength

updateLobLengthSQL	back to summary
private static final String updateLobLengthSQL

updateLobUsage	back to summary
pack-priv Statement updateLobUsage

updateLobUsageSQL	back to summary
private static final String updateLobUsageSQL

usageChanged	back to summary
pack-priv long usageChanged

writeLock	back to summary
pack-priv Lock writeLock

Constructor Detail

LobManager	back to summary
public LobManager(Database database)

Method Detail

adjustUsageCount	back to summary
public Result adjustUsageCount(Session session, long lobID, int delta) Executes in user session. No lock

close	back to summary
public void close()

compare	back to summary
public int compare(long lobId, byte[] b)

compare	back to summary
public int compare(BlobData a, BlobData b)

compare	back to summary
public int compare(Collation collation, long lobId, String b)

compare	back to summary
public int compare(Collation collation, ClobData a, ClobData b)

compareBytesCompressed	back to summary
private int compareBytesCompressed(long aID, long bID)

compareBytesNormal	back to summary
private int compareBytesNormal(long aID, long bID)

compareTextCompressed	back to summary
private int compareTextCompressed(Collation collation, long aID, long bID)

compareTextNormal	back to summary
private int compareTextNormal(Collation collation, long aID, long bID)

compileStatements	back to summary
public void compileStatements()

copyBlockSet	back to summary
private void copyBlockSet(int[][] source, int[][] target)

createBlob	back to summary
public long createBlob(Session session, long length)

createBlockAddresses	back to summary
private Result createBlockAddresses(long lobID, int offset, int count)

createClob	back to summary
public long createClob(Session session, long length)

createDuplicateLob	back to summary
public Result createDuplicateLob(long lobID)

createDuplicateLob	back to summary
public Result createDuplicateLob(long lobID, long newLength)

createFullBlockAddresses	back to summary
private Result createFullBlockAddresses(long lobID, int offset, int count)

createPart	back to summary
private Result createPart(long lobID, long partOffset, int dataLength, int byteLength, int blockOffset, int blockCount)

createSchema	back to summary
public void createSchema()

deflate	back to summary
private int deflate(byte[] data, int offset, int length)

deleteBlockAddresses	back to summary
private void deleteBlockAddresses(long lobID, int offset, int limit)

deleteLob	back to summary
public Result deleteLob(long lobID)

deleteUnusedLobs	back to summary
public Result deleteUnusedLobs()

divideBlockAddresses	back to summary
private void divideBlockAddresses(long lobID, int offset)

getBlob	back to summary
public BlobData getBlob(long lobID)

getBlockAddress	back to summary
private int getBlockAddress(int[][] blockAddresses, int blockOffset)

getBlockAddresses	back to summary
private int[][] getBlockAddresses(long lobID, int offset, int limit)

getBytes	back to summary
public Result getBytes(long lobID, long offset, int length)

getBytesCompressed	back to summary
private Result getBytesCompressed(long lobID, long offset, int length)

getBytesNormal	back to summary
private Result getBytesNormal(long lobID, long offset, int length)

getChars	back to summary
public Result getChars(long lobID, long offset, int length)

getClob	back to summary
public ClobData getClob(long lobID)

getLastPart	back to summary
private long[] getLastPart(long lobID)

getLength	back to summary
public Result getLength(long lobID)

getLob	back to summary
public Result getLob(long lobID, long offset, long length) Used for SUBSTRING

getLobCount	back to summary
public int getLobCount()

getLobHeader	back to summary
private Object[] getLobHeader(long lobID)

getLobStore	back to summary
public LobStore getLobStore()

getNewLobID	back to summary
private Long getNewLobID()

getPartBytesCompressedInBuffer	back to summary
private Result getPartBytesCompressedInBuffer(long lobID, long[] part)

getParts	back to summary
private long[][] getParts(long lobID, long offset, long limit)

getTruncateLength	back to summary
public Result getTruncateLength(long lobID)

getUsageChanged	back to summary
public long getUsageChanged()

inflate	back to summary
private void inflate(byte[] data, int length)

initialiseLobSpace	back to summary
private void initialiseLobSpace()

lock	back to summary
public void lock()

open	back to summary
public void open()

setBytes	back to summary
public Result setBytes(long lobID, long offset, byte[] dataBytes, int dataLength) returns new LOB length

setBytesBA	back to summary
private Result setBytesBA(long lobID, long offset, byte[] dataBytes, int dataLength)

setBytesBACompressed	back to summary
private Result setBytesBACompressed(long lobID, long offset, byte[] dataBytes, int dataLength)

setBytesBACompressedPart	back to summary
private Result setBytesBACompressedPart(long lobID, long offset, byte[] dataBytes, int dataLength) Only for loading parts of the same lob, not for overwriting parts of existing lob

setBytesBANormal	back to summary
private Result setBytesBANormal(long lobID, long offset, byte[] dataBytes, int dataLength)

setBytesForNewBlob	back to summary
public Result setBytesForNewBlob(long lobID, InputStream inputStream, long length) for new blob only blob length is set to inputStream size (not given length which could be incorrect)

setBytesIS	back to summary
private Result setBytesIS(long lobID, InputStream inputStream, long offset, long length)

setBytesISCompressed	back to summary
private Result setBytesISCompressed(long lobID, InputStream inputStream, long baseOffset, long length)

setBytesISNormal	back to summary
private Result setBytesISNormal(long lobID, InputStream inputStream, long length)

setChars	back to summary
public Result setChars(long lobID, long offset, char[] chars, int dataLength) returns new full length of Clob

setCharsForNewClob	back to summary
public Result setCharsForNewClob(long lobID, InputStream inputStream, long length)

setLength	back to summary
private Result setLength(long lobID, long length)

setUsageChanged	back to summary
public void setUsageChanged()

synch	back to summary
public void synch()

truncate	back to summary
public Result truncate(long lobID, long offset)

unlock	back to summary
public void unlock()

org.hsqldb.persist back to summary

private Interface LobManager.ALLOC_BLOCKS

Field Summary

Modifier and Type	Field and Description
public static final int	BLOCK_COUNT
public static final int	BLOCK_OFFSET
public static final int	LOB_ID

Field Detail

BLOCK_COUNT	back to summary
public static final int BLOCK_COUNT

BLOCK_OFFSET	back to summary
public static final int BLOCK_OFFSET

LOB_ID	back to summary
public static final int LOB_ID

org.hsqldb.persist back to summary

private Interface LobManager.ALLOC_PART

Field Summary

Modifier and Type	Field and Description
public static final int	BLOCK_COUNT
public static final int	BLOCK_OFFSET
public static final int	LOB_ID
public static final int	PART_BYTES
public static final int	PART_LENGTH
public static final int	PART_OFFSET

Field Detail

BLOCK_COUNT	back to summary
public static final int BLOCK_COUNT

BLOCK_OFFSET	back to summary
public static final int BLOCK_OFFSET

LOB_ID	back to summary
public static final int LOB_ID

PART_BYTES	back to summary
public static final int PART_BYTES

PART_LENGTH	back to summary
public static final int PART_LENGTH

PART_OFFSET	back to summary
public static final int PART_OFFSET

org.hsqldb.persist back to summary

private Interface LobManager.DELETE_BLOCKS

Field Summary

Modifier and Type	Field and Description
public static final int	BLOCK_LIMIT
public static final int	BLOCK_OFFSET
public static final int	LOB_ID
public static final int	TX_ID

Field Detail

BLOCK_LIMIT	back to summary
public static final int BLOCK_LIMIT

BLOCK_OFFSET	back to summary
public static final int BLOCK_OFFSET

LOB_ID	back to summary
public static final int LOB_ID

TX_ID	back to summary
public static final int TX_ID

org.hsqldb.persist back to summary

private Interface LobManager.DIVIDE_BLOCK

Field Summary

Modifier and Type	Field and Description
public static final int	BLOCK_OFFSET
public static final int	LOB_ID

Field Detail

BLOCK_OFFSET	back to summary
public static final int BLOCK_OFFSET

LOB_ID	back to summary
public static final int LOB_ID

org.hsqldb.persist back to summary

private Interface LobManager.GET_LOB_PART

Field Summary

Modifier and Type	Field and Description
public static final int	BLOCK_LIMIT
public static final int	BLOCK_OFFSET
public static final int	LOB_ID

Field Detail

BLOCK_LIMIT	back to summary
public static final int BLOCK_LIMIT

BLOCK_OFFSET	back to summary
public static final int BLOCK_OFFSET

LOB_ID	back to summary
public static final int LOB_ID

org.hsqldb.persist back to summary

private Interface LobManager.LOB_IDS

Field Summary

Modifier and Type	Field and Description
public static final int	LOB_ID
public static final int	LOB_LENGTH
public static final int	LOB_TYPE
public static final int	LOB_USAGE_COUNT

Field Detail

LOB_ID	back to summary
public static final int LOB_ID

LOB_LENGTH	back to summary
public static final int LOB_LENGTH

LOB_TYPE	back to summary
public static final int LOB_TYPE

LOB_USAGE_COUNT	back to summary
public static final int LOB_USAGE_COUNT

org.hsqldb.persist back to summary

pack-priv Interface LobManager.LOBS

Field Summary

Modifier and Type	Field and Description
public static final int	BLOCK_ADDR
public static final int	BLOCK_COUNT
public static final int	BLOCK_OFFSET
public static final int	LOB_ID

Field Detail

BLOCK_ADDR	back to summary
public static final int BLOCK_ADDR

BLOCK_COUNT	back to summary
public static final int BLOCK_COUNT

BLOCK_OFFSET	back to summary
public static final int BLOCK_OFFSET

LOB_ID	back to summary
public static final int LOB_ID

org.hsqldb.persist back to summary

private Interface LobManager.UPDATE_LENGTH

Field Summary

Modifier and Type	Field and Description
public static final int	LOB_ID
public static final int	LOB_LENGTH

Field Detail

LOB_ID	back to summary
public static final int LOB_ID

LOB_LENGTH	back to summary
public static final int LOB_LENGTH

org.hsqldb.persist back to summary

private Interface LobManager.UPDATE_USAGE

Field Summary

Modifier and Type	Field and Description
public static final int	BLOCK_COUNT
public static final int	LOB_ID

Field Detail

BLOCK_COUNT	back to summary
public static final int BLOCK_COUNT

LOB_ID	back to summary
public static final int LOB_ID