多个线程在访问同一个数据库中的记录的时候，在大并发的情况下，一定要做好事务机制。要不然后果还是很扎心的。可能遇到这样的问题的时候首先想到的就是同步锁机制了。
并发产生的情况以我的平时工作的经验来说，凡是涉及多线程的并发访问的问题一定要小心。因为一不小心就会产生死锁问题。平时编程的时候更要多注意这方面的问题。我们可以产生问题的情况是复杂的，两个线程争同一个对象会有问题，如果你只静态的方法，简单的逻辑不是问题，但是如果你的线程是修改静态变量的值，那应该是线程问题造成的。
java多线程并发最经典的多并发的情况就是生产者和消费者的问题了吧。之前在学校学习 *** 作系统的时候，经常因为类似的并发 *** 作的问题想很久。后来工作的时候真正的实践以后，更能很好的体会到并发线程 *** 作的难度。java是线程安全的，即对任何方法（包括静态方法）都可以不考虑线程冲突，但有一个前提，就是不能存在全局变量。如果存在全局变量，则需要使用同步机制。
并发连接数据库其实在实际项目开发汇总，首先要做的就是避免多个线程共用一个数据库连接，这样会很容易出问题，最好是一个线程一个连接。在必要的时候需要线程同步或存储过程加锁。如果有比较复杂的事务 *** 作的话就需要加锁了，如果不加的话就会出现你说的脏读、死锁等问题。
//将数据库中的数据条数分段public void division(){
//获取要导入的总的数据条数
String sql3="SELECT count(*) FROM [CMD].[dbo].[mycopy1]"
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
residue=sum%30000
}else{
residue=sum
}
System.out.println(n+" "+residue)
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace()
}
}
线程类
public MyThread(int start,int end) {
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 (Exception e) {
e.printStackTrace()
}
// TODO Auto-generated constructor stub
}
public ArrayList<Member>getAll(){
Member member
String sql1="select * from (select row_number() over (order by pmcode) as rowNum,*" +
" from [CMD].[dbo].[mycopy1]) as t where rowNum between "+start+" and "+end
try {
System.out.println("正在获取数据...")
allmembers=new ArrayList()
rss=stas.executeQuery(sql1)
while(rss.next()){
member=new Member()
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数据库数据！")
return allmembers
} catch (SQLException e) {
// TODO Auto-generated catch block
System.out.println("获取sqlserver数据库数据发送异常！")
e.printStackTrace()
}
try {
rss.close()
stas.close()
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace()
}
return null
}
public void inputAll(ArrayList<Member>allmembers){
System.out.println("开始向mysql中写入")
String sql2="insert into test.mycopy2 values (?,?,?,?,?,?,?,?,?,?,?,?,?,?)"
try {
ps=con.prepareStatement(sql2)
System.out.println("-------------------------等待写入数据条数: "+allmembers.size())
for(int i=0i<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 (SQLException e) {
// TODO Auto-generated catch block
System.out.println("向mysql中更新数据时发生异常！")
e.printStackTrace()
}
}
@Override
public void run() {
// TODO Auto-generated method stub
while(true&&flag){
this.inputAll(getAll())
}
}
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）