feat:封装jdbc公共抽象类
parent
17e87d7dad
commit
4535c171ba
|
|
@ -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
|
||||
|
|
|
|||
|
|
@ -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
|
||||
|
|
|
|||
|
|
@ -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
|
||||
|
|
|
|||
|
|
@ -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
|
||||
|
|
|
|||
|
|
@ -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
|
||||
|
|
|
|||
|
|
@ -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
|
||||
|
|
|
|||
|
|
@ -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
|
||||
|
|
|
|||
|
|
@ -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);
|
||||
|
|
|
|||
|
|
@ -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);
|
||||
}
|
||||
|
|
@ -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);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
|
@ -19,8 +19,8 @@ import java.util.HashMap;
|
|||
* on 2024/5/10 星期五
|
||||
*/
|
||||
|
||||
@Component
|
||||
@Log4j2
|
||||
@Component
|
||||
public class DataSourceConfig {
|
||||
|
||||
private static HashMap<Long, DruidDataSource> dataSourceMap = new HashMap();
|
||||
|
|
|
|||
|
|
@ -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
|
||||
|
|
|
|||
|
|
@ -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
|
||||
|
|
|
|||
|
|
@ -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
|
||||
|
|
|
|||
Loading…
Reference in New Issue