开源j2ee 框架bbossgroups 1.0 数据库操作标签初探

yin_bp

浏览: 695374 次
性别:
来自: 长沙

最近访客更多访客>>

kennypho

ymgjava

luk7152

smile1979

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

博客分类：

bboss persistent

框架数据结构 SQL 配置管理 Oracle

看看开源j2ee 框架bbossgroups 中的dbutil,batchutil 标签来如何实现数据库的预编译/普通insert ， update ， delete ，预编译/普通批处理操作，比较简单也比较使用。
文章分三部分介绍：
        预编译/普通insert ， update ， delete 操作
        执行预编译/普通批处理操作标签
        连接池配置
    下面分别介绍。

[1] 预编译/普通insert ， update ， delete 操作

1.1.1 Insert 操作
<%@ page contentType = "text/html; charset=GBK" language = "java" import = "java.sql.*,java.util.List" errorPage = "" %>

1.1.1.1             导入标签定义文件
<%@ taglib uri = "/WEB-INF/pager-taglib.tld" prefix = "pg" %>

1.1.1.2 定义预编译 sql 语句

<%
    String object_id = "1" ;
    String owner = "duoduo" ;
    String object_name = "table_insert" ;
    String created = "2010-03-12 16:52:10" ;
    String last_ddl_time = "2010-03-12 16:52:11" ;
    String sql = "insert into sqltest(object_id,owner,object_name,created,last_ddl_time) values(#[object_id],#[owner],#[object_name],#[created],#[last_ddl_time])" ;

Sql 语句中的变量 #[object_id],#[owner],#[object_name],#[created],#[last_ddl_time]
的值和类型将在标签 pg:sqlparam 中指定
< html >
< head >
< title > 测试在 dbutil 标签上直接执行数据库插入操作 </ title >
</ head >
< body >
    < table >
1.1.1.3             Dbutil 执行预编译插入操作
           < pg:dbutil statement = "<%= sql %> "
                  dbname = "bspf"
                  pretoken = "#\\[" endtoken = "\\]"
                  action = "insert" >
statement 属性指定了先前定义的预编译插入语句
dbname 为数据库连接池的名称
pretoken = "#\\[" endtoken = "\\]" 分别指定了变量的分界符
action=insert 指定了本次执行的是 insert 操作。

1.1.1.4             指定各变量的值和类型
              < pg:sqlparam name = "object_id" value = "<%= object_id %> " type = "int" />
              < pg:sqlparam name = "owner" value = "<%= owner %> " type = "string" />
              < pg:sqlparam name = "object_name" value = "<%= object_name %> " type = "string" />
              < pg:sqlparam name = "created" value = "<%= created %> " type = "date" />
              < pg:sqlparam name = "last_ddl_time" value = "<%= last_ddl_time %> " type = "timestamp" />
           </ pg:dbutil >
<%= dbutil_result %>

Name 属性指定变量的名称，
Value 属性指定变量的值
Type 属性指定变量的类型，如果没有指定那么默认为字符串类型
dbutil_result 存放 insert 操作所插入的记录数
</ table >
</ body >
</ html >

上面说明的是预编译操作，要进行普通插入操作：
< pg:dbutil statement = "<%= sql %> "
                  dbname = "bspf"
                  pretoken = "#\\[" endtoken = "\\]"
                  action = "insert" >
</ pg:dbutil >

<%= dbutil_result %>
其中的 sql 为一条完成的插入语句即可。例如： insert into table （ name ） values(‘duoduo’) 。

1.1.2 update 操作
<%@ page contentType = "text/html; charset=GBK" language = "java" import = "java.sql.*,java.util.List" errorPage = "" %>

1.1.2.1 导入标签定义文件

<%@ taglib uri = "/WEB-INF/pager-taglib.tld" prefix = "pg" %>

1.1.2.2             定义预编译 sql 语句
<%
    String object_id = "1" ;
    String created = "2010-03-12 12:43:54" ;
    String sql = "update sqltest set created=#[created] where object_id=#[object_id]" ;
%>
Sql 语句中的变量 #[created], #[object_id] 的值和类型将在标签 pg:sqlparam 中指定
< html >
< head >
< title > 测试在 dbutil 标签上直接执行数据库 update 操作 </ title >
</ head >
< body >
    < table >
1.1.2.3             Dbutil 执行预编译修改操作
           < pg:dbutil statement = "<%= sql %> "
                  dbname = "bspf"
                  pretoken = "#\\[" endtoken = "\\]"
                  action = "update" >
statement 属性指定了先前定义的预编译 update 语句
dbname 为数据库连接池的名称
pretoken = "#\\[" endtoken = "\\]" 分别指定了变量的分界符
action=update 指定了本次执行的是 update 操作。

1.1.2.4             指定各变量的值和类型
              < pg:sqlparam name = "object_id" value = "<%= object_id %> " type = "int" />
              < pg:sqlparam name = "created" value = "<%= created %> " type = "timestamp" />
           </ pg:dbutil >
<%= dbutil_result %>
Name 属性指定变量的名称，
Value 属性指定变量的值
Type 属性指定变量的类型，如果没有指定那么默认为字符串类型
dbutil_result 存放 update 操作所修改的记录数

</ table >
</ body >
</ html >

上面说明的是预编译操作，要进行普通 update 操作：
< pg:dbutil statement = "<%= sql %> "
                  dbname = "bspf"
                  pretoken = "#\\[" endtoken = "\\]"
                  action = "update" >
</ pg:dbutil >
<%= dbutil_result %>
其中的 sql 为一条完整的 update 语句即可。例如： update table set name=‘duoduo’ 。

1.1.3 Delete 操作
<%@ page contentType = "text/html; charset=GBK" language = "java" import = "java.sql.*,java.util.List" errorPage = "" %>
1.1.3.1 导入标签定义文件

<%@ taglib uri = "/WEB-INF/pager-taglib.tld" prefix = "pg" %>

1.1.3.2 定义预编译 sql 语句

<%
String object_id = "15" ;
String sql = "delete from sqltest where object_id=#[object_id] " ;
%>

Sql 语句中的变量 #[object_id] 的值和类型将在标签 pg:sqlparam 中指定
< html >
< head >
< title > 测试在 dbutil 标签上直接执行数据库 delete 操作 </ title >
</ head >
< body >
< table >

1.1.3.3             Dbutil 执行预编译 delete 操作
< pg:dbutil statement = "<%= sql %> "
                  dbname = "bspf"
                  pretoken = "#\\[" endtoken = "\\]"
                   action = " delete" >
statement 属性指定了先前定义的预编译 delete 语句
dbname 为数据库连接池的名称
pretoken = "#\\[" endtoken = "\\]" 分别指定了变量的分界符
action= delete 指定了本次执行的是 delete 操作。
1.1.3.4             指定各变量的值和类型
    < pg:sqlparam name = "object_id" value = "<%= object_id %> " type = "int" />
</ pg:dbutil >
<%= dbutil_result %>

Name 属性指定变量的名称，
Value 属性指定变量的值
Type 属性指定变量的类型，如果没有指定那么默认为字符串类型
dbutil_result 存放 delete 操作所删除记录数
</ table >
</ body >
</ html >

上面说明的是预编译操作，要进行普通 delete 操作：
< pg:dbutil statement = "<%= sql %> "
                  dbname = "bspf"
                  pretoken = "#\\[" endtoken = "\\]"
                  action = " delete" >
</ pg:dbutil >
<%= dbutil_result %>
其中的 sql 为一条完整的 delete 语句即可。例如： delete frome table where name=‘duoduo’ 。

[2]执行预编译/普通批处理操作标签

相关的一组标签：batchutil,statement,batch,sqlparam
通过这组标签我们可以实现以下功能：

普通批处理操作

预编译批处理操作

下面详细说明上述功能。

1.1.1   普通批处理操作
<%@ page contentType="text/html; charset=GBK" language="java"%>
1.1.1.1             导入标签定义文件

<%@ taglib uri="/WEB-INF/pager-taglib.tld" prefix="pg"%>

1.1.1.2             定义一组要进行批处理操作的sql语句
<% String sql = "update sqltest set batch='1' where object_id=1";
    String sql1 = "update sqltest set batch='2' where object_id=1";
    String sql2 = "update sqltest set batch='3' where object_id=1";
    String sql3 = "update sqltest set batch='4' where object_id=1";
    String sql4 = "update sqltest set batch='5' where object_id=1";
%>
<html>
    <head>
       <title>测试在batchutil标签上直接执行数据库批处理操作</title>
    </head>
    <body>
       <table>
1.1.1.3             使用batchutil标签执行批处理操作

           <pg:batchutil dbname="bspf" type="common">
              <pg:statement sql="<%=sql %>" />
              <pg:statement sql="<%=sql1 %>" />
              <pg:statement sql="<%=sql2 %>" />
              <pg:statement sql="<%=sql3 %>" />
              <pg:statement sql="<%=sql4 %>" />
           </pg:batchutil>
       </table>
    </body>
</html>

1.1.2   预编译批处理操作
<%@ page contentType="text/html; charset=GBK" language="java"%>
1.1.2.1             导入标签定义文件
<%@ taglib uri="/WEB-INF/pager-taglib.tld" prefix="pg"%>

1.1.2.2             定义一组要进行预编译批处理操作的sql语句和参数组
预编译批处理操作可以是多条不同的预编译sql语句，也可以是同一条sql语句的多个不同的绑定变量参数组，也可以是混合的情况。下面我们使用一条sql语句和5组不同的绑定参数的情况做为示例来说明各种不同的情况。
<%
    String object_id = "1";

    String created = "2010-03-12 12:43:54";
    String created1 = "2010-03-13 12:43:54";
    String created2 = "2010-03-14 12:43:54";
    String created3 = "2010-03-15 12:43:54";
    String created4 = "2010-03-16 12:43:54";

    String sql = "update sqltest set created=#[created] where object_id=#[object_id]";
%>
<html>
    <head>
       <title>测试在batchutil标签上直接执行数据库预编译批处理操作</title>
    </head>
    <body>
       <table>
1.1.2.3             使用batchutil标签执行预编译批处理操作
           <pg:batchutil dbname="bspf" type="prepared">
              <pg:statement sql="<%=sql %>" pretoken="#\\[" endtoken="\\]">
1.1.2.3.1   多组不同的参数用batch标签来组织
                  <pg:batch>
                     <pg:sqlparam name="object_id" value="<%=object_id %>" type="int" />
                     <pg:sqlparam name="created" value="<%=created %>" type="timestamp" />
                  </pg:batch>
              </pg:statement>
              <pg:statement sql="<%=sql %>" pretoken="#\\[" endtoken="\\]">
                  <pg:batch>
                     <pg:sqlparam name="object_id" value="<%=object_id %>" type="int" />
                     <pg:sqlparam name="created" value="<%=created1 %>"
                         type="timestamp" />
                  </pg:batch>
              </pg:statement>
              <pg:statement sql="<%=sql %>" pretoken="#\\[" endtoken="\\]">
1.1.2.3.2   如果只有一组参数，那么不需要使用batch标签

                  <pg:sqlparam name="object_id" value="<%=object_id %>" type="int" />
                  <pg:sqlparam name="created" value="<%=created2 %>" type="timestamp" />

              </pg:statement>
              <pg:statement sql="<%=sql %>" pretoken="#\\[" endtoken="\\]">
                  <pg:batch>
                     <pg:sqlparam name="object_id" value="<%=object_id %>" type="int" />
                     <pg:sqlparam name="created" value="<%=created3 %>"
                         type="timestamp" />
                  </pg:batch>
                  <pg:batch>
                     <pg:sqlparam name="object_id" value="<%=object_id %>" type="int" />
                     <pg:sqlparam name="created" value="<%=created4 %>"
                         type="timestamp" />
                  </pg:batch>
              </pg:statement>
           </pg:batchutil>
       </table>
    </body>
</html>

如果要引入事务的话，可以在执行sql的标签代码的外围包一个事务即可使用的方法如下：
import com.frameworkset.orm.transaction.TransactionManager;
<%

                TransactionManager tm = new TransactionManager();
                try
                {
                        tm.begin();//开始事务
                       %>

                            放置操作数据库的标签代码
                       <%
                        tm.commit();//提交事务

                }
                catch(Exception e)
                {
                        try {
                                tm.rollback();//回滚事务
                        } catch (Exception e1) {

                                e1.printStackTrace();
                        }
                }
                %>

[3]连接池配置

概述
bboss persistent的配置文件为poolman.xml，位于classes目录下即可
1.bboss persistent框架支持多个数据源配置
2.bboss persistent框架默认采用apache common dbcp作为数据库连接池
3.bboss persistent框架可以引用外部数据源，例如tomcat，weblogic和WebSphere平台提供的datasource

基本配置实例，只配置了一个datasource，如果需要配置多个datasource，只需要按照相应格式再加数据源就可以了：
<?xml version="1.0" encoding="gb2312"?>
<poolman>
<datasource>
        
    <dbname>bspf</dbname>
    
        <loadmetadata>false</loadmetadata>
        
    <jndiName>bspf_datasource_jndiname</jndiName>
    
    <autoprimarykey>false</autoprimarykey>
     
    <cachequerymetadata>false</cachequerymetadata>
     
    <driver>oracle.jdbc.driver.OracleDriver</driver>
     
        <url>jdbc:oracle:thin:@//localhost:1521/orcl</url>
         
    <username>cmsnew</username>
     
    <password>cmsnew</password>
    
        <txIsolationLevel>READ_COMMITTED</txIsolationLevel>
         
    <initialConnections>2</initialConnections>
     
    <minimumSize>2</minimumSize>
     
    <maximumSize>8</maximumSize>
        
    <maximumSoft>false</maximumSoft>
    
    <removeAbandoned>true</removeAbandoned>
        
    <userTimeout>120</userTimeout>
    
    <logAbandoned>true</logAbandoned>

    
    <readOnly>true</readOnly>

        
        <skimmerFrequency>86400</skimmerFrequency>
        
        <connectionTimeout>120</connectionTimeout>
        
    <shrinkBy>4</shrinkBy>
    
    <testWhileidle>false</testWhileidle>

<!--
       （1）在tableinfo表中配置了sequence时，以下机制不起作用，
        定义数据库主键生成机制
        缺省的采用系统自带的主键生成机制，
        外步程序可以覆盖系统主键生成机制
        由值来决定
        auto:自动，一般在生产环境下采用该种模式，
               解决了单个应用并发访问数据库添加记录产生冲突的问题，效率高，如果生产环境下有多个应用并发访问同一数据库时，必须采用composite模式
        composite：结合自动和实时从数据库中获取最大的主键值两种方式来处理，开发环境下建议采用该种模式，
                   解决了多个应用同时访问数据库添加记录时产生冲突的问题，效率相对较低，如果生产环境下有多个应用并发访问同一数据库时，必须采用composite模式

      （2）通过以下方法获取主键
   DBUtil中的下述方法获取主键
       DBUtil.getNextPrimaryKey(Connection, tablename)
       DBUtil.getNextPrimaryKey(Connection, dbname, tablename)
       DBUtil.getNextPrimaryKey(tablename)
       DBUtil.getNextPrimaryKey(dbname, tablename)
       DBUtil.getNextStringPrimaryKey(Connection, tablename)
       DBUtil.getNextStringPrimaryKey(Connection, dbname, tablename)
       DBUtil.getNextStringPrimaryKey(tablename)
       DBUtil.getNextStringPrimaryKey(dbname, tablename)

       前提是tablename对应的表的主键信息必须配置在tableinfo表中,tableinfo表的结构为：

名称是否为空? 类型描述
----------------------------------------- -------- ----------------------------

TABLE_NAME                                NOT NULL VARCHAR2(255)          表名称
TABLE_ID_NAME                                      VARCHAR2(255)          表的主键名称
TABLE_ID_INCREMENT                                 NUMBER(5)              表主键的自增值
TABLE_ID_VALUE                                     NUMBER(20)             表主键当前值，已经不使用
TABLE_ID_GENERATOR                                 VARCHAR2(255)          表主键生成机制，只有TABLE_ID_TYPE为sequence时才需填为相应sequence的名称
TABLE_ID_TYPE                                      VARCHAR2(255)          表主键的数值类型，int,long,string，sequence，如果为sequence时必须指定TABLE_ID_GENERATOR为对应的sequence的名称
TABLE_ID_PREFIX                                    VARCHAR2(255)          为表主键添加统一的前缀，默认为null，只有表主键类型为string时才能指定前缀。

    -->
    <keygenerate>composite</keygenerate>

<maxWait>10</maxWait>

    
    <validationQuery>select 1 from dual</validationQuery>
        
    <synsequence>false</synsequence>

    
    <poolingPreparedStatements>false</poolingPreparedStatements>
    
    <maxOpenPreparedStatements>-1</maxOpenPreparedStatements>
    
    <showsql>true</showsql>
</datasource>
</poolman>

外部数据源实例
<?xml version="1.0" encoding="gb2312"?>
<poolman>
<datasource external=“true”>
        
    <dbname>bspf</dbname>
    
        <loadmetadata>false</loadmetadata>
        
    <jndiName>bspf_datasource_jndiname</jndiName>
   
    <externaljndiName>external_bspf_datasource_jndiname</externaljndiName>
    
    <autoprimarykey>false</autoprimarykey>
     
    <cachequerymetadata>false</cachequerymetadata>
     
    <driver>oracle.jdbc.driver.OracleDriver</driver>

名称是否为空? 类型描述
----------------------------------------- -------- ----------------------------

<showsql>true</showsql>
</datasource>
</poolman>

分享到：

bbossgroups 1.0rc版本的rpc框架增加jbos ... | 采用jquery来分页，排序，查询

2010-04-20 10:50
浏览 1627
评论(0)
论坛回复 / 浏览 (0 / 1866)
分类:编程语言
查看更多

发表评论

您还没有登录,请您登录后再发表评论

最近访客更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论