dbbean.java

CMS（内容管理系统）

package com.becom;

import java.sql.*;
import java.util.*;
import java.util.Date;

public class DbBean {
String sDBDriver="com.microsoft.jdbc.sqlserver.SQLServerDriver";//数据库驱动
        
String url="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=shopping;SelectMethod=cursor";//数据库连接字符串
private Connection conn=null;
private Statement stmt=null;
private ResultSet rs=null;
  public DbBean() {					//连接数据库
                         try {
                                Class.forName(sDBDriver);
                                 }
                             catch(java.lang.ClassNotFoundException e) {
                           System.err.println(": " + e.getMessage());
                              }
    try {
	  conn = DriverManager.getConnection(url,"sa","");
    }
    catch(SQLException ex) {
      System.err.println("error:" + ex.getMessage());
    }

}

  public ResultSet executeQuery(String sql) {
    rs = null;
    try {
    conn = DriverManager.getConnection(url,"sa","");
    stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
    rs = stmt.executeQuery(sql);
    }
    catch(SQLException ex) {
      System.err.println("aq.executeQuery: " + ex.getMessage());
    }
    return rs;
  }

  public void executeUpdate(String sql) {
    stmt = null;
    rs=null;
    try {
    //conn = DriverManager.getConnection(url,"sa","");
    stmt = conn.createStatement();
    stmt.executeUpdate(sql);
    stmt.close();
    conn.close();
    }
    catch(SQLException ex) {
      System.err.println("aq.executeQuery: " + ex.getMessage());
    }
  }

  public int rowcount(String table,String sign)//查询总行数，输入表格和条件
		{
			int rowcount=0;
			try{
				String row="select count(*) from"+ table+"where"+sign;
				rs=stmt.executeQuery(row);
				rowcount=rs.getInt(1);
			 }catch(Exception e){
				System.out.println(""+new Date());
				System.out.println("查询失败：");}
			
	return rowcount;	
	}

  public void closeStmt(){
    try{
      stmt.close();
     }
    catch(SQLException e){
      e.printStackTrace();
     }
  }
  public void closeConn(){
    try{
      conn.close();
     }
    catch(SQLException e){
      e.printStackTrace();
     }
  }
}