|
数据库连接 和 增删改
QueryBean.java
package weblistbean; import java.sql.*; import java.io.*; public class QueryBean { //public String query_statement; /*定义sql语句*/ public String param[]; /*查询条件*/ public ResultSet result=null; /*查询结果*/ public Connection conn; //设置构造函数 ///数据库连接 public QueryBean() throws Exception{ this.setConnection("com.microsoft.jdbc.sqlserver.SQLServerDriver","jdbc:microsoft:sqlserver://10.0.0.21:1433;DatabaseName=lngprs;SelectMethod=Cursor","sa","sa"); System.out.println("---------设置构造函数--------------"); } //设置查询参数 public void setParam(String[] param) { this.param=param; } //设置SQL查询语句 //public void setQuerystatement(String query_statement) //{ //System.out.println(query_statement); // this.query_statement=query_statement; // System.out.println("---------传入sql语句--------------"); //} //设置连接参数 public void setConnection(String driverName,String jdbcURL,String username,String passwd) throws Exception { Connection conn1; Class.forName(driverName); // conn = DriverManager.getConnection("jdbc:microsoft:sqlserver://"+p.getProperty("dbserver")+":1433;DatabaseName="+p.getProperty("dbname")+";charset=GB2312",p.getProperty("user"),p.getProperty("password")); conn1=DriverManager.getConnection(jdbcURL,username,passwd); //// // Stm = conn.createStatement(); //// conn1.setAutoCommit(false); this.conn = conn1; System.out.println("---------数据连接成功--------------"); } /*获取查询结果*/ public ResultSet getResult(String query_statement) { try { PreparedStatement select_stm=conn.prepareStatement(query_statement,java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY); if (param!=null) for(int i=0;i<param.length;i++) select_stm.setString(i+1,param[i]); result=select_stm.executeQuery(); }catch(Exception e){System.out.println(e);} return result; } /*对数据库进行增加记录操作*/ public void insertRecord(String query_statement) throws SQLException,java.io.UnsupportedEncodingException { try { PreparedStatement insert_stm=conn.prepareStatement(query_statement); if (param!=null) for(int i=0;i<param.length;i++) insert_stm.setString(i+1,param[i]); insert_stm.executeUpdate(); insert_stm.close(); conn.commit(); System.out.println("数据插入成功"); } catch(Exception e) { System.out.println(e); conn.rollback(); } } /*对数据记录进行更新操作*/ public void updateRecord(String query_statement) throws SQLException,java.io.UnsupportedEncodingException { try { //System.out.println(query_statement); PreparedStatement update_stm=conn.prepareStatement(query_statement); if (param!=null) for (int i=0;i<param.length;i++) update_stm.setString(i+1,param[i]); update_stm.executeUpdate(); update_stm.close(); conn.commit(); System.out.println("数据修改成功"); } catch(Exception e) { System.out.println(e); conn.rollback(); } } /*删除数据记录*/ public void deleteRecord(String query_statement) throws SQLException,java.io.UnsupportedEncodingException { try { //System.out.println(query_statement); PreparedStatement delete_stm=conn.prepareStatement(query_statement); if (param!=null) for (int i=0;i<param.length;i++) delete_stm.setString(i+1,param[i]); delete_stm.executeUpdate(); delete_stm.close(); conn.commit(); System.out.println("数据删除成功"); } catch(Exception e) { System.out.println(e); conn.rollback(); } } }
searchtjreport.jsp代码 <jsp:useBean id="query" scope="session" class="weblistbean.QueryBean" /> <%@ page language="java" contentType="text/html;charset=gb2312" import="java.sql.*" import="java.io.*" import="java.util.*" import="javax.sql.*" import="javax.naming.*" import="java.text.*" import="java.lang.*" %> <% String stringSqlString,sumSqlString; String scontionstar,scontionend; scontionstar=request.getParameter("startDate"); scontionend=request.getParameter("endDate"); %> <% //2006-08-10 //scontionstar="2006-08-10"; //scontionend="2006-09-17"; stringSqlString="SELECT a.ALARM_TIME, b.SITE_NAME, a.INFECTANT_ID, a.STANDARD_VALUE,a.ACTUAL_VALUE"; stringSqlString=stringSqlString+" FROM ALARM a LEFT OUTER JOIN T_DIC_SUBSITE b ON a.SITE_ID = b.SITE_ID WHERE (CONVERT(char(10), a.ALARM_TIME, 120) >= '"+scontionstar+"') AND (CONVERT(char(10), a.ALARM_TIME, 120) <= '"+scontionend+"')"; ResultSet rs=query.getResult(stringSqlString); SimpleDateFormat dateformat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); //////格式化日期 DecimalFormat df = new DecimalFormat("##.00"); %> <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"> <html> <head>
<meta http-equiv="Content-Type" content="text/html; charset=gb2312"> <LINK href="Scripts/Global.css" type="text/css" rel="stylesheet"> <LINK href="Scripts/Web_Catalog.css" type="text/css" rel="stylesheet"> <title>统计报表</title> </head>
<body> <table align="center" id="tabList" bordercolordark="#EBEFFC" bordercolor=#ffffff bordercolorlight="#CCD7F7" class="itemList" border="4" cellpadding="3" cellspacing="2" width="100%"> <tr align="center" valign="middle"> <td bgcolor="#1F9CFA" nowrap>月份</td> <td bgcolor="#1F9CFA" nowrap>故障数</td> <td bgcolor="#1F9CFA" nowrap>超标数</td> <td bgcolor="#1F9CFA" nowrap>超标最大值</td> <td bgcolor="#1F9CFA" nowrap colspan="2">有效小时数</td> </tr> <% while(rs.next()) { String curdate=dateformat.format(rs.getTimestamp("ALARM_TIME")); // STANDARD_VALUE=rs.getDouble("STANDARD_VALUE"); double STANDARD_VALUE=rs.getDouble("STANDARD_VALUE"); STANDARD_VALUE = Double.parseDouble(df.format(STANDARD_VALUE));
double ACTUAL_VALUE=rs.getDouble("ACTUAL_VALUE"); ACTUAL_VALUE = Double.parseDouble(df.format(ACTUAL_VALUE)); %> <tr class='tr1' align="center" valign="middle"> <td><%=curdate %></td> <td><%=rs.getString("SITE_NAME") %></td> <td><%=rs.getString("INFECTANT_ID")%></td> <td><%=STANDARD_VALUE %></td> <td><%=ACTUAL_VALUE %></td> </tr> <% } %> <tr align="center" valign="middle"> <td>合计</td> <td> </td> <td> </td> <td> </td> <td colspan="2"> </td> </tr> </table> </body> </html>
数据库分页
Datapagebean.java
package weblistbean; public class Datapagebean{ private int currentPage;//当前页数 private int countRecord;//总记录条数 private int countPage;//总页数 private int sizePage;//每页记录条数 public void setAll(int _countRecord,int _sizePage) //设置四个成员变量的值 { countRecord=_countRecord; sizePage=_sizePage; if(countRecord%sizePage==0) countPage=countRecord/sizePage; else countPage=countRecord/sizePage+1; currentPage=1; } public int getCurrentPage() { return currentPage; } public int getCountPage() { return countPage; } public long getCountRecord() { return countRecord; } public int getSizePage() { return sizePage; } public void setCurrentPage(int currentPage) { this.currentPage = currentPage; } } breakanalyse.jsp 调用分页代码
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"> <jsp:useBean id="dbbean" scope="session" class="org.modern.dbbean" /> <jsp:useBean id="query" scope="session" class="weblistbean.QueryBean" /> <jsp:useBean id="datapagebean" scope="session" class="weblistbean.Datapagebean"> </jsp:useBean>
<%@ page language="java" contentType="text/html;charset=gb2312" import="java.sql.*" import="java.io.*" import="java.util.*" import="javax.sql.*" import="javax.naming.*" import="java.text.*" import="java.lang.*" %> <% String sql; int rowCount; ////////////// //String stringBREAKDOWN_TYPE_ID="gggggggg"; //String stringMEMO="hhhhhhhhhhh"; // int Goods_id=5; // sql="update BREAKDOWN set BREAKDOWN_TYPE_ID = '"+stringBREAKDOWN_TYPE_ID+"',MEMO = '"+stringMEMO+"' where BREAKDOWN_ID = "+Goods_id+" "; // dbbean.update(sql); //////////////////// // sql="SELECT ALARM_TIME,SITE_ID,INFECTANT_ID,STANDARD_VALUE,ACTUAL_VALUE, MEMO FROM ALARM"; sql="SELECT a.BREAKDOWN_TIME, b.SITE_NAME, a.INFECTANT_ID, a.BREAKDOWN_TYPE_ID,"; sql=sql+"a.BREAK_result,a.BREAKDOWN_ID FROM BREAKDOWN a LEFT OUTER JOIN T_DIC_SUBSITE b ON a.SITE_ID = b.SITE_ID WHERE (CONVERT(char(10), a.BREAKDOWN_TIME, 120) >= '2005-08-10') AND (CONVERT(char(10), a.BREAKDOWN_TIME, 120) <= '2006-09-17') order by BREAKDOWN_ID desc"; //dbbean.getvResult(sql); ResultSet rs=query.getResult(sql); //rowCount=dbbean.getrow(); long BREAK_ID; SimpleDateFormat dateformat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); //////格式化日期 /////分页代码///// String pages=request.getParameter("dipage"); //设定Bean的属性 rs.last(); int countRecord=rs.getRow();//得到记录的条数 int countPageRecord=5;//每页5条记录,要设置每页记录条数就更改这个变量的值 if(pages==null||(pages.trim()).length()==0) datapagebean.setAll(countRecord,countPageRecord); else { try { datapagebean.setCurrentPage(Integer.parseInt(pages)); } catch(Exception e) { out.println("参数不正确!"); } } //当前记录号 int currentRecord=(datapagebean.getCurrentPage()-1)*datapagebean.getSizePage(); if(currentRecord==0) rs.beforeFirst(); else rs.absolute(currentRecord); /////分页代码///// %> <html> <head> <meta http-equiv="Content-Type" content="text/html; charset=gb2312"> <LINK href="Scripts/Global.css" type="text/css" rel="stylesheet"> <LINK href="Scripts/Web_Catalog.css" type="text/css" rel="stylesheet"> <title>故障分析</title> </head>
<body> <form name="form1" method="post" action=""> <table align="center" id="tabList" borderColorDark="#EBEFFC" borderColor=#ffffff borderColorLight="#CCD7F7" class="itemList" border="4" cellpadding="3" cellspacing="2" width="100%"> <tr align="center" valign="middle"> <td>故障时间</td> <td>站点</td> <td>污染物</td> <td>故障类型</td> <td>故障处理结果</td> <td></td> </tr> <% /////分页代码///// int i=0; /////分页代码///// while(rs.next()) { // rs.getInt("user_age") String curdate=dateformat.format(rs.getTimestamp("BREAKDOWN_TIME")); %> <tr align="center" valign="middle"> <td><%=curdate %></td> <td><%=rs.getString("SITE_NAME") %></td> <td><%=rs.getString("INFECTANT_ID") %></td> <td><%=rs.getString("BREAKDOWN_TYPE_ID") %></td> <td><%=rs.getString("BREAK_result") %></td> <td><a href='edit_breakanalyse.jsp?ID=<%=rs.getString("BREAKDOWN_ID")%> '><img src="img/ico_edit.gif" width="15" height="15" alt="" border="0"></a></td> </tr> <% } %> <tr align="center" valign="middle"> <td colspan="6">"共"<%=datapagebean.getCountRecord()%>"条记录,共"<%=datapagebean.getCountPage()%>"页,当前第"<%=datapagebean.getCurrentPage()%>"页,每页"<%=datapagebean.getSizePage()%>"条记录," <% if(datapagebean.getCurrentPage()==1)//当前是首页 ; else//当前不是首页 { %> <a href=breakanalyse.jsp?dipage=1>首页</a>,<a href='breakanalyse.jsp?dipage=<%=datapagebean.getCurrentPage()-1%>'>上一页</a>, <% } if(datapagebean.getCurrentPage()==datapagebean.getCountPage())//当前是末页 ; else//当前不是末页 { %> <a href='breakanalyse.jsp?dipage=<%=datapagebean.getCurrentPage()+1%>'>下一页</a>, <a href='breakanalyse.jsp?dipage=<%=datapagebean.getCountPage()%>'>末页</a> <%}%> </td> </tr> </table> </form> </body> </html>
|