Mybatis基本配置以及CRUD
Mybatis框架学习
1.0、Mybatis常用结构
MybatisUtils 帮助类 可以直接使用此类
package com.chris.utils;
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 java.io.IOException;
import java.io.InputStream;
public class MybatisUtils {
private static SqlSessionFactory sqlSessionFactory;
private static final String sqlTypes = null;
// 静态代码块 固定语法
static {
try {
// 使用Mybatis第一步 获取SqlSessionFactory
String resource = "mybatis-config-mysql.xml";
InputStream inputStream = Resources.getResourceAsStream(resource);
sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
} catch (IOException e) {
e.printStackTrace();
}
}
/***
* 既然有了 SqlSessionFactory,顾名思义,我们可以从中获得 SqlSession 的实例。SqlSession 提供了在数据库执行 SQL 命令所需的所有方法。
* 你可以通过 SqlSession 实例来直接执行已映射的 SQL 语句。例如:
*/
public static SqlSession getSqlSession() {
return sqlSessionFactory.openSession();
}
}
1.00、UserMapper 接口类
package com.chris.dao;
import com.chris.pojo.User;
import java.util.List;
public interface UserMapper {
List getListUser();
User getUserById(int Id);
int addUser(User user);
int updateUser(User user);
int delUser(int id);
}
1.01、UserMapper.xml 文件解析
<?xml version="1.0" encoding="UTF-8" ?>
insert into chrisdb.zd_user(id,name) values(#{id},#{name})
update chrisdb.zd_user set name = #{name} where id = #{id}
DELETE from chrisdb.zd_user where id = #{id}
1.02、连接mysql的配置文件
存放目录 \src\main\resources
<?xml version="1.0" encoding="UTF-8" ?>
1.03、测试单元
package com.chris.dao;
import com.chris.pojo.User;
import com.chris.utils.MybatisUtils;
import org.apache.ibatis.session.SqlSession;
import org.junit.Test;
import java.util.List;
public class UserDaoTest {
@Test
public void test() {
SqlSession sqlSession = MybatisUtils.getSqlSession();
UserMapper mapper = sqlSession.getMapper(UserMapper.class);
List listUser = mapper.getListUser();
for (User user : listUser) {
System.out.println(user);
}
}
/***
* 根据ID查询一个
*/
@Test
public void test022() {
SqlSession sqlSession = null;
try {
sqlSession = MybatisUtils.getSqlSession();
UserMapper mapper = sqlSession.getMapper(UserMapper.class);
User userById = mapper.getUserById(1);
System.out.println(userById);
} finally {
if (sqlSession != null) {
sqlSession.close();
}
}
}
@Test
public void test023() {
SqlSession sqlSession = null;
try {
sqlSession = MybatisUtils.getSqlSession();
UserMapper mapper = sqlSession.getMapper(UserMapper.class);
User users = new User(5, "赵六");
int i = mapper.addUser(users);
sqlSession.commit();
System.out.println(i);
} finally {
if (sqlSession != null) {
sqlSession.close();
}
}
}
@Test
public void test03() {
SqlSession sqlSession = null;
try {
sqlSession = MybatisUtils.getSqlSession();
UserMapper mapper = sqlSession.getMapper(UserMapper.class);
User users = new User(5, "赵六");
int i = mapper.updateUser(users);
sqlSession.commit();
System.out.println(i);
} finally {
sqlSession.close();
}
}
@Test
public void test04() {
SqlSession sqlSession = null;
try {
sqlSession = MybatisUtils.getSqlSession();
UserMapper mapper = sqlSession.getMapper(UserMapper.class);
int i = mapper.delUser(5);
sqlSession.commit();
System.out.println(i);
} catch (Exception exception) {
System.out.println(exception.getMessage());
} finally {
sqlSession.close();
}
}
}