JavaEE_Mybatis_SpringMVC_Mybaits_lesson6__MyBatis传递pojo对象实现综合查询
2015-11-30 14:59
387 查看
项目代码
http://pan.baidu.com/s/1c01BLvi
Mybatis中 SQL 如何传入自定义的输入,输出类型
下面对用户自定义的包装类进行演示,展示如何传递用户自定义的类型,以及如何返回自定义类型。
0.配置文件
1.userMapper.java (Dao接口)
2.userMapper.xml (Dao实现) 1,2是通过配置文件中 批量加载mapper 的方式联系的。(package的方式)
注意
(1) xxxMapper.xml 需要与 xxxMapper.java 名称相同,
(2)且放到同一文件夹下面。
3.User.java (ORM)
4.UserCustom.java(po类)
5.UserQueryVo(vo类)
tips:
(1) Vo 视图层面的对象
(2) Po 持久层面的对象
(3) Pojo 用户自定义的对象,综合了Vo与Po的JavaBean
6.junit 单元测试
文档目录结构
0.配置文件
db.properties
jdbc.driver=com.mysql.jdbc.Driver jdbc.url=jdbc:mysql://localhost:3306/mybatis?characterEncoding=utf-8 jdbc.username=root jdbc.password=123456
SqlMapConfig.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="db.properties"></properties> <!-- <settings></settings> --> <typeAliases> <!-- <typeAlias type="cn.itcast.mybatis.po.User" alias="user"/> --> <!-- 批量定义别名 --> <package name="cn.itcast.mybatis.po"/> </typeAliases> <!-- 和spring整合后 environments配置将废除--> <environments default="development"> <environment id="development"> <!-- 使用jdbc事务管理--> <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="sqlmap/User.xml"/> <!-- <mapper resource="mapper/UserMapper.xml"/> --> <!-- <mapper class="cn.itcast.mybatis.mapper.UserMapper"/> --> <package name="cn.itcast.mybatis.mapper"/> </mappers> </configuration>
1.userMapper.java (Dao接口)
package cn.itcast.mybatis.mapper; import java.util.List; import cn.itcast.mybatis.po.User; import cn.itcast.mybatis.po.UserCustom; import cn.itcast.mybatis.po.UserQueryVo; public interface UserMapper { List<UserCustom> findUserList(UserQueryVo userQueryVo) throws Exception; User findUserById(Integer id) throws Exception; public List<User> findUserByName(String name) throws Exception; void insertUser(User user) throws Exception; void deleteUser(int id) throws Exception; }
2.userMapper.xml (Dao实现)
<?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"> <!-- namespace命名空间,作用就是对sql进行分类化管理,理解sql隔离 注意:使用mapper代理方法开发,namespace有特殊重要的作用--> <mapper namespace="cn.itcast.mybatis.mapper.UserMapper"> <!-- 通过OGNL的方式进行获取 --> <select id="findUserList" parameterType="cn.itcast.mybatis.po.UserQueryVo" resultType="cn.itcast.mybatis.po.UserCustom"> SELECT * FROM user WHERE user.sex = #{userCustom.sex} AND user.username like'%${userCustom.username}%' </select> <!-- 在 映射文件中配置很多sql语句 --> <!-- 需求:通过id查询用户表的记录 --> <!-- 通过 select执行数据库查询 id:标识 映射文件中的 sql 将sql语句封装到mappedStatement对象中, =====================所以将id称为statement的id parameterType:指定输入 参数的类型,这里指定int型 #{}表示一个占位符号 #{id}:其中的 ====================id表示接收输入 的参数,参数名称就是id, ====================如果输入 参数是简单类型,#{}中的参数名可以任意,可以value或其它名称 #{}, resultType:指定sql输出结果 的所映射的java对象类型,select指定resultType表示将单条记录映射成的java对象。 --> <!-- cn.itcast.mybatis.po.User --> <select id="findUserById" parameterType="java.lang.Integer" resultType="user"> SELECT * FROM user where id = #{id} </select> <!-- 根据用户名称模糊查询用户信息,可能返回多条 resultType:指定就是单条记录所映射的java对象 类型 ${}:表示拼接sql串,将接收到参数的内容不加任何修饰拼接在sql中。 =============使用${}拼接sql,引起 sql注入 =============${value}:接收输入 参数的内容,如果传入类型是简单类型,${}中只能使用value --> <select id="findUserByName" parameterType="java.lang.String" resultType="cn.itcast.mybatis.po.User"> SELECT * FROM user where username like '%${value}%' </select> <insert id="insertUser" parameterType="cn.itcast.mybatis.po.User"> <!-- 将插入数据的主键返回,返回到user对象中 =================SELECT LAST_INSERT_ID():得到刚insert进去记录的主键值,只适用与自增主键 keyProperty:将查询到主键值设置到parameterType指定的对象的哪个属性 order:SELECT LAST_INSERT_ID()执行顺序,相对于insert语句来说它的执行顺序 resultType:指定SELECT LAST_INSERT_ID()的结果类型 --> <selectKey keyProperty="id" order="AFTER" resultType="java.lang.Integer"> SELECT LAST_INSERT_ID() </selectKey> INSERT INTO user(username,birthday,sex,address) VALUES(#{username},#{birthday},#{sex},#{address}) <!-- 使用mysql的uuid()生成主键 执行过程: 首先通过uuid()得到主键,将主键设置到user对象的id属性中 其次在insert执行时,从user对象中取出id属性值 --> <!-- <selectKey keyProperty="id" order="BEFORE" resultType="java.lang.String"> SELECT uuid() </selectKey> insert into user(id,username,birthday,sex,address) value(#{id},#{username},#{birthday},#{sex},#{address}) --> </insert> <!-- 删除 用户 根据id删除用户,需要输入 id值 --> <delete id="deleteUser" parameterType="java.lang.Integer"> DELETE FROM user WHERE id=#{id} </delete> <!-- 根据id更新用户 分析: 需要传入用户的id 需要传入用户的更新信息 parameterType指定user对象,包括 id和更新信息,注意:id必须存在 #{id}:从输入 user对象中获取id属性值 --> <update id="updateUser" parameterType="cn.itcast.mybatis.po.User"> UPDATE user SET username=#{username},birthday=#{birthday},sex=#{sex},address=#{address} WHERE id=#{id} </update> </mapper>
3.User.java (ORM)
package cn.itcast.mybatis.po; import java.util.Date; //hibernate字段名和属性名相对应 public class User { @Override public String toString() { return "User [id=" + id + ", username=" + username + ", birthday=" + birthday + ", sex=" + sex + ", address=" + address + "]"; } private int id; private String username; private Date birthday; private String sex; private String address; public int getId() { return id; } public void setId(int id) { this.id = id; } public String getUsername() { return username; } public void setUsername(String username) { this.username = username; } public Date getBirthday() { return birthday; } public void setBirthday(Date birthday) { this.birthday = birthday; } public String getSex() { return sex; } public void setSex(String sex) { this.sex = sex; } public String getAddress() { return address; } public void setAddress(String address) { this.address = address; } }
4.UserCustom.java(po类)
package cn.itcast.mybatis.po; /** * <p> * Description:用户的扩展类 * </p> * * @author szh */ public class UserCustom extends User { // 可以扩展用户的信息 }
5.UserQueryVo(vo类)
package cn.itcast.mybatis.po; /** * * @author szh * */ public class UserQueryVo { private UserCustom userCustom; public UserCustom getUserCustom() { return userCustom; } public void setUserCustom(UserCustom userCustom) { this.userCustom = userCustom; } // 可以包装其他的查询条件,订单,商品 }
6.junit 单元测试
package cn.itcast.mybatis.mapper; import java.io.InputStream; import java.util.List; 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 org.junit.Before; import org.junit.Test; import cn.itcast.mybatis.po.User; import cn.itcast.mybatis.po.UserCustom; import cn.itcast.mybatis.po.UserQueryVo; public class UserMapperTest { private SqlSessionFactory sqlSessionFactory; // 此方法是在执行testFindUserById之前执行 @Before public void setUp() throws Exception { String resource = null; // mybatis全局配置文件 InputStream inputStream = null; // 输入流 try { // mybatis配置文件 resource = "SqlMapConfig.xml"; inputStream = Resources.getResourceAsStream(resource); // 创建会话工厂,传入mybatis配置文件信息 // 创建sqlSessionFactory this.sqlSessionFactory = new SqlSessionFactoryBuilder() .build(inputStream); } catch (Exception e) { e.printStackTrace(); } } @Test public void testFindUserById() throws Exception { SqlSession sqlSession = sqlSessionFactory.openSession(); UserMapper userMapper = sqlSession.getMapper(UserMapper.class); User user = userMapper.findUserById(1); System.out.println(user); sqlSession.close(); } @Test public void testFindUserByName() throws Exception { SqlSession sqlSession = sqlSessionFactory.openSession(); // 创建UserMapper对象,mybatis自动生成mapper代理对象 UserMapper userMapper = sqlSession.getMapper(UserMapper.class); List<User> userList = userMapper.findUserByName("小"); System.out.println(userList); sqlSession.close(); } @Test public void testFindUserList() throws Exception { SqlSession sqlSession = null; try { sqlSession = sqlSessionFactory.openSession(); // 创建UserMapper对象,mybatis 自动生成mapper代理对象 UserMapper userMapper = sqlSession.getMapper(UserMapper.class); UserQueryVo userQueryVo = new UserQueryVo(); UserCustom userCustom = new UserCustom(); userCustom.setSex("1"); userCustom.setUsername("小"); userQueryVo.setUserCustom(userCustom); List<UserCustom> list = userMapper.findUserList(userQueryVo); System.out.println(list); } catch (Exception e) { e.printStackTrace(); } finally { sqlSession.close(); } } @Test public void testInsertUser() throws Exception { SqlSession sqlSession = null; try { sqlSession = sqlSessionFactory.openSession(); // 创建UserMapper对象,mybatis自动生成mapper代理对象 UserMapper userMapper = sqlSession.getMapper(UserMapper.class); User user = new User(); user.setUsername("hahak"); userMapper.insertUser(user); sqlSession.commit(); } catch (Exception e) { e.printStackTrace(); } finally { sqlSession.close(); } } @Test public void testDeleteUser() throws Exception { SqlSession sqlSession = null; try { sqlSession = sqlSessionFactory.openSession(); // 创建UserMapper对象,mybatis 自动生成mapper代理对象 UserMapper userMapper = sqlSession.getMapper(UserMapper.class); userMapper.deleteUser(36); sqlSession.commit(); } catch (Exception e) { e.printStackTrace(); } finally { sqlSession.close(); } } }
单元测试结果
对 List<UserCustom> findUserList(UserQueryVo userQueryVo) throws Exception; 进行的测试
相关文章推荐
- IO概述
- json、javaBean、xml互转的几种工具介绍
- eclipse以外关闭,打开闪退
- 我为什么没有分享Java学习方法
- 如何在SpringMVC中获取request对象
- SSH框架之jar包讲解
- Spring整合mq
- Eclipse 链接 微软安卓模拟器(windowsAndroid)
- Drools5集成Spring3
- java向上取整函数Math.ceil()
- myeclipse 8.5利用phonegap开发android程序
- SpringMvc快速入门
- 在Spring MVC中,事务可以加在Controller层
- eclipse设置svn代理
- Spring事务配置的五种方式
- 关于eclipse svn插件的 svn:ignore无法使用的问题
- java位运算
- 学习:java设计模式—Observer模式
- spring data elastic search初识
- Eclipse中Outline里各种图标的含义