Mybatis框架

Mybatis框架
文章图片

MyBatis 是一款优秀的持久层框架,它支持定制化 SQL(灵活)、存储过程(PLSQL模块化的组件,数据库的一部分)以及高级映射(表映射为Bean也可以将Bean映射为表)。MyBatis 避免了几乎所有的 JDBC 代码和手动设置参数以及获取结果集。MyBatis 可以使用简单的 XML 或注解来配置和映射原生信息,将接口(框架的思想都是面向接口来编程)和 Java 的 POJO(Plain Old Java Objects,普通的 Java对象)映射成数据库中的记录。
Mybatis 是一个持久层的架构,是 apache 下的顶级项目。
Mybatis 原先是托管在 googlecode 下,再后来是托管在 Github 上。
Mybatis 让程序员将主要的精力放在 sql 上,通过 Mybatis 提供的映射方式,自由灵活生成(半自动,大部分需要程序员编写 sql )满足需要 sql 语句。
Mybatis 可以将向 preparedStatement 中的输入参数自动进行输入映射,将查询结果集灵活的映射成 java 对象。(输出映射)
Mybatis 框架结构图
Mybatis框架
文章图片

说明:

  • SqlMapConfig.xml (Mybatis的全局配置文件,名称不定)配置了数据源、事务等 Mybatis 运行环境
  • Mapper.xml 映射文件(配置 sql 语句)
  • SqlSessionFactory (会话工厂)根据配置文件配置工厂、创建 SqlSession
  • SqlSession (会话)面向用户的接口、操作数据库(发出 sql 增删改查)
  • Executor (执行器)是一个接口(基本执行器、缓存执行器)、SqlSession 内部通过执行器操作数据库
  • Mapped Statement (底层封装对象)对操作数据库存储封装,包括 sql 语句、输入参数、输出结果类型
Mybatis工程需要引用Maven的本地仓库,关于Maven本地仓库的配制可以参考
地址:https://www.jianshu.com/p/e351f8e22c9a
Mybatis入门程序
1、需求
实现以下功能:
  • 根据用户id查询一个用户信息
  • 根据用户名称模糊查询用户信息列表
  • 添加用户
  • 更新用户
  • 删除用户
    2、环境
  • java 环境 :jdk1.8.0_77
  • 开发工具 : IDEA 2016.1
  • 数据库 : MySQL 5.7
  • Mybatis 运行环境( jar 包)
  • MySQL 驱动包
  • 其他依赖包
数据库表结构如下:
CREATE TABLE `user` ( `id` int(11) NOT NULL AUTO_INCREMENT, `username` varchar(32) NOT NULL COMMENT '用户名称', `birthday` date DEFAULT NULL COMMENT '生日', `sex` char(1) DEFAULT NULL COMMENT '性别', `address` varchar(256) DEFAULT NULL COMMENT '地址', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=32 DEFAULT CHARSET=utf8; INSERT INTO `user` VALUES (1, '王五', NULL, '2', NULL); INSERT INTO `user` VALUES (10, '张三', '2014-7-10', '1', '北京市'); INSERT INTO `user` VALUES (16, '张小明', NULL, '1', '河南郑州'); INSERT INTO `user` VALUES (22, '陈小明', NULL, '1', '河南郑州'); INSERT INTO `user` VALUES (24, '张三丰', NULL, '1', '河南郑州'); INSERT INTO `user` VALUES (25, '陈小明', NULL, '1', '河南郑州'); INSERT INTO `user` VALUES (26, '王五', NULL, NULL, NULL); INSERT INTO `user` VALUES (28, '陈小明111', '2017-9-14', '1', '式'); INSERT INTO `user` VALUES (29, 'tom123', '2018-1-19', '1', 'shenyang'); INSERT INTO `user` VALUES (30, 'tom123', '2018-1-19', '1', 'shenyang'); INSERT INTO `user` VALUES (31, 'aabbcc', '2018-6-12', 'm', 'neusoft');

1.创建一个Maven工程
2.在pom.xml中添加项目的依赖库(mybatis)
4.0.0 com.foreknow foreknow_mybatis 0.0.1-SNAPSHOTwar foreknow_mybatis foreknow_mybatis org.mybatis mybatis 3.3.0 log4j log4j 1.2.17 org.slf4j slf4j-api 1.7.12 org.slf4j slf4j-log4j12 1.7.12 junit junit 4.12 test mysql mysql-connector-java 5.1.38 org.hamcrest hamcrest-core 1.3 test javax.servlet javax.servlet-api 3.1.0 provided

3.需要在resources中添加配制文件:db.properties、log4j.properties、SqlMapConfig.xml(Mybatis的核心配制文件)
db.properties配制
#jdbc.driver=oracle.jdbc.driver.OracleDriver #jdbc.url=jdbc:oracle:thin:@localhost:1521:orcl #jdbc.username=scott #jdbc.password=tigerjdbc.driver=com.mysql.jdbc.Driver jdbc.url=jdbc:mysql://localhost:3306/mybaits?useUnicode=true&characterEncoding=utf8 jdbc.username=root jdbc.password=

log4j.properties配制
# Global logging configuration #\u5728\u5f00\u53d1\u73af\u5883\u4e0b\u65e5\u5fd7\u7ea7\u522b\u8981\u8bbe\u7f6e\u6210DEBUG\uff0c\u751f\u4ea7\u73af\u5883\u8bbe\u7f6e\u6210info\u6216error log4j.rootLogger=DEBUG, stdout # Console output... log4j.appender.stdout=org.apache.log4j.ConsoleAppender log4j.appender.stdout.layout=org.apache.log4j.PatternLayout log4j.appender.stdout.layout.ConversionPattern=%5p [%t] - %m%n

SqlMapConfig.xml(Mybatis的核心配制文件)

4.创建User.java
package com.foreknow.bean; import java.util.Date; public class User { private int id; private String username; private String sex; private Date birthday; 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 String getSex() { return sex; } public void setSex(String sex) { this.sex = sex; } public Date getBirthday() { return birthday; } public void setBirthday(Date birthday) { this.birthday = birthday; } public String getAddress() { return address; } public void setAddress(String address) { this.address = address; } }

5.创建一个映射(Mapper)文件对数据库进行操作User.xml
select * from user where id=#{id} insert into User(username,birthday,sex,address) values(#{username},#{birthday},#{sex},#{address}) select * from user where username like '%${value}%' delete from user where id=#{id} update user set username=#{username},birthday=#{birthday},sex=#{sex},address=#{address} where id=#{id}

6.创建JUnit测试类
package com.foreknow.mybatis_test; import java.io.IOException; import java.io.InputStream; import java.util.Date; 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.Test; import com.foreknow.bean.User; public class MybatisUserTest { @Test public void findUserByIdTest() throws IOException { Stringresource = "SqlMapConfig.xml"; //如何对SqlMapConfig.xml读取并解析 InputStream inputStream = Resources.getResourceAsStream(resource); //创建一个会话工厂(SqlSessionFactory),传入mybatis中的配制信息 SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream); //获取到SqlSession对象,作用是操作数据库 SqlSession sqlSession = sqlSessionFactory.openSession(); //关联User.xml文件进行操作 User user = sqlSession.selectOne("test.findUserById", 1); System.out.println("---------"+user.getUsername()+"-----------"); //释放资源 sqlSession.close(); }@Test public void insertUserTest() throws IOException { Stringresource = "SqlMapConfig.xml"; //如何对SqlMapConfig.xml读取并解析 InputStream inputStream = Resources.getResourceAsStream(resource); //创建一个会话工厂(SqlSessionFactory),传入mybatis中的配制信息 SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream); //获取到SqlSession对象,作用是操作数据库 SqlSession sqlSession = sqlSessionFactory.openSession(); //关联User.xml文件进行操作 User user = new User(); user.setUsername("tom_test"); user.setBirthday(new Date()); user.setSex("1"); user.setAddress("foreknow"); sqlSession.insert("test.insertUser", user); //提交事物 sqlSession.commit(); //释放资源 sqlSession.close(); }@Test public void findUserByNameTest() throws IOException { Stringresource = "SqlMapConfig.xml"; //如何对SqlMapConfig.xml读取并解析 InputStream inputStream = Resources.getResourceAsStream(resource); //创建一个会话工厂(SqlSessionFactory),传入mybatis中的配制信息 SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream); //获取到SqlSession对象,作用是操作数据库 SqlSession sqlSession = sqlSessionFactory.openSession(); //关联User.xml文件进行操作List list = sqlSession.selectList("test.findUserByName", "张"); System.out.println(list.size()); //释放资源 sqlSession.close(); }@Test public void deleteUserTest() throws IOException { Stringresource = "SqlMapConfig.xml"; //如何对SqlMapConfig.xml读取并解析 InputStream inputStream = Resources.getResourceAsStream(resource); //创建一个会话工厂(SqlSessionFactory),传入mybatis中的配制信息 SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream); //获取到SqlSession对象,作用是操作数据库 SqlSession sqlSession = sqlSessionFactory.openSession(); //关联User.xml文件进行操作 sqlSession.delete("test.deleteUser", 33); sqlSession.commit(); //释放资源 sqlSession.close(); }@Test public void updateUserTest() throws IOException { Stringresource = "SqlMapConfig.xml"; //如何对SqlMapConfig.xml读取并解析 InputStream inputStream = Resources.getResourceAsStream(resource); //创建一个会话工厂(SqlSessionFactory),传入mybatis中的配制信息 SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream); //获取到SqlSession对象,作用是操作数据库 SqlSession sqlSession = sqlSessionFactory.openSession(); //关联User.xml文件进行操作 User user = new User(); user.setId(32); user.setUsername("tom_test123"); user.setBirthday(new Date()); user.setSex("0"); user.setAddress("fffff"); sqlSession.update("test.updateUser", user); sqlSession.commit(); //释放资源 sqlSession.close(); } }

总结:
parameterType:指定输入参数类型,mybatis 从输入对象中获取参数值拼接在 sql 中。
resultType:指定输出结果类型,mybatis 将 sql 查询结果的一行记录数据映射为 resultType 指定类型的对象。
Sqlsession 的使用范围
SqlSession 中封装了对数据库的操作,如:查询、插入、更新、删除等。
通过 SqlSessionFactory 创建 SqlSession,而 SqlSessionFactory 是通过 SqlSessionFactoryBuilder 进行创建。
1、SqlSessionFactoryBuilder
SqlSessionFactoryBuilder 用于创建 SqlSessionFacoty,SqlSessionFacoty 一旦创建完成就不需要SqlSessionFactoryBuilder 了,因为 SqlSession 是通过 SqlSessionFactory 生产,所以可以将SqlSessionFactoryBuilder 当成一个工具类使用,最佳使用范围是方法范围即方法体内局部变量。
2、SqlSessionFactory
SqlSessionFactory 是一个接口,接口中定义了 openSession 的不同重载方法,SqlSessionFactory 的最佳使用范围是整个应用运行期间,一旦创建后可以重复使用,通常以单例模式管理 SqlSessionFactory。
3、SqlSession
SqlSession 是一个面向用户的接口, sqlSession 中定义了数据库操作,默认使用 DefaultSqlSession 实现类。
使用DAO实现类的方式操作数据库 创建DAO
package com.foreknow.dao; import java.sql.SQLException; import java.util.List; import com.foreknow.bean.User; public interface UserDao { /** * 根据id查询用户信息 * @param id * @return User * @throws SQLException */ public User findUserById(int id)throws SQLException; /** * 模糊查询用户信息列表 * @param name * @return List * @throws SQLException */ public List findUserByName(String name)throws SQLException; /** * 添加用户信息 * @param user * @throws SQLException */ public void insertUser(User user)throws SQLException; /** * 根据id删除用户信息 * @param id * @throws SQLException */ public void deleteUser(int id)throws SQLException; /** * 修改用户信息 * @param user * @throws SQLException */ public void updateUser(User user)throws SQLException; }

创建DAO实现类
package com.foreknow.dao; import java.util.List; import org.apache.ibatis.session.SqlSession; import org.apache.ibatis.session.SqlSessionFactory; import com.foreknow.bean.User; public class UserDaoImpl implements UserDao {// 需要向dao实现类中注入SqlSessionFactory // 这里通过构造方法注入 private SqlSessionFactory sqlSessionFactory; public UserDaoImpl(SqlSessionFactory sqlSessionFactory) { this.sqlSessionFactory = sqlSessionFactory; }@Override public User findUserById(int id) throws Exception { SqlSession sqlSession = sqlSessionFactory.openSession(); User user = sqlSession.selectOne("test.findUserById", id); // 释放资源 sqlSession.close(); return user; }@Override public List findUserByName(String name) throws Exception { SqlSession sqlSession = sqlSessionFactory.openSession(); List list = sqlSession.selectList("test.findUserByName", name); // 释放资源 sqlSession.close(); return list; }@Override public void insertUser(User user) throws Exception { SqlSession sqlSession = sqlSessionFactory.openSession(); //执行插入操作 sqlSession.insert("test.insertUser", user); // 提交事务 sqlSession.commit(); // 释放资源 sqlSession.close(); }@Override public void deleteUser(int id) throws Exception { SqlSession sqlSession = sqlSessionFactory.openSession(); //执行插入操作 sqlSession.delete("test.deleteUser", id); // 提交事务 sqlSession.commit(); // 释放资源 sqlSession.close(); } }

创建JUnit测试类
public class UserDaoImplTest { private SqlSessionFactory sqlSessionFactory; // 此方法是在执行testFindUserById之前执行 @Before public void setUp() throws Exception { // 创建sqlSessionFactory// mybatis配置文件 String resource = "SqlMapConfig.xml"; // 得到配置文件流 InputStream inputStream = Resources.getResourceAsStream(resource); // 创建会话工厂,传入mybatis的配置文件信息 sqlSessionFactory = new SqlSessionFactoryBuilder() .build(inputStream); }@Test public void testFindUserById() throws Exception { // 创建UserDao的对象 UserDao userDao = new UserDaoImpl(sqlSessionFactory); // 调用UserDao的方法 User user = userDao.findUserById(1); System.out.println(user); } }

自定义别名:
在 SqlMapConfig.xml 中配置:(设置别名)
【Mybatis框架】

Mybatis 的 mapper 接口 程序员需要编写mapper接口(相当于Dao接口,增删改查操作)
程序员需要编写 mapper.xml 映射文件,需遵循一些开发规范,mybatis 可以自动生成 mapper 接口类代理对象。
开发规范:
1.在 mapper.xml 中 namespace 等于 mapper 接口地址(所在包名的全路径)

2.在 xxxmapper.java 接口中的方法名要与 xxxMapper.xml 中 statement 的 id 一致。
3.在 xxxmapper.java 接口中的输入参数类型要与 xxxMapper.xml 中 statement 的 parameterType 指定的参数类型一致。
4.在 xxxmapper.java 接口中的返回值类型要与 xxxMapper.xml 中 statement 的 resultType 指定的类型一致。
5.接口文件名要与xml映射文件名一致(UserMapper.java和UserMapper.xml)
根据用户 id(主键)查询用户信息 定义Mapper接口
public interface UserMapper { public User findUserById(int id); }

定义UserMapper.xml
select * from user where id = #{value}

主方法测试
public static void main(String[] args) throws IOException { //创建sqlSessionFactory //Mybatis 配置文件 String resource = "SqlMapConfig.xml"; //得到配置文件流 InputStream inputStream = Resources.getResourceAsStream(resource); //创建会话工厂,传入Mybatis的配置文件信息 SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream); SqlSession sqlSession = sqlSessionFactory.openSession(); //创建usermapper对象,mybatis自动生成代理对象 UserMapper userMapper = sqlSession.getMapper(UserMapper.class); //调用UserMapper的方法 User user = userMapper.findUserById(1); System.out.println(user.getUsername()); }

复合条件查询(动态SQL)
MyBatis 的强大特性之一便是它的动态 SQL。如果你有使用 JDBC 或其它类似框架的经验,你就能体会到根据不同条件拼接 SQL 语句的痛苦。例如拼接时要确保不能忘记添加必要的空格,还要注意去掉列表最后一个列名的逗号。利用动态 SQL 这一特性可以彻底摆脱这种痛苦。
虽然在以前使用动态 SQL 并非一件易事,但正是 MyBatis 提供了可以被用在任意 SQL 映射语句中的强大的动态 SQL 语言得以改进这种情形。
动态 SQL 元素和 JSTL 或基于类似 XML 的文本处理器相似。在 MyBatis 之前的版本中,有很多元素需要花时间了解。MyBatis 3 大大精简了元素种类,现在只需学习原来一半的元素便可。MyBatis 采用功能强大的基于 OGNL 的表达式来淘汰其它大部分元素。
if
choose (when, otherwise)
trim (where, set)
foreach
创建PO类 UserInfo.java
package com.foreknow.bean; public class UserInfo extends User{ //可以扩展用户的信息 }

UserQueryInfo.java
public class UserQueryInfo {//传入多个id private List ids; //在这里包装所需要的查询条件//用户查询条件 private UserCustom userCustom; public UserCustom getUserCustom() { return userCustom; }public void setUserCustom(UserCustom userCustom) { this.userCustom = userCustom; }public List getIds() { return ids; }public void setIds(List ids) { this.ids = ids; }//可以包装其它的查询条件,订单、商品 //....}

UserMapper.java
// 用户信息综合查询 public List findUserList(UserQueryVo userQueryVo) throws Exception; // 用户信息综合查询总数 public int findUserCount(UserQueryVo userQueryVo) throws Exception;

UserMapper.xml
and USER .sex = #{userCustom.sex} and USER.username LIKE '%${userCustom.username}%' id=#{user_id} SELECT * FROM USERSELECT count(*) FROM USER

Junit测试
//用户信息的综合 查询 @Test public void testFindUserList() throws Exception {SqlSession sqlSession = sqlSessionFactory.openSession(); //创建UserMapper对象,mybatis自动生成mapper代理对象 UserMapper userMapper = sqlSession.getMapper(UserMapper.class); //创建包装对象,设置查询条件 UserQueryInfo userQueryInfo = new UserQueryInfo(); UserInfo userInfo = new UserInfo(); //由于这里使用动态sql,如果不设置某个值,条件不会拼接在sql中 //userInfo.setSex("1"); userInfo.setUsername("张三"); //传入多个id List ids = new ArrayList(); ids.add(1); ids.add(10); ids.add(16); //将ids通过userQueryInfo传入statement中 userQueryInfo.setIds(ids); userQueryInfo.setUserInfo(userInfo); //调用userMapper的方法List list = userMapper.findUserList(userQueryInfo); System.out.println(list); }

使用ResultMap进行多表的操作 首先建立数据库表结构:
user表(用户表):

Mybatis框架
文章图片
CREATE TABLE `user` ( `id` int(11) NOT NULL AUTO_INCREMENT, `username` varchar(32) NOT NULL COMMENT '用户名称', `birthday` date DEFAULT NULL COMMENT '生日', `sex` char(1) DEFAULT NULL COMMENT '性别', `address` varchar(256) DEFAULT NULL COMMENT '地址', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=32 DEFAULT CHARSET=utf8; INSERT INTO `user` VALUES (1, '王五', NULL, '2', NULL); INSERT INTO `user` VALUES (10, '张三', '2014-7-10', '1', '北京市'); INSERT INTO `user` VALUES (16, '张小明', NULL, '1', '河南郑州'); INSERT INTO `user` VALUES (22, '陈小明', NULL, '1', '河南郑州'); INSERT INTO `user` VALUES (24, '张三丰', NULL, '1', '河南郑州'); INSERT INTO `user` VALUES (25, '陈小明', NULL, '1', '河南郑州'); INSERT INTO `user` VALUES (26, '王五', NULL, NULL, NULL); INSERT INTO `user` VALUES (28, '陈小明111', '2017-9-14', '1', '式'); INSERT INTO `user` VALUES (29, 'tom123', '2018-1-19', '1', 'shenyang'); INSERT INTO `user` VALUES (30, 'tom123', '2018-1-19', '1', 'shenyang'); INSERT INTO `user` VALUES (31, 'aabbcc', '2018-6-12', 'm', 'neusoft');

orders表(订单表):

Mybatis框架
文章图片
CREATE TABLE `orders` ( `id` int(11) NOT NULL AUTO_INCREMENT, `user_id` int(11) NOT NULL COMMENT '下单用户id', `number` varchar(32) NOT NULL COMMENT '订单号', `createtime` datetime NOT NULL COMMENT '创建订单时间', `note` varchar(100) DEFAULT NULL COMMENT '备注', PRIMARY KEY (`id`), KEY `FK_orders_1` (`user_id`), CONSTRAINT `FK_orders_id` FOREIGN KEY (`user_id`) REFERENCES `user` (`id`) ON DELETE NO ACTION ON UPDATE NO ACTION ) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=utf8; INSERT INTO `orders` VALUES (3, 1, '1000010', '2015-2-4 13:22:35', NULL); INSERT INTO `orders` VALUES (4, 1, '1000011', '2015-2-3 13:22:41', NULL); INSERT INTO `orders` VALUES (5, 10, '1000012', '2015-2-12 16:13:23', NULL);

orderdetail(订单详情表):

Mybatis框架
文章图片
CREATE TABLE `orderdetail` ( `id` int(11) NOT NULL AUTO_INCREMENT, `orders_id` int(11) NOT NULL COMMENT '订单id', `items_id` int(11) NOT NULL COMMENT '商品id', `items_num` int(11) DEFAULT NULL COMMENT '商品购买数量', PRIMARY KEY (`id`), KEY `FK_orderdetail_1` (`orders_id`), KEY `FK_orderdetail_2` (`items_id`), CONSTRAINT `FK_orderdetail_1` FOREIGN KEY (`orders_id`) REFERENCES `orders` (`id`) ON DELETE NO ACTION ON UPDATE NO ACTION, CONSTRAINT `FK_orderdetail_2` FOREIGN KEY (`items_id`) REFERENCES `items` (`id`) ON DELETE NO ACTION ON UPDATE NO ACTION ) ENGINE=InnoDB AUTO_INCREMENT=5 DEFAULT CHARSET=utf8; INSERT INTO `orderdetail` VALUES (1, 3, 1, 1); INSERT INTO `orderdetail` VALUES (2, 3, 2, 3); INSERT INTO `orderdetail` VALUES (3, 4, 3, 4); INSERT INTO `orderdetail` VALUES (4, 4, 2, 3);

items(商品表):

Mybatis框架
文章图片
CREATE TABLE `items` ( `id` int(11) NOT NULL AUTO_INCREMENT, `name` varchar(32) NOT NULL COMMENT '商品名称', `price` float(10,1) NOT NULL COMMENT '商品定价', `detail` text COMMENT '商品描述', `pic` varchar(64) DEFAULT NULL COMMENT '商品图片', `createtime` datetime NOT NULL COMMENT '生产日期', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8; INSERT INTO `items` VALUES (1, '台式机', 3000.0, '该电脑质量非常好!!!!', NULL, '2015-2-3 13:22:53'); INSERT INTO `items` VALUES (2, '笔记本', 6000.0, '笔记本性能好,质量好!!!!!', NULL, '2015-2-9 13:22:57'); INSERT INTO `items` VALUES (3, '背包', 200.0, '名牌背包,容量大质量好!!!!', NULL, '2015-2-6 13:23:02');

这四张表的关系:
  • 一个用户可以对应多个订单
    用户与订单: 1:N的关联
  • 一个订单对应多个订单信息
    //orders----------orderdetail 1:N
  • 一个订单信息上有一个商品信息
    //Orderdetail------------items 1:1
实体类: Mybatis框架
文章图片
User.java
package com.foreknow.bean; import java.util.Date; import java.util.List; public class User { private int id; private String username; private String sex; private Date birthday; private String address; //用户与订单:1:N的关联 private List ordersList; public List getOrdersList() { return ordersList; } public void setOrdersList(List ordersList) { this.ordersList = ordersList; } 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 String getSex() { return sex; } public void setSex(String sex) { this.sex = sex; } public Date getBirthday() { return birthday; } public void setBirthday(Date birthday) { this.birthday = birthday; } public String getAddress() { return address; } public void setAddress(String address) { this.address = address; }}

Orders.java
package com.foreknow.bean; import java.util.Date; import java.util.List; public class Orders { private Integer id; private Integer userId; private Date createtime; private String note; //orders----------user 1:1 private User user; //orders----------orderdetail 1:N private List orderdetails; public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public Integer getUserId() { return userId; } public void setUserId(Integer userId) { this.userId = userId; } public Date getCreatetime() { return createtime; } public void setCreatetime(Date createtime) { this.createtime = createtime; } public String getNote() { return note; } public void setNote(String note) { this.note = note; } public User getUser() { return user; } public void setUser(User user) { this.user = user; } }

Orderdetail.java:
package com.foreknow.bean; public class Orderdetail { private Integer id; private Integer ordersId; //订单id private Integer itemsId; //商品id private Integer itemsNum; //商品数量 //Orderdetail------------items1:1 private Items items; //商品public Items getItems() { return items; } public void setItems(Items items) { this.items = items; } public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public Integer getOrdersId() { return ordersId; } public void setOrdersId(Integer ordersId) { this.ordersId = ordersId; } public Integer getItemsId() { return itemsId; } public void setItemsId(Integer itemsId) { this.itemsId = itemsId; } public Integer getItemsNum() { return itemsNum; } public void setItemsNum(Integer itemsNum) { this.itemsNum = itemsNum; }}

Items.java
package com.foreknow.bean; import java.util.Date; public class Items { private Integer id; private String name; //商品名称 private double price; //商品价格 private String prc; private Date createtime; private String detail; public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public double getPrice() { return price; } public void setPrice(double price) { this.price = price; } public String getPrc() { return prc; } public void setPrc(String prc) { this.prc = prc; } public Date getCreatetime() { return createtime; } public void setCreatetime(Date createtime) { this.createtime = createtime; } public String getDetail() { return detail; } public void setDetail(String detail) { this.detail = detail; } }

UserDao.java Mybatis框架
文章图片
package com.foreknow.dao; import java.sql.SQLException; import java.util.List; import com.foreknow.bean.User; public interface UserDao { /** * 根据id查询用户信息 * @param id * @return User * @throws SQLException */ public User findUserById(int id)throws SQLException; /** * 根据姓名模糊查询用户 * @param name * @return List * @throws SQLException */ public List findUserByName(String name)throws SQLException; /** * 插入用户信息 * @param user * @throws SQLException */ public void insertUser(User user)throws SQLException; /** * 根据id删除用户 * @param id * @throws SQLException */ public void deleteUser(int id)throws SQLException; /** * 根据用户信息修改用户信息 * @param user * @throws SQLException */ public void updateUser(User user)throws SQLException; }

UserMapper.java
package com.foreknow.dao; import java.sql.SQLException; import java.util.List; import com.foreknow.bean.OrderUserInfo; import com.foreknow.bean.Orders; import com.foreknow.bean.User; import com.foreknow.bean.UserInfo; import com.foreknow.bean.UserQueryInfo; public interface UserMapper { /** * 根据Id查询用户信息 * @param id * @return * @throws SQLException */ public User findUserById(int id)throws SQLException; /** * 模糊查询用户信息列表 * @param username * @return * @throws SQLException */ public List findUserByName(String username)throws SQLException; /** * 添加用户信息 * @param user * @throws SQLException */ public void insertUser(User user)throws SQLException; /** * 根据ID删除用户信息 * @param id * @throws SQLException */ public void deleteUser(int id)throws SQLException; /** * 修改用户信息 * @param user * @throws SQLException */ public void updateUser(User user)throws SQLException; /** * 根据条件查询用户的信息 */ public List findUserList(UserQueryInfo userQueryInfo)throws SQLException; /** * 查询订单所关联的用户信息 * @return * @throws SQLException */ public List findOrdersUser()throws SQLException; /** * 使用Mybatis中的关联映射(一对一)ResultMap * @return * @throws SQLException */ public List findOrderUserResultMap()throws SQLException; /** * 查询订单(用户信息)以及明细信息 * @return * @throws SQLException */ public List findOrderDetailResultMap()throws SQLException; /** * 查询用户所购买的商品信息 * @return * @throws SQLException */ public List findUserItemsResultMap()throws SQLException; }

UserMapper.xml
and user.sex=#{userInfo.sex} and user.username like '%${userInfo.username}%' id = #{user_id} select * from user where id=#{id}insert into User(username,birthday,sex,address) values(#{username},#{birthday},#{sex},#{address})select * from user where username like '%${value}%' delete from user where id=#{id} update user set username=#{username},birthday=#{birthday},sex=#{sex},address=#{address} where id=#{id} select * from user select orders.*,user.username,user.sex,user.address from orders,user where orders.user_id = user.id select orders.*,user.username,user.sex,user.address from orders,user where orders.user_id = user.id select orders.*,user.username,user.sex,user.address, orderdetail.id orderdetail_id,orderdetail.items_num,orderdetail.orders_id from orders,user,orderdetail where orders.user_id = user.id and orders.id = orderdetail.orders_id select orders.*,user.username,user.sex,user.address, orderdetail.id orderdetail_id,orderdetail.items_num,orderdetail.orders_id, items.id items_id,items.name items_name,items.detail items_detail,items.price items_price from orders,user,orderdetail,items where orders.user_id = user.id and orders.id = orderdetail.orders_id and orderdetail.items_id = items.id

SqlMapConfig.xml Mybatis框架
文章图片

测试类: Mybatis框架
文章图片
MybatisUserMapperTest.java
package com.foreknow.mybatis_test; import java.io.IOException; import java.io.InputStream; import java.sql.SQLException; import java.util.ArrayList; 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 com.foreknow.bean.OrderUserInfo; import com.foreknow.bean.Orders; import com.foreknow.bean.User; import com.foreknow.bean.UserInfo; import com.foreknow.bean.UserQueryInfo; import com.foreknow.dao.UserDao; import com.foreknow.dao.UserDaoImpl; import com.foreknow.dao.UserMapper; public class MybatisUserMapperTest { private SqlSessionFactory sqlSessionFactory; @Before public void setUp() throws IOException { String resource="SqlMapConfig.xml"; //如何对SqlMapConfig.xml读取并解析 InputStream inputStream = Resources.getResourceAsStream(resource); //创建一个会话工厂(sqlSessionFactory),传入mybatis中的配置信息 sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream); } @Test public void testFindUserById() throws SQLException { SqlSession sqlSession = sqlSessionFactory.openSession(); //使用Mapper代理的方式来获取到UserMapper接口对象,这样才能调用接口中的方法 UserMapper userMapper = sqlSession.getMapper(UserMapper.class); User user = userMapper.findUserById(1); System.out.println(user.getUsername()); sqlSession.close(); } @Test public void testFindUserList() throws SQLException { SqlSession sqlSession = sqlSessionFactory.openSession(); //使用Mapper代理的方式来获取到UserMapper接口对象,这样才能调用接口中的方法 UserMapper userMapper = sqlSession.getMapper(UserMapper.class); UserQueryInfo userQueryInfo=new UserQueryInfo(); UserInfo userInfo = new UserInfo(); userInfo.setSex("1"); //userInfo.setUsername("张"); // //List ids = new ArrayList(); //ids.add(1); //ids.add(10); // ////设置条件 //userQueryInfo.setIds(ids); userQueryInfo.setUserInfo(userInfo); //查询 List list = userMapper.findUserList(userQueryInfo); System.out.println(list.size()); sqlSession.close(); }@Test public void testFindOrdersUser() throws SQLException { SqlSession sqlSession = sqlSessionFactory.openSession(); //使用Mapper代理的方式来获取到UserMapper接口对象,这样才能调用接口中的方法 UserMapper userMapper = sqlSession.getMapper(UserMapper.class); List list = userMapper.findOrdersUser(); System.out.println(list.size()); sqlSession.close(); }@Test public void testFindOrderUserResultMap() throws SQLException { SqlSession sqlSession = sqlSessionFactory.openSession(); //使用Mapper代理的方式来获取到UserMapper接口对象,这样才能调用接口中的方法 UserMapper userMapper = sqlSession.getMapper(UserMapper.class); List list = userMapper.findOrderUserResultMap(); System.out.println(list.size()); sqlSession.close(); }@Test public void testFindOrderDetailResultMap() throws SQLException { SqlSession sqlSession = sqlSessionFactory.openSession(); //使用Mapper代理的方式来获取到UserMapper接口对象,这样才能调用接口中的方法 UserMapper userMapper = sqlSession.getMapper(UserMapper.class); List list = userMapper.findOrderDetailResultMap(); System.out.println(list.size()); sqlSession.close(); }@Test public void testFindUserItemsResultMap() throws SQLException { SqlSession sqlSession = sqlSessionFactory.openSession(); //使用Mapper代理的方式来获取到UserMapper接口对象,这样才能调用接口中的方法 UserMapper userMapper = sqlSession.getMapper(UserMapper.class); List list = userMapper.findUserItemsResultMap(); System.out.println(list.size()); sqlSession.close(); } }

(老师整理的) Mybatis中的关联查询 数据库表结构
CREATE TABLE `orders` ( `id` int(11) NOT NULL AUTO_INCREMENT, `user_id` int(11) NOT NULL COMMENT '下单用户id', `number` varchar(32) NOT NULL COMMENT '订单号', `createtime` datetime NOT NULL COMMENT '创建订单时间', `note` varchar(100) DEFAULT NULL COMMENT '备注', PRIMARY KEY (`id`), KEY `FK_orders_1` (`user_id`), CONSTRAINT `FK_orders_id` FOREIGN KEY (`user_id`) REFERENCES `user` (`id`) ON DELETE NO ACTION ON UPDATE NO ACTION ) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=utf8; -- ---------------------------- -- Records of orders -- ---------------------------- INSERT INTO `orders` VALUES ('3', '1', '1000010', '2015-02-04 13:22:35', null); INSERT INTO `orders` VALUES ('4', '1', '1000011', '2015-02-03 13:22:41', null); INSERT INTO `orders` VALUES ('5', '10', '1000012', '2015-02-12 16:13:23', null);

数据模型分析思路
1、每张表记录的数据内容
分模块对每张表记录的内容进行熟悉,相当 于你学习系统 需求(功能)的过程。
2、每张表重要的字段设置
非空字段、外键字段
3、数据库级别表与表之间的关系
外键关系
4、表与表之间的业务关系
在分析表与表之间的业务关系时一定要建立 在某个业务意义基础上去分析。
数据模型分析 用户表user:
记录了购买商品的用户信息
订单表:orders
记录了用户所创建的订单(购买商品的订单)
订单明细表:orderdetail:
记录了订单的详细信息即购买商品的信息
商品表:items
记录了商品信息
表与表之间的业务关系:
在分析表与表之间的业务关系时需要建立 在某个业务意义基础上去分析。
先分析数据级别之间有关系的表之间的业务关系:
usre和orders:
user---->orders:一个用户可以创建多个订单,一对多
orders--->user:一个订单只由一个用户创建,一对一
orders和orderdetail:
orders--->orderdetail:一个订单可以包括 多个订单明细,因为一个订单可以购买多个商品,每个商品的购买信息在orderdetail记录,一对多关系
orderdetail--> orders:一个订单明细只能包括在一个订单中,一对一
orderdetail和itesm:
orderdetail--->itesms:一个订单明细只对应一个商品信息,一对一
items--> orderdetail:一个商品可以包括在多个订单明细 ,一对多
再分析数据库级别没有关系的表之间是否有业务关系:
orders和items:
orders和items之间可以通过orderdetail表建立 关系。
创建JavaBean模型关系
Orders模型
public class Orders { private Integer id; private Integer userId; private String orderid; private Date createtime; private String note; // 用户信息(用于resultMap) private User user; //Orders => Orderdetail 为一对多的关系 //最终会将订单信息映射到orders中,订单所对应的订单明细映射到orders中的orderDetails属性中。 private List orderdetails; public List getOrderdetails() { return orderdetails; }public void setOrderdetails(List orderdetails) { this.orderdetails = orderdetails; }public Integer getId() { return id; }public void setId(Integer id) { this.id = id; }public Integer getUserId() { return userId; }public void setUserId(Integer userId) { this.userId = userId; }public String getOrderid() { return orderid; }public void setOrderid(String orderid) { this.orderid = orderid; }public Date getCreatetime() { return createtime; }public void setCreatetime(Date createtime) { this.createtime = createtime; }public String getNote() { return note; }public void setNote(String note) { this.note = note == null ? null : note.trim(); }public User getUser() { return user; }public void setUser(User user) { this.user = user; } }

User模型
User.java //一个用户可以有多个订单(建立用户与商品之间的关系) //用户创建的订单列表 private List ordersList; public List getOrdersList() { return ordersList; }public void setOrdersList(List ordersList) { this.ordersList = ordersList; }

Items模型
public class Items { private Integer id; private String name; private Float price; private String pic; private Date createtime; private String detail; public Integer getId() { return id; }public void setId(Integer id) { this.id = id; }public String getName() { return name; }public void setName(String name) { this.name = name == null ? null : name.trim(); }public Float getPrice() { return price; }public void setPrice(Float price) { this.price = price; }public String getPic() { return pic; }public void setPic(String pic) { this.pic = pic == null ? null : pic.trim(); }public Date getCreatetime() { return createtime; }public void setCreatetime(Date createtime) { this.createtime = createtime; }public String getDetail() { return detail; }public void setDetail(String detail) { this.detail = detail == null ? null : detail.trim(); }@Override public String toString() { return "Items [id=" + id + ", name=" + name + ", price=" + price + ", pic=" + pic + ", createtime=" + createtime + ", detail=" + detail + "]"; } }

Orderdetail模型
public class Orderdetail { private Integer id; private Integer ordersId; private Integer itemsId; private Integer itemsNum; //明细对应的商品信息 private Items items; public Integer getId() { return id; }public void setId(Integer id) { this.id = id; }public Integer getOrdersId() { return ordersId; }public void setOrdersId(Integer ordersId) { this.ordersId = ordersId; }public Integer getItemsId() { return itemsId; }public void setItemsId(Integer itemsId) { this.itemsId = itemsId; }public Integer getItemsNum() { return itemsNum; }public void setItemsNum(Integer itemsNum) { this.itemsNum = itemsNum; }public Items getItems() { return items; }public void setItems(Items items) { this.items = items; }@Override public String toString() { return "Orderdetail [id=" + id + ", ordersId=" + ordersId + ", itemsId=" + itemsId + ", itemsNum=" + itemsNum + "]"; } }

创建UserMapper接口
public interface UserMapper { // 查询订单关联查询用户使用resultMap public List findOrdersUserResultMap() throws Exception; // 查询订单(关联用户)以及订单明细 public List findOrdersAndOrderDetailResultMap() throws Exception; // 查询用户购买商品信息 public List findUserAndItemsResultMap() throws Exception; }

创建UserMapper.xml
SELECT orders.*, USER.username, USER.sex, USER.address FROM orders, USER WHERE orders.user_id = user.id SELECT orders.*, USER.username, USER.sex, USER.address, orderdetail.id orderdetail_id, orderdetail.items_id, orderdetail.items_num, orderdetail.orders_id FROM orders, USER, orderdetail WHERE orders.user_id=user.id and orders.id=orderdetail.orders_id SELECT orders.*, USER.username, USER.sex, USER.address, orderdetail.id orderdetail_id, orderdetail.items_id, orderdetail.items_num, orderdetail.orders_id, items.name items_name, items.detail items_detail, items.price items_price from orders, user, orderdetail, items where orders.user_id=user.id and orders.id=orderdetail.orders_id and orderdetail.items_id=items.id

JUnit测试
public class UserMapperTest { private SqlSessionFactory sqlSessionFactory; // 此方法是在执行testFindUserById之前执行 @Before public void setUp() throws Exception { // 创建sqlSessionFactory// mybatis配置文件 String resource = "SqlMapConfig.xml"; // 得到配置文件流 InputStream inputStream = Resources.getResourceAsStream(resource); // 创建会话工厂,传入mybatis的配置文件信息 sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream); }@Test public void testFindOrdersUserResultMap() throws Exception {SqlSession sqlSession = sqlSessionFactory.openSession(); // 创建代理对象 UserMapper userMapper = sqlSession.getMapper(UserMapper.class); // 调用maper的方法 List list = userMapper.findOrdersUserResultMap(); System.out.println(list); sqlSession.close(); }@Test public void testFindOrdersAndOrderDetailResultMap() throws Exception {SqlSession sqlSession = sqlSessionFactory.openSession(); // 创建代理对象 UserMapper userMapper = sqlSession.getMapper(UserMapper.class); // 调用maper的方法 List list = userMapper.findOrdersAndOrderDetailResultMap(); System.out.println(list); sqlSession.close(); }@Test public void testFindUserAndItemsResultMap() throws Exception {SqlSession sqlSession = sqlSessionFactory.openSession(); // 创建代理对象 UserMapper userMapper = sqlSession.getMapper(UserMapper.class); // 调用maper的方法 List list = userMapper.findUserAndItemsResultMap(); System.out.println(list); sqlSession.close(); } }

    推荐阅读