基于MyBatis的数据持久化框架的使用详解

package com.my.entity;
 
import java.util.Date;
 
//网站信息实体类
public class Website {
    private int id;
    private String name;
    private String url;
    private int age;
    private String country;
    private Date createtime;
    
    @Override
    public String toString() {
        return "Website [id=" + id + ", name=" + name + ", url=" + url + ", age=" + age + ", country=" + country
                + ", createtime=" + createtime + "]";
    }
 
    
    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 getUrl() {
        return url;
    }
    public void setUrl(String url) {
        this.url = url;
    }
    public int getAge() {
        return age;
    }
 
    public void setAge(int age) {
        this.age = age;
    }
    public String getCountry() {
        return country;
    }
    public void setCountry(String country) {
        this.country = country;
    }
    public Date getCreatetime() {
        return createtime;
    }
    public void setCreatetime(Date createtime) {
        this.createtime = createtime;
    }
    
    
}

<?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映射文件：配置执行的SQL语句 -->
<mapper namespace="com.my.mapper.WebsiteMapper">
        <!-- 添加操作的SQL映射 -->
        <insert id = "insertNewWebsite"  parameterType="com.my.entity.Website">
            insert into website(name,url,age,country)values(#{name},#{url},#{age},#{country})
        </insert>
          <!-- 查询所有网站信息 -->
          <select id="selectWebsiteList"   resultType="com.my.entity.Website">
                  select * from website
          </select>
</mapper>

<?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>
      <!-- 框架参数 -->
    <settings>
      <!-- 配置日志为LOG4J -->  
      <setting name="logImpl" value="LOG4J" />
    </settings>
  
    <!-- 配置mybatis运行环境 -->
    <environments default="development">
        <environment id="development">
            <!-- 使用JDBC的事务管理 -->
            <transactionManager type="JDBC" />
            <dataSource type="POOLED">
                <!-- MySQL数据库驱动 -->
                <property name="driver" value="com.mysql.cj.jdbc.Driver" />
                <!-- 连接数据库的URL -->
                <property name="url"
                    value="jdbc:mysql://localhost:3306/my_bank?charset=utf8mb4&amp;useSSL=false&amp;useTimezone=true&amp;serverTimezone=GMT%2B8" />
                <property name="username" value="xxxx" />
                <property name="password" value="xxxxxx" />
            </dataSource>
        </environment>
    </environments>
  
    <!-- 将mapper文件加入到配置文件中 -->
    <mappers>
        <mapper resource="com/my/mapper/EarthquakeMapper.xml" />
    </mappers>
</configuration>

# Global logging configuration
log4j.rootLogger=ERROR,stdout
 
# MyBatis logging configuration...
log4j.logger.com.apesource=DEBUG
 
# 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

package com.my.dao;
 
import java.io.IOException;
 
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
 
public class MybatisDBUtils {
    private static SqlSessionFactory factory = null;
    static {
        try {
            SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
            factory = builder.build(Resources.getResourceAsStream("mybatis-config.xml"));
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
    public static SqlSession getSqlSession() {
        SqlSession session = null;
        if(factory != null) {
            session = factory.openSession();
        }
        return session;
    }
 
}

public class Test04 {
    public static void main(String[] args) {
        //每1000条执行一次批处理，并获取主键回填
        try (SqlSession sqlSession = MybatisDBUtils.getBatchSqlSession()) {
            WebsiteMapper websiteMapper = sqlSession.getMapper(WebsiteMapper.class);
            
            for(int i = 1;i <= 10;i++) {
              Website website = new Website("神码搜索","www.shenma.com",((int)(Math.random()*10)),"CN");
        }
    }
}