MyBatis的增删改简单操作

• MyBatis的增删改查简单操作
• • 1.准备工作
  • • 1.1 创建Maven项目,导入POM坐标
    • 1.2 准备核心配置文件
    • 1.3 创建表sys_user,实体类User
    • 1.4 编写获取SqlSession的静态方法
  • 2.添加操作
  • 3.更新操作
  • 4.删除操作

    4.0.0

    org.example
    mybatis01
    1.0-SNAPSHOT

    
        
            org.mybatis
            mybatis
            3.4.5
        
        
        
            mysql
            mysql-connector-java
            5.1.6
        
        
            junit
            junit
            4.12
        
        
            log4j
            log4j
            1.2.12
        
    

//--------------jdbc.properties-------------------
jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/test
jdbc.user=root
jdbc.password=root

//--------------SqlMapperConfig.xml------------------





    
    

    
    
        
    

    
    
        
        
            
            
            
            
                
                
                
                
                
            
        
    
    
    
        
    

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
-- Table structure for sys_user
-- ----------------------------
DROp TABLE IF EXISTS `sys_user`;
CREATE TABLE `sys_user`  (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `username` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `email` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `password` varchar(80) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `phoneNum` varchar(20) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 4 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;

-- ----------------------------
-- Records of sys_user
-- ----------------------------
INSERT INTO `sys_user` VALUES (1, 'zhangsan', 'zhangsan@itcast.cn', '123', '13888888888');
INSERT INTO `sys_user` VALUES (2, 'lisi', 'lisi@itcast.cn', '123', '13999999999');
INSERT INTO `sys_user` VALUES (3, 'wangwu', 'wangwu@itcast.cn', '123', '18599999999');

SET FOREIGN_KEY_CHECKS = 1;

//------------实体类User--------------
package com.other.domain;

public class User {
    private int id;
    private String username;
    private String email;
    private String password;
    private String phoneNum;

    public String getUsername() {
        return username;
    }

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

    public String getEmail() {
        return email;
    }

    public void setEmail(String email) {
        this.email = email;
    }

    public String getPhoneNum() {
        return phoneNum;
    }

    public void setPhoneNum(String phoneNum) {
        this.phoneNum = phoneNum;
    }

    public int getId() {
        return id;
    }

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

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    @Override
    public String toString() {
        return "User{" +
                "id=" + id +
                ", username='" + username + ''' +
                ", email='" + email + ''' +
                ", password='" + password + ''' +
                ", phoneNum='" + phoneNum + ''' +
                '}';
    }
}

static SqlSession getInstance() throws IOException {
        //加载mybatis核心配置文件
        InputStream config = Resources.getResourceAsStream("SqlMapperConfig.xml");
        //获得SqlSessionFactory工厂对象构建器
        SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
        //获得SqlSessionFactory工厂对象
        SqlSessionFactory sqlSessionFactory = builder.build(config);
        //获得SqlSession对象
        SqlSession sqlSession = sqlSessionFactory.openSession();
        return sqlSession;
    }

    
        insert into sys_user values(#{id},#{username},#{email},#{password},#{phoneNum})
    

 @Test
    public void testAdd() throws IOException {
        SqlSession sqlSession = getInstance();
        User user = new User();
        user.setUsername("tom");
        user.setEmail("123455@qq.com");
        user.setPassword("qwueioqiwjdojasjdzx");
        user.setPhoneNum("1231231231231");
        int insert = sqlSession.insert("UserMapper.save", user);
        System.out.println(insert);
        sqlSession.commit();
        sqlSession.close();
    }

    
        update sys_user
        set
        username=#{username},
        password=#{password},
        email=#{email},
        phoneNum=#{phoneNum}
        where id=#{id};
    

@Test
    public void testUpdate() throws IOException {
        SqlSession sqlSession = getInstance();
        User user = new User();
        user.setId(4);
        user.setUsername("lucy");
        user.setEmail("123455@qq.com");
        user.setPassword("asdasdasd");
        user.setPhoneNum("1111111111111");
        int update = sqlSession.update("UserMapper.update", user);
        System.out.println(update);
        sqlSession.commit();
        sqlSession.close();
    }

    
        delete from sys_user where id=#{id}
    

    @Test
    public void testDel() throws IOException {
        SqlSession sqlSession = getInstance();
        int delete = sqlSession.delete("UserMapper.delete", 5);
        System.out.println(delete);
        sqlSession.commit();
        sqlSession.close();
    }