/* * $Header: /home/cvs/jakarta-slide/src/stores/slidestore/j2ee/J2EEDescriptorsStore.java,v 1.3 2002/02/09 16:53:48 dirkv Exp $ * $Revision: 1.3 $ * $Date: 2002/02/09 16:53:48 $ * * ==================================================================== * * The Apache Software License, Version 1.1 * * Copyright (c) 1999 The Apache Software Foundation. All rights * reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions * are met: * * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in * the documentation and/or other materials provided with the * distribution. * * 3. The end-user documentation included with the redistribution, if * any, must include the following acknowlegement: * "This product includes software developed by the * Apache Software Foundation (http://www.apache.org/)." * Alternately, this acknowlegement may appear in the software itself, * if and wherever such third-party acknowlegements normally appear. * * 4. The names "The Jakarta Project", "Tomcat", and "Apache Software * Foundation" must not be used to endorse or promote products derived * from this software without prior written permission. For written * permission, please contact apache@apache.org. * * 5. Products derived from this software may not be called "Apache" * nor may "Apache" appear in their names without prior written * permission of the Apache Group. * * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE * DISCLAIMED. IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF * SUCH DAMAGE. * ==================================================================== * * This software consists of voluntary contributions made by many * individuals on behalf of the Apache Software Foundation. For more * information on the Apache Software Foundation, please see * . * * [Additional notices, if required by prior licensing conditions] * */ package slidestore.j2ee; import java.lang.reflect.Constructor; import java.util.Hashtable; import java.util.Enumeration; import java.util.Vector; import java.util.Date; import java.util.Arrays; import java.io.FileWriter; import java.io.IOException; import java.sql.*; import javax.transaction.xa.XAException; import javax.transaction.xa.XAResource; import javax.transaction.xa.Xid; import org.apache.slide.common.*; import org.apache.slide.store.*; import org.apache.slide.structure.*; import org.apache.slide.security.*; import org.apache.slide.lock.*; import org.apache.slide.content.*; import org.apache.slide.util.logger.Logger; //For the Datasource implementation import javax.sql.DataSource; import javax.naming.Context; import javax.naming.InitialContext; import javax.naming.NamingException; /** * J2EE store implementation. * * Alpha version (for development only) * * @author Remy Maucherat * @author Ashok Kumar * @author Michael Smith * @version $Revision: 1.3 $ */ public class J2EEDescriptorsStore extends AbstractXAService implements LockStore, NodeStore, RevisionDescriptorsStore, RevisionDescriptorStore, SecurityStore { // -------------------------------------------------------------- Constants public static final int TX_IDLE = 0; public static final int TX_PREPARED = 1; public static final int TX_SUSPENDED = 1; // Column numbers // Structure descriptors protected static final int OBJECTS_URI = 1; protected static final int OBJECTS_CLASS = 2; protected static final int CHILDREN_URI = 1; protected static final int CHILDREN_CHILDURI = 2; protected static final int LINKS_LINK = 1; protected static final int LINKS_LINKTO = 2; // Security descriptors protected static final int PERMISSIONS_OBJECT = 1; protected static final int PERMISSIONS_REVISION_NUMBER = 2; protected static final int PERMISSIONS_SUBJECT = 3; protected static final int PERMISSIONS_ACTION = 4; protected static final int PERMISSIONS_INHERITABLE = 5; protected static final int PERMISSIONS_NEGATIVE = 6; // Lock descriptors protected static final int LOCKS_ID = 1; protected static final int LOCKS_OBJECT = 2; protected static final int LOCKS_SUBJECT = 3; protected static final int LOCKS_TYPE = 4; protected static final int LOCKS_EXPIRATIONDATE = 5; protected static final int LOCKS_INHERITABLE = 6; protected static final int LOCKS_EXCLUSIVE = 7; // Content descriptors protected static final int REVISIONS_URI = 1; protected static final int REVISIONS_ISVERSIONED = 2; protected static final int REVISIONS_INITIALREVISION = 3; protected static final int WORKINGREVISION_URI = 1; protected static final int WORKINGREVISION_BASEREVISION = 2; protected static final int WORKINGREVISION_NUMBER = 3; protected static final int LATESTREVISIONS_URI = 1; protected static final int LATESTREVISIONS_BRANCHNAME = 2; protected static final int LATESTREVISIONS_NUMBER = 3; protected static final int BRANCHES_URI = 1; protected static final int BRANCHES_NUMBER = 2; protected static final int BRANCHES_CHILDNUMBER = 3; protected static final int REVISION_URI = 1; protected static final int REVISION_NUMBER = 2; protected static final int REVISION_BRANCHNAME = 3; protected static final int LABEL_URI = 1; protected static final int LABEL_NUMBER = 2; protected static final int LABEL_LABEL = 3; protected static final int PROPERTY_URI = 1; protected static final int PROPERTY_NUMBER = 2; protected static final int PROPERTY_NAME = 3; protected static final int PROPERTY_VALUE = 4; protected static final int PROPERTY_NAMESPACE = 5; protected static final int PROPERTY_TYPE = 6; protected static final int PROPERTY_PROTECTED = 7; // ----------------------------------------------------- Instance Variables /** * Database connection source. */ protected DataSource ds; protected String datasource; protected Hashtable connectionMap = new Hashtable(); /* A connection used when we aren't associated with a transaction correctly. */ protected Connection globalConnection; // -------------------------------------------------------- Service Methods /** * Initializes the data source with a set of parameters. * * @param parameters Hashtable containing the parameters' name * and associated value * @exception ServiceParameterErrorException Incorrect service parameter * @exception ServiceParameterMissingException Service parameter missing */ public void setParameters(Hashtable parameters) throws ServiceParameterErrorException, ServiceParameterMissingException { // Get the datsource lookup name datasource = (String) parameters.get("datasource"); } /** * Connects to JDBC and creates the basic table structure. * * @exception ServiceConnectionFailedException Connection to the * database failed */ public synchronized void connect() throws ServiceConnectionFailedException { getLogger().log("Trying connect to database", LOG_CHANNEL, Logger.INFO); try { globalConnection = ds.getConnection(); } catch(SQLException e) { getLogger().log("Couldn't get global transaction.", LOG_CHANNEL, Logger.ERROR); } getLogger().log("Done connecting to database. globalConnection is "+ globalConnection, LOG_CHANNEL, Logger.INFO); } /** * Returns connection status */ public boolean isConnected() { try { return ds!=null && globalConnection != null && !globalConnection.isClosed(); } catch(SQLException e) { return false; } } /** * Disconnects from data source. * * @exception ServiceDisconnectionFailedException Disconnection * from database failed */ public void disconnect() throws ServiceDisconnectionFailedException { // This doesn't need to do anything any more. try { globalConnection.close(); } catch(SQLException e) { getLogger().log("Failed to close special global connection: "+ e.getMessage(), LOG_CHANNEL, Logger.ERROR); } } /** * Initializes data source. *

* Occurs in two steps : *

  • Datasource is looked up from the pool
    • *
  • Creation of the basic tables, if they didn't exist before
    • * * @exception ServiceInitializationFailedException Throws an exception * if the data source has already been initialized before */ public synchronized void initialize(NamespaceAccessToken token) throws ServiceInitializationFailedException { try { // Loading and registering driver token.getLogger().log("Loading and registering datasource " + datasource ,LOG_CHANNEL,Logger.INFO); // Initialize database Context initCtx = new InitialContext(); Context envCtx = (Context) initCtx.lookup("java:comp/env"); ds = (DataSource) envCtx.lookup(datasource); } catch (ClassCastException e) { token.getLogger().log("Loading and registering datasource " + datasource + " failed",LOG_CHANNEL,Logger.ERROR); token.getLogger().log(e.toString(),LOG_CHANNEL,Logger.ERROR); throw new ServiceInitializationFailedException(this, e.getMessage()); } catch (NamingException e) { token.getLogger().log("Loading and registering datasource " + datasource + " failed",LOG_CHANNEL,Logger.ERROR); token.getLogger().log(e.toString(),LOG_CHANNEL,Logger.ERROR); throw new ServiceInitializationFailedException(this, e.getMessage()); } catch (Exception e) { token.getLogger().log("Loading and registering datasource " + datasource+ " failed",LOG_CHANNEL,Logger.ERROR); token.getLogger().log(e.toString(),LOG_CHANNEL,Logger.ERROR); throw new ServiceInitializationFailedException(this, e.getMessage()); } if(ds == null) { token.getLogger().log("Datasource is null, can't initialise store"); throw new ServiceInitializationFailedException(this, "Null datasource from context"); } } /** * Deletes data source. Should remove stored data if possible. * * @exception ServiceResetFailedException Reset failed */ public synchronized void reset() throws ServiceResetFailedException { } // ----------------------------------------------------- XAResource Methods /** * Get the transaction timeout value for this XAResource. * Just returns 0, we don't have a way of doing transaction timeouts * with the connection. */ public int getTransactionTimeout() throws XAException { return 0; } /** * Set transaction timeout, not implemented (returns false). */ public boolean setTransactionTimeout(int timeout) throws XAException { return false; } public Xid[] recover(int flag) throws XAException { getLogger().log("recover() for thread: "+Thread.currentThread(), LOG_CHANNEL, Logger.INFO); TransactionId id = (TransactionId)connectionMap.get( Thread.currentThread()); if(id != null && id.status == TX_PREPARED) { Xid[] xids = new Xid[1]; xids[0] = id.xid; return xids; } else return new Xid[0]; } public int prepare(Xid xid) throws XAException { getLogger().log("prepare() for thread: "+Thread.currentThread(), LOG_CHANNEL, Logger.INFO); TransactionId id = (TransactionId)connectionMap.get( Thread.currentThread()); if(id == null) throw new XAException(XAException.XAER_NOTA); if(xid == null) throw new XAException(XAException.XAER_INVAL); if(id.status != TX_IDLE && id.status != TX_SUSPENDED) throw new XAException(XAException.XAER_PROTO); if(id.rollbackOnly) throw new XAException(XAException.XA_RBROLLBACK); id.status = TX_PREPARED; return XAResource.XA_OK; } public boolean isSameRM(XAResource xares) throws XAException { if(xares == null) return false; else return this == xares; } public void forget(Xid xid) throws XAException { getLogger().log("forget() for thread: "+Thread.currentThread(), LOG_CHANNEL, Logger.INFO); TransactionId id = (TransactionId)connectionMap.get( Thread.currentThread()); if(id == null || id.xid == null) throw new XAException(XAException.XAER_NOTA); if(xid == null) throw new XAException(XAException.XAER_INVAL); try { id.connection.close(); } catch(SQLException e) { getLogger().log("Couldn't close connection.", LOG_CHANNEL, Logger.ERROR); } getLogger().log("forget(): removing from map: "+Thread.currentThread(), LOG_CHANNEL, Logger.INFO); connectionMap.remove(Thread.currentThread()); } public void end(Xid xid, int flags) throws XAException { getLogger().log("end() for thread: "+Thread.currentThread(), LOG_CHANNEL, Logger.INFO); TransactionId id = (TransactionId)connectionMap.get(Thread.currentThread()); if(id == null || id.xid == null) throw new XAException(XAException.XAER_NOTA); if(xid == null) throw new XAException(XAException.XAER_INVAL); if(flags == XAResource.TMSUSPEND) id.status = TX_SUSPENDED; if(flags == XAResource.TMFAIL) id.rollbackOnly = true; } /** * Commit the global transaction specified by xid. */ public void commit(Xid xid, boolean onePhase) throws XAException { getLogger().log("commit() for thread "+Thread.currentThread()+", removing from map", LOG_CHANNEL, Logger.INFO); TransactionId id = (TransactionId)connectionMap.remove( Thread.currentThread()); if(id == null) { getLogger().log("Error committing: no transaction associated with current thread", LOG_CHANNEL, Logger.ERROR); throw new XAException(XAException.XAER_NOTA); } if(xid == null) throw new XAException(XAException.XAER_INVAL); if(!onePhase && id.status != TX_PREPARED) throw new XAException(XAException.XAER_PROTO); if(onePhase && (!(id.status == TX_IDLE || id.status == TX_SUSPENDED))) throw new XAException(XAException.XAER_PROTO); Connection conn = id.connection; if(conn == null) { getLogger().log("commit(): No connection in connectionMap for id \""+id+"\"", LOG_CHANNEL, Logger.ERROR); throw new XAException(XAException.XAER_NOTA); } try { if(id.rollbackOnly) conn.rollback(); else conn.commit(); } catch(SQLException e) { throw new XAException(XAException.XA_RBCOMMFAIL); } finally { try { conn.close(); /* We must always return connections to the pool, or we'd eventually run out. */ } catch(SQLException e) { getLogger().log(e,LOG_CHANNEL,Logger.ERROR); } } } /** * Inform the resource manager to roll back work done on behalf of a * transaction branch. */ public void rollback(Xid xid) throws XAException { getLogger().log("rollback() for thread "+Thread.currentThread()+", removing from map", LOG_CHANNEL, Logger.INFO); TransactionId id = (TransactionId)connectionMap.remove( Thread.currentThread()); if(id == null) { getLogger().log("No transaction associated with current thread, can't rollback", LOG_CHANNEL, Logger.ERROR); throw new XAException(XAException.XAER_NOTA); } Connection conn = id.connection; if(conn == null) { getLogger().log("rollback(): No connection in connectionMap for id \""+id+"\"", LOG_CHANNEL, Logger.ERROR); throw new XAException(XAException.XAER_NOTA); } try { conn.rollback(); } catch (SQLException e) { throw new XAException(XAException.XA_HEURCOM); } finally { try { conn.close(); /* We must always return connections to the pool, or we'd eventually run out. */ } catch(SQLException e) { getLogger().log(e,LOG_CHANNEL,Logger.ERROR); } } } /** * Start work on behalf of a transaction branch specified in xid. */ public void start(Xid xid, int flags) throws XAException { getLogger().log("start(): beginning transaction with xid "+xid, LOG_CHANNEL, Logger.INFO); TransactionId id = (TransactionId)connectionMap.get(Thread.currentThread()); switch(flags) { case XAResource.TMNOFLAGS: if(id != null) throw new XAException(XAException.XAER_INVAL); id = new TransactionId(xid, TX_IDLE); getLogger().log("start(): adding to map for "+Thread.currentThread(), LOG_CHANNEL, Logger.INFO); connectionMap.put(Thread.currentThread(), id); break; case XAResource.TMJOIN: getLogger().log("TMJOIN for transaction in thread: "+Thread.currentThread(), LOG_CHANNEL, Logger.DEBUG); if(id == null) throw new XAException(XAException.XAER_NOTA); break; case XAResource.TMRESUME: getLogger().log("TMRESUME for transaction in thread: "+Thread.currentThread(), LOG_CHANNEL, Logger.DEBUG); if(id == null) throw new XAException(XAException.XAER_NOTA); if(id.status != TX_SUSPENDED) throw new XAException(XAException.XAER_INVAL); id.status = TX_IDLE; break; } } // ----------------------------------------------- DescriptorsStore Methods /** * Retrive an object. * * @param uri Uri of the object we want to retrieve * @exception ServiceAccessException Error accessing the Service * @exception ObjectNotFoundException The object to retrieve was not found */ public ObjectNode retrieveObject(Uri uri) throws ServiceAccessException, ObjectNotFoundException { ObjectNode result = null; PreparedStatement statement = null; Connection connection = getCurrentConnection(); try { statement = connection.prepareStatement ("select * from objects where uri= ?"); statement.setString(1, uri.toString()); ResultSet res = statement.executeQuery(); // Parsing result set String className; if (res.next()) { // Retrieving and loading the object className = res.getString(OBJECTS_CLASS); } else { // Object was not found ... throw new ObjectNotFoundException(uri); } closeStatement(statement); // Then, retrieve the children statement = connection.prepareStatement ("select * from children where uri= ?"); statement.setString(1,uri.toString()); res = statement.executeQuery(); Vector childrenVector = new Vector(); // Parse result set while (res.next()) { // Load each permission childrenVector.addElement(res.getString(CHILDREN_CHILDURI)); } closeStatement(statement); statement = connection.prepareStatement ("select * from links where linkto= ?"); statement.setString(1,uri.toString()); res = statement.executeQuery(); Vector linksVector = new Vector(); // Parse result set while (res.next()) { // Load each permission linksVector.addElement(res.getString(LINKS_LINKTO)); } closeStatement(statement); if (className.equals("org.apache.slide.structure.LinkNode")) { String linkTo = new String(); statement = connection.prepareStatement ("select * from links where link= ?"); statement.setString(1,uri.toString()); res = statement.executeQuery(); if(res.next()) linkTo = res.getString(LINKS_LINKTO); closeStatement(statement); result = new LinkNode(uri.toString(), childrenVector, linksVector, linkTo); } else { try { Class objclass = Class.forName(className); Class[] argClasses = { Class.forName("java.lang.String"), Class.forName("java.util.Vector"), Class.forName("java.util.Vector") }; Object[] arguments = { uri.toString(), childrenVector, linksVector }; Constructor constructor = objclass.getConstructor(argClasses); result = (ObjectNode)constructor.newInstance(arguments); } catch(Exception e) { // ClassNotFoundException, NoSuchMethodException, etc. throw new ServiceAccessException(this, e); } } } catch (SQLException e) { getLogger().log(e,LOG_CHANNEL,Logger.ERROR); throw new ServiceAccessException(this, e); } finally { closeStatement(statement); } return result; } /** * Update an object. * * @param object Object to update * @exception ServiceAccessException Error accessing the Service * @exception ObjectNotFoundException The object to update was not found */ public void storeObject(Uri uri, ObjectNode object) throws ServiceAccessException, ObjectNotFoundException { PreparedStatement statement = null; Connection connection = getCurrentConnection(); try { statement = connection.prepareStatement ("select * from objects where uri= ?"); statement.setString(1, uri.toString()); ResultSet res = statement.executeQuery(); // Parsing result set if (!res.next()) { throw new ObjectNotFoundException(uri); } closeStatement(statement); // Updating children statement = connection.prepareStatement ("delete from children where uri= ?"); statement.setString(1, object.getUri()); statement.execute(); closeStatement(statement); statement = null; Enumeration children = object.enumerateChildren(); while (children.hasMoreElements()) { if (statement == null){ statement = connection.prepareStatement ("insert into children values(?, ?)"); } statement.setString(1, object.getUri()); statement.setString(2, (String)children.nextElement()); statement.execute(); } closeStatement(statement); // Updating inbound links /* s = "delete from links where linkto='" + object.getUri() + "'"; statement.execute(s); Enumeration links = object.enumerateLinks(); while (children.hasMoreElements()) { s = "insert into links values('" + (String) links.nextElement() + "', '" + object.getUri() + "')"; statement.execute(s); } */ // Updating links statement = connection.prepareStatement ("delete from links where link= ?"); statement.setString(1, object.getUri()); statement.execute(); closeStatement(statement); if (object instanceof LinkNode) { statement = connection.prepareStatement ("insert into links values(?,?)"); statement.setString(1, object.getUri()); statement.setString(2, ((LinkNode) object).getLinkedUri()); statement.execute(); closeStatement(statement); } } catch (SQLException e) { getLogger().log(e,LOG_CHANNEL,Logger.ERROR); throw new ServiceAccessException(this, e); } finally { closeStatement(statement); } } /** * Create a new object. * * @param object ObjectNode * @param uri Uri of the object we want to create * @exception ServiceAccessException Error accessing the Service * @exception ObjectAlreadyExistsException An object already exists * at this Uri */ public void createObject(Uri uri, ObjectNode object) throws ServiceAccessException, ObjectAlreadyExistsException { PreparedStatement statement = null; Connection connection = getCurrentConnection(); try { String className = object.getClass().getName(); statement = connection.prepareStatement ("select * from objects where uri= ?"); statement.setString(1, uri.toString()); ResultSet res = statement.executeQuery(); // Parsing result set if (res.next()) { throw new ObjectAlreadyExistsException(uri.toString()); } closeStatement(statement); statement = connection.prepareStatement ("insert into objects values(?,?)"); statement.setString(1, uri.toString()); statement.setString(2, className ); statement.execute(); closeStatement(statement); statement = null; // Inserting children Enumeration children = object.enumerateChildren(); while (children.hasMoreElements()) { if (statement == null){ statement = connection.prepareStatement ("insert into children values(?,?)"); } statement.setString(1, uri.toString()); statement.setString(2, (String) children.nextElement()); statement.execute(); } closeStatement(statement); // Updating inbound links /* Enumeration links = object.enumerateLinks(); while (children.hasMoreElements()) { s = "insert into links values('" + (String) links.nextElement() + "', '" + object.getUri() + "')"; statement.execute(s); } */ // If the object is a link, also store the link information if (object instanceof LinkNode) { statement = connection.prepareStatement ("insert into links values(?,?)"); statement.setString(1, uri.toString()); statement.setString(2, ((LinkNode) object).getLinkedUri()); statement.execute(); closeStatement(statement); } } catch (SQLException e) { getLogger().log(e,LOG_CHANNEL,Logger.ERROR); throw new ServiceAccessException(this, e); } finally { closeStatement(statement); } } /** * Remove an object. * * @param object Object to remove * @exception ServiceAccessException Error accessing the Service * @exception ObjectNotFoundException The object to remove was not found */ public void removeObject(Uri uri, ObjectNode object) throws ServiceAccessException, ObjectNotFoundException { PreparedStatement statement = null; Connection connection = getCurrentConnection(); try { // Removing object statement = connection.prepareStatement ("delete from objects where uri= ?"); statement.setString(1,object.getUri()); statement.execute(); closeStatement(statement); // Removing children statement = connection.prepareStatement ("delete from children where uri=?"); statement.setString(1, object.getUri()); statement.execute(); closeStatement(statement); // Removing inbound links /* s = "delete from links where linkto='" + object.getUri() + "'"; statement.execute(s); */ // Removing links statement = connection.prepareStatement ("delete from links where link= ?"); statement.setString(1, object.getUri()); statement.execute(); closeStatement(statement); } catch (SQLException e) { getLogger().log(e,LOG_CHANNEL,Logger.ERROR); throw new ServiceAccessException(this, e); } } /** * Grant a new permission. * * @param permission Permission we want to create * @exception ServiceAccessException Error accessing the Service */ public void grantPermission(Uri uri, NodePermission permission) throws ServiceAccessException { PreparedStatement statement = null; Connection connection = getCurrentConnection(); try { int inheritable = 0; if (permission.isInheritable()) { inheritable = 1; } int negative = 0; if (permission.isNegative()) { negative = 1; } NodeRevisionNumber revisionNumber = permission.getRevisionNumber(); String revisionNumberStr = (revisionNumber == null) ? null : revisionNumber.toString(); statement = connection.prepareStatement ("insert into permissions values(?,?,?,?,?,?)"); statement.setString(1, permission.getObjectUri()); statement.setString(2, revisionNumberStr); statement.setString(3, permission.getSubjectUri()); statement.setString(4, permission.getActionUri()); statement.setInt(5, inheritable); statement.setInt(6, negative); statement.execute(); } catch (SQLException e) { getLogger().log(e,LOG_CHANNEL,Logger.ERROR); throw new ServiceAccessException(this, e); } finally { closeStatement(statement); } } /** * Revoke a permission. * * @param permission Permission we want to create * @exception ServiceAccessException Error accessing the Service */ public void revokePermission(Uri uri, NodePermission permission) throws ServiceAccessException { /* Warning changes to this method should also be done to CloudscapeDescriptorsStore */ PreparedStatement statement = null; Connection connection = getCurrentConnection(); try { NodeRevisionNumber revisionNumber = permission.getRevisionNumber(); if(revisionNumber != null) { statement = connection.prepareStatement ("delete from permissions where object= ? and subject = ? and action = ? and revisionnumber = ? "); statement.setString(4, revisionNumber.toString()); } else { statement = connection.prepareStatement ("delete from permissions where object = ? and subject = ? and action = ? and revisionnumber is NULL"); } statement.setString(1, permission.getObjectUri()); statement.setString(2, permission.getSubjectUri()); statement.setString(3, permission.getActionUri()); statement.execute(); } catch (SQLException e) { getLogger().log(e,LOG_CHANNEL,Logger.ERROR); throw new ServiceAccessException(this, e); } finally { closeStatement(statement); } } /** * Revoke all the permissions on an object. * * @param permission Permission we want to create * @exception ServiceAccessException Error accessing the Service */ public void revokePermissions(Uri uri) throws ServiceAccessException { PreparedStatement statement = null; Connection connection = getCurrentConnection(); try { statement = connection.prepareStatement ("delete from permissions where object= ?"); statement.setString(1, uri.toString()); statement.execute(); } catch (SQLException e) { getLogger().log(e,LOG_CHANNEL,Logger.ERROR); throw new ServiceAccessException(this, e); } finally { closeStatement(statement); } } /** * Enumerate permissions on an object. * * @param permission Permission we want to create * @exception ServiceAccessException Error accessing the Service */ public Enumeration enumeratePermissions(Uri uri) throws ServiceAccessException { Vector permissionVector = new Vector(); PreparedStatement statement = null; Connection connection = getCurrentConnection(); try { statement = connection.prepareStatement ("select * from permissions where object= ?"); statement.setString(1, uri.toString()); ResultSet res = statement.executeQuery(); while (res.next()) { String object = res.getString(PERMISSIONS_OBJECT); String revision = res.getString(PERMISSIONS_REVISION_NUMBER); String subject = res.getString(PERMISSIONS_SUBJECT); String action = res.getString(PERMISSIONS_ACTION); boolean inheritable = false; if (res.getInt(PERMISSIONS_INHERITABLE) == 1) { inheritable = true; } boolean negative = false; if (res.getInt(PERMISSIONS_NEGATIVE) == 1) { negative = true; } NodePermission permission = new NodePermission(object,revision,subject, action,inheritable,negative); permissionVector.addElement(permission); } } catch (SQLException e) { getLogger().log(e,LOG_CHANNEL,Logger.ERROR); throw new ServiceAccessException(this, e); } finally { closeStatement(statement); } return permissionVector.elements(); } /** * Create a new lock. * * @param lock Lock token * @exception ServiceAccessException Service access error */ public void putLock(Uri uri, NodeLock lock) throws ServiceAccessException { PreparedStatement statement = null; Connection connection = getCurrentConnection(); try { int inheritable = 0; if (lock.isInheritable()) { inheritable = 1; } int exclusive = 0; if (lock.isExclusive()) { exclusive = 1; } statement = connection.prepareStatement ("insert into locks values(?,?,?,?,?,?,?)"); statement.setString(1, lock.getLockId()); statement.setString(2, lock.getObjectUri()); statement.setString(3, lock.getSubjectUri()); statement.setString(4, lock.getTypeUri()); statement.setString (5, String.valueOf(lock.getExpirationDate().getTime())); statement.setInt(6,inheritable); statement.setInt(7, exclusive); statement.execute(); } catch (SQLException e) { getLogger().log(e,LOG_CHANNEL,Logger.ERROR); throw new ServiceAccessException(this, e); } finally { closeStatement(statement); } } /** * Renew a lock. * * @param lock Token to renew * @exception ServiceAccessException Service access error * @exception LockTokenNotFoundException Lock token was not found */ public void renewLock(Uri uri, NodeLock lock) throws ServiceAccessException, LockTokenNotFoundException { PreparedStatement statement = null; Connection connection = getCurrentConnection(); try { int inheritable = 0; if (lock.isInheritable()) { inheritable = 1; } int exclusive = 0; if (lock.isExclusive()) { exclusive = 1; } statement = connection.prepareStatement ("delete from locks where id=?"); statement.setString(1, lock.getLockId()); statement.execute(); closeStatement(statement); statement = connection.prepareStatement ("insert into locks values(?,?,?,?,?,?,?)"); statement.setString(1, lock.getLockId()); statement.setString(2, lock.getObjectUri()); statement.setString(3, lock.getSubjectUri()); statement.setString(4, lock.getTypeUri()); statement.setString (5, String.valueOf(lock.getExpirationDate().getTime())); statement.setInt(6, inheritable); statement.setInt(7, exclusive); statement.execute(); } catch (SQLException e) { getLogger().log(e,LOG_CHANNEL,Logger.ERROR); throw new ServiceAccessException(this, e); } finally { closeStatement(statement); } } /** * Unlock. * * @param lock Token to remove * @exception ServiceAccessException Service access error * @exception LockTokenNotFoundException Lock token was not found */ public void removeLock(Uri uri, NodeLock lock) throws ServiceAccessException, LockTokenNotFoundException { Statement statement = null; Connection connection = getCurrentConnection(); try { statement = connection.createStatement(); int inheritable = 0; if (lock.isInheritable()) { inheritable = 1; } String s = null; s = "delete from locks where id='" + lock.getLockId() + "'"; statement.execute(s); } catch (SQLException e) { getLogger().log(e,LOG_CHANNEL,Logger.ERROR); throw new ServiceAccessException(this, e); } finally { closeStatement(statement); } } /** * Kill a lock. * * @param lock Token to remove * @exception ServiceAccessException Service access error * @exception LockTokenNotFoundException Lock token was not found */ public void killLock(Uri uri, NodeLock lock) throws ServiceAccessException, LockTokenNotFoundException { removeLock(uri, lock); } /** * Enumerate locks on an object. * * @param subject Subject * @return Enumeration List of locks which have been put on the subject * @exception ServiceAccessException Service access error */ public Enumeration enumerateLocks(Uri uri) throws ServiceAccessException { Vector lockVector = new Vector(); PreparedStatement statement = null; Connection connection = getCurrentConnection(); try { statement = connection.prepareStatement ("select * from locks where object= ?"); statement.setString(1, uri.toString()); statement.execute(); ResultSet res = statement.getResultSet(); while (res.next()) { Date expirationDate = null; try { Long timeValue = new Long(res.getString (LOCKS_EXPIRATIONDATE)); expirationDate = new Date(timeValue.longValue()); } catch (NumberFormatException e) { expirationDate = new Date(); } NodeLock lock = new NodeLock(res.getString(LOCKS_ID), res.getString(LOCKS_OBJECT), res.getString(LOCKS_SUBJECT), res.getString(LOCKS_TYPE), expirationDate, (res.getInt(LOCKS_INHERITABLE) == 1), (res.getInt(LOCKS_EXCLUSIVE) == 1)); lockVector.addElement(lock); } } catch (SQLException e) { getLogger().log(e,LOG_CHANNEL,Logger.ERROR); throw new ServiceAccessException(this, e); } finally { closeStatement(statement); } return lockVector.elements(); } /** * Retrieve the revisions informations of an object. * * @param uri Uri * @exception ServiceAccessException Service access error * @exception RevisionDescriptorNotFoundException Revision descriptor * was not found */ public NodeRevisionDescriptors retrieveRevisionDescriptors(Uri uri) throws ServiceAccessException, RevisionDescriptorNotFoundException { NodeRevisionDescriptors revisionDescriptors = null; PreparedStatement statement = null; PreparedStatement statement2 = null; Connection connection = getCurrentConnection(); try { ResultSet res = null; NodeRevisionNumber initialRevision = new NodeRevisionNumber(); Hashtable workingRevisions = new Hashtable(); Hashtable latestRevisionNumbers = new Hashtable(); Hashtable branches = new Hashtable(); boolean isVersioned = false; statement = connection.prepareStatement ("select * from revisions where uri= ?"); statement.setString(1, uri.toString()); res = statement.executeQuery(); if (res.next()) { int isVersionedInt = res.getInt(REVISIONS_ISVERSIONED); if (isVersionedInt == 1) { isVersioned = true; } } else { throw new RevisionDescriptorNotFoundException(uri.toString()); } closeStatement(statement); statement = connection.prepareStatement ("select * from workingrevision where uri= ?"); statement.setString(1, uri.toString()); res = statement.executeQuery(); while(res.next()) { // TODO : Parse each working revision definition } closeStatement(statement); statement = connection.prepareStatement ("select * from latestrevisions where uri=?"); statement.setString(1, uri.toString()); res = statement.executeQuery(); while(res.next()) { latestRevisionNumbers .put(res.getString(LATESTREVISIONS_BRANCHNAME), new NodeRevisionNumber (res.getString(LATESTREVISIONS_NUMBER))); } closeStatement(statement); statement = connection.prepareStatement ("select * from revision where uri= ?"); statement.setString(1, uri.toString()); res = statement.executeQuery(); while(res.next()) { String currentRevisionNumber = res.getString(REVISION_NUMBER); // We parse the revision list of the object if (statement2 == null){ statement2 = connection.prepareStatement ("select * from branches where uri = ? and xnumber = ?"); } statement2.setString(1, uri.toString()); statement2.setString(2, currentRevisionNumber); ResultSet res2 = statement2.executeQuery(); Vector childList = new Vector(); while (res2.next()) { childList.addElement(new NodeRevisionNumber (res2.getString(BRANCHES_CHILDNUMBER))); } branches.put(new NodeRevisionNumber(currentRevisionNumber), childList); res2.close(); } closeStatement(statement2); revisionDescriptors = new NodeRevisionDescriptors (uri.toString(), initialRevision, workingRevisions, latestRevisionNumbers, branches, isVersioned); } catch (SQLException e) { getLogger().log(e,LOG_CHANNEL,Logger.ERROR); throw new ServiceAccessException(this, e); } finally { closeStatement(statement); closeStatement(statement2); } return revisionDescriptors; } /** * Create a new revision information object. * * @param uri Uri * @param revisionDescriptors Node revision descriptors * @exception ServiceAccessException Service access error */ public void createRevisionDescriptors (Uri uri, NodeRevisionDescriptors revisionDescriptors) throws ServiceAccessException { // TODO : Here, we have the option of "cleaning up" before // creating the new records in the database. PreparedStatement statement = null; Connection connection = getCurrentConnection(); try { ResultSet res = null; // Creating record in revisions tables int isVersioned = 0; if (revisionDescriptors.isVersioned()) { isVersioned = 1; } statement = connection.prepareStatement ("insert into revisions values(?,?,?)"); statement.setString(1,uri.toString()); statement.setInt(2, isVersioned); statement.setString (3, revisionDescriptors.getInitialRevision().toString()); statement.execute(); closeStatement(statement); // Creating records in working revisions table // ... TODO (working revisions are not used for now) // Creating records in latest revisions table // For now, only the latest revision from the main branch is stored if (revisionDescriptors.getLatestRevision() != null) { statement = connection.prepareStatement ("insert into latestrevisions values(?,?,?)"); statement.setString(1, uri.toString()); statement.setString (2, NodeRevisionDescriptors.MAIN_BRANCH.toString()); statement.setString (3, revisionDescriptors.getLatestRevision().toString()); statement.execute(); closeStatement(statement); } // Creating records in the branches table // TODO } catch (SQLException e) { getLogger().log(e,LOG_CHANNEL,Logger.ERROR); throw new ServiceAccessException(this, e); } finally { closeStatement(statement); } } /** * Update revision information. * * @param uri Uri * @param revisionDescriptors Node revision descriptors * @exception ServiceAccessException Service access error * @exception RevisionDescriptorNotFoundException Revision descriptor * was not found */ public void storeRevisionDescriptors (Uri uri, NodeRevisionDescriptors revisionDescriptors) throws ServiceAccessException, RevisionDescriptorNotFoundException { removeRevisionDescriptors(uri); createRevisionDescriptors(uri, revisionDescriptors); } /** * Remove revision information. * * @param uri Uri * @exception ServiceAccessException Service access error */ public void removeRevisionDescriptors(Uri uri) throws ServiceAccessException { PreparedStatement statement = null; Connection connection = getCurrentConnection(); try { statement = connection.prepareStatement ("delete from revisions where uri= ?"); statement.setString(1, uri.toString()); statement.execute(); closeStatement(statement); statement = connection.prepareStatement ("delete from workingrevision where uri= ?"); statement.setString(1, uri.toString()); statement.execute(); closeStatement(statement); statement = connection.prepareStatement ("delete from latestrevisions where uri= ?"); statement.setString(1, uri.toString()); statement.execute(); closeStatement(statement); statement = connection.prepareStatement ("delete from branches where uri= ?"); statement.setString(1, uri.toString()); statement.execute(); closeStatement(statement); } catch (SQLException e) { getLogger().log(e,LOG_CHANNEL,Logger.ERROR); throw new ServiceAccessException(this, e); } finally { closeStatement(statement); } } /** * Retrieve an individual object's revision descriptor. * * @param Uri uri * @param revisionNumber Node revision number */ public NodeRevisionDescriptor retrieveRevisionDescriptor (Uri uri, NodeRevisionNumber revisionNumber) throws ServiceAccessException, RevisionDescriptorNotFoundException { NodeRevisionDescriptor revisionDescriptor = null; PreparedStatement statement = null; Connection connection = getCurrentConnection(); if(revisionNumber == null) throw new RevisionDescriptorNotFoundException(uri.toString()); try { ResultSet res = null; String branchName = null; Vector labels = new Vector(); Hashtable properties = new Hashtable(); // Retrieving branch name (and also check that revision // does indeed exist) statement = connection.prepareStatement ("select * from revision where uri= ? and xnumber = ?"); statement.setString(1, uri.toString()); statement.setString(2, revisionNumber.toString()); res = statement.executeQuery(); if (res.next()) { branchName = res.getString(REVISION_BRANCHNAME); } else { throw new RevisionDescriptorNotFoundException(uri.toString()); } closeStatement(statement); // Retrieve labels statement = connection.prepareStatement ("select * from label where uri= ? and xnumber = ?"); statement.setString(1, uri.toString()); statement.setString(2, revisionNumber.toString()); res = statement.executeQuery(); while (res.next()) { labels.addElement(res.getString(LABEL_LABEL)); } closeStatement(statement); // Retrieve properties statement = connection.prepareStatement ("select * from property where uri= ? and xnumber = ?"); statement.setString(1, uri.toString()); statement.setString(2, revisionNumber.toString()); res = statement.executeQuery(); while (res.next()) { String propertyName = res.getString(PROPERTY_NAME); String propertyNamespace = res.getString(PROPERTY_NAMESPACE); NodeProperty property = new NodeProperty(propertyName, res.getString(PROPERTY_VALUE), propertyNamespace, res.getString(PROPERTY_TYPE), (res.getInt(PROPERTY_PROTECTED) == 1)); properties.put(propertyNamespace + propertyName, property); } revisionDescriptor = new NodeRevisionDescriptor(revisionNumber, branchName, labels, properties); } catch (SQLException e) { getLogger().log(e,LOG_CHANNEL,Logger.ERROR); throw new ServiceAccessException(this, e); } finally { closeStatement(statement); } return revisionDescriptor; } /** * Create a new revision descriptor. * * @param uri Uri * @param revisionDescriptor Node revision descriptor * @exception ServiceAccessException Service access error */ public void createRevisionDescriptor (Uri uri, NodeRevisionDescriptor revisionDescriptor) throws ServiceAccessException { PreparedStatement statement = null; Connection connection = getCurrentConnection(); try { ResultSet res = null; statement = connection.prepareStatement ("insert into revision values(?, ?, ?)"); statement.setString(1, uri.toString()); statement.setString (2, revisionDescriptor.getRevisionNumber().toString()); statement.setString(3, revisionDescriptor.getBranchName()); statement.execute(); closeStatement(statement); // Creating revision labels statement = null; Enumeration labels = revisionDescriptor.enumerateLabels(); while (labels.hasMoreElements()) { if (statement == null){ statement = connection.prepareStatement ("insert into label values(?,?,?)"); } statement.setString(1, uri.toString()); statement.setString (2, revisionDescriptor.getRevisionNumber().toString()); statement.setString(3, (String)labels.nextElement()); statement.execute(); } closeStatement(statement); // Creating associated properties statement = null; Enumeration properties = revisionDescriptor.enumerateProperties(); while (properties.hasMoreElements()) { NodeProperty property = (NodeProperty) properties.nextElement(); int protectedProperty = 0; if (property.isProtected()) { protectedProperty = 1; } if (statement == null){ statement = connection.prepareStatement ("insert into property values(?,?,?,?,?,?,?)"); } statement.setString(1, uri.toString()); statement.setString (2, revisionDescriptor.getRevisionNumber().toString()); statement.setString(3, property.getName()); statement.setString(4, property.getValue().toString()); statement.setString(5, property.getNamespace()); statement.setString(6, property.getType()); statement.setInt(7, protectedProperty); statement.execute(); } closeStatement(statement); } catch (SQLException e) { getLogger().log(e,LOG_CHANNEL,Logger.ERROR); throw new ServiceAccessException(this, e); } finally { closeStatement(statement); } } /** * Update a revision descriptor. * * @param uri Uri * @param revisionDescriptors Node revision descriptor * @exception ServiceAccessException Service access error * @exception RevisionDescriptorNotFoundException Revision descriptor * was not found */ public void storeRevisionDescriptor (Uri uri, NodeRevisionDescriptor revisionDescriptor) throws ServiceAccessException, RevisionDescriptorNotFoundException { removeRevisionDescriptor(uri, revisionDescriptor.getRevisionNumber()); createRevisionDescriptor(uri, revisionDescriptor); } /** * Remove a revision descriptor. * * @param uri Uri * @param revisionNumber Revision number * @exception ServiceAccessException Service access error */ public void removeRevisionDescriptor(Uri uri, NodeRevisionNumber number) throws ServiceAccessException { PreparedStatement statement = null; Connection connection = getCurrentConnection(); try { statement = connection.prepareStatement ("delete from revision where uri= ? and xnumber = ?"); statement.setString(1, uri.toString()); statement.setString(2, number.toString()); statement.execute(); closeStatement(statement); // Removing revision labels statement = connection.prepareStatement ("delete from label where uri= ? and xnumber = ?"); statement.setString(1, uri.toString()); statement.setString(2, number.toString()); statement.execute(); closeStatement(statement); // Removing associated properties statement = connection.prepareStatement ("delete from property where uri= ? and xnumber = ?"); statement.setString(1, uri.toString()); statement.setString(2, number.toString()); statement.execute(); } catch (SQLException e) { getLogger().log(e,LOG_CHANNEL,Logger.ERROR); throw new ServiceAccessException(this, e); } finally { closeStatement(statement); } } // ------------------------------------------------------ Protected Methods /** * Close specified statement. */ protected void closeStatement(Statement statement) { if (statement != null) { try { statement.close(); } catch (SQLException e) { getLogger().log(e,LOG_CHANNEL,Logger.ERROR); } } } /** * Get the Connection object associated with the current transaction. */ protected Connection getCurrentConnection() { // getLogger().log("Getting current connection for thread "+ // Thread.currentThread(), LOG_CHANNEL, Logger.INFO); TransactionId id = (TransactionId)connectionMap.get(Thread.currentThread()); if(id == null) { getLogger().log("No id for current thread - called outside transaction?", LOG_CHANNEL, Logger.INFO); // getLogger().log("Using global connection object - transaction isolation WILL NOT WORK", LOG_CHANNEL, Logger.INFO); return globalConnection; } Connection conn = id.connection; if(conn == null) { getLogger().log("No connection for current id - shouldn't be possible", LOG_CHANNEL, Logger.ERROR); getLogger().log("Using global connection object - transaction isolation WILL NOT WORK", LOG_CHANNEL, Logger.ERROR); return globalConnection; } getLogger().log("Returning current valid connection from map", LOG_CHANNEL, Logger.INFO); return conn; } private class TransactionId { public Xid xid; public int status; public boolean rollbackOnly; Connection connection; public TransactionId(Xid xid, int status) { this.xid = xid; this.status = status; rollbackOnly = false; /* Now, fetch a connection from the DataSource */ try { connection = ds.getConnection(); if(connection == null) { System.out.println("CONNDEBUG: Got null connection from datasource"); connection = globalConnection; return; } connection.setAutoCommit(false); System.out.println("CONNDEBUG: Got connection successfully"); } catch(SQLException e) { System.out.println("CONNDEBUG: Couldn't get connection: "+e.getMessage()); connection = globalConnection; e.printStackTrace(); } } } }