package com.fgkj.db;
|
|
import java.sql.Connection;
|
import java.sql.PreparedStatement;
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.Date;
|
|
import com.fgkj.actions.ActionUtil;
|
import com.fgkj.dao.DAOHelper;
|
|
public class Upload {
|
//文件上传用到
|
public static int getBattTestRecordCountNew(int bg_id, String table,Connection mysql_con)
|
{
|
String[] sql_strs = new String[4];
|
sql_strs[0] = "SELECT test_record_count_ex FROM " + table
|
+ " WHERE BattGroupId=" + bg_id + " FOR UPDATE";
|
sql_strs[1] = "UPDATE " + table + " SET test_record_count_ex=test_record_count+1"
|
+ " WHERE BattGroupId=" + bg_id;
|
sql_strs[2] = "SELECT MAX(test_record_count_ex) FROM " + table
|
+ " WHERE BattGroupId=" + bg_id;
|
sql_strs[3] = "INSERT INTO " + table + " (BattGroupId,test_record_count, test_record_count_ex) "
|
+ " VALUES (" + bg_id + "," + 1 + "," + 1 + ")";
|
return getIdNewByLock(sql_strs, 1 ,mysql_con);
|
}
|
|
//文件上传用到
|
public static int getIdNewByLock(String[] sql_strs, int id_init,Connection mysql_con)
|
{
|
|
if(sql_strs.length < 4) {
|
return 0;
|
}
|
int count_id = 0;
|
boolean res_exe = true;
|
String sql_str0 = sql_strs[0];
|
String sql_str1 = sql_strs[1];
|
String sql_str2 = sql_strs[2];
|
String sql_str3 = sql_strs[3];
|
PreparedStatement ps=null;
|
ResultSet res=null;
|
int judge=1;
|
|
try {
|
mysql_con.setAutoCommit(false);
|
ps= mysql_con.prepareStatement(sql_str0);
|
res=ps.executeQuery();
|
//ResultSet res = sqlMysqlQuery(sql_str0);
|
if(res.next()) {
|
ps=mysql_con.prepareStatement(sql_str1);
|
judge=ps.executeUpdate();
|
if(0 == judge) {
|
res_exe = false;
|
}
|
ps= mysql_con.prepareStatement(sql_str2);
|
res=ps.executeQuery();
|
//res = sqlMysqlQuery(sql_str2);
|
if(res.next()) {
|
count_id = res.getInt(1);
|
}
|
} else {
|
count_id = id_init;
|
ps=mysql_con.prepareStatement(sql_str3);
|
judge=ps.executeUpdate();
|
if(0 == judge) {
|
res_exe = false;
|
}
|
}
|
// try {
|
// System.out.println("开始休眠30分钟");
|
// Thread.sleep(20*1000);
|
// } catch (InterruptedException e) {
|
// e.printStackTrace();
|
// }
|
// System.out.println("休眠结束");
|
if(true == res_exe) {
|
mysql_con.commit();
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
res_exe = false;
|
} finally {
|
if(false == res_exe) {
|
try {
|
mysql_con.rollback();
|
mysql_con.setAutoCommit(true);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
return count_id;
|
}
|
|
}
|
