MyBatis学习笔记1 简单CURD

墨蓝 2024-03-30 14:24 68阅读 0赞

#### 使用MyBatis实现基本CURD ####

> 采用传统的Dao层开发方式、通过mybatis实现对数据库表基本功能、查询所有、查询单个、新增、删除、修改

*  在Dao层创建接口、有如下几个方法：

public interface UserInfoDao  
\{  
public List<UserInfo> selectAll();

public UserInfo selectUser(int id);

public int insert(UserInfo userInfo);

public int update(UserInfo userInfo);

public int delete(int id);  
\}

*  实现接口、代码如下：

public class UserInfoDaoImpl implements UserInfoDao  
\{  
private SqlSession sqlSession;

/\*\*  
\* 通过构造函数、注入sqlSession对象  
\* @param sqlSession 调用者传入的sqlSession对象  
\*/  
public UserInfoDaoImpl(SqlSession sqlSession)  
\{  
this.sqlSession = sqlSession;  
\}

/\*\*  
\* 查询所有  
\* @return 结果集合  
\*/  
@Override  
public List<UserInfo> selectAll()  
\{  
return this.sqlSession.selectList("com.rg.dao.UserInfoDao.selectAll");  
\}

/\*\*  
\* 查询单个  
\* @param id 条件id  
\* @return 单个对象  
\*/  
@Override  
public UserInfo selectUser(int id)  
\{  
return this.sqlSession.selectOne("com.rg.dao.UserInfoDao.selectUser", id);  
\}

/\*\*  
\* 新增数据  
\* @param userInfo 对象  
\* @return 受影响行数  
\*/  
@Override  
public int insert(UserInfo userInfo)  
\{  
return this.sqlSession.insert("com.rg.dao.UserInfoDao.insert", userInfo);  
\}

/\*\*  
\* 修改数据  
\* @param userInfo 对象  
\* @return 受影响行数  
\*/  
@Override  
public int update(UserInfo userInfo)  
\{  
return this.sqlSession.update("com.rg.dao.UserInfoDao.update", userInfo);  
\}

/\*\*  
\* 删除数据  
\* @param id 条件id  
\* @return 受影响行数  
\*/  
@Override  
public int delete(int id)  
\{  
return this.sqlSession.delete("com.rg.dao.UserInfoDao.delete", id);  
\}  
\}

*  在Dao层创建mapper映射文件、如下：

<mapper namespace="com.rg.dao.UserInfoDao">  
  
<select id="selectAll" resultType="com.rg.entity.UserInfo">  
select \* from UserInfo  
</select>  
<select id="selectUser" resultType="com.rg.entity.UserInfo">  
select \* from UserInfo where id = \#\{id\}  
</select>  
<insert id="insert" parameterType="com.rg.entity.UserInfo">  
insert into UserInfo(Name,Age) values(\#\{Name\},\#\{Age\})  
</insert>  
<update id="update" parameterType="com.rg.entity.UserInfo">  
update UserInfo set Name=\#\{Name\},Age=\#\{Age\} where id = \#\{id\}  
</update>  
<delete id="delete" parameterType="int">  
delete from UserInfo where id=\#\{id\}  
</delete>  
</mapper>

*  在测试类中测试、如下：

private UserInfoDao userInfoDao;  
private SqlSession sqlSession;  
@Before  
public void init() throws IOException  
\{  
//mybatis主配置文件  
String config = "mybatis.xml";  
//读取配置文件  
InputStream is = Resources.getResourceAsStream(config);  
//创建SqlSessionFactory对象，目的是获取SqlSession  
SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);  
//获取SqlSession对象，SqlSession能执行sql语句  
this.sqlSession = sqlSessionFactory.openSession();  
this.userInfoDao = new UserInfoDaoImpl(sqlSession);  
\}  
@After  
public void finish()  
\{  
//关闭selectList，释放资源  
this.sqlSession.close();  
\}  
@Test  
public void selectAll()  
\{  
//执行SqlSession的selectList()  
List<UserInfo> userList = this.userInfoDao.selectAll();  
//循环输出集合中的结果  
userList.forEach(x -> System.out.println(x));  
\}  
@Test  
public void selectUser()  
\{  
UserInfo userInfo = this.userInfoDao.selectUser(2);  
System.out.println(userInfo);  
\}

@Test  
public void insert()  
\{  
UserInfo userInfo = new UserInfo();  
userInfo.setName("张飞");  
userInfo.setAge(16);  
int result = this.userInfoDao.insert(userInfo);  
sqlSession.commit();  
System.out.println(result);  
\}

@Test  
public void update()  
\{  
UserInfo userInfo = new UserInfo();  
userInfo.setId(2);  
userInfo.setName("李白");  
userInfo.setAge(20);  
int result = this.userInfoDao.update(userInfo);  
sqlSession.commit();  
System.out.println(result);  
\}

@Test  
public void delete()  
\{  
int result = this.userInfoDao.delete(2);  
sqlSession.commit();  
System.out.println(result);  
\}  
这样，通过MyBatis就实现了对数据库表的简单CURD。