mybatis开发dao的方法

1     //以流的方式读取总的配置文件
2     Reader reader = Resources.getResourceAsReader("mybatis-config.xml");
3 
4     //生成SqlSessionFactory
5     SqlSessionFactory  sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader);
6 
7     //从SqlSessionFactory中获得SqlSession
8     SqlSession session = sqlSessionFactory.openSession();

 1 public interface UserDao {
 2     
 3     //根据id查询用户信息
 4     public User findUserById(int id) throws Exception;
 5     
 6     //根据用户名列查询用户列表
 7     public List<User> findUserByName(String name) throws Exception;
 8     
 9     //添加用户信息
10     public void insertUser(User user) throws Exception;
11     
12     //删除用户信息
13     public void deleteUser(int id) throws Exception;
14 
15 }

 1 public class UserDaoImpl implements UserDao {
 2 
 3    // 需要向dao实现类中注入SqlSessionFactory
 4 
 5    // 这里通过构造方法注入
 6    private SqlSessionFactory sqlSessionFactory;
 7 
 8    public UserDaoImpl(SqlSessionFactory sqlSessionFactory) {
 9       this.sqlSessionFactory = sqlSessionFactory;
10 
11    }
12 
13    @Override
14    public User findUserById(int id) throws Exception {
15       SqlSession sqlSession = sqlSessionFactory.openSession();
16 
17       User user = sqlSession.selectOne("test.findUserById", id);
18 
19       // 释放资源
20       sqlSession.close();
21 
22       return user;
23 
24    }
25 
26    @Override
27    public void insertUser(User user) throws Exception {
28 
29       SqlSession sqlSession = sqlSessionFactory.openSession();
30 
31       //执行插入操作
32       sqlSession.insert("test.insertUser", user);
33 
34       // 提交事务
35       sqlSession.commit();
36 
37       // 释放资源
38       sqlSession.close();
39 
40    }
41 
42    @Override
43    public void deleteUser(int id) throws Exception {
44       SqlSession sqlSession = sqlSessionFactory.openSession(); 
45 
46       //执行插入操作
47       sqlSession.delete("test.deleteUser", id);
48 
49       // 提交事务
50       sqlSession.commit();
51 
52 
53       // 释放资源
54       sqlSession.close();
55 
56    }
57 
58 }

 1 public class UserDaoImplTest {
 2 
 3     private SqlSessionFactory sqlSessionFactory;
 4 
 5     // 此方法是在执行testFindUserById之前执行
 6     @Before
 7     public void setUp() throws Exception {
 8         // 创建sqlSessionFactory
 9 
10         // mybatis配置文件
11         String resource = "SqlMapConfig.xml";
12         // 得到配置文件流
13         InputStream inputStream = Resources.getResourceAsStream(resource);
14 
15         // 创建会话工厂，传入mybatis的配置文件信息
16         sqlSessionFactory = new SqlSessionFactoryBuilder()
17                 .build(inputStream);
18     }
19 
20     @Test
21     public void testFindUserById() throws Exception {
22         // 创建UserDao的对象
23         UserDao userDao = new UserDaoImpl(sqlSessionFactory);
24 
25         // 调用UserDao的方法
26         User user = userDao.findUserById(1);
27         
28         System.out.println(user);
29     }
30 
31 }

 1     private SqlSessionFactory sqlSessionFactory;
 2 
 3     // 此方法是在执行testFindUserById之前执行
 4     @Before
 5     public void setUp() throws Exception {
 6         // 创建sqlSessionFactory
 7 
 8         // mybatis配置文件
 9         String resource = "SqlMapConfig.xml";
10         // 得到配置文件流
11         InputStream inputStream = Resources.getResourceAsStream(resource);
12 
13         // 创建会话工厂，传入mybatis的配置文件信息
14         sqlSessionFactory = new SqlSessionFactoryBuilder()
15                 .build(inputStream);
16     }
17     @Test
18     public void testFindUserById() throws Exception {
19         
20         SqlSession sqlSession = sqlSessionFactory.openSession();
21         
22         //创建UserMapper对象，mybatis自动生成mapper代理对象
23         UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
24         
25         //调用userMapper的方法
26         
27         User user = userMapper.findUserById(1);
28         
29         System.out.println(user);
30         
31         
32     }
33     //用户信息的综合 查询