初次提交

Administrator

2021-01-22 6d31a7e364b74acb92bb69552e1a0e31f39a55f0

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
package com.dec.dao.impl; 
 
import java.sql.PreparedStatement; 
import java.sql.ResultSet; 
import java.sql.SQLException; 
import java.util.List; 
 
import org.openmuc.openiec61850.app.ConsoleClient; 
 
import com.dec.dao.IRtDataDao; 
import com.dec.dao.RtData; 
import com.dec.fbs9100.MysqlConnPool; 
import com.dec.fbs9100.SQL_Sybase; 
import com.dec.fbs9100.Sql_Mysql; 
import com.dec.model.Db_rtdataModel; 
 
public class DbRtDataDaoImpl implements IRtDataDao { 
     
    final public static String DB_RamDB = "`db_ram_db`"; 
    final public static String DB_BATT_INF = "`db_battinf`"; 
 
    public final static String RTState_Table = DB_RamDB + ".`tb_batt_rtstate`"; 
    public final static String RTdata_Table = DB_RamDB + ".`tb_batt_rtdata`"; 
    public final static String BattInf_Table = DB_BATT_INF + ".`tb_battinf`"; 
 
    static int BattGroupId;    
    static int FBSDeviceId = 618500001; 
 
    private MysqlConnPool mysqlConnPool = new MysqlConnPool(SQL_Sybase.getMysqlServerIp(), SQL_Sybase.getMysqlPort(),  
            SQL_Sybase.getmysqlConnCountMax()); 
     
    public DbRtDataDaoImpl(String args[]){ 
        String str0 = "SELECT BattGroupId FROM "+BattInf_Table+" WHERE FBSDeviceId = "+ FBSDeviceId; 
        Sql_Mysql sql = new Sql_Mysql(mysqlConnPool.getConn()); 
        try { 
            sql.sqlMysqlUseDB(DB_BATT_INF); 
            ResultSet rs=sql.sqlMysqlQuery(str0); 
            if(rs.next()){ 
                System.out.println("结果集不为空!"); 
                } 
                else{ 
                System.out.println("结果集为空!"); 
                } 
            BattGroupId=rs.getInt(1); 
            try { 
                rs.close(); 
            } catch (SQLException e) { 
                e.printStackTrace(); 
            } 
        } catch (SQLException e) { 
            //ConsoleClient.connection(args); 
        }finally{     
            sql.close_con(); 
        }  
    } 
     
     
    private String[] A = null ; 
     
    @Override 
    public boolean addIRtDataModel(Db_rtdataModel rtdata) throws Exception { 
        // TODO Auto-generated method stub 
        String sql = "insert into xxx values(?,?,?,?,?)"; 
        PreparedStatement pstmt = mysqlConnPool.getConn().prepareStatement(sql); 
        pstmt.setInt(1, rtdata.getBattGroupId()); 
        int res =pstmt.executeUpdate(); 
        pstmt.close(); 
        return res > 0 ; 
    } 
 
    @Override 
    public int getallIRtDataCount(int id) { 
        // TODO Auto-generated method stub 
        return 0; 
    } 
 
    @Override 
    public List<Db_rtdataModel> getRtDatabattgroupidByStationid(int stationid) { 
        // TODO Auto-generated method stub 
         
        return null; 
    } 
 
    @Override 
    public boolean updateIRtDataModel(Db_rtdataModel rtdata) throws Exception { 
        // TODO Auto-generated method stub 
        String sql =  " UPDATE "+ RTdata_Table+" SET "+  
                    " mon_vol= ?," 
                    +" mon_tmp= ?, " 
                    +" mon_res= ? " 
                    +" WHERE BattGroupId = ? and mon_num= ? "; 
         
        PreparedStatement pstmt = this.mysqlConnPool.getConn().prepareStatement(sql); 
        pstmt.setFloat(1, rtdata.getMon_vol());// 
        pstmt.setFloat(2, rtdata.getMon_tmp());// 
        pstmt.setFloat(3, rtdata.getMon_res());// 
        pstmt.setFloat(4, BattGroupId);// 
        pstmt.setFloat(5, rtdata.getMon_num());// 
        int res = pstmt.executeUpdate(); 
        System.out.println(sql); 
        pstmt.close(); 
        return res > 0;         
    } 
 
    @Override 
    public boolean dropIRtDataModel(int id) { 
        // TODO Auto-generated method stub 
        return false; 
    } 
 
    @Override 
    public boolean updateIRtDataModel(int id) { 
        // TODO Auto-generated method stub 
        return false; 
    } 
 
}