Java 批量插入数据到数据库(MySQL)中
2016-07-14 17:42
543 查看
实现Java批量插入数据库数据:
package Proxy;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.InputStreamReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
public class TextReader{
public static void main(String args[]) {
try
{
Class.forName("com.mysql.jdbc.Driver");
Connection con = (Connection) DriverManager.getConnection("jdbc:mysql://" +
"localhost:3306/DP", "admin", "123456");
String sql = "Insert into ACT_cdKeytempsss (cdKey, ActivityId) VALUES (?,3577)";
String sqlupdate = "update ACT_cdKey set status=1 where CdKey = ?";
PreparedStatement ps = con.prepareStatement(sql);
PreparedStatement ps1 = con.prepareStatement(sqlupdate);
con.setAutoCommit(false); // 关闭事务自动提交
String pathname = "C:/Users/Administrator/Desktop/result8.txt";
File fileName = new File(pathname);
InputStreamReader reader = new InputStreamReader(new FileInputStream(fileName));
BufferedReader br = new BufferedReader(reader);
String line = "";
line = br.readLine();
while (line != null) {
ps.setString(1, line);
ps1.setString(1, line);
line = br.readLine();
ps.addBatch();
ps1.addBatch();
}
ps.executeBatch();
ps1.executeBatch();
con.commit();
ps.close();
ps1.close();
con.close();
br.close();
}
catch (Exception e) {
e.printStackTrace();// TODO: handle exception
}
}
}
package Proxy;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.InputStreamReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
public class TextReader{
public static void main(String args[]) {
try
{
Class.forName("com.mysql.jdbc.Driver");
Connection con = (Connection) DriverManager.getConnection("jdbc:mysql://" +
"localhost:3306/DP", "admin", "123456");
String sql = "Insert into ACT_cdKeytempsss (cdKey, ActivityId) VALUES (?,3577)";
String sqlupdate = "update ACT_cdKey set status=1 where CdKey = ?";
PreparedStatement ps = con.prepareStatement(sql);
PreparedStatement ps1 = con.prepareStatement(sqlupdate);
con.setAutoCommit(false); // 关闭事务自动提交
String pathname = "C:/Users/Administrator/Desktop/result8.txt";
File fileName = new File(pathname);
InputStreamReader reader = new InputStreamReader(new FileInputStream(fileName));
BufferedReader br = new BufferedReader(reader);
String line = "";
line = br.readLine();
while (line != null) {
ps.setString(1, line);
ps1.setString(1, line);
line = br.readLine();
ps.addBatch();
ps1.addBatch();
}
ps.executeBatch();
ps1.executeBatch();
con.commit();
ps.close();
ps1.close();
con.close();
br.close();
}
catch (Exception e) {
e.printStackTrace();// TODO: handle exception
}
}
}
相关文章推荐
- 在springMvc中的filter里用@Autowired注入bean
- java gc的工作原理、如何优化GC的性能、如何和GC进行有效的交互
- 闲来无事,用Java的软引用写了一个山寨的缓存
- 《文件传输基础----Java IO流---《三》》
- Java性能调优
- Java类的执行顺序
- 《文件传输基础----Java IO流---《二》》
- Java性能优化的9大工具
- java内存分配
- 疯狂java讲义 琐碎知识点
- Java代码优化方案 J2ME内存优化
- GitHub上那些值得一试的JAVA开源库
- Java解读内存,优化编程
- 几个著名java开源缓存系统的介绍
- java递归实现二分查找算法
- jdk1.7和jdk1.8区别
- java递归实现二分查找算法
- 使用JDOM方式解析XML
- 《文件传输基础----Java IO流---《一》》
- SpringMVC拦截器