Java+RestltData获取数据库、数据库表、表字段、执行sql等数据源操作源码资源-CSDN文库

共12个文件

java：10个

sql：1个

xml：1个

需积分: 2 114 浏览量 2021-12-11 21:42:37 上传评论收藏 13KB RAR 举报

在IT行业中，数据库操作是日常开发中的重要环节，特别是在Java应用程序中。`RestltData`可能是一个自定义的工具类或者框架，用于处理与数据库相关的交互。本篇将围绕Java结合`RestltData`获取数据库、数据库表、表字段以及执行SQL等数据源操作的相关知识点进行深入探讨。 `RestltData`这个名字可能是"Result Data"的缩写，它可能是一个用来封装查询结果的对象，用于处理从数据库获取的数据。在Java中，我们通常会使用JDBC（Java Database Connectivity）API来连接和操作数据库。JDBC提供了一组接口和类，使得开发者能够编写与特定数据库无关的代码，实现数据库的增删查改操作。 1. **数据库连接**：使用Java的`java.sql.DriverManager`类注册数据库驱动并建立连接。例如： ```java Class.forName("com.mysql.jdbc.Driver"); // 注册MySQL驱动 Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/testDB", "username", "password"); ``` 2. **创建Statement或PreparedStatement**：`java.sql.Statement`用于执行SQL语句，而`java.sql.PreparedStatement`可以预编译SQL，提高性能，防止SQL注入。例如： ```java Statement stmt = conn.createStatement(); PreparedStatement pstmt = conn.prepareStatement("SELECT * FROM table WHERE id = ?"); ``` 3. **执行SQL**：通过`executeQuery()`执行查询，返回`ResultSet`对象；通过`executeUpdate()`执行增删改操作，返回受影响的行数。 ```java ResultSet rs = stmt.executeQuery("SELECT * FROM table"); int rowsAffected = pstmt.executeUpdate(); ``` 4. **处理ResultSet**：`ResultSet`包含了查询结果，可以通过迭代遍历每一行数据。`RestltData`可能就是用来封装`ResultSet`数据的类，便于进一步处理和返回。 ```java while (rs.next()) { int id = rs.getInt("id"); String name = rs.getString("name"); // ... } ``` 5. **数据库元数据**：`Connection`对象提供了获取数据库元数据的方法，如获取所有表名、列信息等。 ```java DatabaseMetaData dbmd = conn.getMetaData(); ResultSet tables = dbmd.getTables(null, null, "%", new String[]{"TABLE"}); while (tables.next()) { String tableName = tables.getString("TABLE_NAME"); // ... } ``` 6. **关闭资源**：操作完成后，记得关闭`ResultSet`、`Statement`和`Connection`以释放资源。 ```java try (ResultSet rs = stmt.executeQuery()) { // 处理结果集 } finally { if (stmt != null) stmt.close(); if (conn != null) conn.close(); } ``` 7. **使用框架简化操作**：在实际项目中，我们通常会使用ORM（Object-Relational Mapping）框架如Hibernate或MyBatis，它们能极大简化数据库操作，减少JDBC的繁琐工作。在提供的压缩包文件"demo"中，可能包含了一个使用`RestltData`进行数据库操作的示例程序。通过分析这个示例，我们可以更具体地了解`RestltData`的工作原理和使用方式。如果你想要深入理解这个工具类，可以查看其源代码，研究它的方法和内部实现，从而更好地应用于实际项目中。

资源详情

资源评论

资源推荐

收起资源包目录

demo.rar （12个子文件）

demo

pom.xml 3KB

src

test

java

main

resources

java

GetDataSourceService.java 744B

pojo

DataSource.java 3KB

PageParam.java 724B

SqlResult.java 1KB

TableInfoVo.java 1KB

JdbcSourcePoolServer.java 6KB

utils

NewPageBean.java 3KB

JDBCUtil.java 7KB

DataBaseTypeConstant.java 254B

Main.java 5KB

sql

template.sql 8KB

package utils; import com.alibaba.fastjson.JSONObject; import com.microsoft.sqlserver.jdbc.StringUtils; import com.zaxxer.hikari.HikariDataSource; import pojo.DataSource; import pojo.PageParam; import java.sql.*; import java.util.HashMap; import java.util.Map; /** * @Author: LiHuaZhi * @Date: 2020/2/19 14:03 * @Description: **/ public class JDBCUtil { private static Boolean checkValue(Object value) { if (value != null) { return !"null".equals(value); } return false; } /** * 取出对应字段的value值 * * @param rs * @param index * @return * @throws SQLException */ public static Object getValue(ResultSet rs, int index) throws SQLException { Object obj = rs.getObject(index); if (JDBCUtil.checkValue(obj)) { //对特使字段类型进行处理 if (obj instanceof Blob) { Blob blob = (Blob) obj; obj = blob.getBytes(1L, (int) blob.length()); } else if (obj instanceof Clob) { Clob clob = (Clob) obj; obj = clob.getSubString(1L, (int) clob.length()); } } return obj; } /** * 创建数据库连接/对数据源连接进行测试。 * * @param source * @return */ public static Connection testConnection(DataSource source) { Connection conn = null; HikariDataSource ds = null; //拼接请求参数 spliceParams(source); //获取DruidDataSource配置 ds = JDBCUtil.getDruidSource(source); try { //获取连接 conn = ds.getConnection(); } catch (Exception e) { e.printStackTrace(); } finally { closeConnection(conn); closeDataSource(ds); } return conn; } public static void closeConnection(Connection connection) { if (connection != null) { try { System.out.println("关闭数据库连接"); connection.close(); } catch (SQLException e) { e.printStackTrace(); } } } public static void closeDataSource(HikariDataSource ds) { if (ds != null) { try { System.out.println("关闭连接池"); ds.close(); } catch (Exception e) { e.printStackTrace(); } } } /** * 设置当前连接url * * @param source */ public static void spliceParams(DataSource source) { //后面开发参数考虑从数据库中读取 String mysqlPrefix = "jdbc:mysql://"; String oraclePrefix = "jdbc:oracle:thin:@"; String sqlServerPrefix = "jdbc:sqlserver://"; //驱动列表 String mysqlDriver = "com.mysql.cj.jdbc.Driver"; String oracleDriver = "oracle.jdbc.driver.OracleDriver"; String sqlServerDriver = "com.microsoft.sqlserver.jdbc.SQLServerDriver"; //开始拼接 String sourceType = source.getDatabaseType(); //获取数据库前缀 String prefix = null; switch (sourceType) { case DataBaseTypeConstant.MYSQL: prefix = mysqlPrefix; break; case DataBaseTypeConstant.ORACLE: prefix = oraclePrefix; break; case DataBaseTypeConstant.SQL_SERVER: prefix = sqlServerPrefix; break; default: prefix = ""; break; } //数据库后缀名称拼接格式 String sourceName = source.getDatabaseName(); String database = null; switch (sourceType) { case DataBaseTypeConstant.MYSQL: case DataBaseTypeConstant.ORACLE: database = "/" + sourceName; break; case DataBaseTypeConstant.SQL_SERVER: database = ";DatabaseName=" + sourceName; break; default: database = ""; break; } //拼接自定义参数 //解析参数json Map map = new HashMap(); if (!StringUtils.isEmpty(source.getParameter())) { map = JSONObject.parseObject(source.getParameter(), Map.class); } String param = ""; if (sourceType.equals(DataBaseTypeConstant.MYSQL)) { //mysql默认传如下参数 param = "?useUnicode=true&useSSL=false&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai"; //遍历map获取其他参数 } //其他数据库的参数格式后续加入 String url = prefix + source.getAddress() + ":" + source.getPort() + database + param; //驱动 String driver = sourceType.equals(DataBaseTypeConstant.MYSQL) ? mysqlDriver : sourceType.equals(DataBaseTypeConstant.ORACLE) ? oracleDriver : sqlServerDriver; source.setUrl(url); source.setDriver(driver); } public static HikariDataSource getDruidSource(DataSource source) { HikariDataSource ds = new HikariDataSource(); //拼接请求参数 spliceParams(source); ds.setDriverClassName(source.getDriver()); ds.setJdbcUrl(source.getUrl()); ds.setUsername(source.getUsername()); ds.setPassword(source.getPassword()); // 最大连接数，小于等于0会被重置为默认值10 ds.setMaximumPoolSize(50); //最小空闲连接，默认值10 ds.setMinimumIdle(5); //连接最大存活时间，不等于0且小于30秒，会被重置为默认值30分钟.设置应该比mysql设置的超时时间短 ds.setMaxLifetime(540000); //空闲连接超时时间，不等于0且小于10秒，会被重置为10秒。 ds.setIdleTimeout(500000); return ds; } public static String countSql(String sql) { // 获取数据总量，此处按mysql的来进行封装 return "select count(*)" + sql.substring(sql.lastIndexOf("from")); } /** * 设置sql分页参数，此处暂时只考虑了mysq的情况 * * @return */ public static String startPage(String sql, Integer pageNum, Integer pageSize) { int index = pageNum == 1 ? 0 : (pageNum - 1) * pageSize; return sql + " limit " + index + "," + pageSize; } }