oracle.pg.rdbms.index.jdbc

Class OracleJdbcDirectory

java.lang.Object

org.apache.lucene.store.Directory

oracle.pg.rdbms.index.jdbc.OracleJdbcDirectory

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.lucene.store.MultiDeleteDirectory

public class OracleJdbcDirectory
extends org.apache.lucene.store.Directory
implements org.apache.lucene.store.MultiDeleteDirectory

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.lucene.store.Directory

org.apache.lucene.store.Directory.IndexInputSlicer

Constructor Summary

Constructors

Constructor and Description
OracleJdbcDirectory(OraclePool pool, String tableName) Creates a new Oracle directory.

Method Summary

Methods

Modifier and Type	Method and Description
void	clearLock(String name)
void	close() Closes the directory.
void	configureFileEntrySettings()
void	create() Creates a new database table.
org.apache.lucene.store.IndexOutput	createOutput(String name, org.apache.lucene.store.IOContext context)
void	delete() Deletes the database table (drops it) from the database.
void	delete(oracle.jdbc.OracleConnection conn) Deletes the database table (drops it) from the database.
void	deleteContent() Deletes the contents of the database, except for the commit and write lock.
void	deleteFile(String name)
List	deleteFiles(List names) Deletes the given file names.
boolean	fileExists(String name)
long	fileLength(String name)
void	flushDelBatch()
void	flushFileInBatch(String name)
void	flushFilesBatch()
void	forceDeleteFile(String name)
int	getAddBatchSize()
Vector<String>	getDelBatch()
int	getDelBatchSize()
OracleIndexFile	getDocInBatch(String name)
JdbcFileEntrySettings	getFileEntrySettings(String name)
Map<String,OracleIndexFile>	getFilesBatch()
org.apache.lucene.store.LockFactory	getLockFactory()
OraclePool	getOraclePool()
JdbcDirectorySettings	getSettings()
String	getTableName()
boolean	isDelBatchEmpty()
boolean	isDelBatchFull()
boolean	isDocinBatch(String name)
boolean	isFilesBatchEmpty()
boolean	isFilesBatchFull()
String[]	listAll()
org.apache.lucene.store.Lock	makeLock(String name)
org.apache.lucene.store.IndexInput	openInput(String name, org.apache.lucene.store.IOContext context)
void	setAddBatchSize(int size)
void	setDelBatch(Vector<String> files)
void	setDelBatchSize(int size)
void	setFilesBatch(Map<String,OracleIndexFile> files)
void	setLockFactory(org.apache.lucene.store.LockFactory f)
void	sync(Collection<String> names)
boolean	tableExists() Returns true if the database table exists.
boolean	tableExists(oracle.jdbc.OracleConnection conn)
String	toString()

Methods inherited from class org.apache.lucene.store.Directory

copy, createSlicer, getLockID

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

OracleJdbcDirectory

public OracleJdbcDirectory(OraclePool pool,
                   String tableName)
                    throws SQLException

Creates a new Oracle directory. Creates new JdbcDirectorySettings using it's default values.

Parameters:

pool - The data source to use

tableName - The table name

Throws:

OracleIndexException

SQLException

Method Detail

clearLock

public void clearLock(String name)

Overrides:

clearLock in class org.apache.lucene.store.Directory

close

public void close()
           throws IOException

Closes the directory.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in class org.apache.lucene.store.Directory

Throws:

IOException

configureFileEntrySettings

public void configureFileEntrySettings()

create

public void create()
            throws IOException

Creates a new database table. Drops it before hand.

Throws:

IOException

createOutput

public org.apache.lucene.store.IndexOutput createOutput(String name,
                                               org.apache.lucene.store.IOContext context)
                                                 throws IOException

Specified by:

createOutput in class org.apache.lucene.store.Directory

Throws:

IOException

delete

public void delete()
            throws IOException

Deletes the database table (drops it) from the database.

Throws:

IOException

delete

public void delete(oracle.jdbc.OracleConnection conn)
            throws IOException

Deletes the database table (drops it) from the database.

Throws:

IOException

deleteContent

public void deleteContent()
                   throws IOException

Deletes the contents of the database, except for the commit and write lock.

Throws:

IOException

deleteFile

public void deleteFile(String name)
                throws IOException

Specified by:

deleteFile in class org.apache.lucene.store.Directory

Throws:

IOException

deleteFiles

public List deleteFiles(List names)
                 throws IOException

Description copied from interface: MultiDeleteDirectory

Deletes the given file names. Returns a list of the ones that could not be deleted.

Specified by:

deleteFiles in interface org.apache.lucene.store.MultiDeleteDirectory

Throws:

IOException

fileExists

public boolean fileExists(String name)
                   throws IOException

Specified by:

fileExists in class org.apache.lucene.store.Directory

Throws:

IOException

fileLength

public long fileLength(String name)
                throws IOException

Specified by:

fileLength in class org.apache.lucene.store.Directory

Throws:

IOException

flushDelBatch

public void flushDelBatch()

flushFileInBatch

public void flushFileInBatch(String name)

flushFilesBatch

public void flushFilesBatch()

forceDeleteFile

public void forceDeleteFile(String name)
                     throws IOException

Throws:

IOException

getAddBatchSize

public int getAddBatchSize()

getDelBatch

public Vector<String> getDelBatch()

getDelBatchSize

public int getDelBatchSize()

getDocInBatch

public OracleIndexFile getDocInBatch(String name)

getFileEntrySettings

public JdbcFileEntrySettings getFileEntrySettings(String name)

getFilesBatch

public Map<String,OracleIndexFile> getFilesBatch()

getLockFactory

public org.apache.lucene.store.LockFactory getLockFactory()

Overrides:

getLockFactory in class org.apache.lucene.store.Directory

getOraclePool

public OraclePool getOraclePool()

getSettings

public JdbcDirectorySettings getSettings()

getTableName

public String getTableName()

isDelBatchEmpty

public boolean isDelBatchEmpty()

isDelBatchFull

public boolean isDelBatchFull()

isDocinBatch

public boolean isDocinBatch(String name)

isFilesBatchEmpty

public boolean isFilesBatchEmpty()

isFilesBatchFull

public boolean isFilesBatchFull()

listAll

public String[] listAll()
                 throws IOException

Specified by:

listAll in class org.apache.lucene.store.Directory

Throws:

IOException

makeLock

public org.apache.lucene.store.Lock makeLock(String name)

Overrides:

makeLock in class org.apache.lucene.store.Directory

openInput

public org.apache.lucene.store.IndexInput openInput(String name,
                                           org.apache.lucene.store.IOContext context)
                                             throws IOException

Specified by:

openInput in class org.apache.lucene.store.Directory

Throws:

IOException

setAddBatchSize

public void setAddBatchSize(int size)

setDelBatch

public void setDelBatch(Vector<String> files)

setDelBatchSize

public void setDelBatchSize(int size)

setFilesBatch

public void setFilesBatch(Map<String,OracleIndexFile> files)

setLockFactory

public void setLockFactory(org.apache.lucene.store.LockFactory f)

Overrides:

setLockFactory in class org.apache.lucene.store.Directory

sync

public void sync(Collection<String> names)
          throws IOException

Specified by:

sync in class org.apache.lucene.store.Directory

Throws:

IOException

tableExists

public boolean tableExists()
                    throws IOException,
                           UnsupportedOperationException,
                           SQLException

Returns true if the database table exists.

Returns:

true if the database table exists, false otherwise

Throws:

IOException

UnsupportedOperationException - If the database dialect does not support it

SQLException

tableExists

public boolean tableExists(oracle.jdbc.OracleConnection conn)
                    throws IOException,
                           UnsupportedOperationException,
                           SQLException

Throws:

IOException

UnsupportedOperationException

SQLException

toString

public String toString()

Overrides:

toString in class org.apache.lucene.store.Directory