1.定义映射文件中定义selectKey的查询
<?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"> <!-- 此文件主要用于编写sql语句 namespace是为了解决相同名字的sql操作问题 --> <mapper namespace="cn.et.mybatis.lesson02.selectKey.KeyMapper"> <insert id="selectEmp"> <!-- selectKey 标签表示子查询中主键的提取问题 keyColumn表示查询语句返回结果的列名 keyProperty表示将属性设置到某个列中 此处为empNo 中 order="BEFORE表示在插入语句之前执行 resultType="int"表示返回值得类型为int类型 --> <selectKey keyColumn="myNo" keyProperty="empNo" order="BEFORE" resultType="int"> select max(empNo)+1 as myNo from emp </selectKey> <!-- 注意 此处的empNo必须和seleceKey 中返回结果的列名一致 此处的ename必须和测试类中map设置的key的名字一致 此处的sal必须和测试类中map设置的key的名字一致 --> insert into emp(empNo,ename,sal) values(#{empNo},#{ename},#{sal}) </insert> </mapper>
2.定义接口查询方法
package cn.et.mybatis.lesson02.selectKey; import java.util.List; import java.util.Map; public interface KeyMapper { // public void queryEmp(Map map); //查询的方法 public void selectEmp(Map map); //查询的方法 public List<Map> selectEmp2(); }
3.定义主mybatis.xml文件<?xml version=“1.0“ encoding=“UTF-8“ ?>
<!-- 说明mybatis的根节点 --> <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd"> <!--mybatis的根标签configuration --> <configuration> <!-- 资源文件的路径配置 注:cn前面不能用/否则会抛出异常--> <properties resource="cn/et/mybatis/lesson02/jdbc.properties"> </properties> <!-- 配置连接数据库的环境,(开发环境) --> <environments default="development"> <environment id="development"> <!-- 事务交给jdbc管理,Conection(事务) commit(提交) rollback(回滚) --> <transactionManager type="JDBC"/> <!-- 数据源 用来连接数据库(包含四要素,driver,url,username,password) --> <dataSource type="POOLED"> <property name="driver" value="${driverClass}"/> <property name="url" value="${url}"/> <property name="username" value="${userAccount}"/> <property name="password" value="${password}"/> </dataSource> </environment> </environments> <!-- 包含隐射文件主要用于编写sql语句 --> <mappers> <!-- 隐射的资源文件 隐射文件主要编写sql语句 --> <mapper resource="cn/et/mybatis/lesson02/selectKey/key_mapper.xml"/>
</mappers> </configuration>
4.定义测试类
package cn.et.mybatis.lesson02.selectKey; import java.io.IOException; import java.io.InputStream; import java.util.HashMap; import java.util.List; import java.util.Map; import org.apache.ibatis.session.SqlSession; import org.apache.ibatis.session.SqlSessionFactory; import org.apache.ibatis.session.SqlSessionFactoryBuilder; import org.junit.Test; public class TestMyBatis { //封装session的返回 public static SqlSession getSession(){ String resource = "/cn/et/mybatis/lesson02/mybatis.xml"; InputStream inputStream =TestMyBatis.class.getResourceAsStream(resource); SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream); //操作数据库的类 SqlSession SqlSession session=sqlSessionFactory.openSession(); return session; } //调用存储过程 public static void main(String[] args) throws IOException { SqlSession session=getSession(); KeyMapper cm=session.getMapper(KeyMapper.class); //声明一个map集合 Map map=new HashMap(); map.put("ename", "zhangsan"); map.put("sal", 200); //将声明的集合传入到查询的方法中 cm.selectEmp(map); System.out.println(map.get("empNo")); //提交事务 session.commit(); List list =cm.selectEmp2(); System.out.println(list.size()); } }