调用数据库函数

前面章节介绍了 MyBatis 怎样调用 MySQ 存储过程，本章节将介绍怎样调用函数。

（1）假设我们定义了一个名为 func_updateUserName 的函数，该函数接受两个参数。分别是 userId 和 userName。函数将根据 userId 修改用户名为 userName。SQL 脚本如下：

CREATE FUNCTION `func_updateUserName`(`userId` int,`userName` varchar(100)) RETURNS int(11)
BEGIN
    -- 声明一个变量
declare tname varchar(100);
    -- 更新用户名 
    update `user` set `name`=userName where user_id=userId;
    -- 查询刚才修改的用户信息，判断用户名是否修改成功
    select `name` into tname from `user` where user_id=userId;
    if tname=userName then
        return 1;
    else
        return 0;
    end if;
END

（2）MyBatis 配置文件 mybatis-cfg.xml 内容如下：

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
  "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
    <properties resource="database.properties"/>
    <environments default="MySqlDatabase" >
        <environment id="MySqlDatabase" >
            <transactionManager type="JDBC" />
            <dataSource type="POOLED">
                <property name="driver" value="${jdbc.driver}"/>
                <property name="url" value="${jdbc.url}"/>
                <property name="username" value="${jdbc.username}"/>
                <property name="password" value="${jdbc.password}"/>
            </dataSource>
        </environment>
    </environments>
    <mappers>
        <mapper resource="com/hxstrive/mybatis/function/demo1/UserMapper.xml" />
    </mappers>
</configuration>

（3）定义 Mapper 接口文件 UserMapper.java，代码如下：

package com.hxstrive.mybatis.function.demo1;
import org.apache.ibatis.annotations.Param;

public interface UserMapper {
    /**
     * 更新用户名称
     * @param userId
     * @param userName
     */
    int updateUserName(@Param("userId") int userId, @Param("userName") String userName);
}

（4）定义 Mapper XML 文件 UserMapper.xml，代码如下：

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
   "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.hxstrive.mybatis.function.demo1.UserMapper">
    <!-- 调用存储过程 -->
    <select id="updateUserName" resultType="INTEGER">
        select func_updateUserName(#{userId}, #{userName})
    </select>
</mapper>

（5）客户端代码如下：

package com.hxstrive.mybatis.function.demo1;

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 java.io.InputStream;

public class FunctionDemo {
    public static void main(String[] args) throws Exception {
        String cfgName = "com/hxstrive/mybatis/function/demo1/mybatis-cfg.xml";
        InputStream input = Resources.getResourceAsStream(cfgName);
        SqlSessionFactoryBuilder factoryBuilder = new SqlSessionFactoryBuilder();
        SqlSessionFactory sqlFactory = factoryBuilder.build(input);
        SqlSession sqlSession = sqlFactory.openSession(true);
        UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
        int result = userMapper.updateUserName(1, "Helen");
        System.out.println("result=" + result);
    }
}

执行成功后，自行查看数据库记录是否被修改。