package com.ard.utils.jdbc;
|
|
/**
|
* @Description:
|
* @ClassName: Query
|
* @Author: 刘苏义
|
* @Date: 2023年09月19日13:01:28
|
**/
|
|
import com.ard.alarm.digitization.model.DataBridge;
|
import lombok.extern.slf4j.Slf4j;
|
|
import java.sql.Connection;
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.sql.Statement;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
@Slf4j(topic = "digitization3")
|
public class Query {
|
static Connection conn = null;
|
static Statement st = null;
|
static ResultSet rs = null;
|
|
public static List<DataBridge> getAlarmData(Date alarmTime, Integer rowNum) {
|
List<DataBridge> dataBridgeList = new ArrayList<>();
|
try {
|
//1、获取连接对象
|
conn = Conn.getGc().getCon();
|
//2、创建statement类对象，用来执行SQL语句
|
st = conn.createStatement();
|
//3、创建sql查询语句
|
StringBuilder sbd = new StringBuilder();
|
String sql = "select * from (select * from DATABRIDGE order by DB_DATETIME desc ) where 1=1 ";
|
sbd.append(sql);
|
if (rowNum != null) {
|
sbd.append(" and rownum <" + rowNum);
|
}
|
if (alarmTime != null) {
|
SimpleDateFormat fmt = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");
|
String Time = fmt.format(alarmTime);
|
sbd.append(" and DB_DATETIME > to_date('" + Time + "','yyyy/mm/dd hh24:mi:ss')");
|
}
|
//4、执行sql语句并且换回一个查询的结果集
|
rs = st.executeQuery(sbd.toString());
|
while (rs.next()) { //循环遍历结果集
|
DataBridge dataBridge = new DataBridge();
|
dataBridge.setId(rs.getString("DB_GUID"));
|
dataBridge.setXmmc(rs.getString("DB_XMMC"));
|
dataBridge.setFKey(rs.getString("DB_FKEY"));
|
dataBridge.setFName(rs.getString("DB_FNAME"));
|
dataBridge.setValue(rs.getString("DB_VALUE"));
|
dataBridge.setDateTime(rs.getTimestamp("DB_DATETIME"));
|
dataBridgeList.add(dataBridge);
|
}
|
return dataBridgeList;
|
} catch (Exception e) {
|
log.error("三厂数字化报警查询异常:" + e.getMessage());
|
return dataBridgeList;
|
} finally {
|
try {
|
conn.close();
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
}
|
