KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > exoplatform > services > workflow > impl > WorkflowConnectionProvider


1 /***************************************************************************
2  * Copyright 2001-2003 The eXo Platform SARL All rights reserved. *
3  * Please look at license.txt in info directory for more license detail. *
4  **************************************************************************/
5 package org.exoplatform.services.workflow.impl;
6
7 import net.sf.hibernate.HibernateException;
8 import net.sf.hibernate.connection.ConnectionProvider;
9
10 import javax.sql.DataSource JavaDoc;
11 import org.exoplatform.commons.Environment;
12 import org.exoplatform.container.PortalContainer;
13 import org.exoplatform.services.database.DatabaseService;
14 import java.sql.Connection JavaDoc;
15 import java.sql.SQLException JavaDoc;
16 import java.util.Properties JavaDoc;
17
18 public class WorkflowConnectionProvider implements ConnectionProvider {
19   private boolean autocommit_ ;
20
21   public WorkflowConnectionProvider() {
22     int platform = Environment.getInstance().getPlatform() ;
23     autocommit_ = true ;
24     if (platform == Environment.JBOSS_PLATFORM) {
25       autocommit_ = false ;
26     }
27   }
28
29   /**
30    * @see net.sf.hibernate.connection.ConnectionProvider#configure(java.util.Properties)
31    */
32   public void configure(Properties JavaDoc props) throws HibernateException {
33   }
34
35   /**
36    * @see net.sf.hibernate.connection.ConnectionProvider#getConnection()
37    */
38   public Connection JavaDoc getConnection() throws SQLException JavaDoc {
39     PortalContainer container = PortalContainer.getInstance();
40     DatabaseService dbService =
41       (DatabaseService) container.getComponentInstanceOfType(DatabaseService.class);
42     DataSource JavaDoc ds = dbService.getDataSource(DatabaseService.EXO_WORKFLOW_DATASOURCE_NAME) ;
43     Connection JavaDoc conn = ds.getConnection() ;
44     conn.setAutoCommit(autocommit_) ;
45     return conn ;
46   }
47
48   /**
49    * @see net.sf.hibernate.connection.ConnectionProvider#closeConnection(java.sql.Connection)
50    */
51   public void closeConnection(Connection JavaDoc conn) throws SQLException JavaDoc {
52     conn.close() ;
53   }
54
55   public void close() {
56   }
57 }
58
Popular Tags