SqlSession 使用范围
- SqlSessionFactoryBuilder
通过SqlSessionFactoryBuilder 创建会话工厂SqlSessionFactory
将SqlSessionFactoryBuilder当成一个工具类使用即可,不需要使用单例管理。
在需要创建SqlSessionFactory时候,只需要new一次SqlSessionFactoryBuilder即可。
- SqlSessionFactory
通过SqlSessionFactory
创建 SqlSession
, 通过单例模式管理SqlSessionFactory(工厂一旦创建,一直使用一个实例,不销毁)
将来和 spring 整合之后,使用单例模式管理SqlSessionFactory
- SqlSession
SqlSession是一个面向用户的接口。提供了很多操作数据库的方法,如:selectOne、selectList。
SQLSession是线程不安全的。在SQLSession实现类中除了有接口中的方法(操作数据库的方法)还有数据域属性。
SQLSession最佳应用场合在方法体内,定义成局部变量。
原始dao开发方法(需要编写dao接口和dao实现类)
- 思路:
编写dao接口和dao实现类。
需要向dao实现类中注入SqlSessionFactory,在方法体内通过SqlSessionFactory创建SQLSession
- dao接口
- dao 接口实现类
public class UserDaoiImpl implements UserDao{
//向dao实现类注入SqlSessionFactory
//这里通过构造方法注入
private SqlSessionFactory sqlSessionFactory;
public UserDaoiImpl(SqlSessionFactory sqlSessionFactory) {
this.sqlSessionFactory = sqlSessionFactory;
}
@Override
public User findUserById(int id) throws Exception {
SqlSession sqlSession = this.sqlSessionFactory.openSession();
User user = sqlSession.selectOne("user.findUserById", id);
sqlSession.close();
return user;
}
@Override
public void addUser(User user) throws Exception {
SqlSession sqlSession = this.sqlSessionFactory.openSession();
sqlSession.insert("user.insertUser", user);
sqlSession.commit();
sqlSession.close();
}
@Override
public void deleteUserById(int id) throws Exception {
SqlSession sqlSession = this.sqlSessionFactory.openSession();
sqlSession.delete("user.deleteUserById", id);
sqlSession.commit();
sqlSession.close();
}
@Override
public void updateUser(User user) throws Exception {
SqlSession sqlSession = this.sqlSessionFactory.openSession();
sqlSession.update("user.updateUser", user);
sqlSession.commit();
sqlSession.close();
}
}
- 测试代码
public class UserDaoiImplTest {
private SqlSessionFactory buildFactory;
@Before
public void setUp() throws Exception {
//创建工厂
InputStream resourceAsStream = Resources.getResourceAsStream("SqlMapConfig.xml");
buildFactory = new SqlSessionFactoryBuilder().build(resourceAsStream);
}
@Test
public void testFindUserById() throws Exception {
UserDao userDao = new UserDaoiImpl(buildFactory);
User user = userDao.findUserById(2);
System.out.println(user);
}
@Test
public void testAddUser() throws Exception {
UserDao userDao = new UserDaoiImpl(buildFactory);
User user = new User();
user.setUsername("李小飞");
user.setAddress("山东泰安");
user.setBirthday(new Date());
user.setSex("女");
userDao.addUser(user);
}
}
mapper代理方法(只需要编写mapper接口,相当于dao接口)
- 思路 :
需要编写mapper.xml映射文件
需要编写mapper接口,遵循一些开发规范,mybatis可以自动生成mapper接口实现类代理对象。
开发规范:
1、在mapper.xml 中 namespace 等于 mapper接口的地址
2、mapper.java 接口中的方法名和mapper.xml 中statement的id一致
3、mapper.java 接口中方法的输入参数类型和mapper.xml 中statement的 parameterType指定的类型一致
4、mapper.java 接口中方法的返回值类型和mapper.xml 中statement的resultType指定的类型一致
举例:
-
总结:
以上开发规范主要是对下边代码进行统一生成:
User user = sqlSession.selectOne("user.findUserById", id); sqlSession.insert("user.insertUser", user); ...
mapper.java
public interface UserMapper {
//根据id查询用户
public User findUserById(int id) throws Exception;
//新增一个用户
public void insertUser(User user) throws Exception;
//删除用户信息
public void deleteUserById(Integer id) throws Exception;
//修改某个用户信息
public void updateUser(User user) throws Exception;
}
- mapper.xml
- 在SqlMapConfig.xml中加载mapper.xml文件
- 测试