数据库的相关操作：如连接、查询、添加、删除、修改、分页显示

【 tulaoshi.com - Web开发 】

　　数据库的相关操作：如连接、查询、添加、删除、修改、分页显示
　　 
　　package study.database;

　　/**
　　* pTitle: JSP模式学习/p
　　* pDescription: 数据库的相关操作：如连接、查询、添加、删除、修改/p
　　* pCopyright: Copyright (c) 2004/p
　　* pCompany: /p
　　* @author 李艳生
　　* @version 1.0
　　*/
　　import java.sql.*;
　　import java.io.*;
　　import java.util.*;

　　public class Operation {
　　//数据库驱动程序
　　private String strDriver = "";
　　//数据库连接字符串
　　private String strURL = "";
　　//数据库用户名
　　private String username = "";
　　//数据库密码
　　private String password = "";

　　private Connection conn = null;
　　private Statement stmt = null;
　　ResultSet rs = null;

　　/** 读到数据库配置信息
　　*/
　　private void loadProp(){
　　InputStream is = getClass().getResourceAsStream("/setup.txt");
　　Properties props = new Properties();

　　try{
　　props.load(is);
　　}catch(Exception e){
　　System.err.println("不能读取配置文件. 请确保setup.txt在classes指定的路径中");
　　}

　　Enumeration propNames = props.propertyNames();
　　while (propNames.hasMoreElements()) {
　　String name = (String) propNames.nextElement();
　　if (name.endsWith(".driver")) {
　　String poolName = name.substring(0, name.lastIndexOf("."));
　　strDriver = props.getProperty(poolName + ".driver");
　　strURL = props.getProperty(poolName + ".url");
　　username = props.getProperty(poolName + ".user");
　　password = props.getProperty(poolName + ".password");
　　}
　　}
　　}

　　/** 在创建Operation对象时连接数据库
　　*/
　　public Operation() {
　　//读到数据库配置信息
　　loadProp();

　　try{
　　Class.forName(strDriver);
　　}catch(java.lang.ClassNotFoundException e) {
　　System.err.println("数据库连接错误：" + e.getMessage());
　　}

　　try{
　　conn=DriverManager.getConnection(strURL,username,password);
　　}catch(SQLException ex) {
　　System.err.println("数据库连接错误：" + ex.getMessage());
　　}
　　}

　　/** 数据库查询
　　* sql:SQL查询语句
　　*/
　　public ResultSet query(String sql) {
　　try{
　　stmt=conn.createStatement();
　　rs=stmt.executeQuery(sql);
　　}catch(SQLException ex) {
　　System.err.println("数据库查询错误：" + ex.getMessage());
　　}

　　return rs;
　　}

　　/** 数据库添加、修改、删除
　　* sql:SQL语句
　　*/
　　public void update(String sql) {
　　try{
　　stmt=conn.createStatement();
　　stmt.executeUpdate(sql);
　　}catch(SQLException ex) {
　　System.err.println("数据库更新错误："+ex.getMessage());
　　}
　　}

　　/** 得到查询结果的总记录数
　　* rs:查询结果集
　　*/
　　public int totalRecord(ResultSet rs) throws Exception{
　　int total=0;
　　//指针移到最后一条记录上
　　rs.last();
　　total = rs.getRow();
　　rs.first();

　　return total;
　　}

　　/** 分页显示
　　* currPage: 当前页数
　　* pageSize: 页大小
　　* pageCount: 总页数
　　* filename: 使用分页的文件名(文件名后面要加？,多个参数以&分开，有参数的最后以&结束)
　　* http://school.cnd8.com/ 返回字符串： a href="filename？page=当前页数"
　　*/
　　public String showPages(int currPage, int pageSize, int pageCount, String filename){
　　String addr;

　　addr = "table width=100% border=0 align=center cellpadding=0 cellspacing=0form method=Post name=pageformtrtddiv align=right当前第strongfont color=red" + currPage + "/font/strong页 " +
　　"共strongfont color=red" + pageCount + "/font/strong页每页strongfont color=red" + pageSize + "/font/strong条 ";

　　if(currPage pageCount){
　　currPage = pageCount;
　　}
　　if(currPage 1){
　　currPage = 1;
　　}

　　if(currPage 2){
　　addr += "首 页 上一页 ";
　　}
　　else{
　　addr += "a href=" + filename + "page=1首 页/a ";
　　addr += "a href=" + filename + "page=" + (currPage - 1) + "上一页/a ";
　　}

　　if(currPage = pageCount){
　　addr += "下一页 尾 页 ";
　　}
　　else{
　　addr += "a href=" + filename + "page=" + (currPage + 1) + "下一页/a ";
　　addr += "a href=" + filename + "page=" + pageCount + "尾 页/a ";
　　}

　　addr += "转到：select name=´page´ size=´1´ style=´font-size: 9pt´ onChange=´javascript :pageform.submit()´ ";
　　for(int i = 1; i = pageCount; i ++){
　　if(currPage==i){
　　addr += "option value=" + i + " selected 第 "+i+"页 /option ";

　　}
　　else{
　　addr += "option value=" + i + " 第 "+i+"页 /option ";
　　}
　　}
　　addr += "/select/div/td/tr/form/table";

　　return addr;
　　}

　　/** 关闭数据集
　　*/
　　public void closestmt() {
　　try{
　　stmt.close();
　　}catch(SQLException ex) {
　　System.err.println("数据集关闭错误："+ex.getMessage());
　　}
　　}

　　/** 关闭数据库连接
　　*/
　　public void closeconn() {
　　try{
　　conn.close();
　　}catch(SQLException ex) {
　　System.err.println("数据库连接关闭错误："+ex.getMessage());
　　}
　　}
　　}

　　其中的JSP页面中的代码大家自己动手写！很容易的！
　　http://blog.csdn.net/goldbox/archive/2007/01/26/1494667.aspx