前面我们讲了如何搭建mybatis开发环境以及采用接口式编程,基于接口式编程的基础上来讲一下如何通过mybatis来实现数据的增删改查操作。步骤如下:
操作步骤
1.在ActivityDao接口中分别定义insert、destroy、update、selectById四种方法。代码如下:
package com.zhq.dao;
import java.util.List;
import com.zhq.pojo.Activity;
public interface ActivityDao {
List<Activity> selectByAll();
Activity selectById(int id);
void insert(Activity activity);
void update(Activity activity);
void destroy(int id);
}
2.在ActivityMappper配置文件中分别增加以下代码:
<select id="selectById" parameterType="int" resultType="Activity">
select * from activity where id = #{id};
</select>
<update id="update" parameterType="Activity">
update activity set title=#{title},description=#{note},imgPath=#{imgPath},start_time=#{startTime},end_time=#{endTime};
</update>
<delete id="destroy" parameterType="int">
delete from activity where id = #{id};s
</delete>
<insert id="insert" parameterType="Activity">
insert into activity set title=#{title},description=#{note},imgPath=#{imgPath},start_time=#{startTime},end_time=#{endTime};
</insert>
最终效果如下:
<?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.zhq.dao.ActivityDao">
<select id="selectAll" resultType="Activity">
select * from activity;
</select>
<select id="selectById" parameterType="int" resultType="Activity">
select * from activity where id = #{id};
</select>
<update id="update" parameterType="Activity">
update activity set title=#{title},description=#{note},imgPath=#{imgPath},start_time=#{startTime},end_time=#{endTime};
</update>
<delete id="destroy" parameterType="int">
delete from activity where id = #{id};
</delete>
<insert id="insert" parameterType="Activity">
insert into activity set title=#{title},description=#{note},imgPath=#{imgPath},start_time=#{startTime},end_time=#{endTime};
</insert>
</mapper>
ps:mapper、select、update、delete、insert标签属性设置请参考:mybatisXML映射文件
3.在ActivityTest测试类中增加四个测试方法:insert()、update()、delete()、select()。代码如下:
package com.zhq.test;
import java.io.IOException;
import java.io.Reader;
import java.util.Date;
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.Assert;
import org.junit.Before;
import org.junit.Test;
import com.zhq.dao.ActivityDao;
import com.zhq.pojo.Activity;
public class ActivityTest {
private static SqlSessionFactory sqlSessionFactory;
private static Reader reader;
@Before
public void setUp() throws Exception {
try {
reader = Resources.getResourceAsReader("mybatis_config.xml");
sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader);
} catch (IOException e) {
e.printStackTrace();
}
}
@Test
public void select() {
SqlSession session = sqlSessionFactory.openSession();
// Activity activity = session.selectOne("com.zhq.dao.ActivityDao.selectById",10);
ActivityDao activityDao = session.getMapper(ActivityDao.class);
Activity activity = activityDao.selectById(10);
session.commit();
System.out.println(activity);
Assert.assertNotEquals("查找成功", "爱美丽", activity.getTitle());
session.close();
}
@Test
public void insert(){
SqlSession session = sqlSessionFactory.openSession();
ActivityDao activityDao = session.getMapper(ActivityDao.class);
Activity activity = new Activity();
activity.setTitle("耐克大促销");
activity.setNote("耐克大促销");
activity.setImgPath("www.zhq.com/91");
activity.setStartTime(new Date());
activity.setEndTime(new Date());
activityDao.insert(activity);;
session.commit();
session.close();
}
@Test
public void update(){
SqlSession session = sqlSessionFactory.openSession();
ActivityDao activityDao = session.getMapper(ActivityDao.class);
Activity activity = activityDao.selectById(10);
activity.setId(10);
activity.setTitle("爱打游戏");
activity.setNote("爱打游戏");
activity.setStartTime(new Date());
activity.setEndTime(new Date());
activityDao.update(activity);
session.commit();
session.close();
}
@Test
public void delete(){
SqlSession session = sqlSessionFactory.openSession();
ActivityDao activityDao = session.getMapper(ActivityDao.class);
activityDao.destroy(10);;
session.commit();
session.close();
}
}
4.运行测试代码一路绿灯完成