mybatis的mapper代理开发,用mybatis代理进行简单的增删改查

mybatis的mapper代理开发,用mybatis代理进行简单的增删改查,第1张

 使用Mapper代理方法: 

1.定义与SQL映射文件同名的Mapper接口,并将Mapper接口和映射文件(xml文件)放在同一目录下, (一般将xml文件放在resources处,这里的要新建的是dictotry,而且命名时是用/代替. ;如果用.的话不会有分层,会认为包名就是如此比如com.wjy.mapper,用com/wjy/mapper会分层,但是显示的时候仍然是com.wjy.mapper)

2.设置sql映射文件的namespace属性为Mapper接口全限定名

3.在Mapper接口中定义方法,方法名就是sql映射文件中sql语句的id,并保持参数和返回值类型一致。

4.编码   1.通过SqlSession的getMapper方法获取Mapper接口的代理对象2.调用相应的方法完成sql的执行。

记得将主配置文件中的路径改了

 

 

举例:增删改查

1.创建项目

2.创建实体类

3.创建UserDao接口(UserDao和UserMapper作用是一样的)

package com.qcby.dao;

import com.qcby.entity.User;
import java.util.List;

public interface UserDao {
    /**
     * 查询所有用户
     */
    public List findAll();

    /**
     * 通过id查询一条数据
     * @param id
     * @return
     */
    public User findById(int id);

    /**
     * 增加数据
     * @param user
     * @return
     */
    public int insert(User user);

    /**
     * 更新数据
     * @param user
     */
    public int update(User user);

    /**
     * 删除数据
     * @param user
     */
    public int delete(int id);


}

 4.编写UserDao.xml的配置文件代码


        






    /*查询ID
    keyProperty:封装数据到属性
    order:数据添加后的 *** 作
    resulType:数据类型
    */
    
        select last_insert_id();
    
    insert into user(username,birthday,sex,address) values(#{username},#{birthday},#{sex},#{address})


        update user set username = #{username},birthday = #{birthday},sex = #{sex},address = #{address} where id = #{id}
    

        delete from user where id = #{id}
    

    
    

5. UserTest的代码

注意:修改数据(包括添加、删除、修改数据),如果数据库事务管理,使用JDBC本地策略,则需要手动提交事务,否则,数据库中数据无法修改

package com.qcby.test;

import com.qcby.dao.UserDao;
import com.qcby.entity.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.After;
import org.junit.Before;
import org.junit.Test;

import java.io.IOException;
import java.io.InputStream;
import java.util.Date;
import java.util.List;

public class UserTest {
    private InputStream in = null;
    private SqlSession session = null;
    private UserDao mapper = null;

    @Before
    public void init() throws IOException {
        //加载主配置文件,目的是为了构建SqlSessionFactory对象
        in = Resources.getResourceAsStream("SqlMapConfig.xml");
        //创建SqlSessionFactory对象
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(in);
        //通过SqlSessionFactory工厂对象创建SqlSesssion对象
        session = factory.openSession();
        //通过Session创建UserDao接口代理对象
        mapper = session.getMapper(UserDao.class);
    }
    @After
    public void destory() throws IOException {
        //释放资源
        session.close();
        in.close();
    }

    /**
     * 测试查询所有的方法
     */
    @Test
    public void run() throws IOException {
       /* //加载主配置文件,目的是为了构建SqlSessionFactory对象
        InputStream in = Resources.getResourceAsStream("SqlMapConfig.xml");
        //创建SqlSessionFactory对象
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(in);
        //通过SqlSessionFactory工厂对象创建SqlSesssion对象
        SqlSession session = factory.openSession();
        //调用查询所有的方法
        List list = session.selectList("com.qcby.dao.UserDao.findAll");
        //遍历集合
        for (User user : list) {
            System.out.println(user);
        }
        //释放资源
        session.close();
        in.close();*/
    }
    /**
     * 测试查询所有的方法
     */
    @Test
    public void testFindAll() {

        //调用查询所有的方法
        List list = mapper.findAll();
        for (User user : list) {
            System.out.println(user);
        }
    }

    /**
     * 测试
     */
    @Test
    public void testFindById() throws IOException {

        //调用查询ID的方法
        User user = mapper.findById(2);
        System.out.println(user);

    }
    /**
     * 测试增加
     */
    @Test
    public void testInsert() throws IOException {

        //创建user对象
        User user = new User();
        user.setUsername("guos");
        user.setSex("男");
        user.setBirthday(new Date());
        user.setAddress("背景");

        //调用添加方法
        int result = mapper.insert(user);
        session.commit();
        System.out.println(user.getId());
        System.out.println(result);

    }
    /**
     * 测试更新
     */
    @Test
    public void testUpdate() throws IOException {

        //创建user对象
        User user = new User();
        user.setId(4);
        user.setUsername("小花");
        user.setSex("女");
        user.setBirthday(new Date());
        user.setAddress("北京");

        //调用更新
        int result = mapper.update(user);
        session.commit();
        System.out.println(result);
    }

    /**
     * 测试删除
     */
    @Test
    public void testDelete() {
        //调用删除
        int result = mapper.delete(7);
        session.commit();
        System.out.println(result);
    }
    /**
     * 测试模糊查询
     */
    @Test
    public void testfindByUserName(){
        //调用查询数量
        List list = mapper.findByUserName("%熊%");
        session.commit();
        for (User user : list) {
            System.out.println(user);
        }
    }

    /**
     * 测试数量
     */
    @Test
    public void testfindCount(){
        //调用查询数量
        int count = mapper.findCount();
        session.commit();
        System.out.println(count);
    }
}

 模糊查询符号使用的区别${},#{}

#{} 参数是采用预编译 防止sql注入 这个在sql语句中就写的是?

${}参数是采用sql拼接 无法防止sql注入


#{} 参数是简单类型 (基础类型和字符串),变量可以任意

${} 参数是简单类型 (基础类型和字符串),变量必须是value


#{} 参数是引用类型,变量是引用类型中的属性,不可任意

${} 参数是引用类型 ,变量是引用类型中的属性,不可任意

欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/langs/723709.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-04-26
下一篇 2022-04-26

发表评论

登录后才能评论

评论列表(0条)

保存