yin_bp
- 浏览: 669017 次
- 性别:
- 来自: 长沙
-
文章分类
- 全部博客 (364)
- quick start (57)
- bboss aop (43)
- bboss mvc (48)
- bboss persistent (96)
- bboss taglib (30)
- bboss event (10)
- bbossgroups (52)
- bboss (32)
- bboss会话共享 (17)
- bboss rpc (7)
- bboss 国际化 (5)
- bboss 序列化 (9)
- bboss cxf webservice (8)
- bboss hessian (3)
- bboss 安全认证SSO (15)
- bboss 工作流 (6)
- 平台 (18)
- bboss quartz (3)
- 杂谈 (5)
- 大数据 (1)
- bboss elastic (24)
- bboss http (1)
- bboss kafka (1)
- Elasticsearch Scroll和Slice Scroll查询API使用案例 (1)
最新评论
-
qianhao123：
...
采用gradle构建和发布bboss方法介绍 -
qianhao123：
[img][/img]
采用gradle构建和发布bboss方法介绍 -
yin_bp：
欢迎大家参与working
高性能elasticsearch ORM开发库使用介绍 -
qq641879434：
万分感谢
bboss 持久层sql xml配置文件编写和加载方法介绍 -
yin_bp：
qq641879434 写道怎么设置配置文件 可以查看执行的S ...
bboss 持久层sql xml配置文件编写和加载方法介绍
bboss 持久层框架CallableDBUtil组件执行存储过程和函数实例
本文以两个例子来介绍如何通过bboss 持久层框架的CallableDBUtil组件来执行函数和存储过程。切入正题。
函数执行实例：
存储过程执行实例：
函数执行实例：
package com.frameworkset.common;
import javax.transaction.RollbackException;
import com.frameworkset.common.poolman.CallableDBUtil;
import com.frameworkset.common.poolman.Record;
import com.frameworkset.orm.transaction.TransactionManager;
public class TestCallableFunction {
public static void testTest_fWithPositionIndex()
{
CallableDBUtil callableDBUtil = new CallableDBUtil();
try
{
callableDBUtil.prepareCallable("{? = call Test_f(?,?,?)}");
callableDBUtil.registerOutParameter(1, java.sql.Types.INTEGER);
callableDBUtil.setInt(2, 10);
callableDBUtil.registerOutParameter(3, java.sql.Types.VARCHAR);
callableDBUtil.registerOutParameter(4, java.sql.Types.VARCHAR);
callableDBUtil.executeCallable();
System.out.println("ret:" + callableDBUtil.getInt(1));
System.out.println("name:" + callableDBUtil.getString(3));
System.out.println("name1:" + callableDBUtil.getString(4));
}
catch(Exception e)
{
e.printStackTrace();
}
}
/**
* 执行函数时不能通过命名方式绑定变量
*/
public static void testTest_fWithNameIndex()
{
CallableDBUtil callableDBUtil = new CallableDBUtil();
try
{
callableDBUtil.prepareCallable("{? = call Test_f(?,?,?)}");
callableDBUtil.registerOutParameter(1, java.sql.Types.INTEGER);
callableDBUtil.setInt(2, 10);
callableDBUtil.registerOutParameter(3, java.sql.Types.VARCHAR);
callableDBUtil.registerOutParameter(4, java.sql.Types.VARCHAR);
callableDBUtil.executeCallable();
System.out.println("ret:" + callableDBUtil.getInt(1));
System.out.println("name:" + callableDBUtil.getString(3));
System.out.println("name1:" + callableDBUtil.getString(4));
}
catch(Exception e)
{
e.printStackTrace();
}
}
public static void testTest_fWithNameIndexForXMLString()
{
CallableDBUtil callableDBUtil = new CallableDBUtil();
try
{
callableDBUtil.prepareCallable("{? = call Test_f(?,?,?)}");
callableDBUtil.registerOutParameter(1, java.sql.Types.INTEGER);
//不允许的操作: Ordinal binding and Named binding cannot be combined!
callableDBUtil.setInt(2, 10);
callableDBUtil.registerOutParameter(3, java.sql.Types.VARCHAR);
callableDBUtil.registerOutParameter(4, java.sql.Types.VARCHAR);
String xmlString = callableDBUtil.executeCallableForXML();
// System.out.println("name1:" + callableDBUtil.getString("name"));
// System.out.println("name2:" + callableDBUtil.getString("name1"));
System.out.println("xmlString:" + xmlString);
}
catch(Exception e)
{
e.printStackTrace();
}
}
/**
* 对于函数的调用使能使用顺序位置标识来绑定变量
*/
public static void testTest_fWithNameIndexForXMLStringRowHandler()
{
CallableDBUtil callableDBUtil = new CallableDBUtil();
try
{
callableDBUtil.prepareCallable("{? = call Test_f(?,?,?)}");
//不允许的操作: Ordinal binding and Named binding cannot be combined!
callableDBUtil.registerOutParameter(1, java.sql.Types.INTEGER);
callableDBUtil.setInt(2, 10);
callableDBUtil.registerOutParameter(3, java.sql.Types.VARCHAR);
callableDBUtil.registerOutParameter(4, java.sql.Types.VARCHAR);
String xmlString = callableDBUtil.executeCallableForXML(new com.frameworkset.common.poolman.handle.RowHandler()
{
/**
* 对已经处理好的行记录进行处理的逻辑
* @param rowValue
*/
public void handleRow(Object rowValue,Record record)
{
StringBuffer objects = (StringBuffer)rowValue;
objects.append(record);
System.out.println("objects:" + objects);
}
});
// System.out.println("name1:" + callableDBUtil.getString("name"));
// System.out.println("name2:" + callableDBUtil.getString("name1"));
System.out.println("xmlString:" + xmlString);
}
catch(Exception e)
{
e.printStackTrace();
}
}
public static void testTest_fWithNameIndexForObject()
{
CallableDBUtil callableDBUtil = new CallableDBUtil();
try
{
callableDBUtil.prepareCallable("{? = call Test_f(?,?,?)}");
callableDBUtil.registerOutParameter(1, java.sql.Types.INTEGER);
callableDBUtil.setInt(2, 10);
callableDBUtil.registerOutParameter(3, java.sql.Types.VARCHAR);
callableDBUtil.registerOutParameter(4, java.sql.Types.VARCHAR);
Test_f tets = (Test_f)callableDBUtil.executeCallableForObject(Test_f.class,new com.frameworkset.common.poolman.handle.RowHandler()
{
public void handleRow(Object rowValue,Record record) {
Test_f objects = (Test_f)rowValue;
try
{
objects.setRet(record.getString(1));
objects.setName(record.getString(3));
objects.setName1(record.getString(4));
}
catch(Exception e)
{
}
// origine.put(new Integer(4), "55");
System.out.println("rowValue:" + rowValue);
}
}
);
// System.out.println("name1:" + callableDBUtil.getString("name"));
// System.out.println("name2:" + callableDBUtil.getString("name1"));
System.out.println("Test_f is " + tets);
}
catch(Exception e)
{
e.printStackTrace();
}
}
/**
* 经过测试证明存储过程中如果没有对插入/删除/修改操作做事务提交、回滚时，可以通过poolman
* 的事务框架来管理事务;如果存储过程中对插入/删除/修改操作已经做了事务提交或者回滚时，那么应用的事务和存储过程中
* 中的事务就是分离的两个事务。
* @param i 为0时回滚事务，1时提交事务
*/
public static void testTest_fWithNameIndexForObjectTx(int i)
{
TransactionManager tm = new TransactionManager();
try
{
tm.begin();
CallableDBUtil callableDBUtil = new CallableDBUtil();
callableDBUtil.prepareCallable("{? = call Test_f(?,?,?)}");
callableDBUtil.registerOutParameter(1, java.sql.Types.INTEGER);
//不允许的操作: Ordinal binding and Named binding cannot be combined!
callableDBUtil.setInt(2, 10);
callableDBUtil.registerOutParameter(3, java.sql.Types.VARCHAR);
callableDBUtil.registerOutParameter(4, java.sql.Types.VARCHAR);
Test_f tets = (Test_f)callableDBUtil.executeCallableForObject(Test_f.class);
// System.out.println("name1:" + callableDBUtil.getString("name"));
// System.out.println("name2:" + callableDBUtil.getString("name1"));
System.out.println("Test_f is " + tets);
callableDBUtil.executeInsert("insert into test(id,name) values('11','name11')");
if(i == 0)
tm.rollback();
else
tm.commit();
}
catch(Exception e)
{
try {
tm.rollback();
} catch (RollbackException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
e.printStackTrace();
}
}
public static void main(String[] args)
{
System.out.println("1------------------------------------------testTest_fWithNameIndexForObject()");
testTest_fWithNameIndexForObject();
System.out.println("2------------------------------------------testTest_fWithNameIndexForObjectTx(1)");
testTest_fWithNameIndexForObjectTx(1);
System.out.println("3------------------------------------------testTest_fWithPositionIndex()");
testTest_fWithPositionIndex();
System.out.println("4------------------------------------------testTest_fWithNameIndexForXMLString()");
testTest_fWithNameIndexForXMLString();
System.out.println("5------------------------------------------testTest_fWithNameIndexForXMLStringRowHandler()");
testTest_fWithNameIndexForXMLStringRowHandler();
CallableDBUtil.debugStatus();
}
}
存储过程执行实例：
package com.frameworkset.common;
import java.sql.SQLException;
import javax.transaction.RollbackException;
import com.frameworkset.common.poolman.CallableDBUtil;
import com.frameworkset.common.poolman.PreparedDBUtil;
import com.frameworkset.common.poolman.Record;
import com.frameworkset.common.poolman.handle.RowHandler;
import com.frameworkset.common.poolman.util.SQLResult;
import com.frameworkset.orm.transaction.TransactionManager;
public class TestCallableDBUtil {
public static void testTest_pWithPositionIndex()
{
CallableDBUtil callableDBUtil = new CallableDBUtil();
try
{
// callableDBUtil.execute("{call test_p(1,'ss',3,4)}");
callableDBUtil.prepareCallable("{call test_p(?,?,?,?)}");
callableDBUtil.setInt(1, 10);
callableDBUtil.registerOutParameter(2, java.sql.Types.VARCHAR);
callableDBUtil.registerOutParameter(3, java.sql.Types.VARCHAR);
callableDBUtil.registerOutParameter(4, java.sql.Types.INTEGER);
callableDBUtil.executeCallable();
System.out.println("name1:" + callableDBUtil.getString(2));
System.out.println("name2:" + callableDBUtil.getString(3));
System.out.println("test:" + callableDBUtil.getInt(4));
}
catch(Exception e)
{
e.printStackTrace();
}
}
public static void testTest_pWithNameIndex()
{
CallableDBUtil callableDBUtil = new CallableDBUtil();
try
{
callableDBUtil.prepareCallable("{call test_p(?,?,?,?)}");
//不允许的操作: Ordinal binding and Named binding cannot be combined!
callableDBUtil.setInt("id", 10);
callableDBUtil.registerOutParameter("name", java.sql.Types.VARCHAR);
callableDBUtil.registerOutParameter("name1", java.sql.Types.VARCHAR);
callableDBUtil.registerOutParameter("test", java.sql.Types.INTEGER);
callableDBUtil.executeCallable();
System.out.println("name1:" + callableDBUtil.getString("name"));
System.out.println("name2:" + callableDBUtil.getString("name1"));
System.out.println("test:" + callableDBUtil.getInt("test"));
}
catch(Exception e)
{
e.printStackTrace();
}
}
public static void testTest_pWithNameIndexForXMLString()
{
CallableDBUtil callableDBUtil = new CallableDBUtil();
try
{
callableDBUtil.prepareCallable("{call test_p(?,?,?,?,?)}");
//不允许的操作: Ordinal binding and Named binding cannot be combined!
callableDBUtil.setInt("id", 10);
callableDBUtil.registerOutParameter("name", java.sql.Types.VARCHAR);
callableDBUtil.registerOutParameter("name1", java.sql.Types.VARCHAR);
callableDBUtil.registerOutParameter("test", java.sql.Types.INTEGER);
callableDBUtil.registerOutParameter("nomatch", java.sql.Types.INTEGER);
String xmlString = callableDBUtil.executeCallableForXML();
System.out.println("xmlString:" + xmlString);
// System.out.println("name1:" + callableDBUtil.getString("name"));
// System.out.println("name2:" + callableDBUtil.getString("name1"));
// System.out.println("test:" + callableDBUtil.getInt("test"));
}
catch(Exception e)
{
e.printStackTrace();
}
}
public static void testTest_pWithNameIndexForXMLStringRowHandler()
{
CallableDBUtil callableDBUtil = new CallableDBUtil();
try
{
callableDBUtil.prepareCallable("{call test_p(?,?,?,?)}");
//不允许的操作: Ordinal binding and Named binding cannot be combined!
callableDBUtil.setInt("id", 10);
callableDBUtil.registerOutParameter("name", java.sql.Types.VARCHAR);
callableDBUtil.registerOutParameter("name1", java.sql.Types.VARCHAR);
callableDBUtil.registerOutParameter("test", java.sql.Types.INTEGER);
String xmlString = callableDBUtil.executeCallableForXML(new com.frameworkset.common.poolman.handle.RowHandler()
{
/**
* 对已经处理好的行记录进行处理的逻辑
* @param rowValue
*/
public void handleRow(Object rowValue,Record origine)
{
Object objects = (Object)rowValue;
System.out.println("objects rowhandler:" + objects);
// System.out.println("objects【0】:" + objects[0]);
// System.out.println(objects[1]);
}
});
System.out.println("name1:" + callableDBUtil.getString("name"));
System.out.println("name2:" + callableDBUtil.getString("name1"));
System.out.println("xmlString:" + xmlString);
}
catch(Exception e)
{
e.printStackTrace();
}
}
public static void testTest_pWithNameIndexForObject()
{
CallableDBUtil callableDBUtil = new CallableDBUtil();
try
{
callableDBUtil.prepareCallable("{call test_p(?,?,?,?,?)}");
//不允许的操作: Ordinal binding and Named binding cannot be combined!
callableDBUtil.setInt("id", 10);
callableDBUtil.registerOutParameter("name", java.sql.Types.VARCHAR);
callableDBUtil.registerOutParameter("name1", java.sql.Types.VARCHAR);
callableDBUtil.registerOutParameter("test", java.sql.Types.INTEGER);
callableDBUtil.registerOutParameter("nomatch", java.sql.Types.INTEGER);
Test_p tets = (Test_p)callableDBUtil.executeCallableForObject(Test_p.class);
System.out.println("Test_p is " + tets);
}
catch(Exception e)
{
e.printStackTrace();
}
}
public static void testoldMethod()
{
PreparedDBUtil callableDBUtil = new PreparedDBUtil();
try {
SQLResult result = callableDBUtil.execute("select * from tableinfo");
System.out.println(result.size());
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public static void testTest_pWithNameIndexForObjectWithRowHandler()
{
CallableDBUtil callableDBUtil = new CallableDBUtil();
try
{
callableDBUtil.prepareCallable("{call test_p(?,?,?,?)}");
//不允许的操作: Ordinal binding and Named binding cannot be combined!
callableDBUtil.setInt("id", 10);
callableDBUtil.registerOutParameter("name", java.sql.Types.VARCHAR);
callableDBUtil.registerOutParameter("name1", java.sql.Types.VARCHAR);
callableDBUtil.registerOutParameter("test", java.sql.Types.INTEGER);
Test_p tets = (Test_p)callableDBUtil.executeCallableForObject(Test_p.class,new RowHandler(){
public void handleRow(Object rowValue, Record record) {
Test_p test_p = (Test_p)rowValue;
try {
test_p.setTest(record.getString("test")+"天马");
test_p.setName1(record.getString("name1"));
test_p.setName(record.getString("name"));
} catch (SQLException e) {
e.printStackTrace();
}
}
});
// System.out.println("name1:" + callableDBUtil.getString("name"));
// System.out.println("name2:" + callableDBUtil.getString("name1"));
System.out.println("Test_p is " + tets);
}
catch(Exception e)
{
e.printStackTrace();
}
}
/**
* 经过测试证明存储过程中如果没有对插入/删除/修改操作做事务提交、回滚时，可以通过poolman
* 的事务框架来管理事务;如果存储过程中对插入/删除/修改操作已经做了事务提交或者回滚时，那么应用的事务和存储过程中
* 中的事务就是分离的两个事务。
* @param i 为0时回滚事务，1时提交事务
*/
public static void testTest_pWithNameIndexForObjectTx(int i)
{
TransactionManager tm = new TransactionManager();
try
{
tm.begin();
CallableDBUtil callableDBUtil = new CallableDBUtil();
callableDBUtil.prepareCallable("{call test_p(?,?,?,?)}");
//不允许的操作: Ordinal binding and Named binding cannot be combined!
callableDBUtil.setInt("id", 10);
callableDBUtil.registerOutParameter("name", java.sql.Types.VARCHAR);
callableDBUtil.registerOutParameter("name1", java.sql.Types.VARCHAR);
callableDBUtil.registerOutParameter("test", java.sql.Types.INTEGER);
Test_p tets = (Test_p)callableDBUtil.executeCallableForObject(Test_p.class);
System.out.println("name1:" + callableDBUtil.getString("name"));
System.out.println("name2:" + callableDBUtil.getString("name1"));
System.out.println("Test_p is " + tets);
callableDBUtil.executeInsert("insert into test(id,name) values('11','name11')");
if(i == 0)
tm.rollback();
else
tm.commit();
}
catch(Exception e)
{
try {
tm.rollback();
} catch (RollbackException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
e.printStackTrace();
}
}
public static void main(String[] args)
{
// System.out.println("1---------------------------------------------------testTest_pWithPositionIndex()");
// testTest_pWithPositionIndex();
// System.out.println("2---------------------------------------------------testTest_pWithNameIndex()");
// testTest_pWithNameIndex();
// System.out.println("3---------------------------------------------------testTest_pWithNameIndexForObject()");
// testTest_pWithNameIndexForObject();
// System.out.println("4---------------------------------------------------testTest_pWithNameIndexForObjectTx()");
// testTest_pWithNameIndexForObjectTx(0);
// System.out.println("5---------------------------------------------------testTest_pWithNameIndexForXMLString()");
// testTest_pWithNameIndexForXMLString();
// System.out.println("6---------------------------------------------------testTest_pWithNameIndexForXMLStringRowHandler()");
// testTest_pWithNameIndexForXMLStringRowHandler();
// System.out.println("7---------------------------------------------------testTest_pWithNameIndexForObjectWithRowHandler()");
// testTest_pWithNameIndexForObjectWithRowHandler();
// CallableDBUtil.debugStatus();
// testoldMethod();
testTest_pWithNameIndexForXMLString();
}
}
分享到：
发表评论
-
bboss 持久层数据源引用外部属性配置介绍
2018-12-29 21:47 986bboss 持久层数据源外部属性配置引用介绍 bboss持久 ... -
bboss持久层开启和关闭自带主键机制
2017-08-17 11:56 692bboss持久层开启和关闭自带主键机制 请访问文档： bbos ... -
bboss高性能db批处理功能使用方法介绍
2017-05-14 21:28 2062bboss持久层在v5.0.3.5中新增简单的高效的db批处理 ... -
bboss持久层公共sql片段定义和引用方法说明
2017-03-03 13:05 1061bboss持久层公共sql片段定义和引用方法说明 在配置sq ... -
最新版本mysql jdbc驱动包获取表定义信息空指针异常处理方法
2016-12-15 10:24 1275在使用最新的mysql-connector-java 6.0. ... -
持久层快速入门系列一
2016-08-19 13:00 1204持久层快速入门 先在应用中导入bboss 持久层（bboss ... -
bboss与spring中配置和引用bboss数据源和bboss dao组件方法说明
2016-08-10 16:04 863首先在项目中导入bboss 持久层包： maven坐标 & ... -
bboss 持久层sql xml配置文件编写和加载方法介绍
2016-04-05 13:14 1534bboss 持久层sql xml配置文件编写和加载方法介绍 通 ... -
bboss持久层设置数据库查询fetchsize参数方法
2015-11-06 11:54 962bboss持久层设置数据库查询fetchsize参数方法 j ... -
bboss持久层快速入门教程
2015-09-19 13:49 1524bboss持久层快速入门教程，快速搭建bboss持久层的开 ... -
bboss持久层数据库适配器编写和注册方法
2015-02-06 15:21 924bboss持久层数据库适配器编写和注册方法 bboss持久层默 ... -
bboss模糊查询、动态sql、批处理资料荟萃
2015-01-30 12:03 2268bboss模糊查询、动态sql、批处理资料荟萃 bboss持 ... -
bboss持久层查询元数据缓存机制开启方法
2014-11-18 12:03 966bboss持久层为了提升数据库查询操作性能，提供了对查 ... -
bboss开发、模块工程目录结构及功能说明
2014-10-15 19:46 4711基于bboss开发项目说明 ... -
bboss内置数据源apache dbcp与druid数据源切换方法
2014-09-23 09:59 1326bboss内置数据源与druid数据源切换方法 bboss内置 ... -
bboss持久层多数据源配置及多数据库事务控制使用方法
2014-05-11 20:24 2852bboss持久层多数据源配置及使用方法，持久层框架及demo下 ... -
bboss持久层demo使用说明
2014-03-11 09:38 1122持久层案例可以用svn客户端下载eclipse工程，导入ecl ... -
bboss持久层More分页查询API使用介绍
2013-10-18 16:17 1321为了更好地提高数据库分页查询的效率，bboss持久层在Conf ... -
bboss持久层操作Clob和Blob字段示例
2013-09-09 13:29 1155bboss持久层操作Clob和Blob非常方便，基于bboss ... -
bboss持久层ormaping机制详解
2013-09-04 21:04 1089bboss持久层针对db操作即提供了原始sql语句的支持，又提 ...
相关推荐
NULL 博文链接：https://yin-bp.iteye.com/blog/2174863
企业级 J2EE 开源框架：bboss
负载均衡组件特点： 1.服务负载均衡（目前提供RoundRobin负载算法） 2.服务健康检查 3.服务容灾故障恢复 4.服务自动发现（zk，etcd，consul，eureka，db，其他第三方注册中心） 5.路由规则动态切换 5.分组服务管理 ...
bboss功能涵盖ioc，mvc，jsp自定义标签库，持久层，全局事务托管，安全认证，SSO，web会话共享，cxfwebservice服务发布和管理，hessian服务发布和管理等功能。另外还提供了符合中国式自由流的bboss activiti工作流...
bboss会话共享培训文档,学习bboss不可多得的资料，值得拥有。
bboss es特点请访问： https://www.oschina.net/p/bboss-elastic
NULL 博文链接：https://yin-bp.iteye.com/blog/926166
资源目录： 项目源码（eshelloword.rar） bboss elasticsearch开发入门教程.wmv 搭建bboss elasticsearch开发环境.wmv 说明.txt
bboss+es基本操作示例，elasticsearch，bboss，java使用demo
springboot集成ElasticsearchBboss调用Elasticsearch的案例分享
bboss-datatran 由 bboss 开源的数据采集&流批一体化工具，提供数据采集、数据清洗转换处理和数据入库以及数据指标统计计算流批一体化处理功能。
官方版本，亲测可用
Elasticsearch rest client bboss介绍-Elastic2018中国开发者大会演讲稿
NULL 博文链接：https://yin-bp.iteye.com/blog/2177475
浙江移动BBOSS系统快速入门手册V0.1归类.pdf
本实例是一个基于bboss es spring boot starter的demo maven工程，可供spring boot项目集成bboss elasticsearch rest client参考 展示了通过spring boot管理单集群功能和管理多集群功能 单集群测试用例：...
NULL 博文链接：https://yin-bp.iteye.com/blog/1131637
基于java语言比mybatis更实用的orm框架，支持mysql、oracle、postgresql、sqlserver、db2、dm、mongodb
NULL 博文链接：https://yin-bp.iteye.com/blog/1449900
官方版本，亲测可用