Java+RestltData获取数据库、数据库表、表字段、执行sql等数据源操作

• 1、数据源公共类封装
• 2、连接数据源
• 3、获取数据列表
• 4、获取指定数据库中的表
• 5、获取指定表中字段信息
• 6、执行SQL语句
• 7、源码下载

该类用于进行数据源的连接操作，作为一个公共类
GetDataSourceService ：

public class GetDataSourceService {
    public static DataSource getSource() {
        // 实际开发中，可以从数据库中获取数据源的配置项
        DataSource dataSource = new DataSource();
        dataSource.setId("123");
        dataSource.setName("测试");
        dataSource.setDatabaseName("template");
        dataSource.setDatabaseType(DatabaseTypeConstant.MYSQL);
        dataSource.setAddress("127.0.0.1");
        dataSource.setPort("3307");
        dataSource.setUsername("root");
        dataSource.setPassword("lhzlx");

        return dataSource;
    }
}

JdbcSourcePoolServer：

public class JdbcSourcePoolServer {

    
    private static ConcurrentHashMap connPol = new ConcurrentHashMap<>();

    
    public static Connection getConnection(String sourceId) {
        //创建连接池
        Connection conn = null;
        HikariDataSource ds = null;
        try {
            sourceId = sourceId == null ? "" : sourceId;
            //查询当前数据源是否存在连接
            if (connPol.get(sourceId) != null) {
                conn = connPol.get(sourceId).getConnection();
            } else {
                //基本参数4个
                DataSource source = GetDataSourceService.getSource();
                //获取DruidDataSource配置
                ds = JDBCUtil.getDruidSource(source);
                //获取连接
                conn = ds.getConnection();
                //将数据源连接池存入Map中
                connPol.put(source.getId(), ds);
            }
            if (conn == null) {
                throw new Exception();
            }
            return conn;
        } catch (Exception e) {
            JDBCUtil.closeDataSource(ds);
            e.printStackTrace();
            return null;
        }
    }

    
    public static SqlResult searchSql(String sourceId, String sql, int limit) {
        //默认预览条数
        sql = sql + " limit " + limit;

        //存放字段名称
        List cellHeader = null;
        //存放字段类型
        Map colType = null;
        //存放字段值集合
        List