6_代理模式下开发各种功能-4_实现DML操作

墨蓝 2023-09-30 18:02 15阅读 0赞

EmpMapper接口

/\*\*  
\* 增加员工信息  
\* @param emp 存储新增员工信息的Emp对象  
\* @return 对数据库数据产生影响的行数  
\*/  
int addEmp(Emp emp);  
/\*\*  
\* 根据员工编号修改员工姓名的方法  
\* @param empno 要修改的员工编号  
\* @param ename 修改之后的新的员工名字  
\* @return 对数据库数据产生影响的行数  
\*/  
int updateEnameByEmpno(@Param("empno") int empno,@Param("ename") String ename);  
/\*\*  
\* 根据员工编号删除员工信息  
\* @param empno 要删除的员工编号  
\* @return 对数据库数据产生影响的行数  
\*/  
int deleteByEmpno(int empno);

EmpMapper映射 文件

<insert id="addEmp" >  
insert into emp values(DEFAULT ,\#\{ename\},\#\{job\},\#\{mgr\},\#\{hiredate\},\#\{sal\},\#\{comm\},\#\{deptno\})  
</insert>  
  
<update id="updateEnameByEmpno" >  
update emp set ename =\#\{ename\} where empno =\#\{empno\}  
</update>  
  
<update id="deleteByEmpno" >  
delete from emp where empno =\#\{empno\}  
</update>

测试代码

package com.msb.test;  
import com.msb.mapper.DeptMapper;  
import com.msb.mapper.EmpMapper;  
import com.msb.pojo.Dept;  
import com.msb.pojo.Emp;  
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.After;  
import org.junit.Before;  
import org.junit.Test;  
import java.io.IOException;  
import java.io.InputStream;  
import java.util.Date;  
/\*\*  
\* @Author: Ma HaiYang  
\* @Description: MircoMessage:Mark\_7001  
\*/  
public class Test3 \{  
private SqlSession sqlSession;  
@Before  
public void init()\{  
SqlSessionFactoryBuilder ssfb =new SqlSessionFactoryBuilder();  
InputStream resourceAsStream = null;  
try \{  
resourceAsStream = Resources.getResourceAsStream("sqlMapConfig.xml");  
\} catch (IOException e) \{  
e.printStackTrace();  
\}  
SqlSessionFactory factory=ssfb.build(resourceAsStream) ;  
sqlSession=factory.openSession();  
\}  
@Test  
public void testAddEmp()\{  
EmpMapper mapper = sqlSession.getMapper(EmpMapper.class);  
mapper.addEmp(new Emp(null, "TOM", "SALESMAN", 7521, new Date(), 2314.0, 100.0, 10));  
sqlSession.commit();  
\}  
@Test  
public void testUpdateEnameByEmpno()\{  
EmpMapper mapper = sqlSession.getMapper(EmpMapper.class);  
mapper.updateEnameByEmpno(7938, "TOM");  
sqlSession.commit();  
\}  
@Test  
public void testDeletByEmpno()\{  
EmpMapper mapper = sqlSession.getMapper(EmpMapper.class);  
mapper.deleteByEmpno(7938);  
sqlSession.commit();  
\}  
@After  
public void release()\{  
// 关闭SQLSession  
sqlSession.close();  
\}  
\}