java写的socket通信客户端

package dbtools; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException; import dbtools.DBUtility; import dbtools.DateTimestamp; import filecontrol.LogNote; /******************************************************************************* * 功 能：把解析出来的字符串数组根据电文名称插入相对应的表中，并对应用表做处理 * 设计者：屈松涛 * 日 期：2009-05-14 * All Right Reserved. ******************************************************************************/ public class UpdateString { // 中间表sql语句字符串 private static final String L2_RM_HALT_ACT=" INSERT INTO US_L2.L2_RM_HALT_ACT (TL_ID,TMSTP_STR,REASON_CODE,TMSTP_SND) VALUES(?,?,?,?)"; private static final String L2_RM_RL_ACT=" INSERT INTO US_L2.L2_RM_RL_ACT (TL_ID,ID_SCHD_RL,ID_COIL,ID_COIL_SN,TMSTP_STR,TMSTP_END,RL_SCRP_YN,RL_LEN,WT_THEORY,PARAMETER_001,PARAMETER_002,PARAMETER_003,PARAMETER_004,PARAMETER_005,PARAMETER_006,PARAMETER_007,PARAMETER_008,PARAMETER_009,PARAMETER_010,PARAMETER_011,PARAMETER_012,PARAMETER_013,PARAMETER_014,PARAMETER_015,PARAMETER_016,PARAMETER_017,PARAMETER_018,PARAMETER_019,PARAMETER_020,PARAMETER_021,PARAMETER_022,PARAMETER_023,PARAMETER_024,PARAMETER_025,PARAMETER_026,PARAMETER_027,PARAMETER_028,PARAMETER_029,PARAMETER_030,PARAMETER_031,PARAMETER_032,JZHSXLL4,PARAMETER_033,PARAMETER_034,PARAMETER_035,PARAMETER_036,PARAMETER_037,PARAMETER_038,PARAMETER_039,PARAMETER_040,PARAMETER_041,PARAMETER_042,PARAMETER_043,PARAMETER_044,PARAMETER_045,PARAMETER_046,PARAMETER_047,PARAMETER_048,PARAMETER_054,PARAMETER_061,PARAMETER_069,PARAMETER_074,PARAMETER_076,PARAMETER_077,PARAMETER_078,PARAMETER_079,PARAMETER_080,PARAMETER_081,PARAMETER_082,PARAMETER_083,PARAMETER_084,PARAMETER_085,PARAMETER_086,PARAMETER_087,PARAMETER_088,PARAMETER_089,PARAMETER_090,PARAMETER_091,PARAMETER_092,PARAMETER_093,PARAMETER_094,PARAMETER_095,PARAMETER_096,PARAMETER_097,PARAMETER_098,PARAMETER_099,PARAMETER_100,PARAMETER_101,PARAMETER_102,PARAMETER_103,PARAMETER_104,PARAMETER_105,PARAMETER_106,PARAMETER_107,PARAMETER_108,PARAMETER_109,PARAMETER_110,PARAMETER_111,PARAMETER_112,PARAMETER_113,PARAMETER_114,PARAMETER_115,PARAMETER_116,PARAMETER_117,PARAMETER_118,PARAMETER_119,PARAMETER_120,PARAMETER_121,PARAMETER_122,PARAMETER_123,PARAMETER_124,PARAMETER_125,PARAMETER_126,PARAMETER_127,PARAMETER_128,PARAMETER_129,PARAMETER_130,PARAMETER_131,PARAMETER_132,PARAMETER_133,PARAMETER_134,PARAMETER_135,PARAMETER_136,PARAMETER_137,PARAMETER_138,PARAMETER_139,PARAMETER_140,PARAMETER_141,PARAMETER_142,PARAMETER_143,PARAMETER_144,PARAMETER_145,PARAMETER_146,PARAMETER_147,PARAMETER_148,PARAMETER_149,TMSTP_SND) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; private static final String L2_RM_RL_CHG_GV=" INSERT INTO US_L2.L2_RM_RL_CHG_GV (TL_ID,RM_NO,ROLLER_CODE_A,PROC_GV_NO_OLD_A,PROC_GV_NO_NEW_A,PROC_WEI_A,ROLLER_CODE_B,PROC_GV_NO_OLD_B,PROC_GV_NO_NEW_B,PROC_WEI_B,TMSTP_SND) VALUES(?,?,?,?,?,?,?,?,?,?,?)"; private static final String L2_RM_RL_DATA=" INSERT INTO US_L2.L2_RM_RL_DATA (TL_ID,RM_NO,ROLL_GAP,ROLLER_CODE_A,PROC_DIA_A,PROC_GV_DEP_A,GOV_LM_A1,GOV_ACT_A1,GOV_LM_A2,GOV_ACT_A2,GOV_LM_A3,GOV_ACT_A3,GOV_LM_A4,GOV_ACT_A4,GOV_LM_A5,GOV_ACT_A5,GOV_LM_A6,GOV_ACT_A6,GOV_LM_A7,GOV_ACT_A7,GOV_LM_A8,GOV_ACT_A8,GOV_LM_A9,GOV_ACT_A9,GOV_LM_A10,GOV_ACT_A10,GOV_LM_A11,GOV_ACT_A11,GOV_LM_A12,GOV_ACT_A12,GOV_LM_A13,GOV_ACT_A13,GOV_LM_A14,GOV_ACT_A14,GOV_LM_A15,GOV_ACT_A15,GOV_LM_A16,GOV_ACT_A16,GOV_LM_A17,GOV_ACT_A17,GOV_LM_A18,GOV_ACT_A18,GOV_LM_A19,GOV_ACT_A19,GOV_LM_A20,GOV_ACT_A20,GOV_LM_A21,GOV_ACT_A21,GOV_LM_A22,GOV_ACT_A22,GOV_LM_A23,GOV_ACT_A23,GOV_LM_A24,GOV_ACT_A24,GOV_LM_A25,GOV_ACT_A25,ROLLER_CODE_B,PROC_DIA_B,PROC_GV_DEP_B,GOV_LM_B1,GOV_ACT_B1,GOV_LM_B2,GOV_ACT_B2,GOV_LM_B3,GOV_ACT_B3,GOV_LM_B4,GOV_ACT_B4,GOV_LM_B5,GOV_ACT_B5,GOV_LM_B6,GOV_ACT_B6,GOV_LM_B7,GOV_ACT_B7,GOV_LM_B8,GOV_ACT_B8,GOV_LM_B9,GOV_ACT_B9,GOV_LM_B10,GOV_ACT_B10,GOV_LM_B11,GOV_ACT_B11,GOV_LM_B12,GOV_ACT_B12,GOV_LM_B13,GOV_ACT_B13,GOV_LM_B14,GOV_ACT_B14,GOV_LM_B15,GOV_ACT_B15,GOV_LM_B16,GOV_ACT_B16,GOV_LM_B17,GOV_ACT_B17,GOV_LM_B18,GOV_ACT_B18,GOV_LM_B19,GOV_ACT_B19,GOV_LM_B20,GOV_ACT_B20,GOV_LM_B21,GOV_ACT_B21,GOV_LM_B22,GOV_ACT_B22,GOV_LM_B23,GOV_ACT_B23,GOV_LM_B24,GOV_ACT_B24,GOV_LM_B25,GOV_ACT_B25,TMSTP_SND,SEND_FLAG) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; private static final String L2_RM_RL_DATA_ACK=" INSERT INTO US_L2.L2_RM_RL_DATA_ACK (TL_ID,RM_NO,TMSTP_SND) VALUES(?,?,?)"; private static final String L2_RM_RL_PLAN=" INSERT INTO US_L2.L2_RM_RL_PLAN (TL_ID,PLAN_ST,ID_SCHD_RL,NAME_STLGD,DIM_DIA,NUM_BAR,WT_BAR,TMSTP_SND,SEND_FLAG) VALUES(?,?,?,?,?,?,?,?,?)"; private static final String L2_RM_RL_PLAN_ACK=" INSERT INTO US_L2.L2_RM_RL_PLAN_ACK (TL_ID,ID_SCHD_RL,TMSTP_SND) VALUES(?,?,?)"; private static final String L2_RM_RL_WEIGH_ACT=" INSERT INTO US_L2.L2_RM_RL_WEIGH_ACT (TEL_SEQ,RL_PLAN_NO,RL_NO,GOIL_WEI,ROL_SN1,ROL_SSN1,ROL_SN2,ROL_SSN2,ROL_SN3,ROL_SSN3,ROL_SN4,ROL_SSN4,SEND_TM) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?)"; // 成员方法 public void dbChange(String telId, String[] s, int count, int countZ) { Connection cnn = null; DBUtility db = DBUtility.getInstance(); try { DateTimestamp dts = new DateTimestamp(); cnn = db.getConnection(); /**********************L2_RM_HALT_ACT||机组停机实绩(R)*****************************/ if (telId.equals("L2_RM_HALT_ACT") && countZ == 4) { PreparedStatement stmt = cnn.prepareStatement(L2_RM_HALT_ACT); stmt.setString(1, s[(count - 1) * countZ + 1]); stmt.setTimestamp(2, dts.string2Time(s[(count - 1) * countZ + 2])); stmt.setString(3, s[(count - 1) * countZ + 3]); stmt.setString(4, s[(count - 1) * countZ + 4]); stmt.executeUpdate(); } /**********************L2_RM_RL_ACT||轧机生产实绩(R)*****************************/ else if(telId.equals("L2_RM_RL_ACT") && countZ == 137){ PreparedStatement stmt = cnn.prepareStatement(L2_RM_RL_ACT); stmt.setString(1, s[(count - 1) * countZ + 1]); stmt.setString(2, s[(count - 1) * countZ + 2]); stmt.setDouble(3, Double.parseDouble(s[(count - 1) * countZ + 3])); stmt.setDouble(4, Double.parseDouble(s[(count - 1) * countZ + 4])); stmt.setTimestamp(5, dts.string2Time(s[(count - 1) * countZ + 5])); stmt.setTimestamp(6, dts.string2Time(s[(count - 1) * countZ + 6])); stmt.setString(7, s[(count - 1) * countZ + 7]); stmt.setDouble(8, Double.parseDouble(s[(count - 1) * countZ + 8])); stmt.setDouble(9, Double.parseDouble(s[(count - 1) * countZ + 9])); stmt.setDouble(10, Double.parseDouble(s[(count - 1) * countZ + 10])); stmt.setDouble(11, Double.parseDouble(s[(count - 1) * countZ + 11])); stmt.setDouble(12, Double.parseDouble(s[(count - 1) * countZ + 12])); stmt.setDouble(13, Double.parseDouble(s[(count - 1) * countZ + 13])); stmt.setDouble(14, Double.parseDouble(s[(count - 1) * countZ + 14])); stmt.setDouble(15, Double.parseDouble(s[(count - 1) * countZ + 15])); stmt.setDouble(16, Double.parseDouble(s[(count - 1) * countZ + 16])); stmt.setDouble(17, Double.parseDouble(s[(count - 1) * countZ + 17])); stmt.setDouble(18, Double.parseDouble(s[(count - 1) * countZ + 18])); stmt.setDouble(19, Double.parseDouble(s[(count - 1) * countZ + 19])); stmt.setDouble(20, Double.parseDouble(s[(count - 1) * countZ + 20])); stmt.setDouble(21, Double.parseDouble(s[(count - 1) * countZ + 21])); stmt.setDouble(22, Double.parseDouble(s[(count - 1) * countZ + 22])); stmt.setDouble(23, Double.parseD