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();

}

}

}