国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > Java > 正文

Java實(shí)現(xiàn)mybatis批量插入數(shù)據(jù)到Oracle

2019-11-26 14:10:23
字體:
供稿:網(wǎng)友

最近項(xiàng)目中遇到一個(gè)問題:導(dǎo)入數(shù)據(jù)到后臺并將數(shù)據(jù)插入到數(shù)據(jù)庫中,導(dǎo)入的數(shù)據(jù)量有上萬條數(shù)據(jù),考慮采用批量插入數(shù)據(jù)的方式;
 結(jié)合網(wǎng)上資料,寫了個(gè)小demo,文章末尾附上demo下載地址 

1、新建項(xiàng)目:項(xiàng)目目錄結(jié)構(gòu)如下圖所示,添加相應(yīng)的jar包

2、新建數(shù)據(jù)庫表:ACCOUNT_INFO

CREATE TABLE ACCOUNT_INFO ( "ID" NUMBER(12) NOT NULL , "USERNAME" VARCHAR2(64 BYTE) NULL , "PASSWORD" VARCHAR2(64 BYTE) NULL , "GENDER" CHAR(1 BYTE) NULL , "EMAIL" VARCHAR2(64 BYTE) NULL , "CREATE_DATE" DATE NULL )

3、創(chuàng)建AccountInfo實(shí)體類:

package com.oracle.entity;import java.sql.Date;public class AccountInfo { private Long id; private String userName; private String password; private String gender; private String email; private Date createDate; public Long getId() { return id; } public void setId(Long id) { this.id = id; } public String getUserName() { return userName; } public void setUserName(String userName) { this.userName = userName; } public String getPassword() { return password; } public void setPassword(String password) { this.password = password; } public String getGender() { return gender; } public void setGender(String gender) { this.gender = gender; } public String getEmail() { return email; } public void setEmail(String email) { this.email = email; } public Date getCreateDate() { return createDate; } public void setCreateDate(Date createDate) { this.createDate = createDate; } @Override public String toString() { return "AccountInfo [id=" + id + ", userName=" + userName + ", password=" + password + ", gender=" + gender + ", email=" + email + ", createDate=" + createDate + "]"; }}

4、新建接口映射類:AccountInfoMapper.java

package com.oracle.mapper;import java.util.List;import com.oracle.entity.AccountInfo;public interface AccountInfoMapper { /** * 查詢所有的數(shù)據(jù) * @return */ List<AccountInfo> queryAllAccountInfo();  /** * 批量插入數(shù)據(jù) *  * @param accountInfoList * @return */ int batchInsertAccountInfo(List<AccountInfo> accountInfoList);}

5、創(chuàng)建mybatis配置文件:mybatis-configuration.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> <environments default="development"> <environment id="development"> <transactionManager type="JDBC" /> <dataSource type="POOLED"> <property name="driver" value="oracle.jdbc.driver.OracleDriver" /> <property name="url" value="jdbc:oracle:thin:@localhost:1521:orcl" /> <property name="username" value="xxx" /> <property name="password" value="xxx" /> </dataSource> </environment> </environments> <mappers> <mapper resource="config/AccountInfoMapper.xml" /> </mappers></configuration>

6、創(chuàng)建接口映射配置文件:AccountInfoMapper.xml
 Oracle的批量插入數(shù)據(jù)庫跟MySQL不一樣,
 MySQL:
 

復(fù)制代碼 代碼如下:
 INSERT INTO ACCOUNT_INFO(ID, USERNAME,PASSWORD,GENDER, EMAIL,CREATE_DATE)values(,,,,,,)(,,,,,,,)

Oracle:
 
復(fù)制代碼 代碼如下:
INSERT INTO ACCOUNT_INFO(ID, USERNAME,PASSWORD,GENDER, EMAIL,CREATE_DATE) (select 1,,,,,, from dual union all select 1,,,,,, from dual)
 

<?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="com.oracle.mapper.AccountInfoMapper"><!-- 接口的全類名 --> <!-- type:實(shí)體類的全類名 --> <resultMap id="BaseResultMap" type="com.oracle.entity.AccountInfo"> <id column="ID" property="id" jdbcType="DECIMAL" /> <result column="USERNAME" property="userName" jdbcType="VARCHAR" /> <result column="PASSWORD" property="password" jdbcType="VARCHAR" /> <result column="GENDER" property="gender" jdbcType="CHAR" /> <result column="EMAIL" property="email" jdbcType="VARCHAR" /> <result column="CREATE_DATE" property="createDate" jdbcType="DATE" /> </resultMap> <!-- id 跟接口中的方法名稱保持一致 --> <select id="queryAllAccountInfo" resultMap="BaseResultMap"> select ID, USERNAME,PASSWORD, GENDER, EMAIL, CREATE_DATE from ACCOUNT_INFO </select> <insert id="batchInsertAccountInfo" parameterType="java.util.List"> INSERT INTO ACCOUNT_INFO(ID, USERNAME,PASSWORD,GENDER, EMAIL,CREATE_DATE) ( <foreach collection="list" index="" item="accountInfo" separator="union all"> select #{accountInfo.id}, #{accountInfo.userName}, #{accountInfo.password}, #{accountInfo.gender}, #{accountInfo.email}, #{accountInfo.createDate} from dual </foreach> ) </insert></mapper>

7、編寫測試類:

package com.oracle.test;import java.io.InputStream;import java.sql.Date;import java.util.ArrayList;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 com.oracle.entity.AccountInfo;import com.oracle.mapper.AccountInfoMapper;public class MybatisTest { public static void main(String[] args) throws Exception { String resource = "config/mybatis-configuration.xml"; InputStream inputStream = Resources.getResourceAsStream(resource); SqlSessionFactory sessionFactory = new SqlSessionFactoryBuilder() .build(inputStream); SqlSession session = sessionFactory.openSession(); AccountInfoMapper mapper = session.getMapper(AccountInfoMapper.class); List<AccountInfo> accountInfoList = mapper.queryAllAccountInfo(); if (accountInfoList == null) { System.out.println("The result is null."); } else { for (AccountInfo personInfo : accountInfoList) { System.out.println(personInfo); } } mapper.batchInsertAccountInfo(generateData()); session.commit(); }  static List<AccountInfo> generateData(){ List<AccountInfo> result = new ArrayList<AccountInfo>(); AccountInfo account = new AccountInfo(); account.setId(3L); account.setUserName("zhangsanfeng"); account.setPassword("123456"); account.setGender("1"); account.setEmail("zhangsanfeng@wudang.com"); account.setCreateDate(new Date(System.currentTimeMillis())); result.add(account);  account = new AccountInfo(); account.setId(4L); account.setUserName("zhouzhiruo"); account.setPassword("zhangwuji"); account.setGender("0"); account.setEmail("zhouzhiruo@emei.com"); account.setCreateDate(new Date(System.currentTimeMillis())); result.add(account);  account = new AccountInfo(); account.setId(5L); account.setUserName("zhaomin"); account.setPassword("zhangwuji"); account.setGender("0"); account.setEmail("zhaomin@yuan.com"); account.setCreateDate(new Date(System.currentTimeMillis())); result.add(account); return result; }}

源碼下載:http://xiazai.VeVB.COm/201606/yuanma/java-oracle(VeVB.COm).rar

以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持武林網(wǎng)。

發(fā)表評論 共有條評論
用戶名: 密碼:
驗(yàn)證碼: 匿名發(fā)表
主站蜘蛛池模板: 平乐县| 临湘市| 沁水县| 大同市| 金平| 阳信县| 酉阳| 霞浦县| 咸宁市| 西乌珠穆沁旗| 噶尔县| 达孜县| 镇雄县| 钦州市| 高清| 炉霍县| 井陉县| 双流县| 同江市| 黄平县| 宁安市| 南溪县| 黄大仙区| 政和县| 嘉禾县| 白玉县| 屏山县| 华宁县| 大余县| 周至县| 井冈山市| 怀集县| 常熟市| 基隆市| 双鸭山市| 军事| 明溪县| 菏泽市| 休宁县| 昌乐县| 平远县|