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

Mybatis对数据库增删改查操作

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

Mybatis对数据库增删改查操作

Mybatis对数据库增删改查操作 创建工程导入jar包

    org.springframework.boot
    spring-boot-starter


    org.springframework.boot
    spring-boot-starter-web


    org.springframework
    spring-tx
    4.3.14.RELEASE


    org.springframework
    spring-jdbc
    4.3.14.RELEASE


    mysql
    mysql-connector-java
    5.1.45



    com.baomidou
    mybatis-plus
    3.3.2




    commons-dbcp
    commons-dbcp
    1.4


    commons-pool
    commons-pool
    1.6



    org.springframework.boot
    spring-boot-starter-test
    test


    org.shenjia
    MyBatisX
    0.0.5

配置mybatis-config.xml文件



    
    
    
    
        
            
            
            
                
                
                
                
            
        
    
    
    
        

        
    


配置mappper映射




    
       select * from student
    

    
      insert  into  student (sname,sno,clazz) values (#{sname},#{sno},#{clazz})
    
    
     update student set sname=#{sname},sno=#{sno},clazz=#{clazz}
     where sid=#{sid}
    

    
        delete from student where sid=#{sid}
    
    

创建baseDao类
package com.hxci.util;

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 java.io.IOException;
import java.io.Reader;

public class baseDao {
    static  SqlSessionFactory sqlMapper ;
    static {
        String resources = "mybatis-config.xml";
        Reader reader=null;
        try {
            reader= Resources.getResourceAsReader(resources);
        } catch (IOException e) {
            e.printStackTrace();
        }
         sqlMapper= new SqlSessionFactoryBuilder().build(reader);
    }

    public SqlSession getSession(){
        SqlSession session=sqlMapper.openSession();
        return session;
    }

    public void closeSession(SqlSession session){
        session.close();
    }
}
创建db.properties文件连接数据库
db.driver=com.mysql.jdbc.Driver
db.url=jdbc:mysql://localhost:3306/mybatis?serverTimezone=UTC&characterEncoding=utf8&useUnicode=true&useSSL=false
db.username=root
db.password=x5//注意更改为自己的用户名和密码
创建Student实体类

在pojo包下,创建User实体类,并添加sid,sname,sno,clazz属性并添加对应的get/set方法。

package com.hxci.pojo;

public class Student {
    private Integer sid;
    private String sname;
    private String sno;
    private String clazz;

    public Integer getSid() {
        return sid;
    }

    public void setSid(Integer sid) {
        this.sid = sid;
    }

    public String getSname() {
        return sname;
    }

    public void setSname(String sname) {
        this.sname = sname;
    }

    public String getSno() {
        return sno;
    }

    public void setSno(String sno) {
        this.sno = sno;
    }

    public String getClazz() {
        return clazz;
    }

    public void setClazz(String clazz) {
        this.clazz = clazz;
    }
    @Override
    public String toString() {
        return "Student{" +
                "sid=" + sid +
                ", sname='" + sname + ''' +
                ", sno='" + sno + ''' +
                ", clazz='" + clazz + ''' +
                '}';
    }
}

创建UserDao接口
package com.hxci.dao;

        import com.hxci.pojo.Customer;
        import com.hxci.pojo.Student;

        import java.util.List;

public interface StudentDao {

    public List query();

    public void add(Student student);

    public void update(Student student);
    public Student queryById(Integer id);
    public void delete(Integer id);
}
创建StudentService接口
package com.hxci.service;

import com.hxci.pojo.Student;

import java.util.List;

public interface StudentService {
    public List query();

    public void add(Student student);

    public void update(Student student);
    public Student queryById(Integer id);
    public void delete(Integer id);
}
创建StudentServiceImpl类
package com.hxci.service.impl;


import com.hxci.dao.StudentDao;
import com.hxci.pojo.Student;
import com.hxci.service.StudentService;
import com.hxci.util.baseDao;
import org.apache.ibatis.session.SqlSession;

import java.util.List;

public class StudentServiceiceImpl extends baseDao implements StudentService {


    SqlSession session ;
    StudentDao dao ;
    @Override
    public List query() {
        session = getSession();
        dao = session.getMapper(StudentDao.class);
        List list = dao.query();
        closeSession(session);
        return list;
    }

    @Override
    public void add(Student student) {
        session =getSession();
        dao = session.getMapper(StudentDao.class);
        dao.add(student);
        session.commit();
        closeSession(session);

    }

    @Override
    public void update(Student student) {

        session =getSession();
        dao = session.getMapper(StudentDao.class);
        dao.update(student);
        session.commit();
        closeSession(session);
    }

    @Override
    public Student queryById(Integer id) {
        session =getSession();
        dao = session.getMapper(StudentDao.class);
        Student stu = dao.queryById(id);
        session.commit();
        return stu;
    }

    @Override
    public void delete(Integer id) {

        session =getSession();
        dao = session.getMapper(StudentDao.class);
        dao.delete(id);
        session.commit();
        closeSession(session);
    }
}
创建测试类
package com.hxci;

import com.hxci.pojo.Customer;
import com.hxci.pojo.Student;
import com.hxci.service.CustomerService;
import com.hxci.service.StudentService;
import com.hxci.service.impl.CustomerServiceImpl;
import com.hxci.service.impl.StudentServiceiceImpl;

import java.util.List;

public class StudentTest {
    public static void main(String[] args) {

        StudentService service = new StudentServiceiceImpl();

        Student student = new Student();
        student.setSname("33蒋云");
        student.setSno("511999");
        student.setClazz("333");

        service.add(student);
        student.setSid(4);
        service.delete(student.getSid());
        service.add(student);
        service.update(student);

        Student str = service.queryById(2);
        System.out.println(str);



        List list= service.query();
        System.out.println(list);

    }
}

运行效果如下:

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

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

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