src/main/java/com/pas/dao/xml/User.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要定义成Mapper的接口名字 -->
<mapper namespace="com.pas.mapper.IUserMapper">
<resultMap type="com.pas.dao.domain.User" id="RUser">
<id property="userId" column="user_id"/>
<result property="code" column="code"/>
<result property="password" column="password"/>
<result property="email" column="email"/>
<result property="state" column="state"/>
</resultMap>
<parameterMap type="com.pas.dao.domain.User" id="PUser">
<parameter property="userId" javaType="int" />
<parameter property="code" />
<parameter property="password" />
<parameter property="email" />
<parameter property="state" />
</parameterMap>
<select id="queryUserById" parameterType="int" resultMap="RUser">
select user_id, code,password,email, state from User where user_id = #{userId}
</select>
<select id="queryUserByName" parameterType="string" resultMap="RUser">
select user_id, code,password,email, state from User where code = #{code}
</select>
<insert id="insertUser" parameterMap="PUser">
insert into User(user_id, code,password,email, state) values(#{userId}, #{code},#{password},#{email}, #{state})
</insert>
<update id="updateUser">
update User set code=#{code},password=#{password},email=#{email},state=#{state} where user_id=#{userId}
</update>
</mapper>
User.java
package com.pas.dao.domain;
import java.util.Date;
public class User {
private int userId;
private String code;
private String password;
private String email;
private String state;
private String createBy;
private Date createDatetime;
private String modifyBy;
private Date modifyDatetime;
......
}
两种方式 DAO方式:
接口
IUsersDao.java
package com.pas.dao;
import java.util.List;
public interface IUsersDao {
@SuppressWarnings("rawtypes")
public abstract List queryUserByName(String name);
}
实现类
UsersDao.java
package com.pas.dao.impl;
import java.util.List;
import org.mybatis.spring.support.SqlSessionDaoSupport;
import org.springframework.stereotype.Repository;
import com.pas.dao.IUsersDao;
/**
* 这个是使用dao方式,这种方式可以处理自定义异常等.
* @author Administrator
*
*/
@Repository
public class UsersDao extends SqlSessionDaoSupport implements IUsersDao {
@SuppressWarnings("rawtypes")
@Override
public List queryUserByName(String name) {
System.out.println("Users.queryUserByName()");
//com.pas.mapper.IUserMapper.queryUserByName 这里是空间名字+sql id
return getSqlSession().selectList("com.pas.mapper.IUserMapper.queryUserByName", name);
}
}
接口+namespace方式:
Mapper接口
IUserMapper.java
package com.pas.mapper;
import com.pas.dao.domain.User;
/**
* 这里是Mapper接口,接口定义的方法一定跟User.xml里面的sql id一致,否则会出现错误.
* @author Administrator
*
*/
public interface IUserMapper {
public abstract User queryUserById(int id);
public abstract void insertUser(User user);
public abstract void updateUser(User user);
}
UserMapper.java
package com.pas.mapper.impl;
import com.pas.dao.domain.User;
import com.pas.mapper.IUserMapper;
/**
* 这个是Mapper接口方式,接口的方法名字就直接对应User.xml里面的SQL ID.<p>
* 在实现类里面实现并直接使用接口,其实这个接口的实现就是User.xml
* @author Administrator
*
*/
public class UserMapper implements IUserMapper {
private IUserMapper userMapper;
@Override
public User queryUserById(int id) {
return userMapper.queryUserById(id);
}
@Override
public void insertUser(User user) {
System.out.println("userMapper insertUser");
userMapper.insertUser(user);
}
@Override
public void updateUser(User user) {
System.out.println("userMapper updateUser");
userMapper.updateUser(user);
}
public IUserMapper getUserMapper() {
return userMapper;
}
public void setUserMapper(IUserMapper userMapper) {
this.userMapper = userMapper;
}
}
Service:
接口:这个接口并不是必要的
IUsersService.java
package com.pas.service;
import com.pas.dao.domain.User;
public interface IUsersService {
public abstract User queryUsersById(int id);
public abstract User queryUsersByName(String name);
public abstract void saveUser(User user);
}
实现类:
UsersServiceImpl.java
package com.pas.service.impl;
import java.util.List;
import javax.annotation.Resource;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import com.pas.dao.IUsersDao;
import com.pas.dao.domain.User;
import com.pas.mapper.IUserMapper;
import com.pas.service.IUsersService;
@Service(value="usersService")
@Transactional(rollbackFor=Exception.class)
public class UsersServiceImpl implements IUsersService {
@Resource(name="userMapper")
private IUserMapper userMapper;
@Resource(name="usersDao")
private IUsersDao usersDao;
@Override
@Transactional(propagation=Propagation.REQUIRED, readOnly=true)
public User queryUsersById(int id){
return userMapper.queryUserById(id);
}
/**
* 使用dao方式
*/
@SuppressWarnings("rawtypes")
@Override
@Transactional(propagation=Propagation.REQUIRED, readOnly=true)
public User queryUsersByName(String name){
List list = usersDao.queryUserByName(name);
System.out.println("list = "+list==null?"0":list.size());
if(list!=null&&list.size()>0) return (User)list.get(0);
return null;
}
/**
* 使用Mapper接口方式
*/
@Override
@Transactional(propagation=Propagation.REQUIRED)
public void saveUser(User user){
if(user.getUserId()<=0){
System.out.println("insertUser");
userMapper.insertUser(user);
}else{
System.out.println("updateUser");
userMapper.updateUser(user);
}
//throw new RuntimeException("@@ Rollback for Debug..........");
}
}
Controller类:
TestController.java
package com.pas.controller;
import java.util.Date;
import javax.annotation.Resource;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import com.pas.dao.domain.User;
import com.pas.service.IUsersService;
@Controller
public class TestController {
@Resource(name = "usersService")
private IUsersService usersService;
@RequestMapping(value = "/doTest.do")
public String doTest() {
User user = new User();
user.setCode("pandy");
user.setEmail("afasdf");
user.setPassword("pandy");
user.setState("001");
user.setCreateBy("01");
user.setCreateDatetime(new Date());
user.setModifyBy("001");
user.setModifyDatetime(new Date());
usersService.saveUser(user);
user = usersService.queryUsersById(1);
user = usersService.queryUsersByName("pandy");
System.out.println("Test success.......");
return "success";
}
}