如何从页面输入SQL查询条件得到后台结果返回前台页面

拼搏现实的明天。 2021-12-14 14:11 407阅读 0赞

转自： [https://blog.csdn.net/yucongyuqian/article/details/77451578][https_blog.csdn.net_yucongyuqian_article_details_77451578]

使用Jsp编写网页并实现数据库的增删改查: [https://blog.csdn.net/qq\_32539825/article/details/70657340][https_blog.csdn.net_qq_32539825_article_details_70657340]

JSP SQL语句大全: [https://blog.csdn.net/fengyee\_zju/article/details/25118683][https_blog.csdn.net_fengyee_zju_article_details_25118683]

开发一个用来执行sql的jsp页面: [https://blog.csdn.net/qq\_34928194/article/details/83412187][https_blog.csdn.net_qq_34928194_article_details_83412187]

网页上直接sql查询操作数据库,并在网页上展示列表数据的工具页面: [https://blog.csdn.net/yule117737767/article/details/83039509][https_blog.csdn.net_yule117737767_article_details_83039509]

版权声明：本文为博主原创文章，未经博主允许不得转载。 https://blog.csdn.net/yucongyuqian/article/details/77451578  
一、页面：因为查询的表不固定，所以表格需要自助生成（这是利用了“jqGrid”）   
注意：难点一、因为从数据库查询的表不同，所有前台页面遍历时的表头格式不固定   
难点二、数据库连接源   
若是不利用“jqGrid”也可以参考方法2.   
方法1.

//加载的主表（对表格进行遍历  
            $(document).ready(function () \{  
               // var applicationId = $('\#applicationId option:selected').val();  
                $("\#jqGrid").jqGrid(\{  
                    url:"/management/transactionFlow/informationQuery",  
                    mtype: "POST",  
                    datatype: "json",  
                    postData: \{  
                        'sql': function () \{  
                            return $('\#sql').val().trim();\}  
                        \},  
                    styleUI: 'Bootstrap',  
                    colModel: \[  
                        <c:forEach items="$\{list3\}" var="user" varStatus="status">  
                        \{label: '$\{user\}', name: '$\{user\}', autowidth: true, sortable: false\},  
                        </c:forEach>  
                    \],  
                    viewrecords: true,  
                    height: 400,  
                    shrinkToFit: false,  
                    rowNum: 10,  
                    autowidth: true,  
                    pager: "\#jqGridPager",  
                    page: 1  
                \}).trigger("reloadGrid");  
                return false;  
                var len = $("\#jqGrid").getGridParam("width");  
//                $("\#jqGrid").setGridParam().hideCol("id");  
                $("\#jqGrid").setGridWidth(len);  
            \});  
            //点击重置按钮  
            $("\#back").click(function () \{  
                $("\#sql").empty();  
            \});  
        </script>  
    </content>  
</div>  
</body>  
  
方法2.动态生成表格，但是分页还需自己在写一下

参考网址：https://q.cnblogs.com/q/73869/

二、controller   
1）查询表头

@RequestMapping(value = "transactionFlow/informationQuery1", method = RequestMethod.POST)

public String informationQuery1(@ModelAttribute("form") @RequestParam (value = "sql") String sql, Model model) \{  
        List<String> list3 = new LinkedList<>();  
        String query1 = customerLedgersService.query(sql);  
        Map map = new HashMap();  
        if (query1 != null) \{

String\[\] key = query1.split(";");  
            for (int i = 0, len = key.length; i < len; i++) \{  
                list3.add(key\[i\]);  
            \}

model.addAttribute("sql", sql);  
            model.addAttribute("list3", list3);  
            return "/complement/informationQuery";  
        \} else \{  
            model.addAttribute("sql", sql);

return "/complement/informationQuery";  
        \}

\}  
  
2）查询分页信息

@RequestMapping(value = "transactionFlow/informationQuery", method = RequestMethod.POST)  
    @ResponseBody  
    public GridData informationQuery(@RequestParam(value = "sql", required = false) String sql,  
                                     @RequestParam(value = "page", required = false) Integer page,  
                                     @RequestParam(value = "rows", required = false) Integer rows  
    ) \{  
        List list7 = new LinkedList<>();  
        String queryValue = null;

String records1 = customerLedgersService.query1(sql);  
        int records = Integer.parseInt(records1);  
        GridData result = new GridData();

String listTotal = customerLedgersService.query2(sql, page, rows);  
        String query2 = null;  
        List<String> list6 = new ArrayList<>();  
        List<String> list5 = new ArrayList();  
        if (listTotal != null) \{  
            String\[\] keyq3 = listTotal.split("%");  
            for (int i = 0, len = keyq3.length; i < len; i++) \{  
                list6.add(keyq3\[i\]);  
            \}  
            for (int m = 0; m < list6.size(); m++) \{  
                queryValue = list6.get(m);  
                String\[\] value = queryValue.split(";");  
                List<String> list = Arrays.asList(value);  
                ListIterator<String> li = list.listIterator();  
                while (li.hasNext()) \{  
                    Object obj = li.next();  
                    if (obj.equals("0E-8")) \{  
                        li.set("0.00000000");  
                    \}  
                    if (obj.equals("null")) \{  
                        li.set("");  
                    \}  
                \}  
                list7.add(list);

\}  
        \}  
        long totaPage = records % rows == 0 ? records / rows : records / rows + 1;  
        result.setPage(page);  
        result.setRecords(records);  
        result.setTotal((int) totaPage);  
        if (list7 != null) \{  
            result.getRows().addAll(list7);  
        \}  
        return result;  
    \}  
  
三、dao层（利用了JDBC原理）   
需要考虑的是数据库连接问题

@Repository  
public class QueryDaoImpl implements QueryDao \{  
    private static Logger logger = LoggerFactory.getLogger(QueryDaoImpl.class);

@Override  
    public String selectSql(String sql) \{  
        DataSource ds = null;  
        Connection conn = null;  
        PreparedStatement pstmt = null;  
        ResultSet rs = null;  
        StringBuffer sb = new StringBuffer();  
        int index = 1;  
        //1 获得连接  
        try \{

if(sql == null)\{  
                return null;  
            \}

InitialContext initialContext = new InitialContext();  
            ds = (DataSource) initialContext.lookup("jdbc/account-structure");  
            if (ds != null) \{  
                conn = ds.getConnection();  
            \}  
            if(!sql.contains(";"))\{  
                sql=sql+";";  
            \}  
            if(!sql.contains("limit") && !sql.contains("LIMIT"))\{  
                if(sql.contains(";"))\{  
                    sql = sql.replaceAll(";", "");  
                \}  
                sql = sql + " limit 0, 1;";  
            \}  
            pstmt = conn.prepareStatement(sql);  
            rs = pstmt.executeQuery();  
            List<LinkedHashMap<String, Object>> values = new ArrayList<>();  
            ResultSetMetaData rsmd = rs.getMetaData();  
            LinkedHashMap<String, Object> map = null;  
            while (rs.next()) \{  
                //把一条记录放入Map中  
                map = new LinkedHashMap<String, Object>();  
                for (int i = 0; i < rsmd.getColumnCount(); i++) \{  
                    String columnLabel = rsmd.getColumnLabel(i + 1);  
                    Object value = rs.getObject(i + 1);  
                    map.put(columnLabel, value);  
                \}  
                values.add(map);  
            \}

if (values.size() > 0) \{  
                for (Map<String, Object> m : values) \{  
                    Set<String> set = m.keySet();  
                    for (String s : set) \{  
                        sb.append(s + ";");  
                    \}  
                \}

\}  
            return sb.toString();

\} catch (Exception e) \{  
            e.printStackTrace();  
        \} finally \{  
            //6关闭资源  
//            JDBCUtils.close(conn, pstmt, rs);  
            try \{  
                conn.close();  
            \} catch (SQLException e) \{  
                e.printStackTrace();  
                try \{  
                    pstmt.close();  
                \} catch (SQLException e1) \{  
                    e1.printStackTrace();  
                \}  
                try \{  
                    rs.close();  
                \} catch (SQLException e1) \{  
                    e1.printStackTrace();  
                \}  
            \}  
        \}  
        return null;  
    \}

@Override  
    public String selectSql1(String sql) \{  
        DataSource ds = null;  
        Connection conn = null;  
        PreparedStatement pstmt = null;  
        ResultSet rs = null;  
        StringBuffer sb = new StringBuffer();  
        int index = 0;  
        //1 获得连接  
        try \{

if(sql == null)\{  
                return null;  
            \}

InitialContext initialContext = new InitialContext();  
            ds = (DataSource) initialContext.lookup("jdbc/account-structure");  
            if (ds != null) \{  
                conn = ds.getConnection();  
            \}  
            if(!sql.contains(";"))\{  
                sql=sql+";";  
            \}  
            if(!sql.contains("limit") && !sql.contains("LIMIT"))\{  
                if(sql.contains(";"))\{  
                    sql = sql.replaceAll(";", "");  
                \}  
                sql = sql + "  limit 0, 5000;";  
            \}  
            pstmt = conn.prepareStatement(sql);  
            rs = pstmt.executeQuery();  
            List<LinkedHashMap<String, Object>> values = new ArrayList<>();  
            ResultSetMetaData rsmd = rs.getMetaData();  
            LinkedHashMap<String, Object> map = null;  
            while (rs.next()) \{  
                //把一条记录放入Map中  
                map = new LinkedHashMap<String, Object>();  
                for (int i = 0; i < rsmd.getColumnCount(); i++) \{  
                    String columnLabel = rsmd.getColumnLabel(i + 1);  
                    Object value = rs.getObject(i + 1);  
                    map.put(columnLabel, value);  
                \}  
                values.add(map);  
            \}

if (values.size() > 0) \{  
                for (Map<String, Object> m : values) \{  
                    Set<String> set = m.keySet();  
                    for (String s : set) \{  
                        sb.append(s + ";");  
                    \}  
                    sb.append("|"+index++);  
                \}

return String.valueOf(index);

@Override  
    public String selectSq2(String sql, Integer page, Integer rows) \{  
        DataSource ds = null;  
        Connection conn = null;  
        PreparedStatement pstmt = null;  
        ResultSet rs = null;  
        StringBuffer sb = new StringBuffer();  
        StringBuffer sb1 = new StringBuffer();  
        int index = 1;  
        //1 获得连接  
        try \{

sql2=sb1.append(sql1+" "+"limit"+" "+"?"+","+"?;");  
            pstmt = conn.prepareStatement(sql2.toString());  
            int startIndex = (page - 1) \* rows;  
            pstmt.setInt(1,startIndex);  
            pstmt.setInt(2,rows);  
            rs = pstmt.executeQuery();  
            List<LinkedHashMap<String, Object>> values = new ArrayList<>();  
            ResultSetMetaData rsmd = rs.getMetaData();  
            LinkedHashMap<String, Object> map = null;  
            while (rs.next()) \{  
                //把一条记录放入Map中  
                map = new LinkedHashMap<String, Object>();  
                for (int i = 0; i < rsmd.getColumnCount(); i++) \{  
                    String columnLabel = rsmd.getColumnLabel(i + 1);  
                    Object value = rs.getObject(i + 1);  
                    map.put(columnLabel, value);  
                \}  
                values.add(map);  
            \}

if (values.size() > 0) \{  
                for (Map<String, Object> m : values) \{  
                    Set<String> set = m.keySet();

for (String s : set) \{  
                        sb.append(m.get(s) + ";");  
                    \}  
                    sb.append("%");  
                \}  
            \}  
            return sb.toString();

\} catch (Exception e) \{  
            e.printStackTrace();  
        \} finally \{

try \{  
                conn.close();  
            \} catch (SQLException e) \{  
                e.printStackTrace();  
                try \{  
                    pstmt.close();  
                \} catch (SQLException e1) \{  
                    e1.printStackTrace();  
                \}  
                try \{  
                    rs.close();  
                \} catch (SQLException e1) \{  
                    e1.printStackTrace();  
                \}  
            \}  
        \}  
        return null;  
    \}  
\}  
  
查询页面：

输入SQL语句：SELECT \* from ledgers\_entity where customer\_business\_id=’180050602775019520’;   
查询结果：

\---------------------   
作者：yucongyuqian   
来源：CSDN   
原文：https://blog.csdn.net/yucongyuqian/article/details/77451578   
版权声明：本文为博主原创文章，转载请附上博文链接！

[https_blog.csdn.net_yucongyuqian_article_details_77451578]: https://blog.csdn.net/yucongyuqian/article/details/77451578
[https_blog.csdn.net_qq_32539825_article_details_70657340]: https://blog.csdn.net/qq_32539825/article/details/70657340
[https_blog.csdn.net_fengyee_zju_article_details_25118683]: https://blog.csdn.net/fengyee_zju/article/details/25118683
[https_blog.csdn.net_qq_34928194_article_details_83412187]: https://blog.csdn.net/qq_34928194/article/details/83412187
[https_blog.csdn.net_yule117737767_article_details_83039509]: https://blog.csdn.net/yule117737767/article/details/83039509