栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

MyBatis注解实现增删改查

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

MyBatis注解实现增删改查

pom.xml

 
        
        
            org.mybatis
            mybatis
            3.5.4
        
        
        
            mysql
            mysql-connector-java
            5.1.6
            runtime
        
        
        
            junit
            junit
            4.12
            
        


    

User.java

//编写实体类 对应映射User表
public class User implements Serializable {
    private Integer id;
    private String username;
    private Date birthday;
    private String sex;
    private String address;
    private List orderList;
//    保存用户角色列表
    private List roleList;

    public User() {
    }

    public User(String username, Date birthday, String sex, String address) {
        this.username = username;
        this.birthday = birthday;
        this.sex = sex;
        this.address = address;
    }

    public User(Integer id, String username, Date birthday, String sex, String address, List orderList) {
        this.id = id;
        this.username = username;
        this.birthday = birthday;
        this.sex = sex;
        this.address = address;
        this.orderList = orderList ;
    }

    @Override
    public String toString() {
        return "User{" +
                "id=" + id +
                ", username='" + username + ''' +
                ", birthday=" + birthday +
                ", sex='" + sex + ''' +
                ", address='" + address + ''' +
                ", orderList=" + orderList +
                ", roleList=" + roleList +
                '}';
    }

    public List getRoleList() {
        return roleList;
    }

    public void setRoleList(List roleList) {
        this.roleList = roleList;
    }

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public Date getBirthday() {
        return birthday;
    }

    public void setBirthday(Date birthday) {
        this.birthday = birthday;
    }

    public String getSex() {
        return sex;
    }

    public void setSex(String sex) {
        this.sex = sex;
    }

    public String getAddress() {
        return address;
    }

    public void setAddress(String address) {
        this.address = address;
    }

    public List getOrderList() {
        return orderList;
    }

    public void setOrderList(List orderList) {
        this.orderList = orderList;
    }
}

Role.java

package com.qiku.popo;

public class Role {
    private Integer id;
    private String roleNmae;
    private String roleDesc;


    public Role() {
    }

    @Override
    public String toString() {
        return "Role{" +
                "id=" + id +
                ", roleNmae='" + roleNmae + ''' +
                ", roleDesc='" + roleDesc + ''' +
                '}';
    }

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getRoleNmae() {
        return roleNmae;
    }

    public void setRoleNmae(String roleNmae) {
        this.roleNmae = roleNmae;
    }

    public String getRoleDesc() {
        return roleDesc;
    }

    public void setRoleDesc(String roleDesc) {
        this.roleDesc = roleDesc;
    }
}

Order.java

package com.qiku.popo;

import java.io.Serializable;
import java.util.Date;

public class Order implements Serializable {
    private Integer id;
    private Date orderTime;
    private double money;

    // 表示当前订单属于哪个用户
    private User user;


    public Order() {
    }

    public Order(Integer id, Date orderTime, double money, User user) {
        this.id = id;
        this.orderTime = orderTime;
        this.money = money;
        this.user = user;
    }


    @Override
    public String toString() {
        return "Order{" +
                "id=" + id +
                ", orderTime=" + orderTime +
                ", money=" + money +
                ", user=" + user +
                '}';
    }

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public Date getOrderTime() {
        return orderTime;
    }

    public void setOrderTime(Date orderTime) {
        this.orderTime = orderTime;
    }

    public double getMoney() {
        return money;
    }

    public void setMoney(double money) {
        this.money = money;
    }

    public User getUser() {
        return user;
    }

    public void setUser(User user) {
        this.user = user;
    }
}

UserMapper.java

package com.qiku.mapper;


import com.qiku.popo.Order;
import com.qiku.popo.User;
import org.apache.ibatis.annotations.*;

import java.util.List;

@CacheNamespace
public interface UserMapper {

    @Insert("insert into user (username , birthday , sex , address)" + " values (#{username} , #{birthday} , #{sex} , #{address})")
    public void addUser(User user);

    @Delete("delete from user where id = #{id}")
    public void deleteUser(Integer id);

    @Update("update user set address = #{address} where id = #{id}")
    public void updateUser(User user);

    @Select("select * from user")
    public List findAllUser();

    @Select("select * from user where id = #{id}")
    public User findUserById(Integer id);

    @Select("select * from user")
    @Results({
            @Result(id = true , column = "id" ,property = "id"),
            @Result(column = "username" , property = "username"),
            @Result(column = "birthday" , property = "birthday"),
            @Result(column = "sex" , property = "sex"),
            @Result(column = "address" , property = "address"),
            @Result(property = "orderList" , javaType = List.class , column = "id" , many = @Many(select = "com.qiku.mapper.OrderMapper.findOrderByUid"))
    })
    public List findAllUserWithOrder();



//    查询所有用户 及其 角色信息
    @Select("select * from user")
    @Results({
            @Result(id = true , column = "id" ,property = "id"),
            @Result(column = "username" , property = "username"),
            @Result(column = "birthday" , property = "birthday"),
            @Result(column = "sex" , property = "sex"),
            @Result(column = "address" , property = "address"),
            @Result(property = "roleList" , javaType = List.class , column = "id" , many = @Many(select = "com.qiku.mapper.RoleMapper.findRoleByUid"))
    })
    public List findAllUserWithRole();


}

RoleMapper.java

public interface RoleMapper {

    @Select("select * from sys_role r LEFT JOIN sys_user_role ur on r.id = ur.roleid WHERe ur.userid = #{userId}")
    public List findRoleByUid(Integer userId);
}

OrderMapper.java

public interface OrderMapper {

//    查询所有订单 及 订单的用户信息
    @Select("select * from orders ")
    @Results({
            @Result(id = true , column = "id" ,property = "id"),
            @Result(column = "ordertime" , property = "orderTime"),
            @Result(column = "total" , property = "money"),

            @Result(property = "user" , javaType = User.class , column = "uid" ,
                    one = @One(select = "com.qiku.mapper.UserMapper.findUserById" ,
                            fetchType = FetchType.EAGER))

    })
    public List findAllOrderWithUser();

//    根据用户id(uid)查询订单信息
    @Select("select * from orders where uid = #{uid}")
    @Results({
            @Result(id = true , column = "id" , property = "id"),
            @Result(column = "ordertime" , property = "orderTime"),
            @Result(column = "total" , property = "money")
    })
    public List findOrderByUid(Integer uid);
}

核心配置文件

SqlMapConfig.xml





    

    
        
        



        
    
    
    
        
            
            
                
                
                
                
            
        
    


    








        
    

jdbc.properties

jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/mydb03
jdbc.username=root
jdbc.password=123456

测试类

UserMapperTEst.java

package com.qiku.test;

import com.qiku.mapper.UserMapper;
import com.qiku.popo.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.Test;

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

public class UserMapperTEst {

    @Test
    public void testAddUser() throws IOException {
        InputStream resource = Resources.getResourceAsStream("SqlMapConfig.xml");
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(resource);
        SqlSession sqlSession = factory.openSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);

        User user = new User("关羽" , new Date() , "男" , "蜀国" );
        mapper.addUser(user);
        sqlSession.commit();

    }

    @Test
    public void testUpdateUser() throws IOException {
        InputStream resource = Resources.getResourceAsStream("SqlMapConfig.xml");
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(resource);
        SqlSession sqlSession = factory.openSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);

        User user = new User("关羽" , new Date() , "男" , "河东" );
        user.setId(4);
        mapper.updateUser(user);
        sqlSession.commit();

    }

    @Test
    public void testFindAllUser() throws IOException {
        InputStream resource = Resources.getResourceAsStream("SqlMapConfig.xml");
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(resource);
        SqlSession sqlSession = factory.openSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        List userList = mapper.findAllUser();
        System.out.println(userList);

    }

    @Test
    public void testDeleteUser() throws IOException {
        InputStream resource = Resources.getResourceAsStream("SqlMapConfig.xml");
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(resource);
        SqlSession sqlSession = factory.openSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);


        mapper.deleteUser(3);
        sqlSession.commit();

    }


    @Test
    public void testFindAllUserWithOrder() throws IOException {
        InputStream resource = Resources.getResourceAsStream("SqlMapConfig.xml");
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(resource);
        SqlSession sqlSession = factory.openSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);

        List userList = mapper.findAllUserWithOrder();
        for (User u : userList){
            System.out.println(u);
        }

    }



    @Test
    public void testFindAllUserWithRole() throws IOException {
        InputStream resource = Resources.getResourceAsStream("SqlMapConfig.xml");
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(resource);
        SqlSession sqlSession = factory.openSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);

        List userList = mapper.findAllUserWithRole();
        for (User u : userList){
            System.out.println(u);
        }

    }

}

OrderMapperTest.java

public class OrderMapperTest {

    @Test
    public void testFindAllOrderWithUser() throws IOException {
        InputStream resource = Resources.getResourceAsStream("SqlMapConfig.xml");
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(resource);
        SqlSession sqlSession = factory.openSession();
        OrderMapper mapper = sqlSession.getMapper(OrderMapper.class);

        List orderList = mapper.findAllOrderWithUser();
        for (Order o : orderList){
            System.out.println(o);
        }

    }
}

LocalCacheTest02.java

public class LocalCacheTest02 {
    @Test
    public void localCacheTest01() throws IOException {

        InputStream resource = Resources.getResourceAsStream("SqlMapConfig.xml");
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(resource);
        SqlSession sqlSession1 = factory.openSession();
        UserMapper mapper1 = sqlSession1.getMapper(UserMapper.class);
        User userById1 = mapper1.findUserById(1);
        System.out.println("====第一次查询====:" + userById1);

        //将结果存入二级缓存
        sqlSession1.commit();
        SqlSession sqlSession2 = factory.openSession();
        UserMapper mapper2 = sqlSession2.getMapper(UserMapper.class);
        User userById2 = mapper2.findUserById(1);
        System.out.println("====第二次查询====:" + userById2);
    }

}

使用注解实现复杂映射开发

我们在映射文件中通过配置 、、 来实现复杂关系映射。
使用注解开发后,我们可以使用 @Results、@Result,@One、@Many 注解组合完成复杂关系的配置。

 

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/996038.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号