File	Doc	Category	Size	Date	Package
DB4oController.java	API Doc	Apache Lucene 2.1.0	13227	Wed Feb 14 10:46:04 GMT 2007	org.apache.lucene.gdata.storage.db4o

DB4oController

• java.lang.Object

Fields Summary
private static final Log	LOG
private final ThreadLocal	threadLocalStorage
private org.apache.lucene.gdata.utils.Pool	containerPool
private com.db4o.ObjectServer	server
private final org.apache.lucene.gdata.storage.IDGenerator	idGenerator
private boolean	weakReferences
private boolean	runAsServer
private int	port
private String	filePath
private String	user
private String	password
private String	host
private int	containerPoolSize

Constructors Summary
public DB4oController() throws NoSuchAlgorithmException this.idGenerator = new IDGenerator(15);

Methods Summary
private void	createAdminAccount() GDataAccount adminAccount = GDataAccount.createAdminAccount(); visiteInitialize(); Storage sto = this.getStorage(); try { sto.getAccount(adminAccount.getName()); } catch (Exception e) { this.getStorage().storeAccount(adminAccount); } finally { visiteDestroy(); }
public void	destroy() see org.apache.lucene.gdata.storage.StorageController#destroy() this.containerPool.destroy(); this.idGenerator.stopIDGenerator(); this.server.close();
public int	getContainerPoolSize() return Returns the containerPoolSize. return this.containerPoolSize;
public java.lang.String	getFilePath() return Returns the filePath. return this.filePath;
public java.lang.String	getHost() return Returns the host. return this.host;
public java.lang.String	getPassword() return Returns the password. return this.password;
public int	getPort() return Returns the port. return this.port;
public org.apache.lucene.gdata.storage.Storage	getStorage() see org.apache.lucene.gdata.storage.StorageController#getStorage() Storage retVal = this.threadLocalStorage.get(); if (retVal != null) return retVal; retVal = new DB4oStorage(this.containerPool.aquire(), this); this.threadLocalStorage.set(retVal); return retVal;
public java.lang.String	getUser() return Returns the user. return this.user;
public void	initialize() see org.apache.lucene.gdata.server.registry.ServerComponent#initialize() if (LOG.isInfoEnabled()) LOG.info("Initialize " + this.toString()); Db4o.configure().objectClass(DB4oEntry.class).objectField("updated") .indexed(true); Db4o.configure().objectClass(BaseEntry.class).objectField("id") .indexed(true); Db4o.configure().objectClass(BaseFeed.class).objectField("id").indexed( true); Db4o.configure().objectClass(GDataAccount.class).objectField("name") .indexed(true); Db4o.configure().objectClass(ServerBaseFeed.class).cascadeOnDelete( false); Db4o.configure().objectClass(ServerBaseFeed.class) .maximumActivationDepth(0); Db4o.configure().objectClass(BaseFeed.class).minimumActivationDepth(1); Db4o.configure().objectClass(BaseEntry.class) .minimumActivationDepth(1); Db4o.configure().objectClass(BaseFeed.class).cascadeOnDelete(true); Db4o.configure().objectClass(DB4oEntry.class).cascadeOnDelete(true); Db4o.configure().objectClass(GDataAccount.class).cascadeOnDelete(true); Db4o.configure().weakReferences(this.weakReferences); Db4o.configure().optimizeNativeQueries(false); if (this.runAsServer) { this.server = Db4o.openServer(this.filePath, this.port); if(this.server == null) throw new RuntimeException("Can't create server at confiugred destination -- "+this.filePath); this.server.grantAccess(this.user, this.password); } else { InvocationHandler handler = new ObjectServerDecorator(this.user, this.password, this.host, this.port); this.server = (ObjectServer) Proxy.newProxyInstance(this.getClass() .getClassLoader(), new Class[] { ObjectServer.class }, handler); } PoolObjectFactory<ObjectContainer> factory = new ObjectContinerFactory( this.server); this.containerPool = new SimpleObjectPool<ObjectContainer>( this.containerPoolSize, factory); try { createAdminAccount(); } catch (StorageException e) { LOG.error("Can not create admin account -- ",e); }
public boolean	isRunAsServer() return Returns the runAsServer. return this.runAsServer;
public boolean	isUseWeakReferences() return Returns the weakReferences. return this.weakReferences;
com.db4o.ObjectContainer	releaseContainer() return this.server.openClient();
public java.lang.String	releaseId() see org.apache.lucene.gdata.storage.StorageController#releaseId() try{ return this.idGenerator.getUID(); }catch (InterruptedException e) { throw new StorageException("ID producer has been interrupted",e); }
public void	setContainerPoolSize(int containerPoolSize) param containerPoolSize The containerPoolSize to set. this.containerPoolSize = containerPoolSize < 1 ? 1 : containerPoolSize;
public void	setFilePath(java.lang.String filePath) param filePath The filePath to set. this.filePath = filePath;
public void	setHost(java.lang.String host) param host The host to set. this.host = host;
public void	setPassword(java.lang.String password) param password The password to set. this.password = password;
public void	setPort(int port) param port The port to set. this.port = port;
public void	setRunAsServer(boolean runAsServer) param runAsServer The runAsServer to set. this.runAsServer = runAsServer;
public void	setUseWeakReferences(boolean weakReferences) param weakReferences The weakReferences to set. this.weakReferences = weakReferences;
public void	setUser(java.lang.String user) param user The user to set. this.user = user;
public java.lang.String	toString() see java.lang.Object#toString() StringBuilder builder = new StringBuilder(this.getClass().getName()) .append(" "); builder.append("host: ").append(this.host).append(" "); builder.append("port: ").append(this.port).append(" "); builder.append("pool size: ").append(this.containerPoolSize) .append(" "); builder.append("runs as server: ").append(this.runAsServer).append(" "); builder.append("use weak references: ").append(this.weakReferences) .append(" "); builder.append("user: ").append(this.user).append(" "); builder.append("password length: ").append( this.password == null ? "no password" : this.password.length()) .append(" "); return builder.toString();
public void	visiteDestroy() see org.apache.lucene.gdata.server.registry.ScopeVisitor#visiteDestroy() Storage storage = this.threadLocalStorage.get(); if (storage == null) { LOG.warn("no Storage opened -- threadlocal returned null"); return; } this.containerPool.release(((DB4oStorage)storage).getContainer()); this.threadLocalStorage.remove(); if (LOG.isInfoEnabled()) LOG.info("Closed Storage -- request destroyed");
public void	visiteInitialize() see org.apache.lucene.gdata.server.registry.ScopeVisitor#visiteInitialize() if (LOG.isInfoEnabled()) LOG.info("Opened Storage -- request initialized"); Storage storage = this.threadLocalStorage.get(); if (storage != null) { LOG.warn("Storage already opened"); return; } storage = new DB4oStorage(this.containerPool.aquire(), this); this.threadLocalStorage.set(storage);