From 4535c171ba37a9d578701b302faf74bdf43fc1b0 Mon Sep 17 00:00:00 2001 From: Wang XinLong <2142993385@qq.com> Date: Sat, 11 May 2024 18:11:25 +0800 Subject: [PATCH] =?UTF-8?q?feat:=E5=B0=81=E8=A3=85jdbc=E5=85=AC=E5=85=B1?= =?UTF-8?q?=E6=8A=BD=E8=B1=A1=E7=B1=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- muyu-auth/src/main/resources/bootstrap.yml | 1 + muyu-gateway/src/main/resources/bootstrap.yml | 1 + .../src/main/resources/bootstrap.yml | 5 +--- .../src/main/resources/bootstrap.yml | 1 + .../muyu-gen/src/main/resources/bootstrap.yml | 1 + .../muyu-job/src/main/resources/bootstrap.yml | 1 + .../src/main/resources/bootstrap.yml | 1 + .../client/config/SourceClientRunner.java | 12 +++++++++ .../client/jdbcUtils/JDBCAbstractClass.java | 17 +++++++++++++ .../client/jdbcUtils/JDBCConcreteClass.java | 25 +++++++++++++++++++ .../source/dataSource/DataSourceConfig.java | 2 +- .../src/main/resources/bootstrap.yml | 1 + .../src/main/resources/bootstrap.yml | 1 + .../src/main/resources/bootstrap.yml | 1 + 14 files changed, 65 insertions(+), 5 deletions(-) create mode 100644 muyu-modules/muyu-source/muyu-source-client/src/main/java/com/muyu/source/client/jdbcUtils/JDBCAbstractClass.java create mode 100644 muyu-modules/muyu-source/muyu-source-client/src/main/java/com/muyu/source/client/jdbcUtils/JDBCConcreteClass.java diff --git a/muyu-auth/src/main/resources/bootstrap.yml b/muyu-auth/src/main/resources/bootstrap.yml index a7fc5a3..49a72ff 100644 --- a/muyu-auth/src/main/resources/bootstrap.yml +++ b/muyu-auth/src/main/resources/bootstrap.yml @@ -15,6 +15,7 @@ spring: discovery: # 服务注册地址 server-addr: 111.229.37.54:8848 + namespace: a7ca2016-3e34-485e-95ea-e0ea98d6c647 config: # 配置中心地址 server-addr: 111.229.37.54:8848 diff --git a/muyu-gateway/src/main/resources/bootstrap.yml b/muyu-gateway/src/main/resources/bootstrap.yml index 2cdf880..a8af86a 100644 --- a/muyu-gateway/src/main/resources/bootstrap.yml +++ b/muyu-gateway/src/main/resources/bootstrap.yml @@ -15,6 +15,7 @@ spring: discovery: # 服务注册地址 server-addr: 111.229.37.54:8848 + namespace: a7ca2016-3e34-485e-95ea-e0ea98d6c647 config: # 配置中心地址 server-addr: 111.229.37.54:8848 diff --git a/muyu-modules/muyu-data-test/src/main/resources/bootstrap.yml b/muyu-modules/muyu-data-test/src/main/resources/bootstrap.yml index fa3a4cb..54ee6b6 100644 --- a/muyu-modules/muyu-data-test/src/main/resources/bootstrap.yml +++ b/muyu-modules/muyu-data-test/src/main/resources/bootstrap.yml @@ -4,10 +4,6 @@ server: # Spring spring: - redis: - host: 111.229.37.54 - port: 6379 - password: application: # 应用名称 name: muyu-data-test @@ -19,6 +15,7 @@ spring: discovery: # 服务注册地址 server-addr: 111.229.37.54:8848 + namespace: a7ca2016-3e34-485e-95ea-e0ea98d6c647 config: # 配置中心地址 server-addr: 111.229.37.54:8848 diff --git a/muyu-modules/muyu-file/src/main/resources/bootstrap.yml b/muyu-modules/muyu-file/src/main/resources/bootstrap.yml index 37586f2..0558d55 100644 --- a/muyu-modules/muyu-file/src/main/resources/bootstrap.yml +++ b/muyu-modules/muyu-file/src/main/resources/bootstrap.yml @@ -15,6 +15,7 @@ spring: discovery: # 服务注册地址 server-addr: 111.229.37.54:8848 + namespace: a7ca2016-3e34-485e-95ea-e0ea98d6c647 config: # 配置中心地址 server-addr: 111.229.37.54:8848 diff --git a/muyu-modules/muyu-gen/src/main/resources/bootstrap.yml b/muyu-modules/muyu-gen/src/main/resources/bootstrap.yml index 02fc5c7..23f6f1c 100644 --- a/muyu-modules/muyu-gen/src/main/resources/bootstrap.yml +++ b/muyu-modules/muyu-gen/src/main/resources/bootstrap.yml @@ -15,6 +15,7 @@ spring: discovery: # 服务注册地址 server-addr: 111.229.37.54:8848 + namespace: a7ca2016-3e34-485e-95ea-e0ea98d6c647 config: # 配置中心地址 server-addr: 111.229.37.54:8848 diff --git a/muyu-modules/muyu-job/src/main/resources/bootstrap.yml b/muyu-modules/muyu-job/src/main/resources/bootstrap.yml index a73aa5c..5c8d82a 100644 --- a/muyu-modules/muyu-job/src/main/resources/bootstrap.yml +++ b/muyu-modules/muyu-job/src/main/resources/bootstrap.yml @@ -15,6 +15,7 @@ spring: discovery: # 服务注册地址 server-addr: 111.229.37.54:8848 + namespace: a7ca2016-3e34-485e-95ea-e0ea98d6c647 config: # 配置中心地址 server-addr: 111.229.37.54:8848 diff --git a/muyu-modules/muyu-rule-engine/muyu-rule-engine-server/src/main/resources/bootstrap.yml b/muyu-modules/muyu-rule-engine/muyu-rule-engine-server/src/main/resources/bootstrap.yml index 621f0bc..3870f7e 100644 --- a/muyu-modules/muyu-rule-engine/muyu-rule-engine-server/src/main/resources/bootstrap.yml +++ b/muyu-modules/muyu-rule-engine/muyu-rule-engine-server/src/main/resources/bootstrap.yml @@ -15,6 +15,7 @@ spring: discovery: # 服务注册地址 server-addr: 111.229.37.54:8848 + namespace: a7ca2016-3e34-485e-95ea-e0ea98d6c647 config: # 配置中心地址 server-addr: 111.229.37.54:8848 diff --git a/muyu-modules/muyu-source/muyu-source-client/src/main/java/com/muyu/source/client/config/SourceClientRunner.java b/muyu-modules/muyu-source/muyu-source-client/src/main/java/com/muyu/source/client/config/SourceClientRunner.java index 96dcc75..1de1a1a 100644 --- a/muyu-modules/muyu-source/muyu-source-client/src/main/java/com/muyu/source/client/config/SourceClientRunner.java +++ b/muyu-modules/muyu-source/muyu-source-client/src/main/java/com/muyu/source/client/config/SourceClientRunner.java @@ -1,6 +1,8 @@ package com.muyu.source.client.config; import com.muyu.common.core.domain.Result; +import com.muyu.source.client.jdbcUtils.JDBCAbstractClass; +import com.muyu.source.client.jdbcUtils.JDBCConcreteClass; import com.muyu.source.dataSource.DataSourceConfig; import com.muyu.source.domain.DataSource; import com.muyu.source.domain.DataType; @@ -13,6 +15,8 @@ import org.springframework.boot.ApplicationRunner; import org.springframework.context.annotation.Configuration; import java.sql.Connection; +import java.sql.ResultSet; +import java.sql.ResultSetMetaData; import java.util.List; /** @@ -50,6 +54,14 @@ public class SourceClientRunner implements ApplicationRunner { Connection connection = DataSourceConfig.getConnection(key); DataSourceConfig.size(key); Thread.sleep(500); + JDBCConcreteClass jdbcConcreteClass = new JDBCConcreteClass(); + ResultSet resultSet = jdbcConcreteClass.getResultSet(connection, "select * from engine_maintenance"); + ResultSetMetaData rsd = resultSet.getMetaData(); + for (int i = 1; i <= rsd.getColumnCount(); i++) { + log.info("字段名称:{}", rsd.getColumnName(i)); + log.info("数据库类型:{}",rsd.getColumnTypeName(i)); + log.info("java类型:{}",rsd.getColumnClassName(i)); + } System.out.println("返回一个链接,查看连接池:"); DataSourceConfig.returnConn(connection); diff --git a/muyu-modules/muyu-source/muyu-source-client/src/main/java/com/muyu/source/client/jdbcUtils/JDBCAbstractClass.java b/muyu-modules/muyu-source/muyu-source-client/src/main/java/com/muyu/source/client/jdbcUtils/JDBCAbstractClass.java new file mode 100644 index 0000000..9fdbce6 --- /dev/null +++ b/muyu-modules/muyu-source/muyu-source-client/src/main/java/com/muyu/source/client/jdbcUtils/JDBCAbstractClass.java @@ -0,0 +1,17 @@ +package com.muyu.source.client.jdbcUtils; + +import org.springframework.stereotype.Component; + +import java.sql.Connection; +import java.sql.ResultSet; + +/** + * jdbc抽象类 + * + * @author CHX + * on 2024/5/11 星期六 + */ +@Component +public abstract class JDBCAbstractClass { + public abstract ResultSet getResultSet(Connection connection, String sql); +} diff --git a/muyu-modules/muyu-source/muyu-source-client/src/main/java/com/muyu/source/client/jdbcUtils/JDBCConcreteClass.java b/muyu-modules/muyu-source/muyu-source-client/src/main/java/com/muyu/source/client/jdbcUtils/JDBCConcreteClass.java new file mode 100644 index 0000000..d98e33b --- /dev/null +++ b/muyu-modules/muyu-source/muyu-source-client/src/main/java/com/muyu/source/client/jdbcUtils/JDBCConcreteClass.java @@ -0,0 +1,25 @@ +package com.muyu.source.client.jdbcUtils; + +import java.sql.*; + +/** + * jdbc实体类 + * + * @author CHX + * on 2024/5/11 星期六 + */ +public class JDBCConcreteClass extends JDBCAbstractClass { + + @Override + public ResultSet getResultSet(Connection connection, String sql) { + PreparedStatement ps = null; + try { + ps = connection.prepareStatement(sql); + ResultSet resultSet = ps.executeQuery(); + return resultSet; + } catch (SQLException e) { + throw new RuntimeException(e); + } + } + +} diff --git a/muyu-modules/muyu-source/muyu-source-common/src/main/java/com/muyu/source/dataSource/DataSourceConfig.java b/muyu-modules/muyu-source/muyu-source-common/src/main/java/com/muyu/source/dataSource/DataSourceConfig.java index 213836a..216003e 100644 --- a/muyu-modules/muyu-source/muyu-source-common/src/main/java/com/muyu/source/dataSource/DataSourceConfig.java +++ b/muyu-modules/muyu-source/muyu-source-common/src/main/java/com/muyu/source/dataSource/DataSourceConfig.java @@ -19,8 +19,8 @@ import java.util.HashMap; * on 2024/5/10 星期五 */ -@Component @Log4j2 +@Component public class DataSourceConfig { private static HashMap dataSourceMap = new HashMap(); diff --git a/muyu-modules/muyu-source/muyu-source-server/src/main/resources/bootstrap.yml b/muyu-modules/muyu-source/muyu-source-server/src/main/resources/bootstrap.yml index 75d5c84..a6c3fb2 100644 --- a/muyu-modules/muyu-source/muyu-source-server/src/main/resources/bootstrap.yml +++ b/muyu-modules/muyu-source/muyu-source-server/src/main/resources/bootstrap.yml @@ -15,6 +15,7 @@ spring: discovery: # 服务注册地址 server-addr: 111.229.37.54:8848 + namespace: a7ca2016-3e34-485e-95ea-e0ea98d6c647 config: # 配置中心地址 server-addr: 111.229.37.54:8848 diff --git a/muyu-modules/muyu-system/src/main/resources/bootstrap.yml b/muyu-modules/muyu-system/src/main/resources/bootstrap.yml index 66c97af..1e593ca 100644 --- a/muyu-modules/muyu-system/src/main/resources/bootstrap.yml +++ b/muyu-modules/muyu-system/src/main/resources/bootstrap.yml @@ -15,6 +15,7 @@ spring: discovery: # 服务注册地址 server-addr: 111.229.37.54:8848 + namespace: a7ca2016-3e34-485e-95ea-e0ea98d6c647 config: # 配置中心地址 server-addr: 111.229.37.54:8848 diff --git a/muyu-visual/muyu-monitor/src/main/resources/bootstrap.yml b/muyu-visual/muyu-monitor/src/main/resources/bootstrap.yml index 9e80431..464295e 100644 --- a/muyu-visual/muyu-monitor/src/main/resources/bootstrap.yml +++ b/muyu-visual/muyu-monitor/src/main/resources/bootstrap.yml @@ -15,6 +15,7 @@ spring: discovery: # 服务注册地址 server-addr: 111.229.37.54:8848 + namespace: a7ca2016-3e34-485e-95ea-e0ea98d6c647 config: # 配置中心地址 server-addr: 111.229.37.54:8848