SqlSession使用范围
SqlSessionFactory
通过sqlsessionfactory创建sqlsession,使用单例模式管理sqlsessionfactory,工厂模式一旦创建,一直使用一个实例。
将来和spring整合后, 使用单例模式管理sqlsessionfactory
sqlsessionfactorybuilder创建会话工厂
通过上面这个创建工厂,将sqlsessionfactory当成一个工具类,不需要使用单例模式,只需要new一次builder即可。
sqlsession
面向用户程序员的接口
很多操作数据库的方法:selectOne selectList
sqlsession是线程,不安全的,在sqlsession实现类中,有接口中的方法,还有数据域的属性,
原始dao开发方法,程序员需要写dao接口和dao实现类
思路:需要些dao接口和实现类
需要向dao实现类,注入会话工厂
在方法体内,工厂创建session
dao接口
package cn.itcast.mybatis.dao;
import cn.itcast.mybatis.pojo.User;
public interface UserDao {
//根据id查询用户信息
public User findUserById(int id) throws Exception;
//添加用户信息
public void insertUser(User user)throws Exception;
//删除用户信息
public void deleteUser(int id) throws Exception;
}
dao实现类
package cn.itcast.mybatis.dao;
import cn.itcast.mybatis.pojo.User;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
public class UserDaoImpl implements UserDao{
//需要dao实现类注入sqlsessionfactory接口
//这里通过构造函数注入
private SqlSessionFactory sqlSessionFactory;
public UserDaoImpl(SqlSessionFactory sqlSessionFactory){
this.sqlSessionFactory = sqlSessionFactory;
}
@Override
public User findUserById(int id) throws Exception {
SqlSession sqlSession = sqlSessionFactory.openSession();
User user = sqlSession.selectOne("test.findUserById",id);
sqlSession.close();
return user;
}
@Override
public void insertUser(User user) throws Exception {
SqlSession sqlSession = sqlSessionFactory.openSession();
sqlSession.insert("test.insertUser",user);
sqlSession.commit();
sqlSession.close();
}
@Override
public void deleteUser(int id) throws Exception {
SqlSession sqlSession = sqlSessionFactory.openSession();
sqlSession.delete("test.deleteUser",id);
sqlSession.commit();
sqlSession.close();
}
}
** UserDaoImplTest**
测试接口
package cn.itcast.mybatis.dao;
import cn.itcast.mybatis.pojo.User;
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.Before;
import org.junit.Test;
import java.io.InputStream;
import static org.junit.Assert.*;
public class UserDaoImplTest {
private SqlSessionFactory sqlSessionFactory;
@Before
public void setUp() throws Exception{
//创建sqlSessionFactory
String resource = "SqlMapConfig.xml";
//得到配置文件流
InputStream inputStream = Resources.getResourceAsStream(resource);
//创建会话工厂,传入配置文件信息
sqlSessionFactory =new SqlSessionFactoryBuilder().build(inputStream);
//通过工厂得到SqlSession
SqlSession sqlSession = sqlSessionFactory.openSession();
}
@Test
public void findUserById() throws Exception {
//创建UserDao的对象
UserDao userDao = new UserDaoImpl(sqlSessionFactory);
//调用UserDao的方法
User user = userDao.findUserById(1);
System.out.println(user);
}
@Test
public void insertUser() {
}
@Test
public void deleteUser() {
}
}
原始dao开发的代码
dao接口实现类方法,存在大量的模板方法,能否将代码提取出来,大大减轻程序员的工作量
调用 sqlsession方法时,将statement硬编码了
调用方法,传入变量由于sqlsession使用泛型,即使变量类型传入错误,在编译阶段不报错,不利于程序员开发