文档章节

activiti 数据库连接配置

loyal
 loyal
发布于 2016/05/05 21:51
字数 1374
阅读 86
收藏 0

1.1.1. 前言

activiti 动态配置 activiti 监听引擎启动和初始化(高级源码篇)一文中,我们讲解了如何动态的配置DataSource

当我们程序配置了DataSource,activiti 工作流引擎是如何打开数据库连接呢?有没有其他的方式配置数据库连接呢?

这一个章节主要讲解activiti 工作流引擎数据库连接的其他配置方式,以及底层如何封装连接,打开连接操作数据库。本章先从配置入手,了解常用的配置方法,以及引领大家阅读代码,使大家的印象更深刻,而不是只会配置,了解原理才是最重要的。

1.1.2. Datadource方式配置

Datasource的配置如下所示:

  <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"   destroy-method="close">  

    <property name="driverClassName" value="com.mysql.jdbc.Driver" />  

    <property name="url"  value="jdbc:mysql://localhost:3306/activiti" />  

    <property name="username" value="root" />  

    <property name="password" value="********" />  

</bean>  

工作流引擎的配置如下所示:

 <bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">

<property name="dataSource"  ref=”dataSource” />  

</bean>

1.1.3. 普通方式配置

<bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">

    <property name="driverClassName" value="com.mysql.jdbc.Driver" />  

    <property name="url"  value="jdbc:mysql://localhost:3306/activiti" />  

    <property name="username" value="root" />  

<property name="password" value="********" />  

</bean>

 

1.1.4. jndi方式配置

此种配置需要在server.xml中配置具体的数据源信息,具体的配置步骤如下:

  1、在tomcat服务器的lib目录下加入数据库连接的驱动jar

 

2、修改tomcat服务器的conf目录下server.xml配置文件

 

 

3、修改tomcat服务器的conf目录下server.xml配置文件

打开server.xml配置文件,可以看到里面自带的一个全局JNDI配置,如下图所示:

 

 编辑server.xml文件,添加全局JNDI数据源配置,配置如下:

 <Resource      

 name="jdbc/mysql"   

auth="Container"          

type="javax.sql.DataSource"      

  maxActive="100"      

   maxIdle="30"       

    maxWait="10000"47    

     username="root"

password="root"        

driverClassName="com.mysql.jdbc.Driver"50         url="jdbc:mysql://192.168.1.144:3306/leadtest?useUnicode=true&characterEncoding=utf-8"/>

 经过以上的两个步骤,全局JNDI数据源就配置好了,在上述的server.xml文件中,配置了MySQL数据库的全局JNDI数据源。

上面的配置完成了程序中怎么使用呢?

dataSourceJndiName

 <bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">

<property name="dataSourceJndiName"  ref=”dataSourceJndiName” />  

</bean>

1.1.5. initDataSource源码

上面的三种配置足够我们用了,那么这三种方式那种优先级比较高,换言之,那种方式的优先级比较高呢。下面我们就开始跟进源码看看activiti内核 是如何解析执行的吧。

首先进入org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl查找initDataSource()方法详细解析如下:

protected void initDataSource() {
//首先判断dataSource是否存在看来这个优先级是最高的了。
if (dataSource==null) {
//如果dataSource不存在则查找dataSourceJndiName是否配置了,如果jndi配置了使用。
      if (dataSourceJndiName!=null) {
        try {
//查找jndi配置信息。
          dataSource = (DataSource) new InitialContext().lookup(dataSourceJndiName);
        } catch (Exception e) {
          throw new ActivitiException("couldn't lookup datasource from "+dataSourceJndiName+": "+e.getMessage(), e);
        }
        //如果上面的datasource和jndi都不存在就直接使用普通的方式 进行配置获取初始化PooledDataSource
      } else if (jdbcUrl!=null) {
//任何一个为报错
        if ( (jdbcDriver==null) || (jdbcUrl==null) || (jdbcUsername==null) ) {
          throw new ActivitiException("DataSource or JDBC properties have to be specified in a process engine configuration");
        }
//根据配置创建PooledDataSource 对象
        PooledDataSource pooledDataSource =
          new PooledDataSource(ReflectUtil.getClassLoader(), jdbcDriver, jdbcUrl, jdbcUsername, jdbcPassword );
        //下面是配置其他的数据库连接池信息
        if (jdbcMaxActiveConnections > 0) {
          pooledDataSource.setPoolMaximumActiveConnections(jdbcMaxActiveConnections);
        }
        if (jdbcMaxIdleConnections > 0) {
          pooledDataSource.setPoolMaximumIdleConnections(jdbcMaxIdleConnections);
        }
        if (jdbcMaxCheckoutTime > 0) {
          pooledDataSource.setPoolMaximumCheckoutTime(jdbcMaxCheckoutTime);
        }
        if (jdbcMaxWaitTime > 0) {
          pooledDataSource.setPoolTimeToWait(jdbcMaxWaitTime);
        }
        if (jdbcPingEnabled == true) {
          pooledDataSource.setPoolPingEnabled(true);
          if (jdbcPingQuery != null) {
            pooledDataSource.setPoolPingQuery(jdbcPingQuery);
          }
          pooledDataSource.setPoolPingConnectionsNotUsedFor(jdbcPingConnectionNotUsedFor);
        }
        if (jdbcDefaultTransactionIsolationLevel > 0) {
          pooledDataSource.setDefaultTransactionIsolationLevel(jdbcDefaultTransactionIsolationLevel);
        }
        dataSource = pooledDataSource;
      }
      
      if (dataSource instanceof PooledDataSource) {
//调用forceCloseAll方法,如果不调用Ibatis 数据库池子拿不到上面的数据库配置连接信息
        ((PooledDataSource)dataSource).forceCloseAll();
      }
    }
//如果程序没有配置databaseType  数据库类型则activiti自己根据连接字符串打开一次请求获取类型
    if (databaseType == null) {
      initDatabaseType();
    }
  }


1.1.6. databaseType 优化

initDatabaseType()详细的方法如下:

//说白了就是反射数据库拿到元数据信息进行判断 这里最好配置一次可以优化的地方,没有配置的话要打开一次数据库连接

public void initDatabaseType() {
    Connection connection = null;
try {
      connection = dataSource.getConnection();
//根据连接获取到元数据信息
      DatabaseMetaData databaseMetaData = connection.getMetaData();
//获取到数据库生产厂商信息
      String databaseProductName = databaseMetaData.getDatabaseProductName();
      log.debug("database product name: '{}'", databaseProductName);
//因为市面上的数据库库厂商是固定的所以这里一次性加载到内存然后根据查找的数据库厂商匹配
      databaseType = databaseTypeMappings.getProperty(databaseProductName);
      if (databaseType==null) {
        throw new ActivitiException("couldn't deduct database type from database product name '"+databaseProductName+"'");
      }
    } catch (SQLException e) {
    } finally {
      try {
//上面打开了连接所以这里释放了连接
        if (connection!=null) {
          connection.close();
        }
      } catch (SQLException e) {
          log.error("Exception while closing the Database connection", e);
      }
    }
  }


数据库datatype与数据库厂商的映射如下:

 

public static final String DATABASE_TYPE_H2 = "h2";
  public static final String DATABASE_TYPE_HSQL = "hsql";
  public static final String DATABASE_TYPE_MYSQL = "mysql";
  public static final String DATABASE_TYPE_ORACLE = "oracle";
  public static final String DATABASE_TYPE_POSTGRES = "postgres";
  public static final String DATABASE_TYPE_MSSQL = "mssql";
  public static final String DATABASE_TYPE_DB2 = "db2";
 protected static Properties getDefaultDatabaseTypeMappings() {
    Properties databaseTypeMappings = new Properties();
    databaseTypeMappings.setProperty("H2", DATABASE_TYPE_H2);
    databaseTypeMappings.setProperty("HSQL Database Engine", DATABASE_TYPE_HSQL);
    databaseTypeMappings.setProperty("MySQL", DATABASE_TYPE_MYSQL);
    databaseTypeMappings.setProperty("Oracle", DATABASE_TYPE_ORACLE);
    databaseTypeMappings.setProperty("PostgreSQL", DATABASE_TYPE_POSTGRES);
    databaseTypeMappings.setProperty("Microsoft SQL Server", DATABASE_TYPE_MSSQL);
    databaseTypeMappings.setProperty(DATABASE_TYPE_DB2,DATABASE_TYPE_DB2);
    databaseTypeMappings.setProperty("DB2",DATABASE_TYPE_DB2);
    databaseTypeMappings.setProperty("DB2/NT",DATABASE_TYPE_DB2);
    databaseTypeMappings.setProperty("DB2/NT64",DATABASE_TYPE_DB2);
    databaseTypeMappings.setProperty("DB2 UDP",DATABASE_TYPE_DB2);
    databaseTypeMappings.setProperty("DB2/LINUX",DATABASE_TYPE_DB2);
    databaseTypeMappings.setProperty("DB2/LINUX390",DATABASE_TYPE_DB2);
    databaseTypeMappings.setProperty("DB2/LINUXX8664",DATABASE_TYPE_DB2);
    databaseTypeMappings.setProperty("DB2/LINUXZ64",DATABASE_TYPE_DB2);
    databaseTypeMappings.setProperty("DB2/LINUXPPC64",DATABASE_TYPE_DB2);
    databaseTypeMappings.setProperty("DB2/400 SQL",DATABASE_TYPE_DB2);
    databaseTypeMappings.setProperty("DB2/6000",DATABASE_TYPE_DB2);
    databaseTypeMappings.setProperty("DB2 UDB iSeries",DATABASE_TYPE_DB2);
    databaseTypeMappings.setProperty("DB2/AIX64",DATABASE_TYPE_DB2);
    databaseTypeMappings.setProperty("DB2/HPUX",DATABASE_TYPE_DB2);
    databaseTypeMappings.setProperty("DB2/HP64",DATABASE_TYPE_DB2);
    databaseTypeMappings.setProperty("DB2/SUN",DATABASE_TYPE_DB2);
    databaseTypeMappings.setProperty("DB2/SUN64",DATABASE_TYPE_DB2);
    databaseTypeMappings.setProperty("DB2/PTX",DATABASE_TYPE_DB2);
    databaseTypeMappings.setProperty("DB2/2",DATABASE_TYPE_DB2);
    databaseTypeMappings.setProperty("DB2 UDB AS400", DATABASE_TYPE_DB2);
    return databaseTypeMappings;
  }

上面详细的总结了activiti 工作流引擎常用的数据库连接配置,以及优先级的问题,数据库databaseType可以优化性能。

具体的封装自己的datasource可以参考mysql数据库连接池使用(二)实现自己的数据库连接池文章

本文转载自:http://blog.csdn.net/qq_30739519/article/details/51173670

共有 人打赏支持
loyal

loyal

粉丝 70
博文 68
码字总数 334
作品 0
技术主管
私信 提问
activiti事务和自己业务事务共同的使用

本人博客开始迁移,博客整个架构自己搭建及编码 http://www.cookqq.com/listBlog.action 一个数据库事务通常包含了一个序列的对数据库的读/写操作。它的存在包含有以下两个目的: 为数据库操...

cookqq
2013/11/22
0
0
Activiti 工作流学习 (三)

上一篇 Activiti 工作流学习(二) 都是在网上找的一些基本概念,引用的文档比较多比较杂,就不一一列出了。再此表示感谢。 关键对象 1. Deployment:流程部署对象,部署一个流程时创建。 2....

雷斯林
2016/12/10
139
0
推荐csdn里的几篇activiti基础入门及提高的博客

昨天有个网友加qq询问我有没有非maven搭建的activiti项目的demo,因为我博客中写了一个用maven,我当时没有,于是晚上回家尝试了一下,结果比较容易就实现了。 之后和那个网友聊了一下,他说...

涂宗勋
2016/04/20
338
0
activiti 部署在oracle多用户下不能自动建表,求解决?

Oracle11g下有两个用户,bpm与bpm_test用户。两个用户都部署了工作流程,一个是正式环境、一个是测试环境。当两个用户都没有activiti的表时,把databaseSchemaUpdate设置成true时,activiti在...

Jack_dun
2014/03/20
4.4K
3
Activiti工作流引擎初学教程

http://wenku.baidu.com/view/bb7364ad4693daef5ff73d32.html 1. 初识Activiti 1.1. 工作流与工作流引擎 工作流(workflow)就是工作流程的计算模型,即将工作流程中的工作如何前后组织在一起...

孟飞阳
2016/07/31
469
0

没有更多内容

加载失败,请刷新页面

加载更多

如何开发一款以太坊(安卓)钱包系列2 - 导入账号及账号管理

这是如何开发一款以太坊(安卓)钱包系列第2篇,如何导入账号。有时用户可能已经有一个账号,这篇文章接来介绍下,如何实现导入用户已经存在的账号。 导入账号预备知识 从用户需求上来讲,导...

Tiny熊
今天
2
0
intellJ IDEA搭建java+selenium自动化环境(maven,selenium,testng)

1.安装jdk1.8; 2.安装intellJ; 3.安装maven; 3.1 如果是单前用户,配置用户环境变量即可,如果是多用户,则需配置系统环境变量,变量名为MAVEN_HOME,赋值D:\Application\maven,往path中...

不最醉不龟归
今天
4
0
聊聊ShenandoahGC的Brooks Pointers

序 本文主要研究一下ShenandoahGC的Brooks Pointers Shenandoah Shenandoah面向low-pause-time的垃圾收集器,它的GC cycle主要有 Snapshot-at-the-beginning concurrent mark包括Init Mark(P......

go4it
昨天
4
0
Makefile通用编写规则

#简单实用的Makefile模板: objs := a.o b.o test:$(objs) gcc -o test $^ # .a.o.d .b.o.d dep_files := $(foreach f,$(objs),.$(f).d) dep_files := $(wildcard $(dep_files)) ifneq ($(d......

shzwork
昨天
3
0
《万历十五年》的读后感作文4000字

《万历十五年》的读后感作文4000字: 万历十五年,即1587年,距今已过去432年。在明朝276的历史中,这一年很平淡,并没有什么特别之处。黄仁宇的《万历十五年》一书,有别于其他的历史叙述方...

原创小博客
昨天
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部