package com.whyc.service; import com.whyc.dto.Response; import com.whyc.mapper.CallBack; import com.whyc.pojo.db_abe_testdata.AbeTestData; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.sql.ResultSet; import java.sql.SQLException; import java.util.LinkedList; import java.util.List; @Service public class AbeTestDataService { @Autowired private JdbcSqlExecuteService jdbcSqlExecuteService; public List getList(int monId, int testRecordCount) { String sql = "select mon_id,test_record_count,record_time,test_starttime,test_type,record_num,test_timelong,group_vol,test_curr,test_cap,mon_vol,mon_tmp,mon_res from db_abe_testdata.tb_abe_testdata_"+monId +" where test_record_count = "+testRecordCount; List monDatalist = jdbcSqlExecuteService.executeQuery_call(sql, new CallBack() { @Override public List getResults(ResultSet rs) throws SQLException { LinkedList temp = new LinkedList<>(); while (rs.next()) { AbeTestData abeTestData = new AbeTestData(); abeTestData.setMonId(rs.getInt("mon_id")); abeTestData.setTestRecordCount(rs.getInt("test_record_count")); abeTestData.setRecordTime(rs.getTimestamp("record_time")); abeTestData.setTestStartTime(rs.getTimestamp("test_starttime")); abeTestData.setTestType(rs.getInt("test_type")); abeTestData.setRecordNum(rs.getInt("record_num")); abeTestData.setTestTimeLong(rs.getInt("test_timelong")); abeTestData.setGroupVol(rs.getFloat("group_vol")); abeTestData.setTestCurr(rs.getFloat("test_curr")); abeTestData.setTestCap(rs.getFloat("test_cap")); abeTestData.setMonVol(rs.getFloat("mon_vol")); abeTestData.setMonTmp(rs.getFloat("mon_tmp")); abeTestData.setMonRes(rs.getFloat("mon_res")); temp.add(abeTestData); } return temp; } }); return monDatalist; } }