今天就跟大家聊聊有关使用JDBC连接MySQL数据库并实现批量插入数据,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。
1.读取本地json数据
2.jdbc理解数据库
3.批量插入
maven 引入jar包:
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.32</version>
</dependency>
<dependency>
<groupId>commons-io</groupId>
<artifactId>commons-io</artifactId>
<version>2.4</version>
</dependency>
Java实现代码:
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import org.apache.commons.io.FileUtils;
import java.io.File;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
public class Test {
public static void main(String[] args) {
Test test = new Test();
Map<Integer, JSONObject> map = test.readJsonData();
test.jdbcConnBatch(map);
}
//批量插入数据库
void jdbcConnBatch(Map<Integer, JSONObject> map){
try{
//1.注册驱动
Class.forName("com.mysql.cj.jdbc.Driver");
//2.获取连接
Connection con = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=no",
"test", "test");
String sql = "insert into insurance" +
"(product_name,country,tag,tag_type,company," +
"insure_period,observation_period,qzzl,qzbz,qzhm,zjzl," +
"zjbz,zjqc,jbzmq,tdjb,sg," +
"jylstd,fhbfgn,gfqz,bzbf0,bzbf30,bzbf40)" +
" values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
//3.获得预处理对象
PreparedStatement pstmt = con.prepareStatement(sql);
//遍历map
for (Map.Entry<Integer, JSONObject> entry : map.entrySet()) {
String value = entry.getValue().toJSONString();
JSONObject json = JSONObject.parseObject(value);
//4.SQL语句占位符设置实际参数
pstmt = process(pstmt,json);
pstmt.addBatch();
}
//5.执行批量操作
int [] counts = pstmt.executeBatch();
System.out.println("执行条数:"+counts.length);
//6.释放资源
pstmt.close();
con.close();
}catch (ClassNotFoundException e) {
e.printStackTrace();
}catch(SQLException e){
e.printStackTrace();
}
}
/**
* 读取文件数据加入到map缓存中
*/
Map<Integer, JSONObject> readJsonData(){
try{
Map<Integer, JSONObject> map = new ConcurrentHashMap();
File testFile = new File("D:\\data.json");
String jsonString = FileUtils.readFileToString(testFile);
JSONArray jsonArr = JSONArray.parseArray(jsonString);
for(int i = 0; i < jsonArr.size(); i++) {
String str = jsonArr.get(i).toString();
JSONObject json = JSONObject.parseObject(str);
map.put(i,json);
}
return map;
} catch (IOException e) {
e.printStackTrace();
}
return null;
}
//处理PreparedStatement数据
PreparedStatement process(PreparedStatement pstmt,JSONObject json ) {
try {
pstmt.setString(1,getParameter(json.get("product_name")));
pstmt.setString(2,getParameter(json.get("country")));
pstmt.setString(3,getParameter(json.get("tag")));
pstmt.setString(4,getParameter(json.get("tag_type")));
pstmt.setString(5,getParameter(json.get("company")));
pstmt.setString(6,getParameter(json.get("insure_period")));
pstmt.setString(7,getParameter(json.get("observation_period")));
pstmt.setString(8,getParameter(json.get("qzzl")));
pstmt.setString(9,getParameter(json.get("qzbz")));
pstmt.setString(10,getParameter(json.get("qzhm")));
pstmt.setString(11,getParameter(json.get("zjzl")));
pstmt.setString(12,getParameter(json.get("zjbz")));
pstmt.setString(13,getParameter(json.get("zjqc")));
pstmt.setString(14,getParameter(json.get("jbzmq")));
pstmt.setString(15,getParameter(json.get("tdjb")));
pstmt.setString(16,getParameter(json.get("sg")));
pstmt.setString(17,getParameter(json.get("jylstd")));
pstmt.setString(18,getParameter(json.get("fhbfgn")));
pstmt.setString(19,getParameter(json.get("gfqz")));
pstmt.setString(20,getParameter(json.get("bzbf0")));
pstmt.setString(21,getParameter(json.get("bzbf30")));
pstmt.setString(22,getParameter(json.get("bzbf40")));
return pstmt;
}catch (SQLException e) {
e.printStackTrace();
}
return null;
}
String getParameter(Object obj) {
String str = null;
str = obj == null ? null : obj.toString();
return str;
}
}
mysql建表SQL:
CREATE TABLE `insurance` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`product_name` varchar(100) DEFAULT NULL,
`country` varchar(100) DEFAULT NULL,
`tag` varchar(100) DEFAULT NULL,
`tag_type` varchar(100) DEFAULT NULL,
`company` varchar(100) DEFAULT NULL,
`insure_period` varchar(100) DEFAULT NULL,
`observation_period` varchar(100) DEFAULT NULL,
`qzzl` varchar(100) DEFAULT NULL,
`qzbz` varchar(100) DEFAULT NULL,
`qzhm` varchar(100) DEFAULT NULL,
`zjzl` varchar(100) DEFAULT NULL,
`zjbz` varchar(100) DEFAULT NULL,
`zjqc` varchar(100) DEFAULT NULL,
`jbzmq` varchar(100) DEFAULT NULL,
`tdjb` varchar(2048) DEFAULT NULL,
`sg` varchar(2028) DEFAULT NULL,
`jylstd` varchar(2048) DEFAULT NULL,
`fhbfgn` varchar(100) DEFAULT NULL,
`gfqz` varchar(100) DEFAULT NULL,
`bzbf0` varchar(100) DEFAULT NULL,
`bzbf30` varchar(100) DEFAULT NULL,
`bzbf40` varchar(100) DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=231 DEFAULT CHARSET=utf8;
看完上述内容,你们对使用JDBC连接MySQL数据库并实现批量插入数据有进一步的了解吗?如果还想了解更多知识或者相关内容,请关注亿速云行业资讯频道,感谢大家的支持。
亿速云「云数据库 MySQL」免部署即开即用,比自行安装部署数据库高出1倍以上的性能,双节点冗余防止单节点故障,数据自动定期备份随时恢复。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。