package com.fgkj.test;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
import com.fgkj.dao.CallBack;
|
import com.fgkj.dao.DAOHelper;
|
import com.fgkj.db.DBUtil;
|
|
public class Batt_DevdischargeTest {
|
|
public static void main(String[] args) {
|
String table_cm="web_site.tb_batt_devdischarge_CM";
|
String table_cu="web_site.tb_batt_devdischarge_CU";
|
String table_ct="web_site.tb_batt_devdischarge_CT";
|
String table=table_ct;
|
String dev_idSql="select distinct(dev_id) from "+table;
|
List list=DAOHelper.executeQuery(dev_idSql, DBUtil.getConn(), null, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
int dev_id=rs.getInt("dev_id");
|
list.add(dev_id);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
|
for(int i=0;i<list.size();i++){
|
String allSql="select num from "+table+" where dev_id=? order by dev_recordtime asc,num asc ";
|
List listA=DAOHelper.executeQuery(allSql, DBUtil.getConn(), new Object[]{list.get(i)}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List listA=new ArrayList();
|
try {
|
while(rs.next()){
|
int num=rs.getInt("num");
|
listA.add(num);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return listA;
|
}
|
});
|
for(int j=0;j<listA.size();j++){
|
String updateSql="update "+table+" set record_num=? where num=? ";
|
System.out.println(j+1);
|
boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), updateSql, new Object[]{(j+1),listA.get(j)});
|
}
|
}
|
}
|
|
}
|