微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦！

mybatis

分类：JDBC作者：编程之家原文地址AI导航网

一.基本认识

  • mybatis是一个ORM框架
  • ORM:对象关系映射
  • mybatis对jdbc的重复代码进行了封装,依然需要自己写sql(比jdbc开发快,比jpa性能好)

二.hello,mybatis

2.1 导包

  • mybatis核心包 mybatis/mybatis-3.2.1.jar
  • mybatis的依赖包 mybatis/lib/*.jar
  • jdbc驱动包 mysql-connector-java-5.1.26-bin.jar

2.2 基本准备(表,domain)

  • 库(mybatis) -> 表(product)【导入-resources\准备\sql脚本\product.sql】
  • Product对象
 public class Product {
    private Long id;
    //产品名称
    private String productName;
    //成本价
    private Double costPrice;
    //销售价格
    private Double salePrice;
    //供应商
    private String supplier;
    //品牌
    private String brand;
    //折扣
    private Double cutoff;
    //产品类型
    private Long dir_id;
    //省略getter,setter与toString...
}

2.3 创建配置文件

配置文件的位置要注意

image

jdbc.properties:数据库的参数

jdbc.driver=com.MysqL.jdbc.Driver
jdbc.url=jdbc:MysqL:///mybatis
jdbc.username=root
jdbc.password=123456

mybatis-config.xml:mybatis的核心配置

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-config.dtd">
<!-- configuration:配置(xml的一个根)-->
<configuration>
    <!--引入jdbc.propeties文件-->
    <properties resource="jdbc.properties" />
    <!--
        environments:环境(多个环境)
            default="development"：多个环境中默认使用的是哪一个环境
    -->
    <environments default="development">
        <!--
             environment:某一个环境 id:就是这个环境的名称
        -->
        <environment id="development">
            <!--
                transactionManager:事务管理(ACID)
                    type="JDBC|MANAGED" jdbc:简单jdbc事务 MANAGED：啥都不做
            -->
            <transactionManager type="JDBC"/>
            <!-- 数据源(连接池) POOLED:mybatis内置的连接池 -->
            <dataSource type="POOLED">
                <!--四大金刚:驱动,地址,用户名,密码-->
                <property name="driver" value="${jdbc.driver}"/>
                <property name="url" value="${jdbc.url}"/>
                <property name="username" value="${jdbc.username}"/>
                <property name="password" value="${jdbc.password}"/>
            </dataSource>
        </environment>
    </environments>
    <mappers>
        <!--引入(找到)写sql的XML-->
        <mapper resource="cn/itsource/dao/ProductMapper.xml"/>
    </mappers>
</configuration>

ProductMapper.xml:sql语句

<?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">
<!--
    mapper:根(每个xml都得有,不用管它的含义)
        namespace：命名空间(随便取个名称)
-->
<mapper namespace="cn.itsource.dao.ProductMapper">
    <!--
        select:代表这是一个查询语句
            id:代表这个查询语句的唯一命名
                以后你要找到这条sql: namespace+id
                例:cn.itsource.dao.ProductMapper.getone
            parameterType:参数类型
                long -> Long  _long -> long
            resultType:返回的每一条结果的类型
                注:返回类型的全限定名
    -->
    <select id="getone" parameterType="long" resultType="cn.itsource.domain.Product">
        select * from product where id = #{id}
    </select>

</mapper>

2.4 测试

  1. 读取核心配置文件
  2. 获取sqlSession对象 sqlSessionFactoryBuilder -> sqlSessionFactory -> sqlSession
  3. 执行查询
/**
 * ①. 想办法搞到核心配置文件 mybatis-config.xml
 * ②. 获取到它的核心对象 sqlSession【相当于是咱们JPA中的EntityManager对象】
 *          EntityManagerFactory -> EntityManager
 *          sqlSessionFactoryBuilder -> sqlSessionFactory -> sqlSession
 *  ③.sqlSession就可以CRUD..
 */
@Test
public void testHello() throws Exception{
    //①. 想办法搞到核心配置文件 mybatis-config.xml
    Reader reader = Resources.getResourceAsReader("mybatis-config.xml");
    //②.获取到它的核心对象 sqlSession
    // 2.1获到到sqlSessionFactory对象
    sqlSessionFactoryBuilder builder = new sqlSessionFactoryBuilder();
    sqlSessionFactory factory = builder.build(reader);
    // 2.2获取到它的核心对象 sqlSession
    sqlSession session = factory.openSession();

    //③.获取到一个对象
    /**
     * String statement : 获取sql的字符串 namespace+id
     * Object parameter : 参数传递
     */
    Product product = session.selectOne("cn.itsource.dao.ProductMapper.getone",1L);
    System.out.println(product);

    //关闭session
    session.close();
}

三.工具类与CRUD

3.1 准备MyBatisUtil

  • sqlSessionFactoryBuilder:只用于创建factory，用完就可以扔掉
  • sqlSessionFactory：重级量对象，创建后不要随便销毁(一个项目一个这个对象即可)
  • sqlSession :用于完成咱们的CRUD
/**
 * MyBatis的工具类,主要就是为我们创建sqlSession对象
 */
public class MyBatisUtil {
    //定义一个sqlSessionFactory对象
    /**
     * 一个对象写这个位置，而且是静态的，它是有线程安全问题的
     */
    private static sqlSessionFactory factory = null;

    /**
     * sqlSessionFactoryBuilder:唯一的作用就是创建sqlSessionFactory
     *      一旦用完就可以把它把抛弃了
     * 1.类加载的时候就会执行
     * 2.只会执行一次
     */
    static {
        try {
            factory = new sqlSessionFactoryBuilder().build(
                    Resources.getResourceAsReader("mybatis-config.xml")
            );
        } catch (Exception e) {
            e.printstacktrace();
        }
    }

    public static sqlSession openSession(){
        return factory.openSession();
    }

}

3.1 完成CRUD

3.1.1 productMapper.xml

<!--
    select:代表这是一个查询语句
        id:代表这个查询语句的唯一命名
            以后你要找到这条sql: namespace+id
            例:cn.itsource.dao.ProductMapper.getone
        parameterType:参数类型
            long -> Long  _long -> long
        resultType:返回的每一条结果的类型
            注:返回类型的全限定名
-->
<select id="getone" parameterType="long" resultType="product">
    select * from product where id = #{id}
</select>

<!--resultType:返回的每一条结果的类型-->
<select id="getAll" resultType="product" >
    select * from product
</select>

<!--
    添加一条数据
        useGeneratedKeys:是否要主键
        keyColumn="id":在数据库中名称叫id
        keyProperty="id":在类中也叫id
        主键会放到你传过来的对象中
-->
<insert id="save" parameterType="product"
        useGeneratedKeys="true" keyColumn="id" keyProperty="id">
  insert into product
  (productName,dir_id,salePrice,supplier,brand,cutoff,costPrice) values
  (#{productName},#{dir_id},#{salePrice},#{supplier},#{brand},#{cutoff},#{costPrice})
</insert>

<!--修改功能-->
<update id="update" parameterType="product">
    update product set
        productName=#{productName},
        dir_id=#{dir_id},
        salePrice=#{salePrice},
        supplier=#{supplier},
        brand=#{brand},
        cutoff=#{cutoff},
        costPrice=#{costPrice}
        where id=#{id}
</update>

<!-- 删除功能 -->
<delete id="delete" parameterType="long">
    delete from product where id=#{id}
</delete>

3.1.1 productDao中完成功能

  • 增删改需要提交事务
package cn.itsource.dao.impl;

import cn.itsource.dao.IProductDao;
import cn.itsource.domain.Product;
import cn.itsource.util.MyBatisUtil;
import org.apache.ibatis.session.sqlSession;

import java.util.List;

public class ProductDaoImpl implements IProductDao {

    private final String NAMESPACE = "cn.itsource.dao.ProductMapper.";
    @Override
    public void save(Product product) {
        sqlSession session = null;
        try {
            session = MyBatisUtil.openSession();
            session.insert(NAMESPACE+"save",product);
            //提交事务
            session.commit();
        } catch (Exception e) {
            //回滚事务
            session.rollback();
            e.printstacktrace();
        } finally {
            session.close();
        }
    }

    @Override
    public void update(Product product) {
        sqlSession session = null;
        try {
            session = MyBatisUtil.openSession();
            session.update(NAMESPACE+"update",product);
            //提交事务
            session.commit();
        } catch (Exception e) {
            //回滚事务
            session.rollback();
            e.printstacktrace();
        } finally {
            session.close();
        }
    }

    @Override
    public void delete(Long id) {
        sqlSession session = null;
        try {
            session = MyBatisUtil.openSession();
            session.delete(NAMESPACE+"delete",id);
            //提交事务
            session.commit();
        } catch (Exception e) {
            //回滚事务
            session.rollback();
            e.printstacktrace();
        } finally {
            session.close();
        }
    }

    @Override
    public Product getone(Long id) {
        sqlSession session = null;
        try {
            session = MyBatisUtil.openSession();
            return session.selectOne(NAMESPACE+"getone",id);
        } catch (Exception e) {
            e.printstacktrace();
        } finally {
            session.close();
        }
        return null;
    }

    @Override
    public List<Product> getAll() {
        sqlSession session = null;
        try {
            session = MyBatisUtil.openSession();
            return session.selectList(NAMESPACE+"getAll");
        } catch (Exception e) {
            e.printstacktrace();
        } finally {
            session.close();
        }
        return null;
    }
}

四.细节处理

4.1 添加的对象返回id

  • useGeneratedKeys:是否要使用主键
  • keyColumn="id":在数据库中名称叫id
  • keyProperty="id":在类中主键的名称id
  • 主键会放到你传过来的对象中
<!--
    添加一条数据
-->
<insert id="save" parameterType="product"
        useGeneratedKeys="true" keyColumn="id" keyProperty="id">
  insert into product
  (productName,dir_id,salePrice,supplier,brand,cutoff,costPrice) values
  (#{productName},#{dir_id},#{salePrice},#{supplier},#{brand},#{cutoff},#{costPrice})
</insert>

4.2 别名的配置

  • 内置别名(int,long,..)/自定义别名(自己的类)
  • 别名不区分大小写
  • 自定义别名的配置
    • 每个对象单独配置别名 <typeAlias type="cn.itsource.domain.Product" alias="Product" />
    • 扫描包(这个包的对象都会取别名) <package name="cn.itsource.domain" />
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-config.dtd">
<!-- configuration:配置(xml的一个根)-->
<configuration>
    <!--引入jdbc.propeties文件-->
    <properties resource="jdbc.properties" />
    <!--
        typeAliases:配置别名
            注:别名不区别大小写
    -->
    <typeAliases>
        <!-- type:类型   alias:别名-->
        <!--<typeAlias type="cn.itsource.domain.Product" alias="Product" />-->
        <!--为这个包下面的所有类取别名(就是类名)-->
        <package name="cn.itsource.domain" />
        <package name="cn.itsource.query" />
    </typeAliases>
    <environments default="development">
       ...
    </environments>
    <mappers>
       ...
    </mappers>
</configuration>

4.3 日志的处理

  • mybatis中是使用日志来显示sql的
  • 在资源根目录创建一个log4j.properties
# ERROR错误的日志 WARN:警告 INFO:普通信息  DEBUG:调试日志  TRACE:日志
log4j.rootLogger=ERROR, stdout
#log4j.rootLogger=NONE
#把左边包名改成你自己的包名
log4j.logger.cn.itsource=TRACE
# 日志打印到控制台中
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
# 日志打印的一种格式（可以灵活地指定布局模式）
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
# 日志打印的格式是什么样子的  %d:日期 %p:优先级 %c:类的全名  %m:输出的结果 %n:换行
log4j.appender.stdout.layout.ConversionPattern=%d %p [%c] - %m%n

4.4 #与$的区别(面试题)

  • $只能从对象中取属性(getter属性)
  • #支持预编译方案(性能更好，安全性更高)
  • 优先使用#,有些拼接字符串的地方不支持，再使用$

五.批量操作与动态sql

5.1 批量添加

  • sql: insert into 表名 (列名,列名) values (?,?),(?,?),...
  • 实现使用foreach
<!--
    批量添加
     insert into employee (name,age,sex) values
             ("小小良",45,false),("大二良",45,true)
    foreach:循环
        collection:遍历的集合
        item:每次遍历拿到的对象
        separator:分隔符(每个值都使用,隔开)
-->
<insert id="batchSave" parameterType="list">
    insert into employee (name,age,sex) values
    <foreach collection="list" item="e" separator=",">
        (#{e.name},#{e.age},#{e.sex})
    </foreach>
</insert>

5.2 批量删除

  • sql: delete from 表名 where id in(?,?,..)
  • 实现使用foreach
<!--
    批量删除:DELETE FROM employee WHERE id in (?,?,?,...)
    传 : List<Long> ids
     foreach:循环
        collection:遍历的集合
        item:每次遍历拿到的对象
        separator:分隔符(每个值都使用,隔开)
        open:以什么开头
        close:以什么结尾
        index:遍历的索引
-->
<delete id="batchDelete" parameterType="list">
  delete from employee where  id in
  <foreach collection="list" item="id" separator="," open="(" close=")">
      #{id}
  </foreach>
</delete>

5.3 动态修改

  • 解决咱们以前的数据丢失问题
  • 对象中没有值就不做修改
<!--
        动态修改:只修改有值的数据
-->
<update id="dynamicUpdate" parameterType="employee">
    update employee
    <set>
        <if test="name!=null">
            name=#{name},
        </if>
        <if test="age!=null">
            age=#{age},
        </if>
        <if test="sex!=null">
            sex=#{sex},
        </if>
    </set>
    where id=#{id}
</update>

今日扩展

连接池

比较流行的连接池有三个

  • Spring建议使用的DBCP
  • Hibernate建议使用的C3P0
  • 阿里连接池 druid -> 现在外面用得还是比较多

MysqL的数据库引擎

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

讲解JDBC
连接数据库的方式：第一种方式：ODBC：开放数据库连接是微软公司开放服务结构中有关数据库的一个组成部分，是数据库访问接口标准。ODBC是基于C语言实现的。提供了语言和数据库进行交互的一致性的接口，便于语言和数据库通信以及语言对数据库的各种操作。第二种方式：JDBC（本章重点）在Java中，
Jmeter 数据库请求
JDBCRequest 使用VariableNamesmysql：数据库连接池对象variousname：设置的变量名称 如何使用该变量a_#、b_#、c_#、d_#：代表行数a_1：第1行、第1列b_2：第2行、第2列
抽取基本JDBC中的基本操作与数据连接池
 1.JDBCDBC(JavaDataBaseConnectivity)：Java数据库连接技术：具体讲就是通过Java连接广泛的数据库，并对表中数据执行增、删、改、查等操作的技术。JDBC是数据库与Java代码的桥梁。JDBC中定义了操作数据库的各种接口和类型：增删改基本操作：（1）获取连接：Connectionconnection=
JDBC操作流程
1.需要jar包的支持：java.sqljavax.sqlmysql-conneter-java...连接驱动（必须要导入）<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>5.1.46</version></depend
Activiti可视化流程管理器
1.简介Activiti是一个业务流程管理(BPM)框架,它是覆盖了业务流程管理，工作流，服务协作等领域的一个开源，灵活的，易扩展的可执行流程语言框架。在Java工作流引擎中可谓是主流，我们的项目也是使用的这个框架进行流程相关的开发。与流程息息相关的就是我们的流程定义BPMN文件，包含有一系列
0811JDBC随笔
1.JDBC体系系统一组规范：接口JDBC接口（API）包括两个层次：面向应用的API：JavaAPI，抽象接口，供应用开发人员使用（连接数据库，执行SQL语句，获得结果）面向数据库的API：JavaDriverAPI，供开发商开发数据库驱动程序JDBC是sun公司提供一套用于数据库操作的接口，java程序员只需要面向这套接
JDBC的基本概念
原文链接JDBC一般指Java数据库连接（JavaDatabaseConnectivity）api应用程序接口（API）：可以调用或者使用类/接口/方法等去完成某个目标。API制定的类/方法可以做什么。API由开发人员调用。spi服务提供接口（SPI）：需要继承或实现某些类/接口/方法等去完成某个目标。SPI告诉你
Shardingsphere-ShardingSphere-JDBC-Spring Boot配置-分片规则
spring.shardingsphere.datasource.names=#省略数据源配置，请参考用法#标准分表配置spring.shardingsphere.rules.sharding.tables.<table-name>.actual-data-nodes=#描述数据源名称和实际表，分隔符为点，多个数据节点用逗号分隔，支持内联表达式。Absent表示仅对数据库进行分片
20220814 idea_springboot_启动 Cannot load driver class: com.mysql.cj.jdbc.Driver
1问题Cannotloaddriverclass:com.mysql.cj.jdbc.Driver 2解决方案2.1已解决2.1.1首先，去查看项目中MySQL的版本如果找不到，说明可能还没有jdbc驱动，需要配置或者引入       （1）如果是直接引用的jar包，就去lib文件夹中查看，后缀是版
JDBC
JDBC一、JDBC概述什么是JDBC？JDBC是使用Java语言操作关系型数据库的一套API。这套API是交由不同的数据库厂商实现的。我们利用JDBC编写操作数据库的代码，真正执行的是各个数据库的实现类（驱动）。全称：（JavaDataBaseConnectivity）Java数据库连接。JDBC的好处面向接口编
苹果市值2025年有望达4万亿美元
pythonJavaScriptjavaHTMLreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-bootreact-native