在做项目的时候使用hibernate向数据库中写入数据,但是程序执行完毕之后,使用SQLSERVER的查询分析器查询,就不能查出数据,报超时错误。
主要功能代码:
public void sendMessage(List list,String pc,String message,String name,String dm,String no){
Session session=HibernateSessionFactory.getSession();
Session ccuni=CcuniSessionFactory.getSession();
Transaction tr=session.beginTransaction();
Iterator it=list.iterator();
int i=1;
while(it.hasNext()){
String phone=it.next().toString();
Send send =new Send();
Submit sub=new Submit();
send.setPc(Integer.valueOf(pc));
send.setMessage(message);
send.setDm(dm);
send.setPhone(phone);
send.setSTime(new Date());
send.setCode(Integer.valueOf(1));
send.setFszt(Integer.valueOf(0));
send.setJszt(Integer.valueOf(0));
send.setName(name);
session.save(send);
sub.setDestTerminalId(phone);
sub.setPc(Integer.valueOf(pc));
sub.setSubmitNo(no);
sub.setSubmitInfo(message);
sub.setStatus(Integer.valueOf(0));
ccuni.save(sub);
if(i%50==0){
System.out.println("发送50个");
ccuni.flush();
session.flush();
ccuni.clear();
session.clear();
}
i++;
}
tr.commit();
ccuni.flush();
session.flush();
ccuni.clear();
session.clear();
ccuni.close();
session.close();
System.out.println("发送完毕");
}