jeasy-java源代码

package com.main.test.SqlServerInsert; import java.math.BigDecimal; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.Statement; import java.text.SimpleDateFormat; import java.util.ArrayList; import org.apache.log4j.Logger; import javafish.clients.opc.component.OpcItem; /** * Created by it_general on 2018/8/4. */ public class InsertValue{ private static Logger logger = Logger.getLogger(InsertValue.class.getName()); final static String cfn = "com.microsoft.sqlserver.jdbc.SQLServerDriver"; final static String url = "jdbc:sqlserver://localhost:1433;DatabaseName=jinmen_DB"; SimpleDateFormat sfr=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); public void insertValue(ArrayList<OpcItem> arrayLists) { Connection con = null; PreparedStatement statement = null; ResultSet res = null; try { Class.forName(cfn); con = DriverManager.getConnection(url,"sa","supconit@123"); //String sql = "insert into Tage_Value values(?,?,?) "; //泵站信息 String sQu="insert into Alarm_PumpStats values(?,?,?,?,?,?)"; PreparedStatement pst = con.prepareStatement(sQu, Statement.RETURN_GENERATED_KEYS); //累计流量/压力 String pressure="insert into Alarm_WaterThrottle values(?,?,?,?)"; PreparedStatement pressureS = con.prepareStatement(pressure, Statement.RETURN_GENERATED_KEYS); //水质 String waterS="insert into Statistics_WaterQuality values(?,?,?,?,?)"; PreparedStatement waterQ = con.prepareStatement(waterS, Statement.RETURN_GENERATED_KEYS); logger.info("------开始入库------"); if(!arrayLists.isEmpty()){ for (OpcItem arrayList : arrayLists) { if(null!=arrayList.getItemName()&&null!=arrayList.getValue()&&null!=arrayList.getTimeStamp()){ if(arrayList.getItemName().contains("JSH_")){ waterQ.setString(1, sfr.format(arrayList.getTimeStamp().getTime())); if(arrayList.getItemName().contains("JSH_AND")){ waterQ.setInt(2,10); }else if(arrayList.getItemName().contains("JSH_COD_Cr")){ waterQ.setInt(2,7); }else if(arrayList.getItemName().contains("JSH_DD")){ waterQ.setInt(2,3); }else if(arrayList.getItemName().contains("JSH_DO")){ waterQ.setInt(2,4); }else if(arrayList.getItemName().contains("JSH_PH")){ waterQ.setInt(2,2); }else if(arrayList.getItemName().contains("JSH_QHW")){ waterQ.setInt(2,12); }else if(arrayList.getItemName().contains("JSH_SS")){ waterQ.setInt(2,5); }else if(arrayList.getItemName().contains("JSH_Temp")){ waterQ.setInt(2,1); }else if(arrayList.getItemName().contains("JSH_YLS")){ waterQ.setInt(2,11); }else if(arrayList.getItemName().contains("JSH_ZD")){ waterQ.setInt(2,8); }else if(arrayList.getItemName().contains("JSH_ZL")){ waterQ.setInt(2,8); } waterQ.setBigDecimal(3,new BigDecimal(arrayList.getValue()+"")); waterQ.setString(4, "正常"); waterQ.setString(5, "1"); waterQ.addBatch(); }else if("RHK_YL".contains(arrayList.getItemName())){ pst.setBigDecimal(1,new BigDecimal(arrayList.getValue()+"")); pst.setInt(2,7); pst.setInt(3,0); pressureS.setString(4, sfr.format(arrayList.getTimeStamp().getTime())); pst.setString(5,"正常"); pst.setInt(6,1); pst.addBatch(); }else if(arrayList.getItemName().contains("RHK_LL")){ pressureS.setBigDecimal(1,new BigDecimal(arrayList.getValue()+"")); pressureS.setInt(2,5); pressureS.setString(3, sfr.format(arrayList.getTimeStamp().getTime())); pressureS.setInt(4,1); pressureS.addBatch(); }else if(arrayList.getItemName().contains("RHK_LJLL")){ pressureS.setBigDecimal(1,new BigDecimal(arrayList.getValue()+"")); pressureS.setInt(2,6); pressureS.setString(3, sfr.format(arrayList.getTimeStamp().getTime())); pressureS.setInt(4,1); pressureS.addBatch(); } } } } waterQ.executeBatch(); // insert remaining records waterQ.close(); pst.executeBatch(); // insert remaining records pst.close(); pressureS.executeBatch(); // insert remaining records pressureS.close(); logger.info("------结束入库------"); } catch (Exception e) { e.printStackTrace(); logger.info(e.getMessage()); }finally{ try { if(res != null) res.close(); if(statement != null) statement.close(); if(con != null) con.close(); } catch (Exception e2) { // TODO: handle exception e2.printStackTrace(); logger.info(e2.getMessage()); } } } }