sqlserver拉取数据工具类

business-common/pom.xml

@@ -98,5 +98,11 @@
             <groupId>org.springframework</groupId>
             <artifactId>spring-test</artifactId>
         </dependency>
+        <!-- sqlserver的jdbc驱动-->
+        <dependency>
+            <groupId>com.microsoft.sqlserver</groupId>
+            <artifactId>mssql-jdbc</artifactId>
+            <version>8.2.2.jre8</version>
+        </dependency>
     </dependencies>
 </project>

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

@@ -0,0 +1,62 @@
+package com.rongwei.bscommon.sys.utils;
+
+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.sql.*;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * sqlserver拉取数据
+ */
+@Slf4j
+public class SqlServerJdbcUtils {
+
+    // SQL Server连接URL
+    private static final String URL = "jdbc:sqlserver://192.168.0.204:1433;;databaseName=cctest";
+    // 用户名
+    private static final String USERNAME = "sa";
+    // 密码
+    private static final String PASSWORD = "Irongwei@1";
+
+    public static List<ZhcxPmqManagementSource> queryZHCXPMQMANAGEMENTSOURCEData() {
+        List<ZhcxPmqManagementSource> data = new ArrayList<>();
+        try (Connection connection = DriverManager.getConnection(URL, USERNAME, PASSWORD);
+             Statement statement = connection.createStatement()) {
+            // 查询语句
+            String sql = "SELECT * FROM [dbo].[ZHCX_PMQ_MANAGEMENT_SOURCE]";
+            try (ResultSet resultSet = statement.executeQuery(sql)) {
+                int columnCount = resultSet.getMetaData().getColumnCount();
+                while (resultSet.next()) {
+                    ZhcxPmqManagementSource entity = new ZhcxPmqManagementSource();
+                    entity.setId(resultSet.getString(1));
+                    entity.setOrdertype(resultSet.getString(2));
+                    entity.setOrderno(resultSet.getString(3));
+                    entity.setProjectno(resultSet.getString(4));
+                    entity.setProjectname(resultSet.getString(5));
+                    entity.setThemepoint(resultSet.getString(6));
+                    entity.setSeqno(resultSet.getInt(7));
+                    entity.setCurrenttimes(resultSet.getInt(8));
+                    entity.setTotaltimes(resultSet.getInt(9));
+                    entity.setDistributetime(DateUtil.parse(resultSet.getString(10),"yyyy-MM-dd HH:mm:ss"));
+                    entity.setDeptname(resultSet.getString(11));
+                    entity.setQcname(resultSet.getString(12));
+                    data.add(entity);
+                }
+            }
+        } catch (SQLException e) {
+            log.info("读取数据错误");
+            e.printStackTrace();
+        }
+        return data;
+    }
+
+    public static void main(String[] args) {
+        List<ZhcxPmqManagementSource> zhcxPmqManagementSources = queryZHCXPMQMANAGEMENTSOURCEData();
+        for (ZhcxPmqManagementSource zhcxPmqManagementSource : zhcxPmqManagementSources) {
+            System.out.println(zhcxPmqManagementSource);
+        }
+    }
+}

business-entity/src/main/java/com/rongwei/bsentity/dto/sqlServer/ZhcxPmqManagementSource.java

@@ -0,0 +1,49 @@
+package com.rongwei.bsentity.dto.sqlServer;
+
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.util.Date;
+
+/**
+ * sqlserver表ZHCX_PMQ_MANAGEMENT_SOURCE
+ */
+@Data
+public class ZhcxPmqManagementSource {
+
+    // 主键
+    private String id;
+
+    // 单据类别
+    private String ordertype;
+
+    // 单据编号
+    private String orderno;
+
+    // 项目工号
+    private String projectno;
+
+    // 项目名称
+    private String projectname;
+
+    // 主题
+    private String themepoint;
+
+    // 流水号
+    private Integer seqno;
+
+    // 当前次数
+    private Integer currenttimes;
+
+    // 总下发次数
+    private Integer totaltimes;
+
+    // 下发日期
+    private Date distributetime;
+
+    // 部门名称
+    private String deptname;
+
+    // 对应质检
+    private String qcname;
+}