You need to do some special setup on cloned connection for MS JDBC Driver. After I change the codes, it works for me. Please see attachement file.
Ting ----- Original Message ----- From: "Tom Wang" <[EMAIL PROTECTED]> To: "Slide Users Mailing List" <[EMAIL PROTECTED]> Sent: Friday, March 22, 2002 11:17 AM Subject: RE: Slide and MS JDBC driver > Yes we tested our product with it. It is essentailly unusable. We can't > believe Microsoft released it as beta. > > -Tom > > > > -----Original Message----- > > From: Jacob Lund [mailto:[EMAIL PROTECTED]] > > Sent: Friday, March 22, 2002 4:03 AM > > To: 'Slide Users Mailing List' > > Subject: Slide and MS JDBC driver > > > > > > Hi, > > > > Has anyone successfully tried Microsoft's own JDBC driver for sql server > > 2000? I know the driver is still in beta. > > > > /Jacob > > > > > > -- > > To unsubscribe, e-mail: > > <mailto:[EMAIL PROTECTED]> > > For additional commands, e-mail: > > <mailto:[EMAIL PROTECTED]> > > > > > > > -- > To unsubscribe, e-mail: <mailto:[EMAIL PROTECTED]> > For additional commands, e-mail: <mailto:[EMAIL PROTECTED]>
/* * $Header: /home/cvspublic/jakarta-slide/src/stores/slidestore/reference/JDBCDescriptorsStore.java,v 1.30 2002/01/16 23:43:53 remm Exp $ * $Revision: 1.30 $ * $Date: 2002/01/16 23:43:53 $ * * ==================================================================== * * 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 [EMAIL PROTECTED] * * 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.reference; import java.lang.reflect.Constructor; import java.util.Hashtable; import java.util.Enumeration; import java.util.Vector; import java.util.Date; import java.util.Properties; 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; /** * JDBC 1.0 and 2.0 compliant store implementation. * * @author <a href="mailto:[EMAIL PROTECTED]";>Remy Maucherat</a> * @author Dirk Verbeeck * @version $Revision: 1.30 $ */ public class JDBCDescriptorsStore extends AbstractSimpleService 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; /** * 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; } protected String getDatabaseConnectionTestStatement() { return "select 1 from objects where uri is null"; } /** * 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 { // Driver classname driver = (String) parameters.get("driver"); // Connection url url = (String) parameters.get("url"); // FIXME: before slide 1.0.12 the database url was passed // without "jdbc:" this compatibility code sould be removed in the // future code changed 18 jul 2001 if (!url.startsWith("jdbc:")) url="jdbc:" + url; // end compatibility code // User name user = (String) parameters.get("user"); if (user == null) { user = new String(); } // Password password = (String) parameters.get("password"); if (password == null) { password = new String(); } // JDBC version to use jdbcVersion = 1; String version = (String) parameters.get("jdbcversion"); if (version != null) { jdbcVersion = (new Integer(version)).intValue(); } } /** * 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 { // TING Fix Cloned Connection Problem for JDBC Driver String myurl = url.toLowerCase(); if (myurl.startsWith("jdbc:microsoft:sqlserver")) { Properties props = new Properties(); props.setProperty("selectmethod", "cursor"); props.setProperty("user", user); props.setProperty("password", password); connection = DriverManager.getConnection(myurl, props); } else connection = DriverManager.getConnection (url, user, password); } 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); } } /** * Tries to reconnect if needed but doesn't report failure. */ protected synchronized void connectIfNeededAndPossible() { try { connectIfNeeded(); } catch (Throwable ex) { // ignore } } /** * Initializes data source. * <p/> * Occurs in four steps : * <li>Driver class is loaded</li> * <li>Driver is intantiated</li> * <li>Driver registration in the driver manager</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 driver: " + driver,LOG_CHANNEL,Logger.INFO); Class driverClass = Class.forName(driver); Driver databaseDriver = (Driver) driverClass.newInstance(); DriverManager.registerDriver(databaseDriver); } catch (ClassNotFoundException e) { token.getLogger().log("Loading and registering driver " + driver + " failed",LOG_CHANNEL,Logger.ERROR); token.getLogger().log(e.toString(),LOG_CHANNEL,Logger.ERROR); throw new ServiceInitializationFailedException(this, e.getMessage()); } catch (InstantiationException e) { token.getLogger().log("Loading and registering driver " + driver + " failed",LOG_CHANNEL,Logger.ERROR); token.getLogger().log(e.toString(),LOG_CHANNEL,Logger.ERROR); throw new ServiceInitializationFailedException(this, e.getMessage()); } catch (IllegalAccessException e) { token.getLogger().log("Loading and registering driver " + driver + " failed",LOG_CHANNEL,Logger.ERROR); token.getLogger().log(e.toString(),LOG_CHANNEL,Logger.ERROR); throw new ServiceInitializationFailedException(this, e.getMessage()); } catch (SQLException e) { token.getLogger().log("Loading and registering driver " + driver + " failed",LOG_CHANNEL,Logger.ERROR); token.getLogger().log(e.toString(),LOG_CHANNEL,Logger.ERROR); throw new ServiceInitializationFailedException(this, e.getMessage()); } catch (ClassCastException e) { token.getLogger().log("Loading and registering driver " + driver + " 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 driver " + driver + " 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 { if ((connection == null) || (connection.isClosed())) { return false; } PreparedStatement statement = connection.prepareStatement(getDatabaseConnectionTestStatement()); statement.executeQuery(); statement.close(); // testStatement executed without throwing an exception return true; } 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); // test connection connectIfNeeded(); // discard changes made outside a tranaction connection.rollback(); } catch (Exception 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); connectIfNeededAndPossible(); 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); connectIfNeededAndPossible(); 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); connectIfNeededAndPossible(); 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); connectIfNeededAndPossible(); 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); connectIfNeededAndPossible(); 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); connectIfNeededAndPossible(); 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); connectIfNeededAndPossible(); 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); connectIfNeededAndPossible(); 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); connectIfNeededAndPossible(); 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); connectIfNeededAndPossible(); 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); connectIfNeededAndPossible(); 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); connectIfNeededAndPossible(); 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); connectIfNeededAndPossible(); 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); connectIfNeededAndPossible(); 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); connectIfNeededAndPossible(); 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); connectIfNeededAndPossible(); 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); connectIfNeededAndPossible(); 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); connectIfNeededAndPossible(); 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) { connectIfNeededAndPossible(); } } } }
-- To unsubscribe, e-mail: <mailto:[EMAIL PROTECTED]> For additional commands, e-mail: <mailto:[EMAIL PROTECTED]>
