MyBatis实现CRUD

我们在上一节已经介绍过MyBatis实现用户的新增,下面我们将介绍对users数据库的其它操作。

1、实现用户数据的删除操作

    1.1、UserDao接口类中用户的删除方法

    //删除用户
    public int deleteUser(int id);

    1.2、配置UserMapper.xml文件

    <!--根据id值删除用户-->
    <delete id="deleteUser">
        delete from users where id=#{id}
    </delete>

    1.3、删除操作的测试类

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 Demo2 {
    public static void main(String[] args) {
        Reader resourceAsReader=null;
        SqlSession sqlSession=null;
        try {
            resourceAsReader = Resources.getResourceAsReader("mybatis-config.xml");
            SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
            SqlSessionFactory factory = builder.build(resourceAsReader);
            sqlSession = factory.openSession();
            //删除id为1的用户
            int i = sqlSession.delete("com.fan.dao.UserDao.deleteUser",1);
            sqlSession.commit();
            System.out.println("删除成功"+i+"条");

        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            if(sqlSession!=null){
                sqlSession.close();
            }
            if(resourceAsReader!=null){
                try {
                    resourceAsReader.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

    }
}

2、实现用户数据的更新操作

    2.1、UserDao接口类中用户的更新方法

    //更新用户
    public int updateUser(User user);

    2.2、配置UserMapper.xml文件

    <!--根据id更新用户信息-->
    <update id="updateUser">
        update users set name=#{name},sex=#{sex} where id=#{id}
    </update>   

    2.3、更新操作的测试类

import com.fan.entity.User;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

import java.io.IOException;
import java.io.Reader;

public class Demo3 {
    public static void main(String[] args) {
        Reader resourceAsReader=null;
        SqlSession sqlSession=null;
        User user=new User(1,"张三","女");
        try {

            resourceAsReader = Resources.getResourceAsReader("mybatis-config.xml");
            sqlSession = new SqlSessionFactoryBuilder().build(resourceAsReader).openSession();
            //更新id号为1的用户信息
            int i = sqlSession.update("com.fan.dao.UserDao.updateUser", user);
            sqlSession.commit();
            System.out.println("更新成功"+i+"条");
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            if(sqlSession!=null){
                sqlSession.close();
            }
            if(resourceAsReader!=null){
                try {
                    resourceAsReader.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

    }
}

3、根据用户id查询用户

    3.1、UserDao接口类中用户的查询方法

    //主键查询(根据用户id查询用户)
    public User findById(int id);

    3.2、配置UserMapper.xml文件

    <!--根据id查询用户信息-->
    <select id="findById" resultType="com.fan.entity.User">
        select * from users where id=#{id}
    </select>

    3.3、id查询操作的测试类

import com.fan.entity.User;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

import java.io.IOException;
import java.io.Reader;

public class Demo4 {
    public static void main(String[] args) {
        Reader resourceAsReader=null;
        SqlSession sqlSession=null;
        try {
            resourceAsReader = Resources.getResourceAsReader("mybatis-config.xml");
            sqlSession = new SqlSessionFactoryBuilder().build(resourceAsReader).openSession();
            //查询id为1的用户
            User user = sqlSession.selectOne("com.fan.dao.UserDao.findById", 1);
            System.out.println(user.getName()+"..."+user.getSex());
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            if(sqlSession!=null){
                sqlSession.close();
            }
            if(resourceAsReader!=null){
                try {
                    resourceAsReader.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

    }
}

4、查询数据库中所有的用户

    4.1、UserDao接口类中所有用户信息查询方法

    //多行查询(查询users数据库中所有用户信息)
    public List<User> findAll();

    4.2、配置UserMapper.xml文件

    <!--查询所有用户信息-->
    <select id="findAll" resultType="com.fan.entity.User">
        select * from users
    </select>

    4.3、所有用户查询操作的测试类

import com.fan.entity.User;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

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

public class Demo5 {
    public static void main(String[] args) {
        Reader resourceAsReader=null;
        SqlSession sqlSession=null;
        try {
            resourceAsReader = Resources.getResourceAsReader("mybatis-config.xml");
            sqlSession = new SqlSessionFactoryBuilder().build(resourceAsReader).openSession();
            //查询数据库中所有用户信息
            List<User> userList = sqlSession.selectList("com.fan.dao.UserDao.findAll");
            for (User users:userList) {
                System.out.println(users.getName()+"..."+users.getSex());
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            if(sqlSession!=null){
                sqlSession.close();
            }
            if(resourceAsReader!=null){
                try {
                    resourceAsReader.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

    }
}

5、条件查询(根据name和sex查询用户)

    5.1、UserDao接口类中条件查询方法

    //条件查询(根据name和sex查询)
    public User login(Map map); 

    5.2、配置UserMapper.xml文件

    <!--条件查询(根据name和sex查询)-->
    <select id="login" resultType="com.fan.entity.User">
        select * from users where name=#{username} and sex=#{usersex}
    </select>  

    5.3、条件查询操作的测试类

import com.fan.entity.User;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

import java.io.IOException;
import java.io.Reader;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class Demo6 {
    public static void main(String[] args) {
        Reader resourceAsReader=null;
        SqlSession sqlSession=null;
        Map map=new HashMap();
        map.put("username","张三");
        map.put("usersex","女");
        try {
            resourceAsReader = Resources.getResourceAsReader("mybatis-config.xml");
            sqlSession = new SqlSessionFactoryBuilder().build(resourceAsReader).openSession();
            //条件查询(根据name和sex查询)
            User user= sqlSession.selectOne("com.fan.dao.UserDao.login",map);
            System.out.println(user.getId());
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            if(sqlSession!=null){
                sqlSession.close();
            }
            if(resourceAsReader!=null){
                try {
                    resourceAsReader.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

    }
}

6、修改测试类Demo6,调用getMapper(Mapper.class)执行Mapper接口方法来实现条件查询,关键代码如下:

            //条件查询(根据name和sex查询)
            //User user= sqlSession.selectOne("com.fan.dao.UserDao.login",map);
            UserDao userDaoMapper = sqlSession.getMapper(UserDao.class);
            User loginuser = userDaoMapper.login(map);
            System.out.println(loginuser.getId());
注:这种方式是MyBatis官方推荐使用的,其表达方式也更加直白,代码更加清晰,类型更加安全,也不用担心易错的字符串字面值以及强制类型的转换。
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 216,544评论 6 501
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,430评论 3 392
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 162,764评论 0 353
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,193评论 1 292
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,216评论 6 388
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,182评论 1 299
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,063评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,917评论 0 274
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,329评论 1 310
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,543评论 2 332
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,722评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,425评论 5 343
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,019评论 3 326
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,671评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,825评论 1 269
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,729评论 2 368
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,614评论 2 353