oracle.pg.rdbms.index.jdbc

Class OracleJdbcDirectory

java.lang.Object

org.apache.lucene.store.Directory

oracle.pg.rdbms.index.jdbc.OracleJdbcDirectory

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.apache.lucene.store.MultiDeleteDirectory

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

Constructor Summary

Constructors

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

Method Summary

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

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

copy, getLockID, openChecksumInput

Methods inherited from class java.lang.Object

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

Constructor Detail

OracleJdbcDirectory

public OracleJdbcDirectory(OraclePool pool,
                           java.lang.String tableName)
                    throws java.sql.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

java.sql.SQLException

Method Detail

clearLock

public void clearLock(java.lang.String name)

Specified by:

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

close

public void close()
           throws java.io.IOException

Closes the directory.

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

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

Throws:

java.io.IOException

configureFileEntrySettings

public void configureFileEntrySettings()

create

public void create()
            throws java.io.IOException

Creates a new database table. Drops it before hand.

Throws:

java.io.IOException

createOutput

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

Specified by:

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

Throws:

java.io.IOException

delete

public void delete()
            throws java.io.IOException

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

Throws:

java.io.IOException

delete

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

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

Throws:

java.io.IOException

deleteContent

public void deleteContent()
                   throws java.io.IOException

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

Throws:

java.io.IOException

deleteFile

public void deleteFile(java.lang.String name)
                throws java.io.IOException

Specified by:

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

Throws:

java.io.IOException

deleteFiles

public java.util.List deleteFiles(java.util.List names)
                           throws java.io.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:

java.io.IOException

fileExists

public boolean fileExists(java.lang.String name)
                   throws java.io.IOException

Specified by:

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

Throws:

java.io.IOException

fileLength

public long fileLength(java.lang.String name)
                throws java.io.IOException

Specified by:

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

Throws:

java.io.IOException

flushDelBatch

public void flushDelBatch()

flushFileInBatch

public void flushFileInBatch(java.lang.String name)

flushFilesBatch

public void flushFilesBatch()

forceDeleteFile

public void forceDeleteFile(java.lang.String name)
                     throws java.io.IOException

Throws:

java.io.IOException

getAddBatchSize

public int getAddBatchSize()

getDelBatch

public java.util.Vector<java.lang.String> getDelBatch()

getDelBatchSize

public int getDelBatchSize()

getDocInBatch

public OracleIndexFile getDocInBatch(java.lang.String name)

getFileEntrySettings

public JdbcFileEntrySettings getFileEntrySettings(java.lang.String name)

getFilesBatch

public java.util.Map<java.lang.String,OracleIndexFile> getFilesBatch()

getLockFactory

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

Specified by:

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

getOraclePool

public OraclePool getOraclePool()

getSettings

public JdbcDirectorySettings getSettings()

getTableName

public java.lang.String getTableName()

isDelBatchEmpty

public boolean isDelBatchEmpty()

isDelBatchFull

public boolean isDelBatchFull()

isDocinBatch

public boolean isDocinBatch(java.lang.String name)

isFilesBatchEmpty

public boolean isFilesBatchEmpty()

isFilesBatchFull

public boolean isFilesBatchFull()

listAll

public java.lang.String[] listAll()
                           throws java.io.IOException

Specified by:

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

Throws:

java.io.IOException

makeLock

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

Specified by:

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

openInput

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

Specified by:

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

Throws:

java.io.IOException

setAddBatchSize

public void setAddBatchSize(int size)

setDelBatch

public void setDelBatch(java.util.Vector<java.lang.String> files)

setDelBatchSize

public void setDelBatchSize(int size)

setFilesBatch

public void setFilesBatch(java.util.Map<java.lang.String,OracleIndexFile> files)

setLockFactory

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

Specified by:

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

sync

public void sync(java.util.Collection<java.lang.String> names)
          throws java.io.IOException

Specified by:

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

Throws:

java.io.IOException

tableExists

public boolean tableExists()
                    throws java.io.IOException,
                           java.lang.UnsupportedOperationException,
                           java.sql.SQLException

Returns true if the database table exists.

Returns:

true if the database table exists, false otherwise

Throws:

java.io.IOException

java.lang.UnsupportedOperationException - If the database dialect does not support it

java.sql.SQLException

tableExists

public boolean tableExists(oracle.jdbc.OracleConnection conn)
                    throws java.io.IOException,
                           java.lang.UnsupportedOperationException,
                           java.sql.SQLException

Throws:

java.io.IOException

java.lang.UnsupportedOperationException

java.sql.SQLException

toString

public java.lang.String toString()

Overrides:

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