MyBatis-接口开发-User例子

定位sql需要很长的字符串,namespace+id的使用方式很容易出错,因为是string类型的,编译时没发检查,写错运行时才会抛出异常。所以,mybatis提供了一种非常好的设计方式来避免这种问题,即Mapper接口。namespace的值统一为接口的全路径。
接口开发步骤:[]里是你自己需要的名字
1.修改映射文件[User]Mapper.xml
映射文件中的namspace的值是接口的包名+接口的类名
dao.[User]MapperDao(绑定Mapper文件和接口的关系)
(Dao层就是和数据库交互的)
2.创建[User]Mapper接口(interface)
2.1接口所在包的包名+接口名=[User]Mapper.xml中namespace的值
(绑定接口和映射文件的关系)
2.2接口中的方法名=[User]Mapper.xml中定义SQL的id值
(绑定了将要执行的SQL的id)
2.3接口中的方法的返回值类型和参数类型要和UserMapper.xml
映射文件中resultType的类型一致
3.在核心配置文件sqlMapConfig.xml的<mappers>中引入
<mappr resource="[mapper]/[User]Mapper.xml">

<mapper namespace="dao.UserMapperDao"></mapper>

获取接口实现类对象,getMapper方法能基于类全名找到对应名称空间,然后基于名称空间找到映射文件,最后基于你的方法在映射文件找到与元素id相同的方法。

UserMapperDao dao = session.getMapper(UserMapperDao.class);

1、在mysql中执行下面的sql

CREATE DATABASE mybatisdb;
USE mybatisdb;
CREATE TABLE USER(id INT PRIMARY KEY AUTO_INCREMENT,NAME VARCHAR(100),addr VARCHAR(100),age INT);
INSERT INTO USER VALUES(NULL,'张三','北京',28);
INSERT INTO USER VALUES(NULL,'李四','上海',30);
INSERT INTO USER VALUES(NULL,'王五','广州',19);

2、创建maven工程




pom.xml输入如下内容,保存更新项目

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.company</groupId>
    <artifactId>mybatisv2</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>
    <dependencies>
        <!--添加mysql驱动程序依赖 -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.40</version>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.11</version>
        </dependency>
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis</artifactId>
            <version>3.2.8</version>
        </dependency>
        <!--日志包依赖 -->
        <dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>1.2.17</version>
        </dependency>
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.5.1</version>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                    <encoding>UTF-8</encoding>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>

3像下面的方式创建对应的文件,在对应的文件添加代码


UserMapperDao接口

/usermapper/src/main/java/dao/UserMapperDao.java

注意:
1、 包名 + 类名 = UserMapper.xml中namespace的值
2、 接口中方法名 = UserMapper.xml中定义的SQL的id值
3、 方法的返回值类型(resultType)和参数类型(parameterType或sql中的参数(parameterType可以不传))要和UserMapper.xml映射文件中类型一致

package dao;

import java.util.List;

import pojo.User;

/**
 * 这个类用来完成用户表的业务
 * 
 * @author Administrator
 *
 */
public interface UserMapperDao {
    // <select id="findAll" resultType="User">
    // select * from user
    // </select>
    // 查询所有表的所有数据
    public List<User> findAll();

    // <select id="count" resultType="int">
    // select count(*) from user
    // </select>
    public int count();

    // <select id="findOne" parameterType="int" resultType="User">
    // select * from user where id=#{id}
    // </select>
    public User findOne(int id);

    // <insert id="save" parameterType="User">
    // insert into user values(null,#{name},#{addr},#{age})
    // </insert>
    public void save(User user);

    // <update id="updateUser" parameterType="User" >
    // update user <set> age=#{age}</set> <where>name=#{name}</where>
    // </update>
    public void updateUser(User user);

    // <delete id="deleteUser" parameterType="User">
    // delete from user where name=#{name}
    // </delete>
    public void deleteUser(User user);
}

User

/usermapper/src/main/java/pojo/User.java

package pojo;
/**
 * 这个类用来和user表做映射关系
 * 要求:属性名必须和表字段名保持一致
 */
public class User {
    //id
    private int id;
    //用户名
    private String name;
    //地址
    private String addr;
    //年龄
    private int age;
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public String getAddr() {
        return addr;
    }
    public void setAddr(String addr) {
        this.addr = addr;
    }
    public int getAge() {
        return age;
    }
    public void setAge(int age) {
        this.age = age;
    }
    @Override
    public String toString() {
        return "User [id=" + id + ", name=" + name + ", addr=" + addr + ", age=" + age + "]";
    }
    
}

UserMapper

/usermapper/src/main/resources/mapper/UserMapper.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
    PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
    "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<!--映射文件,写SQL,namespace唯一标识  -->
<mapper namespace="dao.UserMapperDao">
    <!--查询所有记录
    id唯一标识
    resultType把结果封装在对象上,要写类的全路径-->
    <select id="findAll" resultType="User">
        select * from user
    </select>
    <select id="count" resultType="int">
        select count(*) from user
    </select>
    <!--根据id查询记录-->
    <select id="findOne" parameterType="int" resultType="User">
        select * from user where id=#{id}
    </select>
    <!--新增一条记录  -->
    <insert id="save" parameterType="User">
        insert into user values(null,#{name},#{addr},#{age})
    </insert>
    <!--修改指定记录
    动态取值:#{age}
    age就是user对象的age属性
    -->
    <update id="updateUser"  parameterType="User" >
        update user <set> age=#{age}</set> <where>name=#{name}</where>  
    </update>
    <delete id="deleteUser" parameterType="User">
        delete from user where name = #{name}
    </delete>
</mapper>

db.properties

/usermapper/src/main/resources/db.properties

driver:com.mysql.jdbc.Driver
url:jdbc:mysql:///mybatisdb
username:root
password:123456

log4j.properties

/usermapper/src/main/resources/log4j.properties

# Global logging configuration
log4j.rootLogger=DEBUG, stdout
# Console output...
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%5p [%t] - %m%n

sqlMapConfig.xml

/usermapper/src/main/resources/sqlMapConfig.xml

<?xml version="1.0" encoding="UTF-8"?>
<!--xml约束信息-->
<!DOCTYPE configuration
  PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
 "http://mybatis.org/dtd/mybatis-3-config.dtd">
 <configuration>
    <!--引入数据源的配置文件
    resource指定文件的位置-->
    <properties resource="db.properties"></properties>
    <!-- 设置别名 -->
    <typeAliases>
        <typeAlias type="pojo.User" alias="User"/>
    </typeAliases>
    <!-- 配置开发环境 ,default用来设置默认的开发环境-->
    <environments default="test">
        <!--测试环境-->
        <environment id="test">
            <!--事务管理器:mybatis的事务交个jdbc处理-->
            <transactionManager type="jdbc"></transactionManager>
            <!--连接池:配置数据源,连接池  -->
            <dataSource type="pooled">
            <!--数据库驱动的名字-->
                <property name="driver" value="${driver}"/>
                <!-- 数据库的url地址-->
                <property name="url" value="${url}"/>
                <!-- 数据库的用户名-->
                <property name="username" value="${username}"/>
                <!-- 数据库的密码-->
                <property name="password" value="${password}"/>
            </dataSource>
        </environment>
    </environments>
     <!--引入映射文件 -->
    <mappers>
        <!--引入UserMapper文件
        resource指定文件的位置
         -->
        <mapper resource="mapper/UserMapper.xml"/>
    </mappers>
 </configuration>

InterfaceTest.java

/usermapper/src/test/java/test/InterfaceTest.java

package test;

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

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.Before;
import org.junit.Test;

import dao.UserMapperDao;
import pojo.User;

/**
 * 这个类用来测试Mapper接口
 * @author Administrator
 *
 */
public class InterfaceTest {
    SqlSessionFactory ssf=null;
    @Before
    public void init(){
        //获取会话工厂
        try {
            InputStream in = Resources.getResourceAsStream("sqlMapConfig.xml");
            ssf = new SqlSessionFactoryBuilder().build(in);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    //查询user表的所有数据
    @Test
    public void findAll(){
        //获取sqlsession,执行SQL
        SqlSession session = ssf.openSession();
        //利用接口方法
        UserMapperDao dao = session.getMapper(UserMapperDao.class);
        List<User> list = dao.findAll();
        //处理结果
        for (User user : list) {
            System.out.println(user);
        }
        //释放资源
        session.close();
    }
    @Test
    public void count() {
        // 2.创建sqlsession对象,执行sql
        SqlSession session = ssf.openSession();
        UserMapperDao dao = session.getMapper(UserMapperDao.class);
        int i = dao.count();
        // 3.处理结果
        System.out.println("count=" + i);
        // 4.释放资源
        session.close();
    }
    
    //根据id查询记录
        @Test
        public void findOne(){
            // 2.创建sqlsession对象,执行sql
            SqlSession session = ssf.openSession();
            UserMapperDao dao = session.getMapper(UserMapperDao.class);
            User user=dao.findOne(1);
            System.out.println(user);
            // 4.释放资源
            session.close();
        }
        //新增一条记录
        @Test
        public void save(){
            //创建sqlsession,执行sql
            SqlSession session = ssf.openSession();
            UserMapperDao dao = session.getMapper(UserMapperDao.class);
            //利用sqlsession执行插入的sql
            User user=new User();
            user.setName("张三");
            user.setAge(28);
            user.setAddr("河北");
            dao.save(user);
            session.commit();
            //释放资源
            session.close();
        }
        //修改指定记录
        @Test
        public void updateUser(){
            //创建sqlsession,执行sql
            SqlSession session = ssf.openSession();
            UserMapperDao dao = session.getMapper(UserMapperDao.class);
            User user=new User();
            user.setAge(9);
            user.setName("张三");
            dao.updateUser(user);
            session.commit();
            //释放资源
            session.close();
        }
        //删除指定记录
        @Test
        public void deleteUser(){
            //创建sqlsession,执行sql
            SqlSession session = ssf.openSession(true);
            UserMapperDao dao = session.getMapper(UserMapperDao.class);
            User user=new User();
            user.setName("张三");
            dao.deleteUser(user);
            session.close();
        }
}

如果在User类中加入输出System.out.println("User.setId()");

    public void setId(int id) {
        System.out.println("User.setId()");
        this.id = id;
    }
DEBUG [main] - ==>  Preparing: select * from user 
DEBUG [main] - ==> Parameters: 
User.setId()
User.setId()
User.setId()
User.setId()
User.setId()
DEBUG [main] - <==      Total: 5
User [id=1, name=张三, addr=北京, age=28]
User [id=2, name=李四, addr=上海, age=6]
User [id=3, name=王五, addr=广州, age=19]
User [id=4, name=张三, addr=河北, age=28]
User [id=5, name=张三, addr=河北, age=28]
DEBUG [main] - Resetting autocommit to true on JDBC Connection [com.mysql.jdbc.JDBC4Connection@4973813a]
DEBUG [main] - Closing JDBC Connection [com.mysql.jdbc.JDBC4Connection@4973813a]
DEBUG [main] - Returned connection 1232306490 to pool.

会发现底层会调用类的set方法,不过当set方法不存在是,底层会直接通过反射为私有属性赋值

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

推荐阅读更多精彩内容

  • Spring Boot 参考指南 介绍 转载自:https://www.gitbook.com/book/qbgb...
    毛宇鹏阅读 46,809评论 6 342
  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,654评论 18 139
  • 长句、短语、邮箱、号码任你自定义!
    Read_Me_阅读 1,881评论 0 0
  • 昨晚都忙疯了,和小伙伴们一起奋战到十二点半才结束,困死了,回来倒头就睡,什么也没写…… 课堂上讲的知识固然...
    Edway阅读 230评论 0 0
  • 嗨!英语三月分享第四次又来了!不瞒大家说我终于会读音标了。 工具很简单,就是赖老师的《赖世雄美语音标》和一个手机A...
    PennyLife阅读 1,113评论 0 4