From 47f9d4a231a116f528f9d18d738420dba7f753bd Mon Sep 17 00:00:00 2001 From: 严智鑫 <test> Date: 星期三, 26 三月 2025 23:43:15 +0800 Subject: [PATCH] 成功使用ModbusTcp,S7连接设备并且存储到数据库 --- nglib/src/ng/devices/MysqlService.java | 25 ++++++++++++++----------- 1 files changed, 14 insertions(+), 11 deletions(-) diff --git a/nglib/src/ng/devices/MysqlService.java b/nglib/src/ng/devices/MysqlService.java index 7785c18..f064719 100644 --- a/nglib/src/ng/devices/MysqlService.java +++ b/nglib/src/ng/devices/MysqlService.java @@ -4,6 +4,8 @@ import java.sql.Connection; import builder.Manager; +import builder.S7control; +import com.github.xingshuangs.iot.protocol.s7.enums.EPlcType; import ng.db.DBHelper; import ng.db.DBSession; import ng.devices.ModbusService.ModbusDataPackage; @@ -110,21 +112,22 @@ DBSession sn=null; String result=null; String flag=null; - + System.out.println(lastGet); try{ //创建连接 sn=this.db.createSession(false); Connection con= sn.getConnection(); - //掉哦那个存储过程 - CallableStatement sql=con.prepareCall("{call Total_method(?,?,?,?)}"); - sql.registerOutParameter(3, java.sql.Types.VARCHAR); - sql.registerOutParameter(4, java.sql.Types.VARCHAR); - sql.setString(1, s); - sql.setLong(2, id); - sql.execute(); - //读取返回参数 - result= sql.getString(3); - flag= sql.getString(4); + //调用那个存储过程 + CallableStatement sql=con.prepareCall("{call Total_method(?,?,?,?)}"); + sql.registerOutParameter(3, java.sql.Types.VARCHAR); + sql.registerOutParameter(4, java.sql.Types.VARCHAR); + sql.setString(1, s); + sql.setLong(2, id); + sql.execute(); + //读取返回参数 + result= sql.getString(3); + flag= sql.getString(4); + } catch(Exception e){ e.printStackTrace(); -- Gitblit v1.8.0