mybatis 插入多数据

2021-09-16 02:02:27 阅读：143 来源： 互联网

标签：jdbc java -- dao 插入 mybatis import 数据 AaDao

mybatis 批量插入数据

文件目录: 
 	项目
 	|--java
 	    |--dao
 		|--AaDao (接口)
 		|--AaDao.xml
       	    |--domain
 		|--Aa.java
 	    |--test.java (主入口)
 	|--resources
 	    |--jdbc.properties
 	    |--mybatis-conf.xml

1. 创建数据库,表

create database if not exists `dd`;
use dd;

DROP TABLE IF EXISTS `temp`;
CREATE TABLE `temp`  (
  `id` int(11) NOT NULL,
  `name` varchar(20) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `age` int(11) NULL DEFAULT NULL,
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;

批量插入数据示例 :

INSERT INTO `temp` 
	VALUES 
		(1, 'aaa', 1),
		(2, 'aaa', 2),
		(3, 'aaa', 3);

2. java代码以及配置文件

mybatis-conf .xml :

<?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>

    <!--使用properties标签导入properties配置文件-->
    <properties resource="jdbc.properties"/>

    <!--settings：控制mybatis全局行为-->
    <settings>
        <!--设置mybatis输出日志-->
        <setting name="logImpl" value="STDOUT_LOGGING"/>

    </settings>
    <!--环境配置： 数据库的连接信息
        default:必须和某个environment的id值一样。
        告诉mybatis使用哪个数据库的连接信息。也就是访问哪个数据库
    -->
    <environments default="mysql">

        <!-- environment : 一个数据库信息的配置， 环境
             id:一个唯一值，自定义，表示环境的名称。
        -->
        <environment id="mysql">
            <!--
               transactionManager ：mybatis的事务类型
                   type: JDBC(表示使用jdbc中的Connection对象的commit，rollback做事务处理)
            -->
            <transactionManager type="JDBC"/>
            <!--
               dataSource:表示数据源，连接数据库的
                  type：表示数据源的类型， POOLED表示使用连接池
            -->
            <dataSource type="POOLED">
                <!--
                   name的值：driver, user, username, password 是固定的，不能自定义。
                   value的值：输入你自己数据库的连接信息
                -->
                <!--数据库的驱动类名-->
                <property name="driver" value="${jdbc.driver}"/>
                <!--连接数据库的url字符串-->
                <property name="url" value="${jdbc.url}"/>
                <!--访问数据库的用户名-->
                <property name="username" value="${jdbc.username}"/>
                <!--密码-->
                <property name="password" value="${jdbc.password}"/>
            </dataSource>
        </environment>
    </environments>

    <!-- sql mapper(sql映射文件)的位置-->
    <mappers>
        <!--一个mapper标签指定一个文件的位置。
           从类路径开始的路径信息。  target/clasess(类路径)
        -->
        <package name="dao"/>
    </mappers>

</configuration>

jdbc.properties

jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/dd?characterEncoding=UTF-8
jdbc.username=root
jdbc.password=root

dao包:

AaDao.java (接口)

package dao;

import domain.Aa;

import java.util.List;

public interface AaDao {
    int createAas(List<Aa> aaList);
}

AaDao.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">

<mapper namespace="dao.AaDao">
    <!--批量插入数据,我们只需要让mybatis将 sql语句拼接为 insert into insert into temp(id,name,age) values (?,?,?) , (?,?,?) ... ; 即可-->
    <insert id="createAas">
        insert into
            temp(id,name,age)
        values
        <foreach collection="list" item="aa"  separator=",">
            (#{aa.id},#{aa.name},#{aa.age})
        </foreach>
        
    </insert>
</mapper>

domain包:

test.java

import dao.AaDao;
import domain.Aa;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

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

public class test {
    public static void main(String[] args) {
        String resource = "mybatis-conf.xml";
        InputStream inputStream = null;
        try {
            inputStream = Resources.getResourceAsStream(resource);
        } catch (IOException e) {
            e.printStackTrace();
        }
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(inputStream);
        // 获取dao接口
        AaDao dao = factory.openSession(true).getMapper(AaDao.class);

        List<Aa> aaList = new ArrayList<>();
        aaList.add(new Aa(4,"aaa",4));
        aaList.add(new Aa(5,"aaa",5));
        aaList.add(new Aa(6,"aaa",6));

        // 插入数据
        int rows = dao.createAas(aaList);
        // mybatis 拼接的字符串为 : insert into temp(id,name,age) values (?,?,?) , (?,?,?) , (?,?,?) ;

        System.out.println("有 "+rows+" 条数据受到影响"); // 有 3 条数据受到影响

    }
}

程序执行结果, 成功插入三条数据:

感谢浏览.

标签：jdbc,java,--,dao,插入,mybatis,import,数据,AaDao
来源： https://www.cnblogs.com/nguyen/p/15291618.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9