关于javabean的代码

数据库连接和增删改

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>

</head>

<body>

<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>

}

</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>

</head>

<body>

<td>故障处理结果</td>

</tr>

/////分页代码/////

int i=0;

/////分页代码/////

while(rs.next()) {

// rs.getInt("user_age")

String curdate=dateformat.format(rs.getTimestamp("BREAKDOWN_TIME"));

</tr>

}

<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>,

<%}%>

 </td>

</tr>

</table>

</form>

</body>

</html>