多线程存数据mysql_java 多线程存储数据库
展开全部
以mysql为数据库32313133353236313431303231363533e4b893e5b19e31333332616431写的一个粗陋的demo,你参考一下,希望不会因为代码过多被百度吞了——
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
public class Test {
public static void main(String[] args) {
allotThread();
}
/**
* 将100条数据分成10份并启动10个线程分别操作
*/
public static void allotThread() {
List datas = buildDatas();
for (int i=0; i<100; i+=10) {
List tenDatas = datas.subList(i, i + 10);
insertData(tenDatas);
}
}
/**
* 创建100条模拟数据
* @return
*/
public static List buildDatas() {
List datas = new ArrayList();
for (int i=0; i<100; i++) {
String[] data = {"id " + i, "name " + i};
datas.add(data);
}
return datas;
}
/**
* 启动线程进行数据插入操作
* @param tenDatas
*/
public static void insertData(final List tenDatas) {
new Thread(new Runnable() {
public void run() {
String sql = "insert into testtable (id, name) values (?, ?)";
Connection conn = null;
PreparedStatement pstmt = null;
try {
conn = getConnection();
conn.setAutoCommit(false);
pstmt = getPstmt(conn, sql);
for (String[] data : tenDatas) {
pstmt.setString(1, data[0]);
pstmt.setString(2, data[1]);
pstmt.addBatch();
}
pstmt.executeBatch();
conn.commit();
conn.setAutoCommit(true);
} catch (SQLException e) {
e.printStackTrace();
rollback(conn);
} catch (ClassNotFoundException e) {
e.printStackTrace();
} finally {
close(pstmt);
close(conn);
}
}
}).start();
}
public static Connection getConnection() throws SQLException, ClassNotFoundException {
Class.forName("com.mysql.jdbc.Driver");
String dbUrl = "jdbc:mysql://localhost/test?useUnicode=true&characterEncoding=UTF-8";
Connection conn = DriverManager.getConnection(dbUrl, "root", "tooeasy");
return conn;
}
public static PreparedStatement getPstmt(Connection conn, String sql) throws SQLException, ClassNotFoundException {
PreparedStatement pstmt = conn.prepareStatement(sql);
return pstmt;
}
public static void rollback(Connection conn) {
try {
if (null != conn) {
conn.rollback();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
public static void close(Connection conn) {
try {
if (null != conn) {
conn.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
public static void close(PreparedStatement pstmt) {
try {
if (null != pstmt) {
pstmt.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
public static void close(ResultSet rs) {
try {
if (null != rs) {
rs.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
多线程存数据mysql_java 多线程存储数据库相关推荐
- 数据引擎-列存储数据库
列式数据库是以列方式存储数据,主要适合于即时查询和批量数据处理 行式数据库是以行方式存储数据,主要适合于联机事物处理和小批量数据处理. 举个栗子 1.事实数据如下 2.在传统数据库行数据库中的存储方法 ...
- java 多线程 共享数据_JAVA多线程提高四:多个线程之间共享数据的方式
多个线程访问共享对象和数据的方式 如果每个线程执行的代码相同,可以使用同一个Runnable对象,这个Runnable对象中有那个共享数据,例如,买票系统就可以这么做. 如果每个线程执行的代码不同,这 ...
- java 多线程跑数据_java——多线程的实现方式、三种办法解决线程赛跑、多线程数据同步(synchronized)、死锁...
多线程的实现方式:demo1.demo2 demo1:继承Thread类,重写run()方法 packagethread_test;public class ThreadDemo1 extendsTh ...
- java多线程 丢数据_多线程list.add()丢数据
问题: 根据项目业务需求需要统计数据传到前台以图表显示,每天数据量大概20万多,但是每次统计只能统计出10万的数据量,出现数据丢失. 原因: 该接口在之前一次优化时加了多线程,但是数据汇总用的仍是Ar ...
- 大量json数据解析OOM 存储数据库 assets下的json压缩文件解压
项目背景:assets包下有个json压缩文件,要求对该文件进行解压,再对解压后的json文件进行解析,并最终将数据存入数据库中.json文件包含30万条数据,文件大小是180M,由于数据量大,采用了 ...
- java 多线程共享数据_Java多线程学习:多个线程间共享数据
多个线程访问共享对象和数据的方式有两种情况: 1.每个线程执行的代码相同,例如,卖票:多个窗口同时卖这100张票,这100张票需要多个线程共享. 2.每个线程执行的代码不同,例如:设计四个线程,其中两 ...
- model存数据_数据库内核杂谈 存储
中文名:顾仲贤 现任Facebook资深架构师 专注于数据库,分布式系统,数据密集型应用后端架构与开发.拥有多年分布式数据库内核开发经验.发表数十篇数据库最顶级期刊并申请获得多项专利.对搜索,即时通讯 ...
- Redis 5.0.8+常见面试题(单线程还是多线程、先更新缓存还是数据库、雪崩穿透击穿解决办法...)
Redis 6.0 保姆级教程(含微服务案例与完整面试题):https://www.yuque.com/yuxuandmbjz/redis Redis是单线程还是多线程 ?为什么这么设计 ? Redi ...
- redis存10万条数据_redis如何存储数据
飞天技术汇 | 阿里云Redis产品升级大全 阿里云Redis重磅产品升级:全球多活版.混合存储版.多线程性能增强版. 这期飞天技术汇你将看到 ● 企业如何实现业务快速全球化布局 ● 冷热数据如何分离 ...
最新文章
- Pycharm 快捷键
- 我先了解一下博客园创建随笔/文章/日记的过程与三者的区别(隐私等级,是否审核等)...
- FLASHCS3多文件上传源代码(类似uccenter社区)
- python的缩进意义_python缩进错误的原因是什么
- oracle 数据结构部署,
- UJAM Beatmaker VICE for Mac(80年代风格鼓机插件)
- 数据中心与云计算关系
- iOS字体大小适配的几种方法
- 我国开始研制电子计算机,我国从( )年开始研制电子计算机。
- ImportError: libopencv_imgcodecs.so.4.3: cannot open shared object file: No such file or directory报错
- python 爬取整部漫画(简单的图片爬取)
- 13 | 关于写简历,必须要注意的一些细节
- 【Maven】什么是Maven?Maven有什么用?
- java开发环境搭建(一)
- 区块链技术如何赋能医学成像?
- ITE IT986X系列build命令实现
- 注入工具 -- DSSS
- 引擎师(引擎)“悠歌”回合文案释义
- DCDC12V升压22V~24V 200W大功率音箱电源芯片 SL4010
- [NLP]如何安装繁简转换工具:opencc
热门文章
- 【C++】简约的for循环
- [云炬创业基础笔记]第六章商业模式测试1
- 云炬Android开发报错处理教程 Gradle下载超时please configure the proxy settings either in IDE or Gradle
- xamarin textview 滚动_微软测试 Win10 Chromium/Edge CPU 优化和滚动新效果
- 大型项目开发,你准备好了吗?
- 23种设计模式C++源码与UML实现--装饰者模式
- linux文件-access函数
- BUUCTF-WEB:[极客大挑战 2019]LoveSQL 1
- The template root requires exactly one element.
- x86分页机制——《x86汇编语言:从实模式到保护模式》读书笔记42