java多线程事务未提交

『壹』 事务未提交解决方法

事务未提交会提示：Lock wait timeout exceeded; try restarting transaction等待超时。散租
在mysql查询中执行以下指者掘旦令

select * from information_schema.innodb_trx

用kill 杀死对应的线程id即可首扰

『贰』 java 多线程操作数据库

//将数据库中的数据条数分段
publicvoiddivision(){
//获取要导入的总的数据条数
Stringsql3="SELECTcount(*)FROM[CMD].[dbo].[my1]";
try{
pss=cons.prepareStatement(sql3);
rss=pss.executeQuery();

while(rss.next()){
System.out.println("总记录条数:"+rss.getInt(1));
sum=rss.getInt(1);
}
//每30000条记录作为一个分割点
if(sum>=30000){
n=sum/30000;
resie=sum%30000;
}else{
resie=sum;
}

System.out.println(n+""+resie);

}catch(SQLExceptione){
//TODOAuto-generatedcatchblock
e.printStackTrace();
}

}
线程类
publicMyThread(intstart,intend){
this.end=end;
this.start=start;
System.out.println("处理掉余数");
try{

System.out.println("--------"+Thread.currentThread().getName()+"------------");
Class.forName(SQLSERVERDRIVER);
System.out.println("加载sqlserver驱动...");
cons=DriverManager.getConnection(CONTENTS,UNS,UPS);
stas=cons.createStatement();
System.out.println("连接SQLServer数据库成功！！");

System.out.println("加载mysql驱动.....");
Class.forName(MYSQLDRIVER);
con=DriverManager.getConnection(CONTENT,UN,UP);
sta=con.createStatement();
//关闭事务自动提交
con.setAutoCommit(false);
System.out.println("连接mysql数据库成功！！");

}catch(Exceptione){
e.printStackTrace();
}
//TODOAuto-generatedconstructorstub
}


publicArrayList<Member>getAll(){
Membermember;
Stringsql1="select*from(selectrow_number()over(orderbypmcode)asrowNum,*"+
"from[CMD].[dbo].[my1])astwhererowNumbetween"+start+"and"+end;
try{
System.out.println("正在获取数据...");
allmembers=newArrayList();
rss=stas.executeQuery(sql1);
while(rss.next()){
member=newMember();
member.setAddress1(rss.getString("address1"));
member.setBnpoints(rss.getString("bnpoints"));
member.setDbno(rss.getString("dbno"));
member.setExpiry(rss.getString("expiry"));
member.setHispoints(rss.getString("hispoints"));
member.setKypoints(rss.getString("kypoints"));
member.setLevels(rss.getString("levels"));
member.setNames(rss.getString("names"));
member.setPmcode(rss.getString("pmcode"));
member.setRemark(rss.getString("remark"));
member.setSex(rss.getString("sex"));
member.setTelephone(rss.getString("telephone"));
member.setWxno(rss.getString("wxno"));
member.setPmdate(rss.getString("pmdate"));
allmembers.add(member);
//System.out.println(member.getNames());
}
System.out.println("成功获取sqlserver数据库数据！");
returnallmembers;

}catch(SQLExceptione){
//TODOAuto-generatedcatchblock
System.out.println("获取sqlserver数据库数据发送异常！");
e.printStackTrace();
}
try{
rss.close();
stas.close();
}catch(SQLExceptione){
//TODOAuto-generatedcatchblock
e.printStackTrace();
}
returnnull;
}

publicvoidinputAll(ArrayList<Member>allmembers){
System.out.println("开始向mysql中写入");
Stringsql2="insertintotest.my2values(?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
try{
ps=con.prepareStatement(sql2);
System.out.println("-------------------------等待写入数据条数:"+allmembers.size());
for(inti=0;i<allmembers.size();i++){
ps.setString(1,allmembers.get(i).getPmcode());
ps.setString(2,allmembers.get(i).getNames());
//System.out.println(allmembers.get(i).getNames());
ps.setString(3,allmembers.get(i).getSex());
ps.setString(4,allmembers.get(i).getTelephone());
ps.setString(5,allmembers.get(i).getAddress1());
ps.setString(6,allmembers.get(i).getPmdate());
ps.setString(7,allmembers.get(i).getExpiry());
ps.setString(8,allmembers.get(i).getLevels());
ps.setString(9,allmembers.get(i).getDbno());
ps.setString(10,allmembers.get(i).getHispoints());
ps.setString(11,allmembers.get(i).getBnpoints());
ps.setString(12,allmembers.get(i).getKypoints());
ps.setString(13,allmembers.get(i).getWxno());
ps.setString(14,allmembers.get(i).getRemark());
//插入命令列表
//ps.addBatch();
ps.executeUpdate();
}
//ps.executeBatch();
con.commit();

ps.close();
con.close();
this.flag=false;
System.out.println(Thread.currentThread().getName()+"--->OK");
}catch(SQLExceptione){
//TODOAuto-generatedcatchblock
System.out.println("向mysql中更新数据时发生异常！");
e.printStackTrace();
}
}
@Override
publicvoidrun(){
//TODOAuto-generatedmethodstub
while(true&&flag){
this.inputAll(getAll());
}
}

『叁』 java中一个线程怎么通知另外一个线程进行数据库事务回滚或者提交

需要一个 全局的标志位 来控制 线程是否回滚

在 运行的线程中 改变 全局的标志位 然后 回滚线程 判定这个 标志位的 状态 来进行 是否的回滚开关。

『肆』 java事务和锁的问题，如果事务没提交，其他线程能修改数据库中的同条数据吗

题主，你说的这种情况是允许出现的。这与事务的隔离程度有关。

如果事务隔离程度设置得当，就没有必要显式的通过synchronized保护资源（除非资源是某个service中的公共属性）。

『伍』 JAVA 线程池 其中一个线程执行失败 则线程重新执行或者重新提交任务 急

futrue.get()是在线程执行完毕之后才返回的结果。 就是说你能得到get的返回值的时候，线程已经执行完毕并退出了。

『陆』 求助java多线程问题

问题现象：

js">if(num>4&&p.isAlive()==false){
//主线程的判断逻辑中num的值一直都没增加，所以if中的逻辑一直没有执行
//因此，线程未启动
}

问题原因：

并发中的线程安全问题导致。

原因分析：

线程A对num的修改体让晌现坦销锋在线程A的寄存器及内存中

主线程中，通过while循环不间断的访问num，导致JVM为了提高速度，一直都在从主线程寄存器中获取num的值，因此num的值一直未增加到5。

问题解决：

方法一：在num前增加修饰符volatile，使所有线程对num的访问都从内存读取

斗空方法一：对num进行同步处理

	(){
		num++;
	}

	(){
		returnnum;
	}

『柒』 java程序往oracle的事务性临时表里插入数据后,没提交或回滚事务,却无法查到数据

你在Dao实现类里的那个1sql 语句执行完后 在this.2sql语句的方法试试

『捌』 Java多线程问题总结

Java多线程分类中写了21篇多线程的文章，21篇文章的内容很多，个人认为，学习，内容越多、越杂的知识，越需要进行深刻的总结，这样才能记忆深刻，将知识变成自己的。java课程培训机构认为这篇文章主要是对多线程的问题进行总结的，因此罗列了多个多线程的问题。

这些多线程的问题，有些来源于各大网站、有些来源于自己的思考。

（1）发挥多核CPU的优势

随着工业的进步，现在的笔记本、台式机乃至商用的应用服务器至少也都是双核的，4核、8核甚至16核的也冲行培都不少见，如果是单线程的程序，那么在双核CPU上就浪费了50%，在4核CPU上就浪费了75%。单核CPU上所谓的”多线程”那是假的多线程，同一时间处理器只会处理一段逻辑，只不过线程之间切换得比较快，看着像多个线程”同时”运行罢了。多核CPU上的多线程才是真正的多线程，它能散唯让你的多段逻辑同时工作，多线程，可以真正发挥出多核CPU的优势来，达到带念充分利用CPU的目的。

（2）防止阻塞

从程序运行效率的角度来看，单核CPU不但不会发挥出多线程的优势，反而会因为在单核CPU上运行多线程导致线程上下文的切换，而降低程序整体的效率。但是单核CPU我们还是要应用多线程，就是为了防止阻塞。试想，如果单核CPU使用单线程，那么只要这个线程阻塞了，比方说远程读取某个数据吧，对端迟迟未返回又没有设置超时时间，那么你的整个程序在数据返回回来之前就停止运行了。多线程可以防止这个问题，多条线程同时运行，哪怕一条线程的代码执行读取数据阻塞，也不会影响其它任务的执行。

（3）便于建模

这是另外一个没有这么明显的优点了。假设有一个大的任务A，单线程编程，那么就要考虑很多，建立整个程序模型比较麻烦。但是如果把这个大的任务A分解成几个小任务，任务B、任务C、任务D，分别建立程序模型，并通过多线程分别运行这几个任务，那就简单很多了。

『玖』 Java多线程问题

System.out.println("End of method.");
可虚芦含能在System.out.println("run.");之前也可能在之后执行。

但是一旦throw new RuntimeException("Problem");执行就不会再执行System.out.println("End of method.");

所以就是三种可能性。

这里因为输出和抛出异哗改常的操作都差笑是同步的，所以可以看成原子操作。另外就是发生异常程序就会停止。

『拾』 数据库事务不提交或提交失败需要回滚吗

1.

在同一事务条件下,回滚和不提交,表现是一样的
但是还有些差别

事务处理,是将操作事件交给数据库(模拟)运行,直到吵渣commit操作,才使得修改实际产生效果,你可以看做是未提交事务都是处于一个临时库中进行
回滚是对于同一个事务,如果产生了错误,那么取消这个临时库中的操作,不对实际数据产生影响

最主要的区别在于,如果不回滚,这些临时操作会持续到这个御渗个connection结束为止,也就是虽然你看不到,但是临时库的操作依然存在,而回镇碰脊滚是即时生效,其实都是回滚了,只是时间点的不一样

2.

我说你在开玩笑吧。没有提交事务并不代表你对数据库的改变不存在，如果是脏读的隔离层级你修改数据到提交完成前的变更其他访问者也是可以看到的。只有你提交后这部分修改才确认不会变更而已，哪怕设定了其他隔离级别也可以看到了。

如果你不回滚，那么线程就停在哪里搁着？制造出数据库死链放着不管直到数据库认为这个连接超时自动断开并自动回滚？

ISOLATION_READ_UNCOMMITTED:允许读取其他并发事务还未提交的更新，会导致事务之间的3个缺陷发生，这是速度最快的一个隔离级别，但同 时它的隔离级别也是最低