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);
                 }
            }
  • 相关阅读:
    sqlserver 执行脚本报内存溢出的处理方式
    框架重构:测试中的DateTime.Now
    框架重构:规范集成测试的结构和命名规则
    框架重构:记录创建人、最后修改人、创建时间、最后修改时间
    从VS2010跳跃到VS2017
    ASP.NET网站发布时的那些坑
    使用pjax时点击浏览器刷新按钮仅加载内容页的解决办法
    让ASP.NET第一次请求不变慢
    正确设置Firefox下载文件文件名的方法
    通过反编译让SpecFlow支持多层属性值的验证
  • 原文地址:https://www.cnblogs.com/cuijinlong/p/7244845.html
Copyright © 2011-2022 走看看