sqlserver拉取数据工具类2

business-common/src/main/java/com/rongwei/bscommon/sys/service/impl/ZhcxPMQMServiceImpl.java

@@ -19,6 +19,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
+import java.security.Security;
 import java.sql.*;
 import java.util.*;
 import java.util.Date;
@@ -215,6 +216,8 @@ public class ZhcxPMQMServiceImpl implements ZhcxPMQMService {
         List<ZhcxPmqManagementSourceDo> list = new ArrayList<>();
         String url ="jdbc:sqlserver://"+nxurl+":1433;databaseName="+nxdbname+";"+nxurlfix+"";
         log.info("三单连接字符串" + url);
+        // 加入TLS1.0
+        Security.setProperty("jdk.tls.client.protocols", "TLSv1.2,TLSv1.1,TLSv1");
         try(Connection connection = DriverManager.getConnection(url,nxdbuser,nxdbpw);
             Statement statement = connection.createStatement()) {
             String sqlStr = "SELECT TOP (300) * FROM JUV1841 WHERE 下发日期 > '"+maxTime+"'";

business-common/src/main/java/com/rongwei/bscommon/sys/utils/SqlServerJdbcUtils.java

@@ -4,6 +4,8 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.io.unit.DataUnit;
 import com.rongwei.bsentity.dto.sqlServer.ZhcxPmqManagementSource;
 import lombok.extern.slf4j.Slf4j;
+
+import java.security.Security;
 import java.sql.*;
 import java.util.ArrayList;
 import java.util.List;
@@ -22,6 +24,7 @@ public class SqlServerJdbcUtils {
     private static final String PASSWORD = "Irongwei@1";
 
     public static List<ZhcxPmqManagementSource> queryZHCXPMQMANAGEMENTSOURCEData() {
+        Security.setProperty("jdk.tls.client.protocols", "TLSv1.2,TLSv1.1,TLSv1");
         List<ZhcxPmqManagementSource> data = new ArrayList<>();
         try (Connection connection = DriverManager.getConnection(URL, USERNAME, PASSWORD);
              Statement statement = connection.createStatement()) {
@@ -53,8 +56,43 @@ public class SqlServerJdbcUtils {
         return data;
     }
 
+    public static List<ZhcxPmqManagementSource> queryZHCXPMQMANAGEMENTSOURCEDataPRO() {
+        Security.setProperty("jdk.tls.client.protocols", "TLSv1.2,TLSv1.1,TLSv1");
+        List<ZhcxPmqManagementSource> data = new ArrayList<>();
+        String url = "jdbc:sqlserver://10.28.52.32:1433;;databaseName=nxcellsnew";
+        String username = "qm";
+        String password = "cxqm_sugar1029";
+        try (Connection connection = DriverManager.getConnection(url, username, password);
+             Statement statement = connection.createStatement()) {
+            // 查询语句
+            String sql = "SELECT TOP (300) * FROM [nxcellsnew].[dbo].[JUV1841] order by 下发日期 desc";
+            try (ResultSet resultSet = statement.executeQuery(sql)) {
+                int columnCount = resultSet.getMetaData().getColumnCount();
+                while (resultSet.next()) {
+                    ZhcxPmqManagementSource entity = new ZhcxPmqManagementSource();
+                    entity.setOrdertype(resultSet.getString(1));
+                    entity.setOrderno(resultSet.getString(2));
+                    entity.setProjectno(resultSet.getString(3));
+                    entity.setProjectname(resultSet.getString(4));
+                    entity.setThemepoint(resultSet.getString(5));
+                    entity.setSeqno(resultSet.getInt(6));
+                    entity.setCurrenttimes(resultSet.getInt(7));
+                    entity.setTotaltimes(resultSet.getInt(8));
+                    entity.setDistributetime(DateUtil.parse(resultSet.getString(9),"yyyy-MM-dd HH:mm:ss"));
+                    entity.setDeptname(resultSet.getString(10));
+                    entity.setQcname(resultSet.getString(11));
+                    data.add(entity);
+                }
+            }
+        } catch (SQLException e) {
+            log.info("读取数据错误");
+            e.printStackTrace();
+        }
+        return data;
+    }
+
     public static void main(String[] args) {
-        List<ZhcxPmqManagementSource> zhcxPmqManagementSources = queryZHCXPMQMANAGEMENTSOURCEData();
+        List<ZhcxPmqManagementSource> zhcxPmqManagementSources = queryZHCXPMQMANAGEMENTSOURCEDataPRO();
         for (ZhcxPmqManagementSource zhcxPmqManagementSource : zhcxPmqManagementSources) {
             System.out.println(zhcxPmqManagementSource);
         }