• Java使用mybatis框架调用MySQL存储过程


    存储过程毕竟是存放在数据库的,需求变更太频繁,相比于改动代码,数据库sql的改动风险高,难度大。

    1.存储过程的简介

    我们常用的操作数据库语言SQL语句在执行的时候需要要先编译,然后执行,而存储过程(Stored Procedure)是一组为了完成特定功能的SQL语句集,经编译后存储在数据库中,用户通过指定存储过程的名字并给定参数(如果该存储过程带有参数)来调用执行它。

    一个存储过程是一个可编程的函数,它在数据库中创建并保存。它可以有SQL语句和一些特殊的控制结构组成。当希望在不同的应用程序或平台上执行相同的函数,或者封装特定功能时,存储过程是非常有用的。数据库中的存储过程可以看做是对编程中面向对象方法的模拟。它允许控制数据的访问方式。

    2.存储过程优点

    1. 存储过程增强了SQL语言的功能和灵活性。存储过程可以用流控制语句编写,有很强的灵活性,可以完成复杂的判断和较复杂的运算。

    2. 存储过程允许标准组件是编程。存储过程被创建后,可以在程序中被多次调用,而不必重新编写该存储过程的SQL语句。而且数据库专业人员可以随时对存储过程进行修改,对应用程序源代码毫无影响。

    3. 存储过程能实现较快的执行速度。如果某一操作包含大量的Transaction-SQL代码或分别被多次执行,那么存储过程要比批处理的执行速度快很多。因为存储过程是预编译的。在首次运行一个存储过程时查询,优化器对其进行分析优化,并且给出最终被存储在系统表中的执行计划。而批处理的Transaction-SQL语句在每次运行时都要进行编译和优化,速度相对要慢一些。

    4. 存储过程能过减少网络流量。针对同一个数据库对象的操作(如查询、修改),如果这一操作所涉及的Transaction-SQL语句被组织程存储过程,那么当在客户计算机上调用该存储过程时,网络中传送的只是该调用语句,从而大大增加了网络流量并降低了网络负载。

    5. 存储过程可被作为一种安全机制来充分利用。系统管理员通过执行某一存储过程的权限进行限制,能够实现对相应的数据的访问权限的限制,避免了非授权用户对数据的访问,保证了数据的安全。

    3.存储过程缺点

    1. 不易维护,一旦逻辑变了修改起来麻烦
    2. 如果写此存储过程的人离职了,对于接手她代码的人估计是一场灾难,因为别人还要去读懂你程序逻辑,还要读懂你存储逻辑。不利于扩展。
    3. 最大的缺点! 虽然存储过程可以减少代码量,提高开发效率。但是有一点非常致命的就是太耗性能。

    首先提供一个的存储过程逻辑:

    1. create table p_user(
    2. id int primary key auto_increment,
    3. name varchar(10),
    4. sex char(2)
    5. );
    6. insert into p_user(name,sex) values('A',"男");
    7. insert into p_user(name,sex) values('B',"女");
    8. insert into p_user(name,sex) values('C',"男");
    9. -- 创建存储过程(查询得到男性或女性的数量, 如果传入的是0就女性否则是男性)
    10. DELIMITER $
    11. CREATE PROCEDURE mybatis.ges_user_count(IN sex_id INT, OUT user_count INT)
    12. BEGIN
    13. IF sex_id=0 THEN
    14. SELECT COUNT(*) FROM mybatis.p_user WHERE p_user.sex='女' INTO user_count;
    15. ELSE
    16. SELECT COUNT(*) FROM mybatis.p_user WHERE p_user.sex='男' INTO user_count;
    17. END IF;
    18. END
    19. $
    20. -- 调用存储过程
    21. DELIMITER ;
    22. SET @user_count = 0;
    23. CALL mybatis.ges_user_count(1, @user_count);
    24. SELECT @user_count;

    然后在Mapper.xml进行调用

    在mapper文件中可以使用statementType标记使用什么的对象操作SQL语句。 

    statementType:标记操作SQL的对象 

    要实现动态传入表名、列名,需要做如下修改 ,添加属性statementType=”STATEMENT” ,同时sql里的属有变量取值都改成${xxxx},而不是#{xxx}

     
                delete from ${table} where 
            ${col} < ${date}]]>  
     
    注意!注意!注意!重点!重点!重点!

    取值说明: 
    1、STATEMENT:直接操作sql,不进行预编译,获取数据:$—Statement 
    2、PREPARED:预处理,参数,进行预编译,获取数据:#—–PreparedStatement:默认 
    3、CALLABLE:执行存储过程————CallableStatement 
    另外说明下:如果只为STATEMENT,那么sql就是直接进行的字符串拼接,这样为字符串需要加上引号,如果为PREPARED,是使用的参数替换,也就是索引占位符,我们的#会转换为?再设置对应的参数的值
    在MySQL中直接用Call 调用 CALL procedure_name ( [ parameter [ , ... ] ] )

    mybatis调用存储过程
    userMapper.xml配置文件的编写:里面的statementType="CALLABLE",就是用来调用存储过程的标志,必须这样写

    1. <!--
    2. 查询得到男性或女性的数量, 如果传入的是0就女性否则是男性
    3. -->
    4. <select id="getUserCount" parameterMap="getUserCountMap" statementType="CALLABLE">
    5. CALL mybatis.ges_user_count(?,?)
    6. </select>
    7. <!--
    8. parameterMap.put("sexid", 0);
    9. parameterMap.put("usercount", -1);
    10. -->
    11. <parameterMap type="java.util.Map" id="getUserCountMap">
    12. <parameter property="sexid" mode="IN" jdbcType="INTEGER"/>
    13. <parameter property="usercount" mode="OUT" jdbcType="INTEGER"/>
    14. </parameterMap>

    编写单元测试代码

    1. package me.gacl.test;
    2. import java.util.HashMap;
    3. import java.util.List;
    4. import java.util.Map;
    5. import me.gacl.custom.model.ConditionUser;
    6. import me.gacl.domain.User;
    7. import me.gacl.util.MyBatisUtil;
    8. import org.apache.ibatis.session.SqlSession;
    9. import org.junit.Test;
    10. /**
    11. * @author gacl
    12. * 测试调用存储过程
    13. */
    14. public class Test6 {
    15. @Test
    16. public void testGetUserCount(){
    17. SqlSession sqlSession = MyBatisUtil.getSqlSession();
    18. /**
    19. * 映射sql的标识字符串,
    20. * me.gacl.mapping.userMapper是userMapper.xml文件中mapper标签的namespace属性的值,
    21. * getUserCount是select标签的id属性值,通过select标签的id属性值就可以找到要执行的SQL
    22. */
    23. String statement = "me.gacl.mapping.userMapper.getUserCount";//映射sql的标识字符串
    24. Map parameterMap = new HashMap();
    25. parameterMap.put("sexid", 1);
    26. parameterMap.put("usercount", -1);
    27. sqlSession.selectOne(statement, parameterMap);
    28. Integer result = parameterMap.get("usercount");
    29. System.out.println(result);
    30. sqlSession.close();
    31. }
    32. }

  • 相关阅读:
    Kube-OVN子网
    怎样用一台手机做自媒体?
    修改I2C上拉电阻的值
    Spring中的任务调度:探索@Scheduled和@Schedules注解的威力
    开了店铺没访客没流量?Shopee店铺日常运营引流方式来啦
    子网的划分
    AC8015笔记
    git 分支管理进阶
    C语言基础
    2022-9月报
  • 原文地址:https://blog.csdn.net/qq_45637260/article/details/126099843