java.sql.sql,SQL编程

　　00-1010难度分析项目回顾(在线SQL查询编写)最终效果演示技术选择：需求分析项目构建介绍项目所需的相关Maven依赖项编写配置文件创建控制器前端控制器在JDBC探索ResultSet中的方法获取所有数据源实现查询执行逻辑Vue前端介绍摩纳哥。-编辑器组件写SQL语句项目总结前言：因为前段时间项目负责人布置的任务是完成一个在线SQL编写和查询功能的需求。最后，有必要将查询的数据以JSON格式显示在响应数据区域，以便操作员进行检查。刚开始你得到需求的时候，以为直接用Mybatis操作就可以了，没必要大费周章。因为MyBatis中有一个拼接sql的语法，可以使用${sql}来执行输入的SQL语句，但是实际操作并没有想象中那么简单，因为使用MyBatis会固定本项目所用数据库中的数据源，但是不能在数据源之间切换，也不能查询其他数据源中的表，所以实现过程相当困难和曲折。

　　00-1010在线SQL查询的主要难点：一是对JDBC API的理解不够透彻，导致部分工具的实现不如预期的顺利；其次，如何用Java实现查询部分属性的SQL语句，是对输入字符串进行分割拼接还是直接使用整个语句的查询操作；第三，用户可以动态切换数据源，查询相应数据源下的表格。如果用Mybatis查询SQL，数据源不能切换，只能查询连接到微服务项目的数据库。否则无法进行相应的操作，即该数据库下不存在被查询数据库表的错误信息。

目录

难度分析

　　00-1010 Springbootmybatis-Plusjdbvue代码编辑器monaco-editor

　　10月10-1010日，用户可以在页面上选择切换要操作的数据源，在编辑区输入SQL语句进行查询。查询语句可以是整个表中的所有字段，也可以根据需要查询指定某些列字段的对应值。点击查询后，他们可以将每个查询到的数据封装成JSON格式，最终显示在响应数据区供操作人员观看，从而达到可视化工具的效果。

项目回顾（在线编写SQL查询）

最终效果演示

!-spring boot dependency-dependency groupIdorg.springframework.boot/groupId artifactId spring-boot-starter-web/artifactId/dependency dependency groupId commons-lang/groupId artifactId commons-lang/artifactId version 2.6/version/dependency！-servlet-API Dependency-Dependency groupIdjavax.servlet/groupId artifactid servlet-API/artifactid version 2.5/version Scope Provided/Scope/Dependency！- MySQL驱动程序依赖关系-依赖关系groupid MySQL/groupid artifactid MySQL-con

　　nector-java</artifactId> <version>8.0.28</version></dependency>

② 编写配置文件

server: port: 8080spring: datasource: username: root password: root driver-class-name: com.mysql.cj.jdbc.Driver url: jdbc:mysql://localhost:3306/data_source?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai

③ 创建Controller前端控制器

@PostMapping("/dynamic-query")@ApiOperation(value = "动态执行SQL")public Result<?> dynamicQuery(@RequestBody DynamicQuery dynamicQuery){List<HashMap<Object,Object>> res = null;BladeVisualDb visualDb = bladeVisualDbService.getOne(new QueryWrapper<BladeVisualDb>().eq("id", dynamicQuery.getId()));List<HashMap<String,Object>> result = ConnectBySql.connAndExecSql(visualDb.getUrl(), visualDb.getDriverClass(), visualDb.getUsername(), visualDb.getPassword(),dynamicQuery.getSql());return Result.ok(result);}

④ 探究 JDBC中ResultSet中的方法

next()

　　解释： 将光标从其当前位置向前移动一行。 ResultSet 游标最初位于第一行之前；第一次调用 next 方法使第一行成为当前行；第二次调用使第二行成为当前行，依此类推。实则对查询到的数据进行遍历操作

　　getString(String columnLabel)

　　解释： 根据表中对应的列名称来查询到该列对应到的数据

　　getMetaData()

　　解释： 获取某张表中列的数量、类型和列名称

　　findColumn(String columnLabel)

　　解释： 返回某个列的索引值即下标

⑤ 获取所有的数据源

因为使用者是可以动态的选择数据源从而来对表中的数据进行相关操作，所以首先要查询出可供连接的数据源

 /** * 下拉数据源列表 * @return */@ApiOperation(value = "下拉列表")@GetMapping("/db-list")public Result<?> list(){List<BladeVisualDb> bladeVisualDbs = bladeVisualDbService.list();return Result.ok(bladeVisualDbs);}

⑥ 实现执行查询逻辑

首先执行查询有两种方式：所有字段的全查询即select * from xx 或者 查询指定字段即select xx from xx

　　所有字段的全查询即select * from xx

　　在进行所有字段的查询时，由于无法得知需要查询的表中有什么字段，所以首先需要对输入的SQL字符串进行判断是否是全字段查询，然后即可获取查询表中的所有字段，然后再一一的进行查询出字段对应的值即可，此操作也是需要对输入SQL字符串进行分割的，拿出所有插叙的表名即可。

ResultSet resultSet = stmt.executeQuery(sql);//如果输入的SQL属于select * 操作if (sql.contains("*")){ List<String> list = new ArrayList<>(); //获取SQL中需要查询的表的结构 ResultSetMetaData metaData = resultSet.getMetaData(); int columnCount = metaData.getColumnCount(); for (int i = 1; i <= columnCount; i++) { log.info("属性列 ======>{}",metaData.getColumnName(i)); //获取表中的所有列 list.add(metaData.getColumnName(i)); } while (resultSet.next()){ HashMap<String,Object> hashMap = new HashMap<>(); for (String index : list) { //根据列名称查询出该列对应的数据 String rs = resultSet.getString(index); //将其放入列和值存放HashMap中 hashMap.put(index,rs); //将多个HashMap合并成一个Map hashMap.putAll(hashMap); } res.add(hashMap); }}

查询指定字段即select xx from xx

　　在使用JDBC进行指定字段查询时需要对输入的SQL字符串进行分割后将所需要查询到的字段再使用JDBC中的getString(String columnName)进行查询字段对应的值

 /** * 将SQL语句进行拆分 * @param sql * @return */ @NotNull private static List<String> getString(String sql) { List<String> list = new ArrayList<>(); String str = sql.substring(0, sql.indexOf("from")); String realSql = str.replace("select", "").trim(); if (realSql.contains(",")){ String[] split = realSql.split(","); for (String s : split) { list.add(s); } }else { list.add(realSql); } return list; }

随后将分割完成的SQL存放到List集合中再进行查询操作

ResultSet resultSet = stmt.executeQuery(sql);while (resultSet.next()){ HashMap<String,Object> hashMap = new HashMap<>(); List<String> str = getString(sql); for (String index : str) { String rs = resultSet.getString(index); hashMap.put(index,rs); hashMap.putAll(hashMap); } res.add(hashMap);}

经过对操作者输入的SQL即可完成对表的查询操作，由于所要实现的是可动态切换数据源从而进行相关的查询操作，所以在此操作逻辑中首先需要连接数据库，后再对输入的SQL进行分割查询等操作。合并后的完整代码：

 /** * 连接数据库并根据输入的SQL语句查询数据 * @param url * @param driverClass * @param username * @param password * @param sql * @return */ public static List<HashMap<String,Object>> connAndExecSql(String url, String driverClass, String username, String password, String sql) { Boolean result = false; Connection conn = null; Statement stmt = null; List<HashMap<String,Object>> res = new ArrayList<>(); try { Class.forName(driverClass); System.out.println("------------连接数据库-----------"); conn = DriverManager.getConnection(url,username,password); stmt = conn.createStatement(); ResultSet resultSet = stmt.executeQuery(sql); //如果输入的SQL属于select * 操作 if (sql.contains("*")){ List<String> list = new ArrayList<>(); //获取SQL中需要查询的表的结构 ResultSetMetaData metaData = resultSet.getMetaData(); int columnCount = metaData.getColumnCount(); for (int i = 1; i <= columnCount; i++) { log.info("属性列 ======>{}",metaData.getColumnName(i)); //获取表中的所有列 list.add(metaData.getColumnName(i)); } while (resultSet.next()){ HashMap<String,Object> hashMap = new HashMap<>(); for (String index : list) { //根据列名称查询出该列对应的数据 String rs = resultSet.getString(index); //将其放入列和值存放HashMap中 hashMap.put(index,rs); //将多个HashMap合并成一个Map hashMap.putAll(hashMap); } res.add(hashMap); } }else { while (resultSet.next()){ HashMap<String,Object> hashMap = new HashMap<>(); List<String> str = getString(sql); for (String index : str) { String rs = resultSet.getString(index); hashMap.put(index,rs); hashMap.putAll(hashMap); } res.add(hashMap); } } //完成连接数据库 stmt.close(); conn.close(); System.out.println("查询连接结束"); } catch (ClassNotFoundException e) { e.printStackTrace(); }catch (SQLException e){ e.printStackTrace(); } return res; } /** * 将SQL语句进行拆分 * @param sql * @return */ @NotNull private static List<String> getString(String sql) { List<String> list = new ArrayList<>(); String str = sql.substring(0, sql.indexOf("from")); String realSql = str.replace("select", "").trim(); if (realSql.contains(",")){ String[] split = realSql.split(","); for (String s : split) { list.add(s); } }else { list.add(realSql); } return list; }

⑦ Vue前端引入monaco-editor组件进行编写SQL语句

郑重声明：本文由网友发布，不代表盛行IT的观点，版权归原作者所有，仅为传播更多信息之目的，如有侵权请联系，我们将第一时间修改或删除，多谢。