You are viewing a plain text version of this content. The canonical link for it is here.
Posted to slide-dev@jakarta.apache.org by re...@apache.org on 2001/12/24 23:08:13 UTC
cvs commit: jakarta-slide/src/stores/slidestore/j2ee J2EEDescriptorsStore.java J2EEContentStore.java
remm 01/12/24 14:08:13
Added: src/stores/slidestore/j2ee J2EEDescriptorsStore.java
J2EEContentStore.java
Log:
- Adding many of the contributed code.
- New store using a DataSource connection pool, derived from the JDBC store.
This provides a good starting point for work on a more efficient store, although
the original store will remain as the "reference" store.
- Code submitted by Ashok Kumar <akumar at metatomix.com>
Revision Changes Path
1.1 jakarta-slide/src/stores/slidestore/j2ee/J2EEDescriptorsStore.java
Index: J2EEDescriptorsStore.java
===================================================================
/*
* $Header: /home/cvs/jakarta-slide/src/stores/slidestore/j2ee/J2EEDescriptorsStore.java,v 1.1 2001/12/24 22:08:13 remm Exp $
* $Revision: 1.1 $
* $Date: 2001/12/24 22:08:13 $
*
* ====================================================================
*
* 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
* <http://www.apache.org/>.
*
* [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.io.FileWriter;
import java.io.IOException;
import java.sql.*;
import javax.transaction.xa.XAException;
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;
/**
* JDBC 1.0 and 2.0 compliant store implementation.
*
* @author <a href="mailto:remm@apache.org">Remy Maucherat</a>
* @author Ashok Kumar
* @version $Revision: 1.1 $
*/
public class J2EEDescriptorsStore
extends AbstractService
implements LockStore, NodeStore, RevisionDescriptorsStore,
RevisionDescriptorStore, SecurityStore {
// -------------------------------------------------------------- Constants
// 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.
*/
protected Connection connection;
protected DataSource ds;
protected String datasource;
/**
* Driver class name.
*/
protected String driver;
/**
* Connection URL.
*/
protected String url;
/**
* User name.
*/
protected String user;
/**
* Password.
*/
protected String password;
/**
* JDBC Version to use.
*/
protected int jdbcVersion;
/**
* This store doesn't handle nested transactions, this variable keeps track
* if the store is already enlisted to a transaction.
*/
protected boolean alreadyEnlisted=false;
// -------------------------------------------------------- Service Methods
/**
* Returns the sql statements to create the database objects.
*/
protected String[] getDatabaseCreateStatements()
{
String[] statements = {
"create table objects(uri varchar(65536) primary key," +
" classname varchar(4096))",
"create table children(uri varchar(65536), " +
" childuri varchar(65536))",
"create table links(link varchar(65536), " +
" linkto varchar(65536))",
"create table permissions(object varchar(65536)," +
" revisionnumber varchar(20), " +
" subject varchar(65536), action varchar(65536), " +
" inheritable int, negative int)",
"create table locks(id varchar(65536), object varchar(4096)," +
" subject varchar(4096), type varchar(4096), " +
" expirationdate varchar(15), inheritable int, " +
" xexclusive int)",
"create table revisions(uri varchar(65536) primary key, " +
" isversioned int, initialrevision varchar(10))",
"create table workingrevision(uri varchar(65536), " +
" baserevision varchar(20), xnumber varchar(20))",
"create table latestrevisions(uri varchar(65536), " +
" branchname varchar(4096), xnumber varchar(20))",
"create table branches(uri varchar(65536), xnumber varchar(20)," +
" childnumber varchar(20))",
"create table revision(uri varchar(65536), xnumber varchar(20)," +
" branchname varchar(4096))",
"create table label(uri varchar(65536), xnumber varchar(20)," +
" label varchar(4096))",
"create table property(uri varchar(65536), xnumber varchar(20)," +
" name varchar(4096), value varchar(65536), " +
" namespace varchar(4096), type varchar(100), protected int)"};
return statements;
}
/**
* 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("Connecting to \"" + url + "\" as user \"" + user + "\"",LOG_CHANNEL,Logger.INFO);
try {
connection = ds.getConnection();
} catch (SQLException e) {
getLogger().log("Connecting to \"" + url + "\" as user \"" + user + "\" failed",LOG_CHANNEL,Logger.ERROR);
getLogger().log(e.toString(),LOG_CHANNEL,Logger.ERROR);
throw new ServiceConnectionFailedException(this, e);
}
// all updates must be done inside a transaction, no auto commits
try {
connection.setAutoCommit(false);
} catch (SQLException e) {
}
Statement statement = null;
try {
statement = connection.createStatement();
String[] statements = getDatabaseCreateStatements();
for (int i=0; i<statements.length ; i++ ) {
statement.execute(statements[i]);
}
// Cloudscape needs a commit on DDL statements (create,...)
connection.commit();
} catch (SQLException e) {
try { connection.rollback(); } catch (SQLException ex) { }
} finally {
closeStatement(statement);
}
// we are just connected and are not enlisted
alreadyEnlisted=false;
}
/**
* Disconnects from data source.
*
* @exception ServiceDisconnectionFailedException Disconnection
* from database failed
*/
public void disconnect()
throws ServiceDisconnectionFailedException {
getLogger().log("Disconnecting from \"" + url + "\" as user \"" + user + "\"",LOG_CHANNEL,Logger.INFO);
try {
if (connection != null)
connection.close();
connection = null;
} catch (SQLException e) {
getLogger().log("Disconnecting from \"" + url + "\" as user \"" + user + "\" failed",LOG_CHANNEL,Logger.ERROR);
getLogger().log(e.toString(),LOG_CHANNEL,Logger.ERROR);
throw new ServiceDisconnectionFailedException(this, e);
}
}
/**
* Initializes data source.
* <p/>
* Occurs in four steps :
* <li>Datasource is looked up from the pool</li>
* <li>Creation of the basic tables, if they didn't exist before</li>
*
* @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());
}
}
/**
* Deletes data source. Should remove stored data if possible.
*
* @exception ServiceResetFailedException Reset failed
*/
public synchronized void reset()
throws ServiceResetFailedException {
Statement statement = null;
try {
connectIfNeeded();
statement = connection.createStatement();
String s = null;
s = "drop table objects";
statement.execute(s);
s = "drop table children";
statement.execute(s);
s = "drop table links";
statement.execute(s);
s = "drop table permissions";
statement.execute(s);
s = "drop table locks";
statement.execute(s);
s = "drop table revisions";
statement.execute(s);
s = "drop table workingrevision";
statement.execute(s);
s = "drop table latestrevisions";
statement.execute(s);
s = "drop table branches";
statement.execute(s);
s = "drop table revision";
statement.execute(s);
s = "drop table label";
statement.execute(s);
s = "drop table property";
statement.execute(s);
statement.close();
disconnect();
} catch (SQLException e) {
throw new ServiceResetFailedException(this, e.getMessage());
} catch (ServiceAccessException e) {
throw new ServiceResetFailedException(this, e.getMessage());
} catch (ServiceConnectionFailedException e) {
throw new ServiceResetFailedException(this, e.getMessage());
} catch (ServiceDisconnectionFailedException e) {
throw new ServiceResetFailedException(this, e.getMessage());
} finally {
closeStatement(statement);
}
}
/**
* This function tells whether or not the data source is connected.
*
* @return boolean true if we are connected
* @exception ServiceAccessException Error accessing DataSource
*/
public boolean isConnected()
throws ServiceAccessException {
try {
return ((connection != null) && (!connection.isClosed()));
} catch (SQLException e) {
throw new ServiceAccessException(this, e);
}
}
// ----------------------------------------------------- XAResource Methods
/**
* Commit the global transaction specified by xid.
*/
public void commit(Xid xid, boolean onePhase)
throws XAException {
super.commit(xid, onePhase);
try {
// getLogger().log("commit",LOG_CHANNEL,Logger.DEBUG);
connection.commit();
} catch (SQLException e) {
throw new XAException(XAException.XA_RBCOMMFAIL);
}
alreadyEnlisted=false;
}
/**
* Inform the resource manager to roll back work done on behalf of a
* transaction branch.
*/
public void rollback(Xid xid)
throws XAException {
super.rollback(xid);
try {
// getLogger().log("rollback",LOG_CHANNEL,Logger.DEBUG);
connection.rollback();
} catch (SQLException e) {
throw new XAException(XAException.XA_HEURCOM);
}
alreadyEnlisted=false;
}
/**
* Start work on behalf of a transaction branch specified in xid.
*/
public void start(Xid xid, int flags)
throws XAException {
super.start(xid, flags);
if (!alreadyEnlisted)
{
try {
// getLogger().log("start",LOG_CHANNEL,Logger.DEBUG);
// discard changes made outside a tranaction
connection.rollback();
} catch (SQLException e) {
throw new XAException(XAException.XAER_RMERR);
}
alreadyEnlisted=true;
}
}
// ----------------------------------------------- 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;
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;
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;
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;
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;
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;
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;
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;
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;
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;
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;
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;
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;
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;
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;
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;
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;
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;
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) {
}
}
}
}
1.1 jakarta-slide/src/stores/slidestore/j2ee/J2EEContentStore.java
Index: J2EEContentStore.java
===================================================================
/*
* $Header: /home/cvs/jakarta-slide/src/stores/slidestore/j2ee/J2EEContentStore.java,v 1.1 2001/12/24 22:08:13 remm Exp $
* $Revision: 1.1 $
* $Date: 2001/12/24 22:08:13 $
*
* ====================================================================
*
* 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
* <http://www.apache.org/>.
*
* [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.io.FileWriter;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.InputStreamReader;
import java.io.IOException;
import java.io.File;
import java.sql.*;
import javax.transaction.xa.XAException;
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.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 2.0 compliant implementation of ContentStore.
*
* @author Ashok Kumar
* @contact <a href="mailto:remm@apache.org">Remy Maucherat</a>
* @version $Revision: 1.1 $
*/
public class J2EEContentStore extends AbstractService
implements ContentStore {
// -------------------------------------------------------------- Constants
public static final int BUFFER_SIZE = 2048;
public static final String CHARACTER_ENCODING = "8859_1";
protected static final int REVISION_URI = 1;
protected static final int REVISION_NUMBER = 2;
protected static final int REVISION_CONTENT = 3;
// ----------------------------------------------------- Instance Variables
/**
* Datasource connection.
*/
protected Connection connection;
protected DataSource ds;
protected String datasource;
/**
* Driver class name.
*/
protected String driver;
/**
* Connection URL.
*/
protected String url;
/**
* User name.
*/
protected String user;
/**
* Password.
*/
protected String password;
/**
* This store doesn't handle nested transactions, this variable keeps track
* if the store is already enlisted to a transaction.
*/
protected boolean alreadyEnlisted=false;
// -------------------------------------------------------- Service Methods
/**
* Returns the sql statements to create the database objects.
*/
protected String[] getDatabaseCreateStatements()
{
String[] statements = {
"create table revisioncontent(uri varchar(65536), " +
"xnumber varchar(20), content LONGVARBINARY)"};
return statements;
}
/**
* Read parameters.
*
* @param parameters Hashtable containing the parameters' name
* and associated value
*/
public synchronized void setParameters(Hashtable parameters)
throws ServiceParameterErrorException,
ServiceParameterMissingException {
// Get the datsource lookup name
datasource = (String) parameters.get("datasource");
}
/**
* Connects to Datasource and creates the basic table structure.
*
* @exception ServiceConnectionFailedException Connection to the
* database failed
*/
public synchronized void connect()
throws ServiceConnectionFailedException {
getLogger().log("Connecting to datasource: " + datasource,LOG_CHANNEL,Logger.INFO);
try {
connection = ds.getConnection();
} catch (SQLException e) {
getLogger().log("Connecting to datasource: " + datasource +" failed",LOG_CHANNEL,Logger.ERROR);
getLogger().log(e.toString(),LOG_CHANNEL,Logger.ERROR);
throw new ServiceConnectionFailedException(this, e);
}
// all updates must be done inside a transaction, no auto commits
try {
connection.setAutoCommit(false);
} catch (SQLException e) {
}
Statement statement = null;
try {
statement = connection.createStatement();
String[] statements = getDatabaseCreateStatements();
for (int i=0; i<statements.length ; i++ ) {
statement.execute(statements[i]);
}
// Cloudscape needs a commit on DDL statements (create,...)
connection.commit();
} catch (SQLException e) {
try { connection.rollback(); } catch (SQLException ex) { }
} finally {
closeStatement(statement);
}
// we are just connected and are not enlisted
alreadyEnlisted=false;
}
/**
* Disconnects from content store.
*
* @exception ServiceDisconnectionFailedException
*/
public synchronized void disconnect()
throws ServiceDisconnectionFailedException {
getLogger().log("Disconnecting from datasource: " + datasource,LOG_CHANNEL,Logger.INFO);
try {
if (connection != null)
connection.close();
connection = null;
} catch (SQLException e) {
getLogger().log("Disconnecting from datasource: " + datasource +" failed",LOG_CHANNEL,Logger.ERROR);
getLogger().log(e.toString(),LOG_CHANNEL,Logger.ERROR);
throw new ServiceDisconnectionFailedException(this, e);
}
}
/**
* Initializes content store.
*
* @exception ServiceInitializationFailedException Throws an exception
* if the store 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());
}
}
/**
* Deletes content store.
*
* @exception ServiceResetFailedException
*/
public void reset()
throws ServiceResetFailedException {
try {
connectIfNeeded();
Statement statement = connection.createStatement();
String s = "drop table revisioncontent";
statement.execute(s);
statement.close();
disconnect();
} catch (SQLException e) {
throw new ServiceResetFailedException(this, e.getMessage());
} catch (ServiceAccessException e) {
throw new ServiceResetFailedException(this, e.getMessage());
} catch (ServiceConnectionFailedException e) {
throw new ServiceResetFailedException(this, e.getMessage());
} catch (ServiceDisconnectionFailedException e) {
throw new ServiceResetFailedException(this, e.getMessage());
}
}
/**
* This function tells whether or not the service is connected.
*
* @return boolean true if we are connected
* @exception ServiceAccessException Service access error
*/
public boolean isConnected()
throws ServiceAccessException {
try {
return ((connection != null) && (!connection.isClosed()));
} catch (SQLException e) {
throw new ServiceAccessException(this, e);
}
}
// ----------------------------------------------------- XAResource Methods
/**
* Commit the global transaction specified by xid.
*/
public void commit(Xid xid, boolean onePhase)
throws XAException {
super.commit(xid, onePhase);
try {
// getLogger().log("commit",LOG_CHANNEL,Logger.DEBUG);
connection.commit();
} catch (SQLException e) {
throw new XAException(XAException.XA_RBCOMMFAIL);
}
alreadyEnlisted=false;
}
/**
* Inform the resource manager to roll back work done on behalf of a
* transaction branch.
*/
public void rollback(Xid xid)
throws XAException {
super.rollback(xid);
try {
// getLogger().log("rollback",LOG_CHANNEL,Logger.DEBUG);
connection.rollback();
} catch (SQLException e) {
throw new XAException(XAException.XA_HEURCOM);
}
alreadyEnlisted=false;
}
/**
* Start work on behalf of a transaction branch specified in xid.
*/
public void start(Xid xid, int flags)
throws XAException {
super.start(xid, flags);
if (!alreadyEnlisted)
{
try {
// getLogger().log("start",LOG_CHANNEL,Logger.DEBUG);
// discard changes made outside a tranaction
connection.rollback();
} catch (SQLException e) {
throw new XAException(XAException.XAER_RMERR);
}
alreadyEnlisted=true;
}
}
// --------------------------------------------------- ContentStore Methods
/**
* Retrive revision content.
*
* @param uri Uri
* @param revisionNumber Node revision number
*/
public NodeRevisionContent retrieveRevisionContent
(Uri uri, NodeRevisionDescriptor revisionDescriptor)
throws ServiceAccessException, RevisionNotFoundException {
NodeRevisionContent result = null;
String revisionUri = uri.toString();
String revisionNumber =
revisionDescriptor.getRevisionNumber().toString();
try {
PreparedStatement selectStatement = connection.prepareStatement
("select * from revisioncontent where uri = ? and "
+ "xnumber = ?");
selectStatement.setString(1, revisionUri);
selectStatement.setString(2, revisionNumber);
ResultSet rs = selectStatement.executeQuery();
if (!rs.next()) {
rs.close();
selectStatement.close();
throw new RevisionNotFoundException
(uri.toString(),
revisionDescriptor.getRevisionNumber());
}
InputStream is = rs.getBinaryStream(REVISION_CONTENT);
if (is == null) {
throw new RevisionNotFoundException
(uri.toString(),
revisionDescriptor.getRevisionNumber());
}
InputStreamReader reader = new InputStreamReader
(is, CHARACTER_ENCODING);
result = new NodeRevisionContent();
result.setContent(reader);
result.setContent(is);
// Don't close the statement or the result set here (because
// otherwise the is and the reader returned would be closed).
// If this proves to be a problem, then the binary content of the
// resource must either be buffer to the disk or to memory.
// FIXME ?
} catch (SQLException e) {
getLogger().log(e,LOG_CHANNEL,Logger.ERROR);
throw new ServiceAccessException(this, e.getMessage());
} catch (RevisionNotFoundException e) {
// we do NOT want this caught by next clause.
throw e;
} catch (Exception e) {
getLogger().log(e,LOG_CHANNEL,Logger.ERROR);
throw new ServiceAccessException(this, e.getMessage());
}
return result;
}
/**
* Create a new revision
*
* @param uri Uri
* @param revisionDescriptor Node revision descriptor
* @param revisionContent Node revision content
*/
public void createRevisionContent
(Uri uri, NodeRevisionDescriptor revisionDescriptor,
NodeRevisionContent revisionContent)
throws ServiceAccessException, RevisionAlreadyExistException {
String revisionUri = uri.toString();
String revisionNumber =
revisionDescriptor.getRevisionNumber().toString();
long contentLength = revisionDescriptor.getContentLength();
PreparedStatement selectStatement = null;
try {
selectStatement = connection.prepareStatement
("select * from revisioncontent where uri = ? and "
+ "xnumber = ?");
selectStatement.setString(1, revisionUri);
selectStatement.setString(2, revisionNumber);
ResultSet rs = selectStatement.executeQuery();
if (rs.next()) {
rs.close();
throw new RevisionAlreadyExistException
(uri.toString(),
revisionDescriptor.getRevisionNumber());
}
rs.close();
storeContent(revisionUri, revisionNumber, revisionDescriptor,
revisionContent);
} catch (SQLException e) {
getLogger().log(e,LOG_CHANNEL,Logger.ERROR);
throw new ServiceAccessException(this, e.getMessage());
} catch (IOException e) {
getLogger().log(e,LOG_CHANNEL,Logger.ERROR);
throw new ServiceAccessException(this, e.getMessage());
} catch(RevisionAlreadyExistException e) {
throw e; // we do NOT want this caught by next clause.
} catch (Exception e) {
getLogger().log(e,LOG_CHANNEL,Logger.ERROR);
throw new ServiceAccessException(this, e.getMessage());
} finally {
closeStatement(selectStatement);
}
}
/**
* Modify the latest revision of an object.
*
* @param uri Uri
* @param revisionDescriptor Node revision descriptor
* @param revisionContent Node revision content
*/
public void storeRevisionContent
(Uri uri, NodeRevisionDescriptor revisionDescriptor,
NodeRevisionContent revisionContent)
throws ServiceAccessException, RevisionNotFoundException {
String revisionUri = uri.toString();
String revisionNumber =
revisionDescriptor.getRevisionNumber().toString();
PreparedStatement selectStatement = null;
try {
selectStatement = connection.prepareStatement
("select * from revisioncontent where uri = ? and "
+ "xnumber = ?");
selectStatement.setString(1, revisionUri);
selectStatement.setString(2, revisionNumber);
ResultSet rs = selectStatement.executeQuery();
if (!rs.next()) {
rs.close();
selectStatement.close();
throw new RevisionNotFoundException
(uri.toString(),
revisionDescriptor.getRevisionNumber());
}
rs.close();
removeContent(revisionUri, revisionNumber);
storeContent(revisionUri, revisionNumber, revisionDescriptor,
revisionContent);
} catch (SQLException e) {
getLogger().log(e,LOG_CHANNEL,Logger.ERROR);
throw new ServiceAccessException(this, e.getMessage());
} catch (IOException e) {
getLogger().log(e,LOG_CHANNEL,Logger.ERROR);
throw new ServiceAccessException(this, e.getMessage());
} catch(RevisionNotFoundException e) {
throw e; // we do NOT want this caught by next clause.
} catch (Exception e) {
getLogger().log(e,LOG_CHANNEL,Logger.ERROR);
throw new ServiceAccessException(this, e.getMessage());
} finally {
closeStatement(selectStatement);
}
}
/**
* Remove revision.
*
* @param uri Uri
* @param revisionNumber Node revision number
*/
public void removeRevisionContent
(Uri uri, NodeRevisionDescriptor revisionDescriptor)
throws ServiceAccessException {
String revisionUri = uri.toString();
String revisionNumber =
revisionDescriptor.getRevisionNumber().toString();
try {
removeContent(revisionUri, revisionNumber);
} catch (Exception e) {
getLogger().log(e,LOG_CHANNEL,Logger.ERROR);
throw new ServiceAccessException(this, e.getMessage());
}
}
// ------------------------------------------------------ Protected Methods
/**
* Store a revision.
*/
protected void storeContent(String revisionUri, String revisionNumber,
NodeRevisionDescriptor revisionDescriptor,
NodeRevisionContent revisionContent)
throws IOException, SQLException {
PreparedStatement insertStatement = connection.prepareStatement
("insert into revisioncontent values(?, ?, ?)");
insertStatement.setString(1, revisionUri);
insertStatement.setString(2, revisionNumber);
InputStream is = revisionContent.streamContent();
if (is != null) {
OutputStream os = null;
// We copy 8 ko with each read
byte[] buffer = new byte[BUFFER_SIZE];
long position = 0;
long contentLength = revisionDescriptor.getContentLength();
File tempFile = null;
String tempFileName = null;
if (contentLength == -1) {
// If content length is unspecified, we have to buffer
// to a temp file.
try {
tempFileName = revisionUri + "-" + revisionNumber;
tempFileName = tempFileName.replace('/', '.');
int tempFileNameLength = tempFileName.length();
if (tempFileNameLength > 200)
tempFileName = tempFileName.substring
(tempFileNameLength - 200, tempFileNameLength);
tempFile = File.createTempFile(tempFileName, null);
FileOutputStream fos = new FileOutputStream(tempFile);
while (true) {
int nChar = is.read(buffer);
if (nChar == -1) {
break;
}
fos.write(buffer, 0, nChar);
position = position + nChar;
}
fos.close();
is = new FileInputStream(tempFile);
contentLength = tempFile.length();
}
catch (IOException ex) {
getLogger().log(ex.toString() + " during the calculation of the content length.",LOG_CHANNEL,Logger.ERROR);
getLogger().log("tempFileName: " + tempFileName,LOG_CHANNEL,Logger.ERROR);
getLogger().log("tempFile: " + tempFile.getAbsolutePath(),LOG_CHANNEL,Logger.ERROR);
throw ex;
}
}
// FIXME ? Cast from long to int won't allow files > 4GB.
insertStatement.setBinaryStream(3, is, (int) contentLength);
insertStatement.executeUpdate();
revisionDescriptor.setContentLength(contentLength);
if (tempFile != null) {
is.close();
tempFile.delete();
}
}
insertStatement.close();
}
/**
* Remove content.
*/
protected void removeContent(String revisionUri, String revisionNumber)
throws SQLException {
PreparedStatement deleteStatement = connection.prepareStatement
("delete from revisioncontent where uri = ? and xnumber = ?");
deleteStatement.setString(1, revisionUri);
deleteStatement.setString(2, revisionNumber);
deleteStatement.executeUpdate();
deleteStatement.close();
}
/**
* Close specified statement.
*/
protected void closeStatement(Statement statement) {
if (statement != null) {
try {
statement.close();
} catch (SQLException e) {
}
}
}
}
--
To unsubscribe, e-mail: <ma...@jakarta.apache.org>
For additional commands, e-mail: <ma...@jakarta.apache.org>