SQLServer多版本兼容Java方案和数据采集

Maven引入

<dependency><groupId>com.microsoft.sqlserver</groupId><artifactId>sqljdbc4</artifactId><version>4.0</version></dependency><dependency><groupId>net.sourceforge.jtds</groupId><artifactId>jtds</artifactId><version>1.3.1</version></dependency>

连接创建

// 数据库URL，用户名和密码String connectionUrl = "jdbc:jtds:sqlserver://"+dataSource.getIp()+":"+dataSource.getPort()+";databaseName="+dataSource.getDatabaseName()+";user="+dataSource.getUserName()+";password="+dataSource.getPassword()+";";try {Class.forName("net.sourceforge.jtds.jdbc.Driver");} catch (ClassNotFoundException e) {throw new RuntimeException("当前不支持的SQLServer驱动版本");}

查询样例（SQLServer通用数据采集）

表内容查询

public List<List<JSONObject>> importData(DataSourceImportDataVO dataSourceImportDataVO) {List<List<JSONObject>> rtn = new ArrayList<>();// 创建SQLServer连接TbDataSource dataSource = dataSourceImportDataVO.getDataSource();Long dataCollectJobId = dataSourceImportDataVO.getDataCollect().getId();if (!DataSourceLinkTypeEnum.SQLSERVER.getTypeCode().equals(dataSource.getLinkType())){// 配置的连接不是SQLServer类型collectStatusMQService.send(dataCollectJobId, CollectJobRunStatusTypeEnum.CONNECT_FAILED);collectRecordMQService.send(dataSourceImportDataVO, CollectJobRunStatusTypeEnum.CONNECT_FAILED, "", "");throw new CustomException("数据源不是 SQLServer 连接");}SQLServerDataDealBaseService dataDealBaseService =(SQLServerDataDealBaseService) dataSourceImportDataVO.getDataDealBaseService();// 开始时间Date date = new Date();// 文件类型和文件名称枚举值// 数据库连接URL，格式为：jdbc:sqlserver://服务器地址:端口号;databaseName=数据库名String connectionUrl = "jdbc:jtds:sqlserver://"+dataSource.getIp()+":"+dataSource.getPort()+";databaseName="+dataSource.getDatabaseName();try {Class.forName("net.sourceforge.jtds.jdbc.Driver");} catch (ClassNotFoundException e) {// 数据源连接失败：可能发身在数据源连接创建过程中，或后续数据查询过程中，都算做连接失败collectStatusMQService.send(dataCollectJobId, CollectJobRunStatusTypeEnum.CONNECT_FAILED);collectRecordMQService.send(dataSourceImportDataVO, CollectJobRunStatusTypeEnum.CONNECT_FAILED, "", "");return new ArrayList<>();}// 数据库用户和密码String user = dataSource.getUserName();String password = dataSource.getPassword();List<JSONObject> datas = new ArrayList<>();try (Connection con = DriverManager.getConnection(connectionUrl, user, password);Statement stmt = con.createStatement()) {SQLServerDealVO sqlServerDealVO = new SQLServerDealVO();sqlServerDealVO.setConnection(con);sqlServerDealVO.setStatement(stmt);sqlServerDealVO.setTableName(dataSourceImportDataVO.getDataCollect().getFileType());sqlServerDealVO.setDataSourceImportData(dataSourceImportDataVO);sqlServerDealVO.setDataCollectJobId(dataCollectJobId);// 预置连接成功，后边查询数据过程中可能还会出现连接失败的情况，通过SQLException捕捉collectStatusMQService.send(dataCollectJobId, CollectJobRunStatusTypeEnum.CONNECT_SUCCESS);datas = dataDealBaseService.fromSQLServer(sqlServerDealVO);rtn.add(datas);} catch (SQLException e) {// 发送作业MQ状态log.error("【SQLServer 连接创建失败】 ", e);// 数据源连接失败：可能发身在数据源连接创建过程中，或后续数据查询过程中，都算做连接失败collectStatusMQService.send(dataCollectJobId, CollectJobRunStatusTypeEnum.CONNECT_FAILED);collectRecordMQService.send(dataSourceImportDataVO, CollectJobRunStatusTypeEnum.CONNECT_FAILED, "", "");return new ArrayList<>();}catch (DataParsingException e){// 发送作业MQ状态log.error("【SQLServer 数据解析失败】 ", e);collectRecordMQService.send(dataSourceImportDataVO, CollectJobRunStatusTypeEnum.PARSE_FAILED, JSON.toJSONString(datas), "采集数据源中的表 "+dataSourceImportDataVO.getDataCollect().getFileType()+" 或该表同步字段 "+dataSourceImportDataVO.getDataCollect().getSynchronousField()+" 不存在");return new ArrayList<>();}log.info("【数据接入】【SQLServer】处理完成 耗时 {} 秒 ", (new DateBetween(date, new Date())).between(DateUnit.SECOND));return rtn;}

表名称获取

public List<String> getDataSourceTables(TbDataSource dataSource) {// 数据库URL，用户名和密码String connectionUrl = "jdbc:jtds:sqlserver://"+dataSource.getIp()+":"+dataSource.getPort()+";databaseName="+dataSource.getDatabaseName()+";user="+dataSource.getUserName()+";password="+dataSource.getPassword()+";";List<String> tables = new ArrayList<>();try {Class.forName("net.sourceforge.jtds.jdbc.Driver");} catch (ClassNotFoundException e) {throw new RuntimeException("当前不支持的SQLServer驱动版本");}try (Connection connection = DriverManager.getConnection(connectionUrl)) {// 创建Statement对象来执行查询Statement statement = connection.createStatement();// 执行查询获取所有表名ResultSet resultSet = statement.executeQuery("SELECT TABLE_NAME FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_TYPE = 'BASE TABLE'");// 遍历结果集while (resultSet.next()) {tables.add(resultSet.getString("TABLE_NAME"));}} catch (SQLException e) {e.printStackTrace();}return tables;}

字段名称获取

/**
* SQLServer 2005后版本判断
*/
private final String pattern = "对象名\\s+'.*?'\\s+无效";public List<GetSourceColumnOutputDTO> getSourceColumns(TbDataSource dataSource, String tableName) {// 数据库URL，用户名和密码String connectionUrl = "jdbc:jtds:sqlserver://" + dataSource.getIp() + ":" + dataSource.getPort() + ";databaseName="+ dataSource.getDatabaseName() + ";user=" + dataSource.getUserName() + ";password=" + dataSource.getPassword() + ";";List<GetSourceColumnOutputDTO> colums = new ArrayList<>();try {Class.forName("net.sourceforge.jtds.jdbc.Driver");} catch (ClassNotFoundException e) {throw new RuntimeException("当前不支持的SQLServer驱动版本");}try (Connection connection = DriverManager.getConnection(connectionUrl)) {
//            // 获取DatabaseMetaData对象
//            DatabaseMetaData metaData = connection.getMetaData();
//
//            // 查询表的列名
//            ResultSet resultSet = metaData.getColumns(null, null, tableName, "%");// 创建Statement对象来执行查询Statement statement = connection.createStatement();String sql = "SELECT \n" +"     CONVERT(NVARCHAR(100), c.name) AS ColumnName,\n" +"    CONVERT(NVARCHAR(100),ep.value) AS ColumnComment\n" +"FROM \n" +"    sys.columns c\n" +"INNER JOIN \n" +"    sys.objects o ON c.object_id = o.object_id\n" +"LEFT OUTER JOIN \n" +"    sys.extended_properties ep ON ep.major_id = c.object_id \n" +"                                AND ep.minor_id = c.column_id \n" +"                                AND ep.name = 'MS_Description'\n" +"WHERE \n" +String.format("    o.name = '%s' \n", tableName) +"ORDER BY \n" +"    c.column_id;";// 执行查询获取所有表名ResultSet resultSet = null;try {resultSet = statement.executeQuery(sql);} catch (SQLException e) {// sys.extended_properties等 是 SQL Server 2005 引入的系统视图，用于存储扩展属性信息。SQL Server 2000 及更早版本中没有这个视图。if (e.getMessage().matches(".*" + pattern + ".*")){sql = "SELECT \n" +"        CONVERT(NVARCHAR(100), sc.name) AS ColumnName,\n" +"        CONVERT(NVARCHAR(100), sp.value) AS ColumnComment\n" +"    FROM \n" +"        syscolumns sc\n" +"    INNER JOIN \n" +"        sysobjects so ON sc.id = so.id\n" +"    LEFT OUTER JOIN \n" +"        sysproperties sp ON sp.id = sc.id \n" +"                          AND sp.smallid = sc.colid \n" +"                          AND sp.name = 'MS_Description'\n" +"    WHERE \n" +String.format("    so.name = '%s' \n", tableName) +"    ORDER BY \n" +"        sc.colid";resultSet = statement.executeQuery(sql);}}if (Objects.isNull(resultSet)) {return colums;}// 遍历结果集int sort = 1;while (resultSet.next()) {GetSourceColumnOutputDTO tmp = new GetSourceColumnOutputDTO();String columnName = resultSet.getString("ColumnName");String columnComment = resultSet.getString("ColumnComment");tmp.setName(StringUtils.isEmpty(columnComment) ? columnName : columnComment);tmp.setCode(columnName);tmp.setOriginCode(columnName);tmp.setSort(sort++);colums.add(tmp);}} catch (SQLException e) {e.printStackTrace();}return colums;}

public class GetSourceColumnOutputDTO implements Serializable {private static final long serialVersionUID = 1L;@ApiModelProperty(value = "字段中文名")private String name;@ApiModelProperty(value = "源字段编码")private String code;@ApiModelProperty(value = "源字段原始编码")private String originCode;@ApiModelProperty(value = "源字段协议中的排序")private Integer sort;}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/diannao/81151.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

【每日八股】复习 Redis Day4：线程模型

【每日八股】复习 Redis Day4：线程模型

文章目录 复习 Redis Day4&#xff1a;线程模型介绍一下 Redis 的线程模型核心线程模型&#xff08;Redis 6.0 之前&#xff09;Redis 6.0 的多线程改进Redis 真的是单线程吗&#xff1f;Redis 的线程模型剖析 上一篇 Redis 的应用我今天才完成&#xff0c;因此明天一并复习 Re…
阅读更多...
树莓派智能摄像头实战指南：基于TensorFlow Lite的端到端AI部署

树莓派智能摄像头实战指南：基于TensorFlow Lite的端到端AI部署

引言&#xff1a;嵌入式AI的革新力量 在物联网与人工智能深度融合的今天&#xff0c;树莓派这一信用卡大小的计算机正在成为边缘计算的核心载体。本文将手把手教你打造一款基于TensorFlow Lite的低功耗智能监控设备&#xff0c;通过MobileNetV2模型实现实时物体检测&#xff0…
阅读更多...
vs2019编译occ7.9.0时，出现fatal error C1060: compiler is out of heap space

vs2019编译occ7.9.0时，出现fatal error C1060: compiler is out of heap space

问题描述 visual studio 2019编译opencascade 7.9.0时&#xff0c;出现编译错误 fatal error C1060: compiler is out of heap space 解决方案 修改vs2019并行编译的线程个数&#xff0c;默认是12个&#xff0c;我改成了4个&#xff0c;问题解决 Tools > Project and Sol…
阅读更多...
vue跨域问题总结笔记

vue跨域问题总结笔记

目录 一、Websocket跨域问题 1.nginx配置 2.VUE CLI代理 3.env.development配置 4.nginx日志 5.解决 一、解决跨域的几种常用方法 1.Vue CLI代理 2.JSONP 3.WebSocket 4.NGINX解决跨域问题 6.Java解决跨域 二、Vue跨域问题详解 1. 什么是跨域 2. 跨域的例子 3.…
阅读更多...
数据结构篇：线性表的另一表达—链表之单链表(下篇)

数据结构篇：线性表的另一表达—链表之单链表(下篇)

目录 1.前言 2.是否使用二级指针 3.插入/删除 3.1 pos位置前/后插入 3.2 查找函数 3.3 pos位置删除 3.4 pos位置后面删除 3.5 函数的销毁 4.断言问题 4.1 断言pphead 4.2 断言*pphead 5.三个文件的代码 5.1 头文件 5.2 具体函数实现 5.3 测试用例 1.前言 之前是讲…
阅读更多...
完美解决react-native文件直传阿里云oss问题一

完美解决react-native文件直传阿里云oss问题一

前言 通常情况下&#xff0c;作为前后端分离的项目来说&#xff0c;文件上传是最寻常的功能之一。虽然每个公司选择的文件管理云库各不相同&#xff0c;但实现思路基本一致。我所在公司使用阿里云oss文件管理&#xff0c;之前服务端做了透传&#xff0c;但是由于每个测试环境的…
阅读更多...
5.运输层

5.运输层

5. 运输层 1. 概述 第2~4章依次介绍了计算机网络体系结构中的物理层、数据链路层和网络层&#xff0c;它们共同解决了将主机通过异构网络互联起来所面临的问题&#xff0c;实现了主机到主机的通信然而在计算机网络中实际进行通信的真正实体&#xff0c;是位于通信两端主机中的…
阅读更多...
告别手动时代！物联网软件开发让万物自动互联

告别手动时代！物联网软件开发让万物自动互联

清晨&#xff0c;智能窗帘随着阳光自动拉开&#xff1b;运动时&#xff0c;手表精准记录着健康数据&#xff1b;回到家&#xff0c;室温早已调节至最舒适状态...这些场景的实现&#xff0c;都离不开物联网软件开发的技术支撑。在智能家居软件开发、智能穿戴软件开发、医疗器械软…
阅读更多...
Fiori学习专题十二：Shell Control as Container

Fiori学习专题十二：Shell Control as Container

为了让我们的app更加适应不同的设备&#xff0c;这节课我们引入shell控件作为根元素 1.修改App.view.xml&#xff0c;加入Shell控件 <mvc:ViewcontrollerName"ui5.walkthrough.controller.App"xmlns"sap.m"xmlns:mvc"sap.ui.core.mvc"displa…
阅读更多...
AI 与高性能计算的深度融合：开启科技新纪元

AI 与高性能计算的深度融合：开启科技新纪元

在当今科技迅猛发展的时代&#xff0c;人工智能&#xff08;AI&#xff09;与高性能计算&#xff08;HPC&#xff09;正以前所未有的态势深度融合&#xff0c;这种融合宛如一场强大的风暴&#xff0c;席卷并重塑着众多领域的格局。从科学研究的突破到商业应用的革新&#xff0c…
阅读更多...
「Unity3D」TextMeshPro使用TMP_InputField实现，输入框高度自动扩展与收缩

「Unity3D」TextMeshPro使用TMP_InputField实现，输入框高度自动扩展与收缩

先看实现效果&#xff1a; 要实现这个效果&#xff0c;有三个方面的问题需要解决&#xff1a; 第一&#xff0c;输入框的高度扩展&#xff0c;内部子元素会随着锚点&#xff0c;拉伸变形——要解决这个问题&#xff0c;需要将内部元素改变父类&#xff0c;然后增加父类高度&am…
阅读更多...
多模态大语言模型arxiv论文略读（四十七）

多模态大语言模型arxiv论文略读（四十七）

AdaShield: Safeguarding Multimodal Large Language Models from Structure-based Attack via Adaptive Shield Prompting ➡️ 论文标题&#xff1a;AdaShield: Safeguarding Multimodal Large Language Models from Structure-based Attack via Adaptive Shield Prompting …
阅读更多...
美的人形机器人即将投入实际应用

美的人形机器人即将投入实际应用

国内家电巨头美的集团近日公布了其自主研发的人形机器人的具体落地计划。根据公司披露的信息&#xff0c;这款机器人将于5月在湖北荆州的洗衣机工厂率先投入使用&#xff0c;承担设备运维、质量检测和物料搬运等工作任务。预计今年下半年&#xff0c;该机器人还将进入美的线下门…
阅读更多...
从零开始搭建你的个人博客：使用 GitHub Pages 免费部署静态网站

从零开始搭建你的个人博客：使用 GitHub Pages 免费部署静态网站

&#x1f310; 从零开始搭建你的个人博客&#xff1a;使用 GitHub Pages 免费部署静态网站 在互联网时代&#xff0c;拥有一个属于自己的网站不仅是一种展示方式&#xff0c;更是一种技术能力的体现。今天我们将一步步学习如何通过 GitHub Pages 搭建一个免费的个人博客或简历…
阅读更多...
canvas动画：点随机运动 距离内自动连接成线 鼠标移动自动吸附附近的点

canvas动画：点随机运动 距离内自动连接成线 鼠标移动自动吸附附近的点

思路/实现步骤 创建canvas元素 获取canvas的上下文ctx 初始化点的信息&#xff08;数量、初始坐标、移动方向、移动速度、大小、颜色&#xff09; 绘制点 绘制点之间的连线 点有规律的动起来 动画循环 鼠标移动相关逻辑 点鼠标之间连线 鼠标吸附逻辑 添加配置项 重绘…
阅读更多...
2025年4月AI科技领域周报（4.21-4.27）：大模型生态加速演进 通用AI开启产业融合新范式

2025年4月AI科技领域周报（4.21-4.27）：大模型生态加速演进 通用AI开启产业融合新范式

2025年4月AI科技领域周报&#xff08;4.21-4.27&#xff09;&#xff1a;大模型生态加速演进 通用AI开启产业融合新范式 一、本周热点回顾1. OpenAI发布全球首款通用AI芯片「GPT-NPU」 重塑AI算力架构2. 谷歌DeepMind发布医疗AI系统「Med-Pathfinder」 实现全科室智能诊断3. 微…
阅读更多...
【Bash】可以请您解释性地说明一下“2＞1”这个语法吗？

【Bash】可以请您解释性地说明一下“2＞1”这个语法吗？

Qwen3-235B 当然可以&#xff01;我们一步步拆解 2>&1 的含义&#xff0c;用生活化的例子来理解它&#xff1a; &#x1f9e0; 前提知识&#xff1a;三个“水流通道” 在 Linux/Unix 系统中&#xff0c;程序运行时有三种默认的“水流通道”&#xff1a; 标准输入&…
阅读更多...
MAC如何安装多版本jdk(以8,11,17为例）

MAC如何安装多版本jdk(以8,11,17为例）

MAC如何安装多版本jdk(以8,11,17为例&#xff09;_mac安装jdk17-CSDN博客
阅读更多...
Nginx核心

Nginx核心

一、概述 Nginx一个具有高性能的【HTTP】和【反向代理】的【WEB服务器】&#xff0c;同时也是一个电子邮件代理服务器。正向代理服务的是客户端&#xff08;比如VPN&#xff09;&#xff0c;反向代理服务的是服务端。Nginx是多进程的&#xff0c;有一个Master进程控制多个Worke…
阅读更多...
综合开发-手机APP远程控制PLC1500柱灯的亮灭

综合开发-手机APP远程控制PLC1500柱灯的亮灭

要通过 ​​Unity3D​​ 开发的手机 App 控制 ​​电气柜上面的柱灯&#xff0c;需要WIFI模块作为桥梁&#xff0c;按照以下步骤实现&#xff1a; ​​1. 硬件准备&#xff08;硬件部分&#xff09;​​ ​​所需材料​​ ​​ESP32开发板​​&#xff08;如ESP32-WROOM-32&a…
阅读更多...
最新文章

Copyright @ 2022~2023