原始Dao开发方法
dao接口
package dao;
import po.Items;
import java.util.List;
/**
* Created by admin on 2017/7/1.
*/
public interface ItemsDao {
//根据id查询商品信息
public Items findItemsById(int id) throws Exception;
//根据商品名列查询商品列表
public List<Items> findItemsByName(String name) throws Exception;
//添加商品信息
public void insertItems(Items items) throws Exception;
//删除商品信息
public void deleteItems(int id) throws Exception;
}
dao接口实现类
package dao.impl;
import dao.ItemsDao;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import po.Items;
import java.util.List;
/**
* Created by admin on 2017/7/1.
*/
public class ItemsDaoImpl implements ItemsDao {
// 需要向dao实现类中注入SqlSessionFactory
// 这里通过构造方法注入
private SqlSessionFactory sqlSessionFactory;
public ItemsDaoImpl(SqlSessionFactory sqlSessionFactory){
this.sqlSessionFactory = sqlSessionFactory;
}
@Override
public Items findItemsById(int id) throws Exception {
SqlSession sqlSession = sqlSessionFactory.openSession();
Items items = sqlSession.selectOne("mapper.ItemsMapper.findItemsById", id);
//释放资源
sqlSession.close();
return items;
}
@Override
public List<Items> findItemsByName(String name) throws Exception {
SqlSession sqlSession = sqlSessionFactory.openSession();
List<Items> list = sqlSession.selectList("mapper.ItemsMapper.findItemsByName", name);
//释放资源
sqlSession.close();
return list;
}
@Override
public void insertItems(Items items) throws Exception {
SqlSession sqlSession = sqlSessionFactory.openSession();
sqlSession.insert("mapper.ItemsMapper.insertItems", items);
//提交事务
sqlSession.commit();
//释放资源
sqlSession.close();
}
@Override
public void deleteItems(int id) throws Exception {
SqlSession sqlSession = sqlSessionFactory.openSession();
sqlSession.delete("mapper.ItemsMapper.deleteItems",id);
sqlSession.commit();
sqlSession.close();
}
}
映射文件ItensMapper.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">
<!--
namespace 命名空间,作用就是对sql进行分类化管理,理解为sql隔离
注意:使用mapper代理方法开发,namespace有特殊重要的作用
-->
<mapper namespace="mapper.ItemsMapper">
<!-- 通过select执行数据库查询
id:标识映射文件中的sql,称为statement的id
将sql语句封装到mappedStatement对象中,所以将id称为statement的id
parameterType:指定输入参数的类型
#{}标示一个占位符,
#{value}其中value表示接收输入参数的名称,如果输入参数是简单类型,那么#{}中的值可以任意。
resultType:指定sql输出结果的映射的java对象类型,select指定resultType表示将单条记录映射成java对象
-->
<!-- public List<Items> queryItemsById(Integer id);-->
<select id="queryItemsById" parameterType="int" resultType="po.Items">
SELECT * FROM items WHERE id = #{id}
</select>
<!-- public Items findItemsById(int id) throws Exception;-->
<select id="findItemsById" parameterType="int" resultType="po.Items">
SELECT * FROM items WHERE id = #{id}
</select>
<!-- 根据商品名称模糊查询商品信息,可能返回多条
resultType:指定就是单条记录所映射的java对象类型
${}:表示拼接sql串,将接收到参数的内容不加任何修饰拼接在sql中。
使用${}拼接sql,引起 sql注入
${value}:接收输入参数的内容,如果传入类型是简单类型,${}中只能使用value
-->
<!-- public List<Items> findItemsByName(String name) throws Exception;-->
<select id="findItemsByName" parameterType="string" resultType="po.Items">
SELECT * FROM items WHERE name LIKE '%#{name}%'
</select>
<!-- public void insertItems(Items items) throws Exception;-->
<select id="insertItesm" parameterType="po.Items">
INSERT INTO items(name, price, detail, pic) VALUES (#{name},#{price},#{detail},#{pic})
</select>
<!-- public void deleteItems(int id) throws Exception;-->
<select id="deleteItems" parameterType="int">
DELETE FROM items WHERE id = #{id}
</select>
</mapper>
测试类Test02.java
package test;
/**
* Created by admin on 2017/7/1.
*/
public class Test02 {
private SqlSessionFactory sqlSessionFactory;
// 此方法是在执行testFindUserById之前执行
@Before
public void setUp() throws IOException {
// 创建sqlSessionFactory
// mybatis配置文件
String resource = "SqlMapConfig.xml";
// 得到配置文件流
InputStream inputStream = Resources.getResourceAsStream(resource);
// 创建会话工厂,传入mybatis的配置文件信息
sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
}
@org.junit.Test
public void testFindItemsById() throws Exception {
//创建ItemsDao对象
ItemsDao itemsDao = new ItemsDaoImpl(sqlSessionFactory);
//调用ItemsDao方法
Items itemsById = itemsDao.findItemsById(2);
System.out.println(itemsById);
}
}
运行结果
总结原始dao开发问题
1.dao接口实现类方法中存在大量模板方法,设想能否将这些代码提取出来,大大减轻程序员的工作量。
2.调用sqlsession方法时将statement的id硬编码了
3.调用sqlsession方法时传入的变量,由于sqlsession方法使用泛型,即使变量类型传入错误,在编译阶段也不报错,不利于程序员开发。
mapper代理方法
程序员只需要mapper接口(相当 于dao接口)
程序员还需要编写mapper.xml映射文件
程序员编写mapper接口需要遵循一些开发规范,mybatis可以自动生成mapper接口实现类代理对象。
开发规范
在mapper.xml中namespace等于mapper接口地址
<!--
namespace 命名空间,作用就是对sql进行分类化管理,理解为sql隔离
注意:使用mapper代理方法开发,namespace有特殊重要的作用
-->
<mapper namespace="mapper.ItemsMapper">
- mapper.java接口中的方法名和mapper.xml中statement的id一致
- mapper.java接口中的方法输入参数类型和mapper.xml中statement的parameterType指定的类型一致。
- mapper.java接口中的方法返回值类型和mapper.xml中statement的resultType指定的类型一致。
<select id="findItemsById" parameterType="int" resultType="po.Items">
SELECT * FROM items WHERE id = #{id}
</select>
//根据id查询商品信息
public Items findItemsById(int id) throws Exception;
以上开发规范主要是对下边的代码进行统一生成:
SqlSession sqlSession = sqlSessionFactory.openSession();
Items items = sqlSession.selectOne("mapper.ItemsMapper.findItemsById", id);
代码部分
ItemsMapper.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="mapper.ItemsMapper">
<!-- public List<Items> queryItemsById(Integer id);-->
<select id="queryItemsById" parameterType="int" resultType="po.Items">
SELECT * FROM items WHERE id = #{id}
</select>
<!-- public Items findItemsById(int id) throws Exception;-->
<select id="findItemsById" parameterType="int" resultType="po.Items">
SELECT * FROM items WHERE id = #{id}
</select>
<!-- public List<Items> findItemsByName(String name) throws Exception;-->
<select id="findItemsByName" parameterType="string" resultType="po.Items">
SELECT * FROM items WHERE name LIKE '%#{name}%'
</select>
<!-- public void insertItems(Items items) throws Exception;-->
<select id="insertItesm" parameterType="po.Items">
INSERT INTO items(name, price, detail, pic) VALUES (#{name},#{price},#{detail},#{pic})
</select>
<!-- public void deleteItems(int id) throws Exception;-->
<select id="deleteItems" parameterType="int">
DELETE FROM items WHERE id = #{id}
</select>
</mapper>
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>
<environments default="development">
<environment id="development">
<!-- 使用jdbc事务管理,事务控制由mybatis-->
<transactionManager type="JDBC"/>
<!-- 数据库连接池,由mybatis管理-->
<dataSource type="POOLED">
<property name="driver" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql:///mybatis001"/>
<property name="username" value="root"/>
<property name="password" value="root"/>
</dataSource>
</environment>
</environments>
<mappers>
<mapper resource="mapper/ItemsMapper.xml"/>
</mappers>
</configuration>
ItemsMapper.java
package dao;
import po.Items;
import java.util.List;
/**
* Created by admin on 2017/7/1.
*/
public interface ItemsMapper{
//根据id查询商品信息
public Items findItemsById(int id) throws Exception;
//根据商品名列查询商品列表
public List<Items> findItemsByName(String name) throws Exception;
//添加商品信息
public void insertItems(Items items) throws Exception;
//删除商品信息
public void deleteItems(int id) throws Exception;
}
Test03.java
package test;
import dao.ItemsDao;
import dao.impl.ItemsDaoImpl;
import mapper.ItemsMapper;
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.*;
import po.Items;
import java.io.InputStream;
/**
* Created by admin on 2017/7/1.
*/
public class Test03 {
private SqlSessionFactory sqlSessionFactory;
//注解Before是在执行本类所有测试方法之前先调用这个方法
@Before
public void setup() throws Exception{
//创建SqlSessionFactory
String resource="SqlMapConfig.xml";
//将配置文件加载成流
InputStream inputStream = Resources.getResourceAsStream(resource);
//创建会话工厂,传入mybatis配置文件的信息
sqlSessionFactory=new SqlSessionFactoryBuilder().build(inputStream);
}
@org.junit.Test
public void testFindItemsById() throws Exception{
SqlSession sqlSession=sqlSessionFactory.openSession();
//创建ItemsDao代理对象
ItemsMapper mapper = sqlSession.getMapper(ItemsMapper.class);
//调用userMapper的方法
Items items =mapper.findItemsById(1);
System.out.println(items.getName());
}
}
运行结果