我用jdbc做了个定时更新数据库的功能,当插入1w条数据时候没点问题,当插入2w条数据时候,就报连接超时的错误接着,但是程序还是没有挂掉,不知道是什么原因就解?
[code='java']
package com.jgre.org;
import java.sql.Connection;
import java.sql.Date;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.List;
public class DB {
//设置
static int precount=1000;
public static Connection getConnect() throws Exception{
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver").newInstance();
//?useUnicode=true&characterEncoding=utf8
Connection conn= DriverManager.getConnection("jdbc:sqlserver://146.12.62.208:1433;DatabaseName=LHJGXN", "sa", "flying-321");
return conn;
}
public static void free(ResultSet rs,PreparedStatement ps,Connection conn){
try {
if(rs!=null) rs.close();
if(ps!=null) ps.close();
if(conn!=null) conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
public static void free(PreparedStatement ps,Connection conn){
try {
if(ps!=null) ps.close();
if(conn!=null) conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
//插入数据
public synchronized int insertObject(List<AJXX> list){
list=DB.initArray(list);
Connection conn=null;
PreparedStatement ps=null;
try {
conn=DB.getConnect();
//关闭自动提交
conn.setAutoCommit(false);
//清空数据库
ps=conn.prepareStatement("truncate table LHJGXN.dbo.TB_AJXX");
ps.executeUpdate();
long startTime=System.currentTimeMillis();
String sql="insert into LHJGXN.dbo.TB_AJXX( " +
"AH,NH,ZH,SAXH,AY,LARQ,LAR,CBT,SJCBT, " +
"CBR,AJLB,SPCX,SYCX,SFDA,SFYA,AJSJ,ZZRQ," +
"JARQ, JAFS,GDRQ,DTXP,FDSXDQR,KCSXTS,SXDQR," +
"AJZT,XLABZ)values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
ps=conn.prepareStatement(sql);
for(int i=0;i<list.size();i++){
System.out.println(i);
AJXX a=list.get(i);
if(a.getAH()!=null&&!a.getAH().equals("")){
ps.setString(1, a.getAH());
ps.setInt(2, a.getNH());
ps.setString(3, a.getZH());
ps.setInt(4, a.getSAXH());
ps.setInt(5, a.getAY());
// Date d=new Date();
if(tDate(a.getLARQ())==0){
ps.setDate(6, null);
}else{
ps.setDate(6, new Date(tDate(a.getLARQ())));
}
ps.setString(7, a.getLAR());
ps.setString(8, a.getCBT());
ps.setString(9, a.getSJCBT());
ps.setString(10, a.getCBR());
ps.setString(11, a.getAJLB());
ps.setString(12, a.getSPCX());
ps.setString(13, a.getSYCX());
ps.setString(14, a.getSFDA());
ps.setString(15, a.getSFYA());
ps.setString(16, a.getAJSJ());
if(tDate(a.getZZRQ())==0){
ps.setDate(17, null);
}else{
ps.setDate(17, new Date(tDate(a.getZZRQ())));
}
if(tDate(a.getJARQ())==0){
ps.setDate(18, null);
}else{
ps.setDate(18, new Date(tDate(a.getJARQ())));
}
ps.setString(19, getJAFS(a.getJAFS(),conn));
if(tDate(a.getGDRQ())==0){
ps.setDate(20, null);
}else{
ps.setDate(20, new Date(tDate(a.getGDRQ())));
}
ps.setInt(21, a.getDTXP());
ps.setString(22, a.getFDSXDQR());
ps.setInt(23, a.getKCSXTS());
ps.setString(24, a.getSXDQR());
ps.setString(25, a.getAJZT());
ps.setString(26, a.getXLABZ());
// ps.executeUpdate();
ps.addBatch();
}
//每precount次就批量处理一次
if((i+1)%precount==0){
ps.executeBatch();
//因为不确定总数所以没有去分很多批去执行,我整体做了个批量处理
}
}
//提交
//ps.executeBatch();
conn.commit();
ps.clearBatch();
long endTime=System.currentTimeMillis();
System.out.println("插入数据时间为:"+(endTime-startTime)+"ms");
return (int)(endTime-startTime);
} catch (Exception e) {
try {
//如果出现问题就回滚
conn.rollback();
} catch (SQLException e1) {
e1.printStackTrace();
}
e.printStackTrace();
PrintLog.writeLog("error:"+e.toString());
}finally{
DB.free(ps, conn);
}
return -1;
}
//根据案由名称获取案由编号
public static int getAYBH(String AYMC){
Connection conn=null;
PreparedStatement ps=null;
ResultSet rs=null;
try {
conn=DB.getConnect();
ps=conn.prepareStatement("select AYBH from LHJGXN.dbo.TB_AY where AYMC=?");
ps.setString(1, AYMC);
rs=ps.executeQuery();
if(rs.next()){
return rs.getInt(1);
}
} catch (Exception e) {
e.printStackTrace();
}finally{
DB.free(rs, ps, conn);
}
return -1;
}
//得到字号
public static String getZH(String ZHMC){
Connection conn=null;
PreparedStatement ps=null;
ResultSet rs=null;
try {
conn=DB.getConnect();
ps=conn.prepareStatement("select ZH from LHJGXN.dbo.TB_ZHXX where ZHMC=?");
ps.setString(1, ZHMC);
rs=ps.executeQuery();
if(rs.next()){
return rs.getString(1);
}
} catch (Exception e) {
e.printStackTrace();
}finally{
DB.free(rs, ps, conn);
}
return null;
}
//跟根据结案名称获取JAFS、AJLB、SPCX
public static int getInfo(String cmd,String MC,Connection conn){
//Connection conn=null;
PreparedStatement ps=null;
ResultSet rs=null;
String sql=null;
if(cmd.equalsIgnoreCase("JAFS")){
sql="select JAFS from LHJGXN.dbo.TB_JAFS where MC=?";
}else if(cmd.equalsIgnoreCase("AJLB")){
sql="select AJLB from LHJGXN.dbo.TB_JAFS where MC=?";
}else if(cmd.equalsIgnoreCase("SPCX")){
sql="select SPCX from LHJGXN.dbo.TB_JAFS where MC=?";
}
try {
conn=DB.getConnect();
ps=conn.prepareStatement(sql);
ps.setString(1, MC);
rs=ps.executeQuery();
if(rs.next()){
return rs.getInt(1);
}
} catch (Exception e) {
e.printStackTrace();
}finally{
DB.free(rs, ps, conn);
}
return -1;
}
public static long tDate(String d){
SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd");
try {
if(d!=null&&!d.equals("")){
java.util.Date date=sdf.parse(d);
return date.getTime();}
} catch (ParseException e) {
e.printStackTrace();
}
return 0;
}
public static String getJAFS(String jafs,Connection conn){
if(jafs!=null&&!jafs.trim().equals("")){
// Connection conn=null;
PreparedStatement ps=null;
ResultSet rs=null;
try {
conn=DB.getConnect();
ps=conn.prepareStatement("select JAFS from LHJGXN.dbo.TB_JAFS where MC=?");
ps.setString(1, jafs);
rs=ps.executeQuery();
if(rs.next()){
return rs.getString(1);
}
} catch (Exception e) {
e.printStackTrace();
}finally{
DB.free(rs,ps, conn);
}
}
return null;
}
public static List<AJXX> initArray(List<AJXX> d){
while(d!=null&d.size()>0&d.size()%precount!=0){
AJXX a=new AJXX();
d.add(a);
}
System.out.println("格式化后的数据长度:"+d.size());
return d;
}
}
然后报的错误是这样的
22238
22239
22240
com.microsoft.sqlserver.jdbc.SQLServerException: 到主机 的 TCP/IP 连接失败。 java.net.BindException: Address already in use: connect
at com.microsoft.sqlserver.jdbc.SQLServerException.makeFromDriverError(Unknown Source)
at com.microsoft.sqlserver.jdbc.SQLServerConnection.connectHelper(Unknown Source)
at com.microsoft.sqlserver.jdbc.SQLServerConnection.loginWithoutFailover(Unknown Source)
at com.microsoft.sqlserver.jdbc.SQLServerConnection.connect(Unknown Source)
at com.microsoft.sqlserver.jdbc.SQLServerDriver.connect(Unknown Source)
at java.sql.DriverManager.getConnection(DriverManager.java:582)
at java.sql.DriverManager.getConnection(DriverManager.java:185)
at com.jgre.org.DB.getConnect(DB.java:22)
at com.jgre.org.DB.getJAFS(DB.java:226)
at com.jgre.org.DB.insertObject(DB.java:98)
at com.jgre.org.PickTask$1.run(TimerUse.java:120)
at java.util.TimerThread.mainLoop(Timer.java:512)
at java.util.TimerThread.run(Timer.java:462)
com.microsoft.sqlserver.jdbc.SQLServerException: 该连接已关闭。
at com.microsoft.sqlserver.jdbc.SQLServerException.makeFromDriverError(Unknown Source)
at com.microsoft.sqlserver.jdbc.SQLServerConnection.checkClosed(Unknown Source)
at com.microsoft.sqlserver.jdbc.SQLServerConnection.rollback(Unknown Source)
at com.jgre.org.DB.insertObject(DB.java:130)
at com.jgre.org.PickTask$1.run(TimerUse.java:120)
at java.util.TimerThread.mainLoop(Timer.java:512)
at java.util.TimerThread.run(Timer.java:462)
com.microsoft.sqlserver.jdbc.SQLServerException: 该连接已关闭。
at com.microsoft.sqlserver.jdbc.SQLServerException.makeFromDriverError(Unknown Source)
at com.microsoft.sqlserver.jdbc.SQLServerConnection.checkClosed(Unknown Source)
at com.microsoft.sqlserver.jdbc.SQLServerStatement.checkClosed(Unknown Source)
at com.microsoft.sqlserver.jdbc.SQLServerPreparedStatement.setterGetParam(Unknown Source)
at com.microsoft.sqlserver.jdbc.SQLServerPreparedStatement.setString(Unknown Source)
at com.jgre.org.DB.insertObject(DB.java:98)
at com.jgre.org.PickTask$1.run(TimerUse.java:120)
at java.util.TimerThread.mainLoop(Timer.java:512)
at java.util.TimerThread.run(Timer.java:462)
2012-12-04 00:54:08 00:54
2012-12-04 00:55:08 00:55
2012-12-04 00:56:08 00:56
求遇到过类似情况的,麻烦告诉下解决办法,急救,谢谢!!
相关推荐
其实我在插入1000万条数据的时候遇到了一些问题,现在先来解决他们,一开始我插入100万条数据时候报错,控制台的信息如下: com.mysql.jdbc.PacketTooBigException: Packet for query is too large (4232009 > ...
原来一次性向数据库里插入数据的条数不能太多,上限是500条。超出会报错。 解决方案就是只好分多次插入数据库了。 您可能感兴趣的文章:SQLite教程(八):命令行工具介绍SQLite教程(十二):锁和并发控制详解...
报错信息:Store update, insert, or delete statement affected an unexpected number of rows (0). Entities may have been modified or deleted since entities were loaded. See ...
本文介绍了四种常见的数据插入方式,它们分别是:向表中所有字段插入数据、向表中某字段插入数据、同时插入多条记录以及将查询结果插入至数据表。以下是这四种数据插入方式的详细介绍: 1. 向表中所有字段插入数据 ...
### MySQL插入数据中文报错问题及解决方法 #### 背景介绍 在使用MySQL数据库进行数据管理的过程中,经常会遇到中文字符的存储需求。然而,在实际操作中可能会遇到中文字符无法正常插入数据库的问题,通常表现为错误...
我想往数据库插入多条数据时,使用了如下语句: insert into 表1 (字段1,字段2) values (1,2),(2,3),(3,4); 这条语句在mysql中执行的话,语法一点毛病都没有,但是,在oracle上执行一直报错: ORA-00933: SQL ...
本文实例讲述了Python MongoDB 插入数据时已存在则不执行,不存在则插入的解决方法。分享给大家供大家参考,具体如下: 前言: 想把QQ日志爬虫(Python)爬下来的日志保存到 MongoDB 里面。 但 insert 的时候报错: E...
- 如果数据导出时使用的是批量插入语句(如`INSERT INTO table (col1, col2) VALUES (val1, val2), (val3, val4), ...`),这在某些情况下可能会导致性能问题或错误。 - 考虑改为逐条插入的方式(即每条记录使用...
### ob多线程插入报错知识点详解 #### 一、问题背景及定义 根据文档标题“ob多线程插入报错.docx”及其描述“ob多线程插入报错.docx”,可以推断出该文档主要关注的是在使用OceanBase(简称OB)数据库时,在进行多...
1. **未限定的列名被解释为一个有相互关系的引用(+012 01545)** - **原因**:当 SQL 语句中出现未明确指定所属表的列名时,系统可能会将该列解释为一个与其他表相关的列。 - **解决方法**:确保所有的列名都有...
在IT行业中,数据库操作是应用开发中的重要环节,特别是在大数据量的情况下,如何高效地进行数据插入成为了一个关键问题。MyBatis,作为一个优秀的Java持久层框架,提供了多种优化手段,其中包括多线程和批处理技术...
在MyBatis中,每个数据源对应一个SqlSessionFactory,我们需要为每个数据源创建一个单独的配置文件,并在Spring配置中声明对应的SqlSessionFactoryBean。然后,通过@MapperScan注解,指定不同的Mapper接口应该与哪个...
python连接hbase需要用到hbase-thirft类库,但是hbase-thirft只在python2下能正常使用,如果在python3下,会报错,主要有一下几个错误 except IOError, io: SyntaxError: invalid syntax ModuleNotFoundError: No ...
### bcp导库报错:错误字符串数据,右截位 在进行数据库操作时,我们经常会遇到各种各样的错误提示,这些错误提示虽然有时让人感到困惑,但它们往往是解决问题的关键线索。本文将针对一个常见的问题——使用`bcp`...
如果要插入数据到临时表中,需要在同一个连接中执行插入操作,否则将会报错。 在插入数据时,需要注意临时表的生命周期。如果在插入数据时,连接关闭,临时表将被删除,数据将丢失。因此,在插入数据前,需要确保...
VC 演示如何使用insert语句批量向数据库插入数据,这个我感觉挺有用处吧,一般情况下,我们录入都是一条一条的,但信息量较大的时候,就需要批量插入数据了,我们可以先读取外部指定格式的文件,然后将数据转换为可...
例如,"ORA-00001"代表“唯一性约束违反”,这通常发生在尝试插入或更新已经存在唯一键值的数据时。 在处理Oracle报错时,首先要理解错误代码的意义。错误描述会提供更详细的信息,比如违反了哪个约束、哪个操作...
,当出现重复插入的情况,MySQL 会返回 Affected rows: 0,表示插入的数据为 0 条,并且 id 的值不是连续的。二是使用 on duplicate key update 语句,例如 insert into userinfo(nickname, openid) VALUE (ENCRYPT...
【报错注入】是一种安全漏洞,它发生在攻击者能够通过输入特定的数据,导致应用程序返回关于其内部结构或数据库状态的错误信息。这种错误信息可以揭示敏感信息,如数据库名称、表名、列名,甚至数据本身,从而为攻击...