MyBatis基于注解的增删改查示例(SpringIOC注入)

 代码:

数据模型层

package com.sunline.entity;import java.io.Serializable;public class User implements Serializable{private Integer user_id;private String user_name;private String user_password;private String user_kind;private Double user_balance;private String user_status;
public Integer getUser_id() {return user_id;
}
public void setUser_id(Integer user_id) {this.user_id &＃61; user_id;
}
public String getUser_name() {return user_name;
}
public void setUser_name(String user_name) {this.user_name &＃61; user_name;
}
public String getUser_password() {return user_password;
}
public void setUser_password(String user_password) {this.user_password &＃61; user_password;
}
public String getUser_kind() {return user_kind;
}
public void setUser_kind(String user_kind) {this.user_kind &＃61; user_kind;
}
public Double getUser_balance() {return user_balance;
}
public void setUser_balance(Double user_balance) {this.user_balance &＃61; user_balance;
}
public String getUser_status() {return user_status;
}
public void setUser_status(String user_status) {this.user_status &＃61; user_status;
}
&＃64;Override
public String toString() {return "User [user_id&＃61;" &＃43; user_id &＃43; ", user_name&＃61;" &＃43; user_name &＃43; ", user_password&＃61;" &＃43; user_password &＃43; ", user_kind&＃61;"&＃43; user_kind &＃43; ", user_balance&＃61;" &＃43; user_balance &＃43; ", user_status&＃61;" &＃43; user_status &＃43; "]";
}}



#数据访问层

   &＃64;数据操作接口

package com.sunline.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.Options;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Result;
import org.apache.ibatis.annotations.Results;
import org.apache.ibatis.annotations.Select;
import org.apache.ibatis.annotations.SelectProvider;
import org.apache.ibatis.annotations.Update;
import org.apache.ibatis.annotations.UpdateProvider;import com.sunline.entity.User;public interface UserDao {/** 插入一条用户记录*/&＃64;Insert("insert into user(user_name,user_password,user_kind,user_balance,user_status)"&＃43; " values(#{user_name},#{user_password},#{user_kind},#{user_balance},#{user_status})")&＃64;Options(useGeneratedKeys &＃61; true,keyProperty&＃61;"id")int SaveUser(User user);/** 删除指定id的用户*/&＃64;Delete("delete from user where user_id &＃61; #{user_id}")int RemoveUser(&＃64;Param("user_id") Integer user_id);/** 修改用户的指定字段*/&＃64;Update("update user set user_name &＃61; #{user_name}, user_balance &＃61; #{user_balance} where user_id &＃61; #{user_id}")void ModifyUser(User user);/** 查找所有用户*/&＃64;Select("select * from user")List findAll();/** 查找某个id的用户*/&＃64;Select("select * from user where user_id &＃61; #{user_id}")&＃64;Results({&＃64;Result(id&＃61;true,column&＃61;"user_id",property&＃61;"user_id"),&＃64;Result(column&＃61;"user_name",property&＃61;"user_name"),&＃64;Result(column&＃61;"user_password",property&＃61;"user_password"),&＃64;Result(column&＃61;"user_kind",property&＃61;"user_kind"),&＃64;Result(column&＃61;"user_balance",property&＃61;"user_balance"),&＃64;Result(column&＃61;"user_status",property&＃61;"user_status")})User findById(int user_id);/** 模糊查询*/&＃64;Select("select * from user where user_name like #{user_name} and user_balance >&＃61;#{user_balance}")public List findByMoHu(User user);/** 动态SQL查询(有输入的则为查询条件)*/&＃64;SelectProvider(type &＃61; UserSqlProvider.class, method &＃61; "SelectByParam")List findByDyna(Map param);/** 动态SQL修改参数(有输入的则为修改条件)*/&＃64;UpdateProvider(type &＃61; UserSqlProvider.class, method &＃61; "UpdateByParam")void UpdateUser(User user);}


 
&＃64;动态SQL生产类

package com.sunline.dao;import java.util.Map;import org.apache.ibatis.jdbc.SQL;import com.sunline.entity.User;public class UserSqlProvider {public String SelectByParam(Map param){return new SQL(){{SELECT("*"); FROM("user");if(param.get("user_id") !&＃61;null){WHERE("user_id &＃61; #{user_id}");}if(param.get("user_name") !&＃61;null){WHERE("user_name &＃61; #{user_name}");}if(param.get("user_password") !&＃61;null){WHERE("user_password &＃61; #{user_password}");}if(param.get("user_kind") !&＃61;null){WHERE("user_kind &＃61; #{user_kind}");}if(param.get("user_balance") !&＃61;null){WHERE("user_balance &＃61; #{user_balance}");}if(param.get("user_status") !&＃61;null){WHERE("user_status &＃61; #{user_status}");}}}.toString();}public String UpdateByParam(User user){return new SQL(){{UPDATE("user");if(user.getUser_name() !&＃61;null){SET("user_name &＃61; #{user_name}");}if(user.getUser_password() !&＃61;null){SET("user_password &＃61; #{user_password}");}if(user.getUser_kind() !&＃61;null){SET("user_kind &＃61; #{user_kind}");}if(user.getUser_balance() !&＃61;null){SET("user_balance &＃61; #{user_balance}");}if(user.getUser_status() !&＃61;null){SET("user_status &＃61; #{user_status}");}WHERE("user_id &＃61; #{user_id}");}}.toString();}
}



#业务逻辑层

package com.sunline.biz;import java.util.List;
import java.util.Map;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Isolation;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;import com.sunline.dao.UserDao;
import com.sunline.entity.User;&＃64;Transactional(propagation&＃61;Propagation.REQUIRED,isolation&＃61;Isolation.DEFAULT)
&＃64;Service("userBiz")
public class UserBiz {/** 自动注入UserDao*/&＃64;Autowiredprivate UserDao userDao;/** 添加用户*/public void SaveUser(User user){userDao.SaveUser(user);}/** 删除指定id的用户*/public void DeleteUser(int user_id){userDao.RemoveUser(user_id);}/** 修改用户的指定字段*/public void ModifyUser(User user){userDao.ModifyUser(user);}/** 查找所有用户*/public List findAll(){return userDao.findAll();}/** 根据id查找指定用户*/public User findById(int user_id){return userDao.findById(user_id);}/** 模糊查询*/public List findByMoHu(User user){return userDao.findByMoHu(user);}/** 动态SQL查询(有输入的则为查询条件)*/public List findByDyna(Map param){return userDao.findByDyna(param);}/** 动态SQL修改参数(有输入的则为修改条件)*/public void UpdateUser(User user){userDao.UpdateUser(user);}
}



#测试类

package com.sunline.test;import java.util.HashMap;
import java.util.List;
import java.util.Map;import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;import com.sunline.biz.UserBiz;
import com.sunline.entity.User;public class Test {public static void main(String[] args) {// TODO Auto-generated method stubApplicationContext ctx &＃61; new ClassPathXmlApplicationContext("applicationContext.xml");UserBiz userBiz &＃61; (UserBiz) ctx.getBean("userBiz");/** 1.添加用户 */User user &＃61; new User();user.setUser_name("张宇");user.setUser_password("123456");user.setUser_kind("客户");user.setUser_status("正常");user.setUser_balance(6500.0);userBiz.SaveUser(user);/** 2.删除指定id的用户*/userBiz.DeleteUser(7);/** 3.修改用户的指定字段*/User user &＃61; new User();user.setUser_id(5);user.setUser_name("毛仁");user.setUser_balance(8000.0);userBiz.ModifyUser(user);/** 4.查找所有用户*/List list &＃61; userBiz.findAll();for(User user : list){System.out.println("用户信息为: "&＃43;user.getUser_name()&＃43;" "&＃43;user.getUser_password()&＃43;" "&＃43;user.getUser_status()&＃43;" "&＃43;user.getUser_kind()&＃43;" "&＃43;user.getUser_balance());}/** 5.根据id查找用户信息*/User user &＃61; userBiz.findById(5);System.out.println("用户信息为: "&＃43;user.getUser_name()&＃43;" "&＃43;user.getUser_password()&＃43;" "&＃43;user.getUser_status()&＃43;" "&＃43;user.getUser_kind()&＃43;" "&＃43;user.getUser_balance());/** 6.模糊查询*/User user &＃61; new User();String user_name &＃61; "%"&＃43;"杨"&＃43;"%";double user_balance &＃61; 3000.0;user.setUser_name(user_name);user.setUser_balance(user_balance);List list &＃61; userBiz.findByMoHu(user);for(User us : list){System.out.println("用户信息为: "&＃43;us.getUser_name()&＃43;" "&＃43;us.getUser_password()&＃43;" "&＃43;us.getUser_status()&＃43;" "&＃43;us.getUser_kind()&＃43;" "&＃43;us.getUser_balance());}/** 7.动态SQL查询(有输入的则为查询条件)*/Map param &＃61; new HashMap();param.put("user_name", "杨旭");param.put("user_status", "正常");param.put("user_kind", "客户");List list &＃61; userBiz.findByDyna(param);for(User us : list){System.out.println("用户信息为: "&＃43;us.getUser_name()&＃43;" "&＃43;us.getUser_password()&＃43;" "&＃43;us.getUser_status()&＃43;" "&＃43;us.getUser_kind()&＃43;" "&＃43;us.getUser_balance());}/** 8.动态SQL修改参数(有输入的则为修改条件)*/User user &＃61; new User();user.setUser_id(5);user.setUser_name("毛仁义");user.setUser_password("1234567");user.setUser_balance(10000.0);userBiz.UpdateUser(user);}}