• UID80
  • 登录2017-02-10
  • 粉丝58
  • 关注21
  • 发帖1115
  • 主页
  • 金币6312枚
社区居民
忠实会员
原创写手
潇潇宇 发布于2015-12-07 18:20
1/997

mybatis调用存储过程

楼层直达
mybatis调用存储过程

mybatis调用存储过程

 

环境: JDK1.7,MySQL 5.6,windows7

存储过程SQL如下: 

 

CREATE  PROCEDURE `saveTender`(IN brwId  VARCHAR(26),IN money VARCHAR(26),IN userid  VARCHAR(26),IN ordid  VARCHAR(20),OUT pResult VARCHAR(512))
    COMMENT '--  '
BEGIN
#声明变量必须在程序前面,置后会报错误
DECLARE flag INT DEFAULT 0;
DECLARE err INT DEFAULT 0; #声明一个整形变量err,默认值是0
DECLARE vaccount decimal(11,2) DEFAULT 0; #总额度
DECLARE vSumTend decimal(11,2) DEFAULT 0; #已经投标的额度
DECLARE vBrrNid  varchar(50) DEFAULT ''; #借款编号

START TRANSACTION; #声明事务开始
SET pResult := NULL;
   

SELECT account,borrow_nid INTO vaccount,vBrrNid FROM yyd_borrow WHERE id= brwId  LIMIT 1;
INSERT into yyd_borrow_tender set chinapnr_OrdId=ordid, chinapnr_isSucc='0', addtime = UNIX_TIMESTAMP(),addip = '127.0.0.1',borrow_nid = vBrrNid,user_id = userid,account = money,contents = '',status = '0',nid = CONCAT ( 'tender_',ordid),account_tender = money;

#最近半小时投资未成功和投资已经成功的资金综合

SELECT sum(account) INTO vSumTend FROM yyd_borrow_tender where  borrow_nid =vBrrNid and (chinapnr_isSucc='1' or (chinapnr_isSucc='0' and  UNIX_TIMESTAMP()-addtime<30*60));

IF vSumTend >vaccount THEN
  SET pResult := '001'; #已经满标 
     rollback;
ELSE
     SET pResult := '000';
    commit;
END IF;



END

===========================================================================

mybatis的定义文件investBackMapper.xml内容片段:

    <!--事务过程保存投标,防止冒投-->
    <select id="saveTender" parameterType="java.util.Map" statementType="CALLABLE"  
     resultType="String" >  
      {call youqian3.saveTender(
      #{brwId,jdbcType=VARCHAR,mode=IN},
      #{money,jdbcType=VARCHAR,mode=IN},
      #{userid,jdbcType=VARCHAR,mode=IN},  
      #{ordId,jdbcType=VARCHAR,mode=IN},  
      #{retStr,jdbcType=VARCHAR,mode=OUT})
        }
    </select>    

 

===========================================================================

InvestBackMapper.java程序内容:

import java.util.List;
import java.util.Map;
import com.youqian.vo.YydBorrow;
import com.youqian.vo.YydBorrowTenderVo;
import com.youqian.vo.YydBorrowVo;
import com.youqian.vo.YydCreditRank;


public interface InvestBackMapper extends Base<YydBorrow>{
    /**
     * 查询用户下的投标
     * @param userid
     * @return
     */
    public List<YydBorrowTenderVo> queryBrrTendByUser(int userid);
    /**
     * 翻页查询可投资的项目表,Count记录数
     * @param map
     * @return
     */
    public long qeuryBorrAvaCount(Map<String, Object> map);
    /**
     * 翻页查询可投资的项目表,
     * @param map
     * @return
     */
    public List<YydBorrowVo> qeuryBorrAvaPage(Map<String, Object> map);
    /**
     * 查询积分等级和图片,类型为6
     * @return
     */
    public List<YydCreditRank> qeuryCrdRank();
    /**
     * 调用事务过程,防止冒投
     * @return
     */
    public String saveTender(Map<String, Object> param);
    /**
     * ,
     * @param tendVo
     */
    public void updateTender(YydBorrowTenderVo tendVo);
    /**
     * 更新yyd_borrow的剩余金额,已经投资金额
     * @param tendVo
     */
    public void updateBorrow(YydBorrowTenderVo tendVo);
}

===========================================================================

SpringMVC的Service层代码片段

    /**
     * 调用事务过程,
     * @return
     * @throws ActionException 
     */
    public String saveTender(String id,String money,String useid,String ordId) throws ActionException {
        try {
        Map<String, Object> map = new HashMap<String, Object>();

        map.put("brwId", id);    //借款项目 id
        map.put("money", money); //投标金额
        map.put("userid", useid); //
        map.put("ordId", ordId);    //订单号
        map.put("retStr", "");
        String ret2=investBackMapper.saveTender(map);
        //System.out.println("saveTender ret2:"+ret2);
        String retStr=(String)map.get("retStr");
        return retStr;
    } catch (Exception e) {
        e.printStackTrace();
        throw new ActionException(
                "InvestBackServiceImpl.saveTender.err5", e);
    }
    }

=====================================================

注意的地方是,虽然存储过程有返回值(ret2),但是返回值很诡异,不可以使用。一般都是用  map.put("retStr", "");输出参数来使用自定义的返回值。

 

 

===========================================================

存储过程也可以返回结果集合,XML定义片段如下:

<resultMap type="com.springdemo.usermgr.vo.Stb2" id="itemResult">  
  
</resultMap> 

<select id="getTestProc" parameterType="java.util.Map" statementType="CALLABLE"  
  resultMap="itemResult">  
  {call test.test(
  #{queryStr,jdbcType=VARCHAR,mode=IN},  
  #{retStr,jdbcType=VARCHAR,mode=OUT})
    }
</select>

 

存储过程定义如下:

CREATE DEFINER=`root`@`localhost` PROCEDURE `test`(IN p1  VARCHAR(26), OUT pResult VARCHAR(512))
BEGIN
#声明变量必须在程序前面,置后会报错误
DECLARE flag INT DEFAULT 0;
DECLARE err INT DEFAULT 0; #声明一个整形变量err,默认值是0


   SET pResult := NULL;
   SET pResult :=CONCAT ( 'test',p1);
   SELECT * FROM tb2 WHERE commet like  Concat('%',p1, '%');-- this 返回一个结果集


START TRANSACTION; #声明事务开始
break_label:WHILE flag>10 DO
      insert into  suser(userName,pwd,signUpTime)values(CONCAT('user',flag),'8899',sysdate());
set flag = flag+1;
IF flag=5 THEN
        set err=1;    
         LEAVE  break_label;  #跳出循环
END if;
END WHILE break_label; 

IF err=0 THEN
    commit;
ELSE
    rollback;
END IF; 

END

====================================================

Mybatis的Map程序如下:

import java.util.List;
import java.util.Map;
import com.springdemo.usermgr.vo.SUser;
import com.springdemo.usermgr.vo.Stb2;

public interface SUserMapper {   
    public int  insertSUser(SUser user);   
    public SUser getSUser(String name);  
    public List<Stb2> getTestProc(Map<String, Object> param); 
    public List<Stb2> selectSUser(int id); 

=====================================================

调用Map的java程序如下:

import java.io.IOException;  
import java.io.Reader;  
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.apache.ibatis.io.Resources;  
import org.apache.ibatis.session.SqlSession;  
import org.apache.ibatis.session.SqlSessionFactory;  
import org.apache.ibatis.session.SqlSessionFactoryBuilder;  
import com.springdemo.usermgr.vo.SUserMapper;
import com.springdemo.usermgr.vo.Stb2;

      
    public class Test2 {  
        public static void main(String[] args) throws IOException {  
            String resource = "config.xml";  
            Reader reader = Resources.getResourceAsReader(resource);  
            SqlSessionFactory ssf = new SqlSessionFactoryBuilder().build(reader);  
            SqlSession session = ssf.openSession(true); //true 为自动提交事务

            try {  
                Map<String, Object> parms = new HashMap<String, Object>();  
                parms.put("queryStr", "的");  
               
                  
                SUserMapper spMapper = session.getMapper(SUserMapper.class);  
                  
                List<Stb2> as=spMapper.getTestProc(parms);  
                String outPara=(String) parms.get("retStr");  
                System.out.println(outPara);
                System.out.println(as.toString());
                //org.apache.ibatis.type.JdbcType.VARCHAR
               // org.apache.ibatis.mapping.ParameterMode.OUT
            } catch (Exception e) { 

                e.printStackTrace();  
            } finally {  
                session.close();  
            }  
        }  
    }  

 

==============================================================

批量插入记录的例子: 

Service类代码片段:

public void insertBatch(List<DtoListVo> insVo) throws ActionException {
        try{
            int reti=dtoListVoMapper.insertBatch(insVo);
            System.out.println(reti);
        } catch (Exception e) {
            e.printStackTrace();
            throw new ActionException("DtoListVoService.insertBatch.err1", e);
        }
    }

 

Mapper类:

 

public interface DtoListVoMapper extends Base<DtoListVo>{
    public int insertBatch(List<DtoListVo> insVo);

    public long getDtoListCount(Map<String, Object> map);

    public List<DtoListVo> getDtoListPage(Map<String, Object> map);

    public int insertTrfBatch(List<DtoListVo> listMap);

    public long getDtoTrfCount(Map<String, Object> map);
    

    public List<DtoListVo> getDtoTrfPage(Map<String, Object> map);
 
    public int insertCashBatch(List<DtoListVo> listMap);

    public long getDtoCashCount(Map<String, Object> map);

    public List<DtoListVo> getDtoCashPage(Map<String, Object> map);

    public int insertSaveBatch(List<DtoListVo> listMap);

    public long getDtoSaveCount(Map<String, Object> map);
 
    public List<DtoListVo> getDtoSavePage(Map<String, Object> map);
    
    

}

===================================================================

DtoListVoMapper.xml定义片段:

    <!-- 批量插入语句, -->
    <insert id="insertSaveBatch" >
    insert into candy_dtosave (   
     OrdId,  UsrCustId,  MerCustId,  OrdDate,  TransAmt ,  TransStat,  GateBusiId ,
     OpenBankId ,  OpenAcctId,  FeeCustId,   FeeAcctId,  FeeAmt ,  addtime)
    values
    <foreach collection="list" item="item" index="index" separator=",">
    (#{item.OrdId},#{item.UsrCustId},#{item.MerCustId},#{item.OrdDate},#{item.TransAmt},#{item.TransStat},
    #{item.GateBusiId},#{item.OpenBankId},#{item.OpenAcctId},#{item.FeeCustId},#{item.FeeAcctId},#{item.FeeAmt},UNIX_TIMESTAMP())
    </foreach>
    
    </insert>

 


0人打赏
  • UID1752
  • 登录2015-12-23
  • 粉丝0
  • 关注0
  • 发帖10
  • 主页
  • 金币12枚
清醒i 发布于2015-12-23 17:03
沙发F
有用拿走了
您需要登录后才可以回帖
发表回复
极贡献
技术问答
专题荟萃
程序人生
视觉设计
Android开发
iOS开发
编程语言
前端开发
后端开发
服务器架构
软件测试
运维方案
创业路上



最热文章墙

  • 60444/343   【精品推荐】200多种Android动画效果的强悍框架,太全了,不看这个,再有动画的问题,不理你了^@^

  • 33651/188   情人节福利,程序员表白的正确姿势:改几行代码就变成自己的表白了

  • 32068/141   省时省力的Android组件群来了,非常棒的原型参考

  • 29333/226   【精品推荐】Android版产品级的音乐播放器源码,功能太强大了,最好的产品原型有木有?

  • 26288/2   超全!整理常用的iOS第三方资源

  • 26209/0   Python爬虫:常用浏览器的useragent

  • 24834/70   原创表白APP,以程序员的姿势备战新年后的7夕,持续完善中!

  • 23141/138   2016抢红包软件及源码

  • 20039/29   麻省理工的一帮疯子,真的实现了随意操控万物!(绝对黑科技)

  • 19878/25   Android工程师面试题大全

  • 19300/27   2016程序员跳槽全攻略

  • 19080/9   GitHub上排名前50的iOS项目:总有一款你用得着

  • 18571/20   码魂:程序员的牛B漫画

  • 17016/149   Android版类似UC浏览器:非常赞,产品级的源码

  • 16922/3   吐槽那些程序员的搞笑牛逼注释

  • 15749/1   iOS 动画总结

  • 15489/10   2016年最全的Android面试考题+答案 精编版

  • 15324/41   一个绚丽的loading动效分析与实现!

  • 14902/73   【持续更新中】Android福利贴(二):资料源码大放送

  • 14862/83   Android小而全的博客源码:非常适合全面掌握开发技巧

  • 14726/10   女程序员的梦,众网友的神回复

  • 14612/44   惊艳的App引导页:背景图片切换加各个页面动画效果

  • 14515/11   年会上现场review代码是怎么样的体验!

  • 14293/23   个人收集的Android 各类功能源代码

  • 14170/5   新一代Android渠道打包工具:1000个渠道包只需要5秒

  • 13352/19   珍藏多年的素材,灵感搜寻网站

  • 13322/53   基于瀑布流的美女图片浏览App,有注释的源代码

  • 12964/17   用JavaScript 来开发iOS和Android 原生应用:React Native开源框架中文版来啦

  • 12861/74   仿京东商城客户端Android最新版,不错的原型和学习资料

  • 12811/15   基于Android支付宝支付设计和开发方案

  • 12597/20   Android福利第三波【Android电子书】

  • 12391/17   什么是真正的黑客:收获12200+Stars,人气远超微软开源VS

  • 12314/94   Android带弹幕的视频播放器源码,来自大名鼎鼎的Bilibili弹幕网站

  • 12258/18   65条最常用正则表达式,你要的都在这里了

  • 12134/70   【精品推荐】类似360安全卫士安Android源码:非常赞的产品原型

  • 11787/7   用程序员的姿势抢过年的火车票

  • 11772/0   iOS中文版资源库,非常全

  • 11723/7   一张图搞定iOS学习路线,非常全面

  • 11700/11   有木有这样一张酷图帮你集齐所有git命令超实用

  • 11220/10   成为Java顶尖程序员 ,看这11本书就够了

  • 10976/18   一张图搞定Android学习路线,非常全面

  • 10892/10   微信支付终于成功了(安卓,iOS),在此分享

  • 10590/44   在线音乐播放器完整版(商用级的源码):非常赞,可听免费高品质专辑

  • 10531/3   基于Node.js的强大爬虫,能直接发布抓取的文章哦

  • 10442/29   【持续更新中】Android福利贴(一):资料源码

  • 10415/0   GitHub iOS 库和框架Top100 

  • 9991/4   46 个非常有用的 PHP 代码片段

  • 9746/3   即时通信第三方库

  • 9722/61   【技巧一】搭配Android Studio,如何实现App远程真机debug?

  • 9550/9   烧了5亿美金,这家神秘的公司即将颠覆人类未来!

  • 9513/8   流媒体视频直播方案

  • 9392/9   B站建开源工作组:APP想支持炫酷弹幕的看过来

  • 9253/18   八个最优秀的Android Studio插件

  • 9202/2   【精品推荐】高质量PHP代码的50个实用技巧:非常值得收藏

  • 9118/9   中国黑客的隐秘江湖:攻守对立,顶尖高手月入千万美元

  • 8687/6   开箱即用!Android四款系统架构工具

  • 8571/3   一张图看清Linux 内核运行原理

  • 8473/10   十大技巧快速提升Android应用开发性能

  • 8450/3   10款GitHub上最火爆的国产开源项目——可以媲美西半球

  • 8139/1   Android性能优化视频,文档以及工具

  • 返回顶部