zoukankan      html  css  js  c++  java
  • DriverManager 查询数据库拼接BUFFER

            Connection conn = null;
            Statement stmt = null;
            ResultSet rs = null;
            try{
                Class.forName("com.mysql.jdbc.Driver");
                 String dbNmae = "logall"+params.get("dbName");
                 String dbIp = ConfigUtil.pro.get("linkLogIp").toString();
                 String linkCloudSql = "jdbc:mysql://"+dbIp+"/"+dbNmae;
                 String linkCloudUsername =ConfigUtil.pro.get("linkLogIpUsername").toString();
                 String linkCloudPassword =ConfigUtil.pro.get("linkLogIpPassword").toString();
                 
                 
                 conn = DriverManager
                         .getConnection(
                                 linkCloudSql,linkCloudUsername, linkCloudPassword);
                 stmt = conn.createStatement();
                 PreparedStatement ps=null;
                 
                 StringBuffer buffer = new StringBuffer("SELECT `id`,`idc`,`flag`,`cmdStartTime`,`json`,`cmdEndTime`,`retValue`,`crmId`,CASE WHEN `fName` = '' OR `fName` IS NULL THEN `idsid` ELSE `fName` END `fName`,`insertTime`,TIMESTAMPDIFF(FRAC_SECOND,cmdstarttime,cmdendtime )  AS duration FROM  log_controlresult  WHERE idc = ? and flag in ('BlueToothControl','carControlNew')");
                 if(params.get("ret") != null && StringUtils.isNoneEmpty(params.get("ret").toString())){
                     buffer.append("and retValue=?");
                 }
                 buffer.append(" order by crmid desc");
                 buffer.append(" LIMIT "+params.get("startIndex")+","+params.get("pageSize"));
                 
                 
                 
                 ps=(PreparedStatement) conn.prepareStatement(buffer.toString());
                  ps.setString(1, params.get("idc").toString());
    
                  
                  if(params.get("ret") != null && StringUtils.isNoneEmpty(params.get("ret").toString())){
                     ps.setString(2, params.get("ret").toString());
                 }
                 
                 log.info("控制历史sql:"+buffer.toString());
                  rs = ps.executeQuery();
                 while(rs.next())
                 {
                     controlresult cresult = new controlresult();
                     cresult.setId(rs.getLong("id"));
                     cresult.setIdc(rs.getString("idc"));
                     cresult.setFlag(rs.getString("flag"));
                     cresult.setCmdStartTime(rs.getTimestamp("cmdStartTime"));
                     cresult.setJson(rs.getString("json"));
                     cresult.setCmdEndTime(rs.getTimestamp("cmdEndTime"));
                     cresult.setRetValue(rs.getString("retValue"));
                     cresult.setCrmId(rs.getLong("crmId"));
                     cresult.setfName(rs.getString("fName"));
                     cresult.setInsertTime(rs.getTimestamp("insertTime"));
                     cresult.setDuration(rs.getInt("duration"));
                     cresult.setCmdName(GetSendTypeNameByJson(cresult.getJson()));
                     resultList.add(cresult);
                 }
            }
  • 相关阅读:
    uniapp 画圆形或多边形雷达图
    uniApp开发之公用配置文件common.js
    FastAdmin 表格排序
    fastadmin SelectPage field显示多个字段
    PHP装饰器模式
    PHP原型模式,(理解:创建并初始化对象,再复制一个对象避免重复初始化)
    PHP设计模式-观察者模式
    为什么 echo 3 . print(2) . print(4) . 5 . 'c'的结果是45c2131
    PHP数组式访问接口ArrayAccess用法分析
    浏览器兼容性问题总结
  • 原文地址:https://www.cnblogs.com/cuijinlong/p/7244845.html
Copyright © 2011-2022 走看看