mybatis开发Dao-低调大师

mybatis开发Dao

2018-06-18 603

参考文献:https://blog.csdn.net/u013036274/article/details/55668317

原始dao方式

需要写dao接口和dao实现类。

创建dao接口：UserDao.java

package cn.itcast.mybatis.dao;
import cn.itcast.mybatis.po.Employee;
public interface UserDao {
    public Employee findUserById(int id) throws Exception;
    public void insertUser(Employee employee) throws Exception;
    public void deleteUser(int id) throws Exception;
}

创建dao实现类：UserDaoImpl.java

package cn.itcast.mybatis.dao;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import cn.itcast.mybatis.po.Employee;
public class UserDaoImpl implements UserDao{
    private SqlSessionFactory sqlSessionFactory;
    public  UserDaoImpl(SqlSessionFactory sqlSessionFactory) {
        this.sqlSessionFactory = sqlSessionFactory;
    }
    @Override
    public Employee findUserById(int id) throws Exception {
        SqlSession sqlSession =sqlSessionFactory.openSession();
        Employee employee = sqlSession.selectOne("test.findUserById",id);
        sqlSession.close();
        return employee;
    }
    @Override
    public void insertUser(Employee employee) throws Exception {
        SqlSession sqlSession =sqlSessionFactory.openSession();
        sqlSession.insert("test.insertUser",employee);
        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(); 
    }
}

测试方法：

package cn.itcast.mybatis.dao;
import static org.junit.Assert.*;
import java.io.InputStream;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import org.junit.Before;
import org.junit.Test;
import cn.itcast.mybatis.po.Employee;
public class UserDaoImplTest {
    private SqlSessionFactory sqlSessionFactory;
    @Before
    public void setUp() throws Exception{
        String resource="SqlMapConfig.xml";
        InputStream inputStream= Resources.getResourceAsStream(resource);
        sqlSessionFactory =new SqlSessionFactoryBuilder().build(inputStream);
    }
    @Test
    public void test() throws Exception {
        UserDao userDao = new UserDaoImpl(sqlSessionFactory);
        Employee employee = userDao.findUserById(3);
        System.out.println(employee);
    }
}

缺点：

接口实现类方法中存在大量模板方法，设想能否将这些代码提取出来。
另外调用SqlSession方法时，将Statement的id硬编码了。
调用SqlSession方法时，传入的变量，由于SqlSession方法使用泛型，即使变量类型传入错误，在编译阶段也不报错，不利于开发。

mapper代理方法

xml映射文件 (UserMapper.xml)
①在mapper.xml中namespace等于mapper接口地址
②mapper.java接口中的方法名和mapper.xml中的Statement的id一致
③mapper.java接口中的方法输入参数类型和mapper.xml中Statement的parameterType指定类型一致
④mapper.java接口中的方法返回值类型和mapper.xml中Statement的resultType指定的类型一致

<mapper namespace="cn.itcast.mybatis.mapper.UserMapper">
     <select id="findUserById" parameterType="int" resultType="cn.itcast.mybatis.po.Employee">
         select id,username,sex,address from users where id=#{id};
     </select>

mapper接口，相当于dao接口(UserMapper.java)

package cn.itcast.mybatis.mapper;
import cn.itcast.mybatis.po.Employee;
public interface UserMapper {
    public Employee findUserById(int id) throws Exception;
        public java.util.List<Employee> findUserByName(String name) throws Exception;
    public void insertUser(Employee employee ) throws Exception;
    public void deleteUser(int id) throws Exception;

}

还需在SqlMapConfig.xml加载映射文件

<mapper resource="mapper/UserMapper.xml"/>

测试文件

package cn.itcast.mybatis.mapper;
import static org.junit.Assert.*;
import java.io.InputStream;
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 cn.itcast.mybatis.po.Employee;
public class UserMapperTest {
private SqlSessionFactory sqlSessionFactory;
    @Before
    public void setUp() throws Exception{
        String resource="SqlMapConfig.xml";
        InputStream inputStream= Resources.getResourceAsStream(resource);
        sqlSessionFactory =new SqlSessionFactoryBuilder().build(inputStream);
    }
    @Test
    public void test() throws Exception {
        SqlSession sqlSession =sqlSessionFactory.openSession();
        UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
        Employee employee =userMapper.findUserById(2);
        System.out.println(employee);
    }
        @Test
    public void test1() throws Exception {
        SqlSession sqlSession =sqlSessionFactory.openSession();
        UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
        java.util.List<Employee> list =userMapper.findUserByName("zhao");
        sqlSession.close();
        System.out.println(list);
    }
}

通过调用单独的文件连接数据库

SqlMapConfig.xml

<properties resource="db.properties"></properties>
<environments default="development">  
<environment id="development">
 <transactionManager type="JDBC"/> 
 <dataSource type="POOLED">
 <property name="driver" value="${jdbc.driver}"/> 
 <property name="url" value="${jdbc.url}"/> 
 <property name="username" value="${jdbc.username}"/> 
 <property name="password" value="${jdbc.password}"/> 
 </dataSource>
 </environment>
</environments>

db.properties（和SqlMapConfig.xml在同一目录下）

jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/test?serverTimezone=GMT%2B8
jdbc.username=root
jdbc.password=

pojo包装类型实现

UserMapper.xml（定义用户信息综合查询，查询条件复杂）

 <select id="findUserList" parameterType="cn.itcast.mybatis.po.UserQueryVo" resultType="cn.itcast.mybatis.po.EmployeeCustom">
         select id,username,sex,address from users where sex= #{employeeCustom.sex} and username like '%${employeeCustom.username}%';
     </select>

UserQueryVo.java（包装对象）

package cn.itcast.mybatis.po;
public class UserQueryVo {
    private EmployeeCustom employeeCustom;
    public EmployeeCustom getEmployeeCustom() {
        return employeeCustom;
    }
    public void setEmployeeCustom(EmployeeCustom employeeCustom) {
        this.employeeCustom = employeeCustom;
    }
}

EmployeeCustom.java

package cn.itcast.mybatis.po;
public class EmployeeCustom extends Employee{   
}

测试文件

@Test
    public void test1() throws Exception {
        SqlSession sqlSession =sqlSessionFactory.openSession();
        UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
                //创建包装对象，设置查询条件
        UserQueryVo userQueryVo= new UserQueryVo();
        EmployeeCustom employeeCustom=new EmployeeCustom();
        employeeCustom.setSex("nv");
        employeeCustom.setUsername("zhou");
        userQueryVo.setEmployeeCustom(employeeCustom);
               //调用userMapper的方法
        java.util.List<EmployeeCustom> list =userMapper.findUserList(userQueryVo);
        sqlSession.close(); 
        System.out.println(list);
    }

动态sql判断

UserMapper.xml(判断传入的sex和username是否为空，若是空则不进行拼接)

 <select id="findUserList" parameterType="cn.itcast.mybatis.po.UserQueryVo" resultType="cn.itcast.mybatis.po.EmployeeCustom">
         select id,username,sex,address from users 
         <where>
              <if test="employeeCustom!=null">
                 <if test="employeeCustom.sex!=null and employeeCustom.sex!=''">
                      and sex= #{employeeCustom.sex}
                 </if>
                 <if test="employeeCustom.username!=null and employeeCustom.username!=''">
                       and username like '%${employeeCustom.username}%';
                 </if>
               </if>
         </where>  
          
     </select>

测试文件

@Test
    public void test1() throws Exception {
        SqlSession sqlSession =sqlSessionFactory.openSession();
        UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
        UserQueryVo userQueryVo= new UserQueryVo();
        EmployeeCustom employeeCustom=new EmployeeCustom();
        //employeeCustom.setSex("nv");//注释此句后，查询语句中没有sex这个条件
        employeeCustom.setUsername("zhou");
        userQueryVo.setEmployeeCustom(employeeCustom);
        java.util.List<EmployeeCustom> list =userMapper.findUserList(userQueryVo);
        sqlSession.close(); 
        System.out.println(list);
    }

** 进行select * from users where id=1 or id=10 or id=11 ;**

在上面的UserMapper.xml中添加

<if test="ids!=null">
                 <!-- collection:指定输入对象中集合属性 item:每个遍历生成对象中 open:开始遍历时拼接串 
                 close:结束遍历时拼接的串 separator:遍历两个对象须拼接的串
                                实现拼接 AND (id=1 or id=10 or id=13) -->
                 <foreach collection="ids" item="user_id" open="AND (" close=")" separator="or">
                      id=#{user_id}
                 </foreach>

测试文件

@Test
    public void test1() throws Exception {
        SqlSession sqlSession =sqlSessionFactory.openSession();
        UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
        UserQueryVo userQueryVo= new UserQueryVo();
        EmployeeCustom employeeCustom=new EmployeeCustom();
        //employeeCustom.setSex("nv");
        employeeCustom.setUsername("zhou");
        java.util.List<Integer> ids =new ArrayList<Integer>();
        ids.add(1);
        ids.add(10);
        ids.add(14);
        userQueryVo.setIds(ids);
        userQueryVo.setEmployeeCustom(employeeCustom);
        java.util.List<EmployeeCustom> list =userMapper.findUserList(userQueryVo);
        sqlSession.close(); 
        System.out.println(list);
    }

微信关注我们

原文链接：https://yq.aliyun.com/articles/654377

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

完美解决setInterval在浏览器切换时加速的问题

JavaScript中当我们切换浏览器的时候，setInterval会加快速度导致这个原因是：发现这是因为浏览器本着节省内存的性质，当切换到其他页面时，采油系统页面的定时器不运动，但是动画依然排列，当切换回来的时候，动画加速运动，出现错误，在轮播图之类的页面经常会发生这样的情况在这里我们需要用到以下三个知识点： document.onvisibilitychange ：只要页面发生变化，不管是切换到其他的页面还是把浏览器缩小，都会触发这个事件。 document.hidden 这个是指当页面不是当前页面时为true，否则为false document.visibilityState: 这个属性有四个值，分为是：visible，hidden，prerender，unloaded visible 表示当前网页是可见或者是部分可见的。 hidden：当前网页是不可见的 prerender 网页内容被预渲染并且用户不可见 unloaded 如果文档被卸载，那么这个值将被返回实际操作效果如下： document.onvisibilitychange=function(){ consol...

2018-06-19

585

参考文献：https://blog.csdn.net/yerenyuan_pku/article/details/71909325 逆向工程： MyBatis需要程序员自己编写sql，如果表太多的话，会很麻烦。所以mybatis官方提供了一个逆向工程，可以针对单表自动生成mybatis执行所需要的代码（包括mapper.xml、mapper.java、po..）。通过数据库的表生成代码，这个真的是很方便，感觉前几天看了那么久的mybatis整合的我有点傻。。目录结构 7.png 导入需要的jar包： mybatis-generator-core-1.3.5.jar 配置逆向工程的配置文件mbg.xml <?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE generatorConfiguration PUBLIC "-//mybatis.org//DTD MyBatis Generator Configuration 1.0//EN" "http://mybatis.org/dtd/mybatis-generator-co...

2018-06-19

538

资源下载

更多资源

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。