`

插入1w条数据不报错,但是插入2w条数据时候报错,为什么呢?

阅读更多
   我用jdbc做了个定时更新数据库的功能,当插入1w条数据时候没点问题,当插入2w条数据时候,就报连接超时的错误接着,但是程序还是没有挂掉,不知道是什么原因就解?
   
    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
  


    求遇到过类似情况的,麻烦告诉下解决办法,急救,谢谢!!
分享到:
评论

相关推荐

    一个基于Qt Creator(qt,C++)实现中国象棋人机对战

    qt 一个基于Qt Creator(qt,C++)实现中国象棋人机对战.

    热带雨林自驾游自然奇观探索.doc

    热带雨林自驾游自然奇观探索

    冰川湖自驾游冰雪交融景象.doc

    冰川湖自驾游冰雪交融景象

    C51 单片机数码管使用 Keil项目C语言源码

    C51 单片机数码管使用 Keil项目C语言源码

    基于智能算法的无人机路径规划研究 附Matlab代码.rar

    1.版本:matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点:参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象:计算机,电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。

    前端分析-2023071100789s12

    前端分析-2023071100789s12

    Delphi 12.3控件之Laz-制作了一些窗体和对话框样式.7z

    Laz_制作了一些窗体和对话框样式.7z

    ocaml-docs-4.05.0-6.el7.x64-86.rpm.tar.gz

    1、文件内容:ocaml-docs-4.05.0-6.el7.rpm以及相关依赖 2、文件形式:tar.gz压缩包 3、安装指令: #Step1、解压 tar -zxvf /mnt/data/output/ocaml-docs-4.05.0-6.el7.tar.gz #Step2、进入解压后的目录,执行安装 sudo rpm -ivh *.rpm 4、更多资源/技术支持:公众号禅静编程坊

    学习笔记-沁恒第六讲-米醋

    学习笔记-沁恒第六讲-米醋

    工业机器人技术讲解【36页】.pptx

    工业机器人技术讲解【36页】

    基于CentOS 7和Docker环境下安装和配置Elasticsearch数据库

    内容概要:本文档详细介绍了在 CentOS 7 上利用 Docker 容器化环境来部署和配置 Elasticsearch 数据库的过程。首先概述了 Elasticsearch 的特点及其主要应用场景如全文检索、日志和数据分析等,并强调了其分布式架构带来的高性能与可扩展性。之后针对具体的安装流程进行了讲解,涉及创建所需的工作目录,准备docker-compose.yml文件以及通过docker-compose工具自动化完成镜像下载和服务启动的一系列命令;同时对可能出现的问题提供了应对策略并附带解决了分词功能出现的问题。 适合人群:从事IT运维工作的技术人员或对NoSQL数据库感兴趣的开发者。 使用场景及目标:该教程旨在帮助读者掌握如何在一个Linux系统中使用现代化的应用交付方式搭建企业级搜索引擎解决方案,特别适用于希望深入了解Elastic Stack生态体系的个人研究与团队项目实践中。 阅读建议:建议按照文中给出的具体步骤进行实验验证,尤其是要注意调整相关参数配置适配自身环境。对于初次接触此话题的朋友来说,应该提前熟悉一下Linux操作系统的基础命令行知识和Docker的相关基础知识

    基于CNN和FNN的进化神经元模型的快速响应尖峰神经网络 附Matlab代码.rar

    1.版本:matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点:参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象:计算机,电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。

    网络小说的类型创新、情节设计与角色塑造.doc

    网络小说的类型创新、情节设计与角色塑造

    毕业设计-基于springboot+vue开发的学生考勤管理系统【源码+sql+可运行】50311.zip

    毕业设计_基于springboot+vue开发的学生考勤管理系统【源码+sql+可运行】【50311】.zip 全部代码均可运行,亲测可用,尽我所能,为你服务; 1.代码压缩包内容 代码:springboo后端代码+vue前端页面代码 脚本:数据库SQL脚本 效果图:运行结果请看资源详情效果图 2.环境准备: - JDK1.8+ - maven3.6+ - nodejs14+ - mysql5.6+ - redis 3.技术栈 - 后台:springboot+mybatisPlus+Shiro - 前台:vue+iview+Vuex+Axios - 开发工具: idea、navicate 4.功能列表 - 系统设置:用户管理、角色管理、资源管理、系统日志 - 业务管理:班级信息、学生信息、课程信息、考勤记录、假期信息、公告信息 3.运行步骤: 步骤一:修改数据库连接信息(ip、port修改) 步骤二:找到启动类xxxApplication启动 4.若不会,可私信博主!!!

    57页-智慧办公园区智能化设计方案.pdf

    在智慧城市建设的大潮中,智慧园区作为其中的璀璨明珠,正以其独特的魅力引领着产业园区的新一轮变革。想象一下,一个集绿色、高端、智能、创新于一体的未来园区,它不仅融合了科技研发、商业居住、办公文创等多种功能,更通过深度应用信息技术,实现了从传统到智慧的华丽转身。 智慧园区通过“四化”建设——即园区运营精细化、园区体验智能化、园区服务专业化和园区设施信息化,彻底颠覆了传统园区的管理模式。在这里,基础设施的数据收集与分析让管理变得更加主动和高效,从温湿度监控到烟雾报警,从消防水箱液位监测到消防栓防盗水装置,每一处细节都彰显着智能的力量。而远程抄表、空调和变配电的智能化管控,更是在节能降耗的同时,极大地提升了园区的运维效率。更令人兴奋的是,通过智慧监控、人流统计和自动访客系统等高科技手段,园区的安全防范能力得到了质的飞跃,让每一位入驻企业和个人都能享受到“拎包入住”般的便捷与安心。 更令人瞩目的是,智慧园区还构建了集信息服务、企业服务、物业服务于一体的综合服务体系。无论是通过园区门户进行信息查询、投诉反馈,还是享受便捷的电商服务、法律咨询和融资支持,亦或是利用云ERP和云OA系统提升企业的管理水平和运营效率,智慧园区都以其全面、专业、高效的服务,为企业的发展插上了腾飞的翅膀。而这一切的背后,是大数据、云计算、人工智能等前沿技术的深度融合与应用,它们如同智慧的大脑,让园区的管理和服务变得更加聪明、更加贴心。走进智慧园区,就像踏入了一个充满无限可能的未来世界,这里不仅有科技的魅力,更有生活的温度,让人不禁对未来充满了无限的憧憬与期待。

    一种欠定盲源分离方法及其在模态识别中的应用 附Matlab代码.rar

    1.版本:matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点:参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象:计算机,电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。

    Matlab实现基于BO贝叶斯优化Transformer结合GRU门控循环单元时间序列预测的详细项目实例(含完整的程序,GUI设计和代码详解)

    内容概要:本文介绍了使用 Matlab 实现基于 BO(贝叶斯优化)的 Transformer 结合 GRU 门控循环单元时间序列预测的具体项目案例。文章首先介绍了时间序列预测的重要性及其现有方法存在的限制,随后深入阐述了该项目的目标、挑战与特色。重点描述了项目中采用的技术手段——结合 Transformer 和 GRU 模型的优点,通过贝叶斯优化进行超参数调整。文中给出了模型的具体实现步骤、代码示例以及完整的项目流程。同时强调了数据预处理、特征提取、窗口化分割、超参数搜索等关键技术点,并讨论了系统的设计部署细节、可视化界面制作等内容。 适合人群:具有一定机器学习基础,尤其是熟悉时间序列预测与深度学习的科研工作者或从业者。 使用场景及目标:适用于金融、医疗、能源等多个行业的高精度时间序列预测。该模型可通过捕捉长时间跨度下的复杂模式,提供更为精准的趋势预判,辅助相关机构作出合理的前瞻规划。 其他说明:此项目还涵盖了从数据采集到模型发布的全流程讲解,以及GUI图形用户界面的设计实现,有助于用户友好性提升和技术应用落地。此外,文档包含了详尽的操作指南和丰富的附录资料,包括完整的程序清单、性能评价指标等,便于读者动手实践。

    漫画与青少年教育关系.doc

    漫画与青少年教育关系

    励志图书的成功案例分享、人生智慧提炼与自我提升策略.doc

    励志图书的成功案例分享、人生智慧提炼与自我提升策略

    人工智能在食品安全与检测中的应用.doc

    人工智能在食品安全与检测中的应用

Global site tag (gtag.js) - Google Analytics