- 要想开发基于注解的MyBatis应用。需要先写一个带有注解的接口。
PersonDao.java的写法如下：
|
package com.rl.dao; import java.util.List; import java.util.Map; import org.apache.ibatis.annotations.Delete; import org.apache.ibatis.annotations.Insert; import org.apache.ibatis.annotations.Result; import org.apache.ibatis.annotations.ResultMap; import org.apache.ibatis.annotations.Results; import org.apache.ibatis.annotations.Select; import org.apache.ibatis.annotations.SelectKey; import org.apache.ibatis.annotations.SelectProvider; import org.apache.ibatis.annotations.Update; import com.rl.model1.Person; import com.rl.util.SqlHelper; public interface PersonDao { @Select("select * from person t where t.person_id = #{personId}") @Results(value={ @Result(column="person_id", property="personId", id=true), @Result(column="name", property="name"), @Result(column="gender", property="gender"), @Result(column="person_addr", property="personAddr"), @Result(column="birthday", property="birthday") }) public Person selectPersonById(Integer personId); @Select("select * from person") @Results(value={ @Result(column="person_id", property="personId", id=true), @Result(column="name", property="name"), @Result(column="gender", property="gender"), @Result(column="person_addr", property="personAddr"), @Result(column="birthday", property="birthday") }) public List<Person> selectPersonAll(); @Select("select * from person t where t.gender = #{gender} and t.birthday < #{birthday}") @Results(value={ @Result(column="person_id", property="personId", id=true), @Result(column="name", property="name"), @Result(column="gender", property="gender"), @Result(column="person_addr", property="personAddr"), @Result(column="birthday", property="birthday") }) public List<Person> selectPersonByParams(Map<String,Object> map); @Select("select * from person t where t.name like ‘%${name}%‘") @Results(value={ @Result(column="person_id", property="personId", id=true), @Result(column="name", property="name"), @Result(column="gender", property="gender"), @Result(column="person_addr", property="personAddr"), @Result(column="birthday", property="birthday") }) public List<Person> selectPersonByLike(Map<String,Object> map); @Insert("insert into person (person_id, name, gender, person_addr, birthday) " + "values(#{personId}, #{name}, #{gender}, #{personAddr}, #{birthday})") @SelectKey(before = false, keyProperty = "personId", resultType = java.lang.Integer.class, statement = { "select LAST_INSERT_ID()" }) public void insert(Person person); @Update("update person p set p.name = #{name}," + "p.gender = #{gender}," + "p.person_addr = #{personAddr}," + "p.birthday = #{birthday} " + "where p.person_id = #{personId}") public void update(Person person); @Delete("delete from person where person_id = #{personId}") public void delete(Integer personId); @SelectProvider(type=SqlHelper.class, method="getSql") @Results(value={ @Result(column="person_id", property="personId", id=true), @Result(column="name", property="name"), @Result(column="gender", property="gender"), @Result(column="person_addr", property="personAddr"), @Result(column="birthday", property="birthday") }) public List<Person> selectPersonByCondition(Map<String,Object> map); @Select("select * from person p, orders o where p.person_id = o.person_id and p.person_id = #{personId}") @ResultMap(value="com.rl.mapper.PersonMapper.selectPersonAndOrderByPIdRM") public Person selectOrdersByPersonId(Integer personId); } |
测试类：
|
package com.rl.test; import java.io.InputStream; import java.text.SimpleDateFormat; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; 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.rl.dao.PersonDao; import com.rl.model1.Person; /** * mybatis的注解开发 */ public class MybatisTest6 { SqlSessionFactory sessionFactory; @Before public void setUp() throws Exception { InputStream in = Resources.getResourceAsStream("sqlMapConfig.xml"); sessionFactory = new SqlSessionFactoryBuilder().build(in); //注册接口 sessionFactory.getConfiguration().addMapper(PersonDao.class); } @Test public void selectPersonById(){ SqlSession session = sessionFactory.openSession(); //获得接口的实现类 PersonDao personDao = session.getMapper(PersonDao.class); try { Person person = personDao.selectPersonById(1); System.out.println(person); }finally{ session.close(); } } @Test public void selectPersonAll(){ SqlSession session = sessionFactory.openSession(); //获得接口的实现类 PersonDao personDao = session.getMapper(PersonDao.class); try { List<Person> pList = personDao.selectPersonAll(); for(Person p : pList){ System.out.println(p); } } finally { session.close(); } } @Test public void selectPersonByParams() throws Exception { SqlSession session = sessionFactory.openSession(); //获得接口的实现类 PersonDao personDao = session.getMapper(PersonDao.class); Map<String,Object> map = new HashMap<String,Object>(); map.put("gender", 0); map.put("birthday", new SimpleDateFormat("yyyy-MM-dd").parse("2014-08-08")); try { List<Person> pList = personDao.selectPersonByParams(map); for(Person p : pList){ System.out.println(p); } } finally { session.close(); } } @Test public void selectPersonByLike() throws Exception{ SqlSession session = sessionFactory.openSession(); //获得接口的实现类 PersonDao personDao = session.getMapper(PersonDao.class); Map<String,Object> map = new HashMap<String,Object>(); map.put("name", "安"); try { List<Person> pList = personDao.selectPersonByLike(map); for(Person p : pList){ System.out.println(p); } }finally{ session.close(); } } @Test public void insert() throws Exception{ SqlSession session = sessionFactory.openSession(); //获得接口的实现类 PersonDao personDao = session.getMapper(PersonDao.class); try { Person p = new Person(); p.setName("西门庆"); p.setGender("0"); p.setPersonAddr("阳谷县"); p.setBirthday(new Date()); personDao.insert(p); session.commit(); }catch(Exception ex){ ex.printStackTrace(); session.rollback(); }finally{ session.close(); } } @Test public void update() throws Exception{ SqlSession session = sessionFactory.openSession(); //获得接口的实现类 PersonDao personDao = session.getMapper(PersonDao.class); try { Person p = new Person(); p.setPersonId(5); p.setName("大官人"); p.setGender("0"); p.setPersonAddr("阳谷县"); p.setBirthday(new Date()); personDao.update(p); session.commit(); }catch(Exception ex){ ex.printStackTrace(); session.rollback(); }finally{ session.close(); } } @Test public void delete() throws Exception{ SqlSession session = sessionFactory.openSession(); //获得接口的实现类 PersonDao personDao = session.getMapper(PersonDao.class); try { personDao.delete(5); session.commit(); }catch(Exception ex){ ex.printStackTrace(); session.rollback(); }finally{ session.close(); } } /** * 动态条件组合查询 */ @Test public void selectPersonByCondition() throws Exception{ SqlSession session = sessionFactory.openSession(); //获得接口的实现类 PersonDao personDao = session.getMapper(PersonDao.class); Map<String,Object> map = new HashMap<String,Object>(); //map.put("name", "安"); //map.put("gender", "0"); //map.put("personAddr", "府"); //map.put("birthday", new Date()); try { List<Person> pList = personDao.selectPersonByCondition(map); for(Person p : pList){ System.out.println(p); } } finally { session.close(); } } /** * 管理查询 */ @Test public void selectOrdersByPersonId() throws Exception{ SqlSession session = sessionFactory.openSession(); //获得接口的实现类 PersonDao personDao = session.getMapper(PersonDao.class); try { Person person = personDao.selectOrdersByPersonId(1); System.out.println(person); }finally{ session.close(); } } } |