mybatis完成增删改查

package com.dyt.dao;

import com.dyt.entity.User;
import org.apache.ibatis.annotations.Param;

import java.util.List;

public interface UserDao {
    public ListfindAll();

    public int add(@Param("username") String username, @Param("realname") String realname);

    public int update(@Param("userid") int userid ,@Param("username") String username, @Param("realname") String realname);
    public int del(int id);
    public User findOne(int id);
    public User findUsernameAndPwd( @Param("username") String username, @Param("realname") String realname);
}

注意，方法名要和实体类中的方法名保持一致




        
    
        select * from tb_user where userid=#{id}
    
    
    
        insert into tb_user(username,realname) values(#{username},#{realname})
    
    
    
        delete from tb_user where userid=#{id}
    
    
    
        update tb_user set username=#{username},realname=#{realname} where userid=#{userid}
    
    
    
        select * from tb_user
    
    
        select * from tb_user where username=#{username} and realname=#{realname}
    

测试

package Test;

import com.dyt.dao.UserDao;
import com.dyt.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.Test;

import java.io.Reader;
import java.util.List;

public class test1 {
    //查询单个操作
    @Test
    public void TestFind() throws Exception {
        Reader reader = Resources.getResourceAsReader("mybatis.xml");
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(reader);
        SqlSession session = factory.openSession();
        UserDao userDao = session.getMapper(UserDao.class);
        User one = userDao.findOne(4);
        System.out.println(one);
        session.close();
    }

    //添加操作
    @Test
    public void testadd() throws Exception {
        Reader reader = Resources.getResourceAsReader("mybatis.xml");
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(reader);
        SqlSession session = factory.openSession();
        UserDao userDao = session.getMapper(UserDao.class);
        int add = userDao.add("崔灿", "崔");
        System.out.println(add);
        session.commit();
        session.close();
    }

    //删除操作
    @Test
    public void del() throws Exception {
        Reader reader = Resources.getResourceAsReader("mybatis.xml");
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(reader);
        SqlSession session = factory.openSession();
        UserDao userDao = session.getMapper(UserDao.class);
        int del = userDao.del(4);
        System.out.println();
        session.commit();
        session.close();
    }

    //修改
    @Test
    public void updata() throws Exception {
        Reader reader = Resources.getResourceAsReader("mybatis.xml");
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(reader);
        SqlSession session = factory.openSession();
        UserDao userDao = session.getMapper(UserDao.class);
        int update = userDao.update(8, "AAA", "SS");
        System.out.println(update);
        session.commit();
        session.close();
    }

    //查询所有
    @Test
    public void TestfindAll() throws Exception {
        Reader reader = Resources.getResourceAsReader("mybatis.xml");
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(reader);
        SqlSession session = factory.openSession();
        //获取相应接口的代理对象
        UserDao userDao = session.getMapper(UserDao.class);
        List list = userDao.findAll();
        System.out.println(list);
        session.commit();
        session.close();
    }

    //条件查询
    @Test
    public void TsetFindNameAndPwd() throws Exception {
        Reader reader = Resources.getResourceAsReader("mybatis.xml");
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(reader);
        SqlSession session = factory.openSession();
        //获取相应接口的代理对象
        UserDao userDao = session.getMapper(UserDao.class);
        User usernameAndPwd = userDao.findUsernameAndPwd("zxy", "张学友");
        System.out.println(usernameAndPwd.getUserid());
        session.commit();
        session.close();
    }


}