java 多线程操作数据库

2025-02-25 08:36:25

推荐回答（4个）

回答1：

//将数据库中的数据条数分段
 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 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 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=0;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());
  }
 }

回答2：

楼上说的对，
你这个类写的不健壮，
多访问，应该写个连接池的. 给你写点核心代码，参考一下
private static final vector pool=new vector();
private static final int MAX_SIZE=10;
private static final int MIN_SIZE=3;
private static Connection createConnection(){
Connection conn = null;
Class.forName("com.mysql.jdbc.Driver");
conn = DriverManager.getConnection( ("jdbc:mysql://localhost:3306/print", "root", "root");
}
static {
for(int i=0;ipool.add(createConnection());
}
}
public static synchronized Connection getConnection() {

Connection conn = null;
if (pool.isEmpty()) {
conn = createConnection();
} else {
int last_idx = pool.size() - 1;
conn = (Connection) pool.get(last_idx);
pool.remove(conn);
}

return conn;
}
public static synchronized void close(Connection conn){

if(pool.size()pool.add(conn);
}else{
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}

回答3：

1. 不要每次访问，都重新连接
2. 这里不是stmt被关闭了，而是你新建对象的时候把原来stmt的引用丢弃了。不要多个访问公用一组变量。

回答4：

已进行基本修改，有必要使用Dao和DataSource，使用连接池技术进行优化。
代码几乎未作变动。
private static Connection conn;
private static Statement stmt;
public static Connection getConn() {
return conn;
}
public static boolean createConn() {
try {
Class.forName("com.mysql.jdbc.Driver");
conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/print", "root", "root");
stmt = conn.createStatement();
return true;
} catch (Exception e) {
return false;
}
}
public static ResultSet executeQuerySql(String sql) throws SQLException {
ResultSet rs = null;
try {
rs = stmt.executeQuery(sql);
return rs;
} finally{
closedb();
}

}

public static void closedb() {
try {
if (stmt != null)
stmt.close();
if (conn != null)
conn.close();
} catch (Exception e) {
System.out.println(e);
}
}

沈阳市中央大街邮编

什么是形变热处理？

民俗说：“龙生龙，凤生凤，老鼠生儿会打洞。”这说明了生物的（）。 A．进化现象 B．适应现象 C．

汽车4S店有哪些职位？

肾结石可不可以喝红酒吗

求吉檀迦利（泰戈尔）全文赏析~回答好加分。

在拳皇99里(街机)里边,怎么弄出草疾和八神？

「多くの人に闻いてもらう」是什么意思呢？

博学之，审问之，慎思之，明辨之，笃行之什么意思